redis 鏈接池 - 轉載

所需jar：jedis-2.1.0.jar和commons-pool-1.5.4.jar

Jedis操做步驟以下：
1->獲取Jedis實例須要從JedisPool中獲取；
2->用完Jedis實例須要返還給JedisPool；
3->若是Jedis在使用過程當中出錯，則也須要還給JedisPool；

package com.ljq.utils;  
  
import redis.clients.jedis.Jedis;  
import redis.clients.jedis.JedisPool;  
import redis.clients.jedis.JedisPoolConfig;  
  
/**    
 * Redis操做接口 
 * 
 * @author 
 * @version 1.0 2013-6-14 上午08:54:14    
 */  
public class RedisAPI {  
    private static JedisPool pool = null;  
      
    /** 
     * 構建redis鏈接池 
     *  
     * @param ip 
     * @param port 
     * @return JedisPool 
     */  
    public static JedisPool getPool() {  
        if (pool == null) {  
            JedisPoolConfig config = new JedisPoolConfig();  
            //控制一個pool可分配多少個jedis實例，經過pool.getResource()來獲取；  
            //若是賦值爲-1，則表示不限制；若是pool已經分配了maxActive個jedis實例，則此時pool的狀態爲exhausted(耗盡)。  
            config.setMaxActive(500);  
            //控制一個pool最多有多少個狀態爲idle(空閒的)的jedis實例。  
            config.setMaxIdle(5);  
            //表示當borrow(引入)一個jedis實例時，最大的等待時間，若是超過等待時間，則直接拋出JedisConnectionException；  
            config.setMaxWait(1000 * 100);  
            //在borrow一個jedis實例時，是否提早進行validate操做；若是爲true，則獲得的jedis實例均是可用的；  
            config.setTestOnBorrow(true);  
            pool = new JedisPool(config, "192.168.2.191", 8888);  
        }  
        return pool;  
    }  
      
    /** 
     * 返還到鏈接池 
     *  
     * @param pool  
     * @param redis 
     */  
    public static void returnResource(JedisPool pool, Jedis redis) {  
        if (redis != null) {  
            pool.returnResource(redis);  
        }  
    }  
      
    /** 
     * 獲取數據 
     *  
     * @param key 
     * @return 
     */  
    public static String get(String key){  
        String value = null;  
          
        JedisPool pool = null;  
        Jedis jedis = null;  
        try {  
            pool = getPool();  
            jedis = pool.getResource();  
            value = jedis.get(key);  
        } catch (Exception e) {  
            //釋放redis對象  
            pool.returnBrokenResource(jedis);  
            e.printStackTrace();  
        } finally {  
            //返還到鏈接池  
            returnResource(pool, jedis);  
        }  
          
        return value;  
    }  
}  

　　

 

代碼說明：
a、獲取jedis實例時，實際上可能有兩類錯誤。
一類是pool.getReource()，得不到可用的jedis實例；
另外一類是jedis.set/get時出錯也會拋出異常；
爲了實現區分，因此根據instance是否爲null來實現，若是爲空就證實instance根本就沒初始化，也就不用return給pool；若是instance不爲null，則證實是須要返還給pool的；

b、在instance出錯時，必須調用returnBrokenResource返還給pool，不然下次經過getResource獲得的instance的緩衝區可能還存在數據，出現問題！

-------------------------------------------------

JedisPool的配置參數很大程度上依賴於實際應用需求、軟硬件能力。之前沒用過commons-pool，因此此次花了一成天專門看這些參數的含義。。。JedisPool的配置參數大部分是由JedisPoolConfig的對應項來賦值的。

maxActive：控制一個pool可分配多少個jedis實例，經過pool.getResource()來獲取；若是賦值爲-1，則表示不限制；若是pool已經分配了maxActive個jedis實例，則此時pool的狀態爲exhausted。

maxIdle：控制一個pool最多有多少個狀態爲idle(空閒)的jedis實例；

whenExhaustedAction：表示當pool中的jedis實例都被allocated完時，pool要採起的操做；默認有三種。
WHEN_EXHAUSTED_FAIL --> 表示無jedis實例時，直接拋出NoSuchElementException；
WHEN_EXHAUSTED_BLOCK --> 則表示阻塞住，或者達到maxWait時拋出JedisConnectionException；
WHEN_EXHAUSTED_GROW --> 則表示新建一個jedis實例，也就說設置的maxActive無用；

maxWait：表示當borrow一個jedis實例時，最大的等待時間，若是超過等待時間，則直接拋出JedisConnectionException；

testOnBorrow：在borrow一個jedis實例時，是否提早進行alidate操做；若是爲true，則獲得的jedis實例均是可用的；

testOnReturn：在return給pool時，是否提早進行validate操做；

testWhileIdle：若是爲true，表示有一個idle object evitor線程對idle object進行掃描，若是validate失敗，此object會被從pool中drop掉；這一項只有在timeBetweenEvictionRunsMillis大於0時纔有意義；

timeBetweenEvictionRunsMillis：表示idle object evitor兩次掃描之間要sleep的毫秒數；

numTestsPerEvictionRun：表示idle object evitor每次掃描的最多的對象數；

minEvictableIdleTimeMillis：表示一個對象至少停留在idle狀態的最短期，而後才能被idle object evitor掃描並驅逐；這一項只有在timeBetweenEvictionRunsMillis大於0時纔有意義；

softMinEvictableIdleTimeMillis：在minEvictableIdleTimeMillis基礎上，加入了至少minIdle個對象已經在pool裏面了。若是爲-1，evicted不會根據idle time驅逐任何對象。若是minEvictableIdleTimeMillis>0，則此項設置無心義，且只有在timeBetweenEvictionRunsMillis大於0時纔有意義；

lifo：borrowObject返回對象時，是採用DEFAULT_LIFO（last in first out，即相似cache的最頻繁使用隊列），若是爲False，則表示FIFO隊列；

其中JedisPoolConfig對一些參數的默認設置以下：
testWhileIdle=true
minEvictableIdleTimeMills=60000
timeBetweenEvictionRunsMillis=30000
numTestsPerEvictionRun=-1

 

 附：

前些天遇到問題：先是Redis報錯redis.clients.jedis.exceptions.JedisConnectionException:Java.NET.SocketTimeoutException: Read timed out

網絡恢復後又報： java.lang.ClassCastException: [B cannot be cast to java.lang.Long

問題復現及分析可參考另一篇文章：http://my.oschina.net/zhuguowei/blog/406807