為什么要用Jedis連接池+淺談jedis連接池使用

為什么要使用Jedis連接池

Redis作為緩存數據庫理論上和MySQL一樣需要客戶端和服務端建立起來連接進行相關操作，使用MySQL的時候相信大家都會使用一款開源的連接池,例如C3P0.因為直連會消耗大量的數據庫資源，每一次新建一個連接之，使用后再斷開連接，對於頻繁訪問的場景，這顯然不是高效的。

Jedis直連Redis

生產環境一般使用連接池的方式對Redis連接進行管理，所有Jedis對象先放在池子中每一次需要的時候連接Redis，只需要在池子中借，用完了再歸還給池子。

Jedis連接池使用方式

客戶端連接Redis使用的是TCP協議，直連的方式每次需要建立TCP連接，而連接池的方式是可以預先初始化好Jedis連接，所以每次只需要從Jedis連接池借用即可，而借用和歸還操作是在本地進行的，只有少量的並發同步開銷，遠遠小於新建TCP連接的開銷。另外直連的方式無法限制Jedis對象的個數，在極端情況下可能會造成連接泄露，而連接池的形式可以有效的保護和控制資源的使用。但是直連的方式也並不是一無是處，下面給出兩種方式各自的優劣勢。

Jedis直連方式和連接池方式對比

Jedis提供了JedisPool這個類作為對Jedis的連接池。使用如下：

public class RedisPool {
    //聲明成static的原因：保證jedis連接池在tomcat啟動時就加載出來
    //jedis連接池
    private static JedisPool pool;
    //與redis連接池連接的最大連接數
    private static Integer maxTotal = Integer.parseInt(PropertiesUtil.getProperty("redis.max.total", "20"));
    //在這個連接池中最多有多少個狀態為idle的jedis實例，jedis連接池里就是jedis的實例，idle就是空閑的jedis實例
    //在jedis連接池中最大的idle狀態（空閑的）的jedis實例的個數
    private static Integer maxIdle = Integer.parseInt(PropertiesUtil.getProperty("redis.max.idle", "10"));
    //在jedis連接池中最小的idle狀態（空閑的）的jedis實例的個數
    private static Integer minIdle = Integer.parseInt(PropertiesUtil.getProperty("redis.min.idle", "2"));

    //在borrow一個jedis實例的時候，是否要進行驗證操作，如果賦值為true，則得到的jedis實例肯定是可用的
    private static Boolean testOnBorrow = Boolean.parseBoolean(PropertiesUtil.getProperty("redis.test.borrow", "true"));
    //在return一個jedis實例的時候，是否要進行驗證操作，如果賦值為true，則返回jedis連接池的jedis實例肯定是可用的
    private static Boolean testOnReturn = Boolean.parseBoolean(PropertiesUtil.getProperty("redis.test.return", "true"));

    private static String redisIp = PropertiesUtil.getProperty("redis.ip");
    private static Integer redisPort = Integer.parseInt(PropertiesUtil.getProperty("redis.port"));

    //初始化連接池，只會調用一次
    private static void initPool() {
        JedisPoolConfig config = new JedisPoolConfig();

        config.setMaxTotal(maxTotal);
        config.setMaxIdle(maxIdle);
        config.setMinIdle(minIdle);

        config.setTestOnBorrow(testOnBorrow);
        config.setTestOnReturn(testOnReturn);

        //連接池耗盡的時候，是否阻塞，false會拋出異常，true阻塞直到超時，會拋出超時異常，默認為true
        config.setBlockWhenExhausted(true);

        //這里超時時間是2s
        pool = new JedisPool(config, redisIp, redisPort, 1000*2);

    }

    static {
        initPool();
    }

    //從連接池中拿取一個實例
    public static Jedis getJedis() {
        return pool.getResource();
    }

    //將正常實例放回jedis連接池
    public static void returnResource(Jedis jedis) {
        pool.returnResource(jedis);
    }

    //將破損實例放回jedis連接池
    public static void returnBrokenResource(Jedis jedis) {
        pool.returnResource(jedis);
    }

}

JedisPoolUtil向外提供的工具類如下所示：

 

public class RedisPoolUtil {

    //重新設置有效期
    //參數只有key和有效期，因為只需要根據key設置有效期即可
    public static Long expire(String key, int exTime) {
        Jedis jedis = null;
        Long result = null;
        try {
            jedis = RedisPool.getJedis();
            //設置有效期
            result = jedis.expire(key, exTime);
        } catch (Exception e) {
            log.error("setex key:{} error", key, e);
            RedisPool.returnBrokenResource(jedis);
            return result;
        }
        RedisPool.returnResource(jedis);
        return result;
    }

    //exTime單位是s，設置session有效時間
    //當用戶初次登錄的時候，需要設置有限期，存在redis session中
    //后續如果用戶再次請求登錄，則只需要調用expire，重新設置有效期即可
    public static String setEx(String key, String value, int exTime) {
        Jedis jedis = null;
        String result = null;
        try {
            jedis = RedisPool.getJedis();
            result = jedis.setex(key, exTime, value);
        } catch (Exception e) {
            log.error("setex key:{} value:{} error", key, value, e);
            RedisPool.returnBrokenResource(jedis);
            return result;
        }
        RedisPool.returnResource(jedis);
        return result;
    }

    public static String set(String key, String value) {
        Jedis jedis = null;
        //jedis返回的結果
        String result = null;
        try {
            jedis = RedisPool.getJedis();
            //設置key-value
            result = jedis.set(key, value);
        } catch (Exception e) {
            log.error("set key:{} value:{} error", key, value, e);
            RedisPool.returnBrokenResource(jedis);
            return result;
        }
        RedisPool.returnResource(jedis);
        return result;
    }

    public static String get(String key) {
        Jedis jedis = null;
        String result = null;
        try {
            jedis = RedisPool.getJedis();
            //根據key獲取value值
            result = jedis.get(key);
        } catch (Exception e) {
            log.error("set key:{} error", key, e);
            RedisPool.returnBrokenResource(jedis);
            return result;
        }
        RedisPool.returnResource(jedis);
        return result;
    }

    public static Long del(String key) {
        Jedis jedis = null;
        Long result = null;
        try {
            jedis = RedisPool.getJedis();
            //根據key刪除key-value
            result = jedis.del(key);
        } catch (Exception e) {
            log.error("set key:{} error", key, e);
            RedisPool.returnBrokenResource(jedis);
            return result;
        }
        RedisPool.returnResource(jedis);
        return result;
    }
}