Redis JedisPool

Posted 2020-08-21 wq3435

获取连接池，通常连接池为单例，这里使用 双端检测机制保证只有一个实例

 

public class JedisPoolUtil {

    private static volatile JedisPool jedisPool = null;

    private JedisPoolUtil() {
    }

    public static JedisPool getJedisPoolInstance() {
        if (null == jedisPool) {
            synchronized (JedisPoolUtil.class) {   //这里使用双端检测设计模式
                if (null == jedisPool) {
                    JedisPoolConfig poolConfig = new JedisPoolConfig();
                    //控制一个pool可分配多少个jedis实例，通过pool.getResource()来获取；如果赋值为-1，则表示不限制，
                    //如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted
                    poolConfig.setMaxActive(1000);
                    poolConfig.setMaxIdle(32);  //设置剩余连接各数，如果小于这个就会抛异常
                    //表示当borrow一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛JedisConnectionException
                    poolConfig.setMaxWait(100*1000); 
                    //获得一个jedis实例的时候是否检查连接可用性(ping()),如果为true，则得到的jedis实例均是可用的
                    poolConfig.setTestOnBorrow(true); 
                    jedisPool = new JedisPool(poolConfig, "192.168.1.201", 6379);
                }
            }
        }
        return jedisPool;
    }
    /**
     * 释放
     * @param jedisPool 释放哪个池中
     * @param jedis        的哪个对象
     */
    public static void release(JedisPool jedisPool,Jedis jedis){
        if(null != jedis){
            jedisPool.returnResourceObject(jedis);
        }
    }

}

 

 测试代码：

public class TestJedisPool {

    public static void main(String[] args) {
        JedisPool jedisPool = JedisPoolUtil.getJedisPoolInstance();

        Jedis jedis = null;

        try {
            jedis = jedisPool.getResource();

            jedis.set("aa", "bb");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            JedisPoolUtil.release(jedisPool, jedis);
        }
    }

}

 

 

127.0.0.1:6379> get aa
"bb"
127.0.0.1:6379>

 

JedisPoolCinfig