java Jedis鏈接池的使用

所需jar:jedis-2.1.0.jar和commons-pool-1.5.4.jarjava

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

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的緩衝區可能還存在數據,出現問題!code

-------------------------------------------------對象

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

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

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

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

maxWait:表示當borrow一個jedis實例時,最大的等待時間,若是超過等待時間,則直接拋出JedisConnectionException;it

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

相關文章
相關標籤/搜索