1. 程式人生 > >Jedis 連線池JedisPool 解決connection timeout問題

Jedis 連線池JedisPool 解決connection timeout問題

quote: http://java-er.com/blog/jedispool/

今天發現Jedis 預設的連線方式 jedis=new Jedis(“localhost”,6379),老是發生connection timeout. 後來發現jedis類包還有一種可以設定最大連線時間的方法。

1->獲取Jedis例項需要從JedisPool中獲取;
2->用完Jedis例項需要還給JedisPool;
3->如果Jedis在使用過程中出錯,則也需要還給JedisPool;

程式碼如下

JedisPoolConfig config = new JedisPoolConfig();
 
config.setMaxActive(100);
 
config.setMaxIdle(20);
 
config.setMaxWait(1000l);
JedisPool pool;
pool = new JedisPool(config, "2xx.xx.xx.14", 6379);
 
boolean borrowOrOprSuccess = true;
try {
jedis = pool.getResource();
// do redis opt by instance
} catch (JedisConnectionException e) {
borrowOrOprSuccess = false;
if (jedis != null)
pool.returnBrokenResource(jedis);
 
} finally {
if (borrowOrOprSuccess)
pool.returnResource(jedis);
}
jedis = pool.getResource();

JedisPool依賴apache類包

commons-pool-1.5.6.jar

1->雖然丟擲JedisConnectionException,但實際上有兩類錯誤,一類是pool.getReource(),得不到可用的jedis例項;另一類是jedis.set/get時出錯也會丟擲這個Exception;為了實現區分,所以根據instance是否為null來實現,如果為空就證明instance根本就沒初始化,也就不用return給pool;如果instance不為null,則證明是需要返還給pool的;
2->在instance出錯時,也要呼叫returnBrokenResource返還給pool,否則下次通過getResource得到的instance的緩衝區可能還存在資料,出現問題!

JedisPool的配置引數很大程度上依賴於實際應用需求、軟硬體能力。以前沒用過commons-pool,所以這次花了一整間專門看這些引數的含義。。。JedisPool的配置引數大部分是由JedisPoolConfig的對應項來賦值的。

maxActive:控制一個pool可分配多少個jedis例項,通過pool.getResource()來獲取;如果賦值為-1,則表示不限制;如果pool已經分配了maxActive個jedis例項,則此時pool的狀態就成exhausted了,在JedisPoolConfig

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