redis連接池 jedis-2.9.0.jar+commons-pool2-2.4.2.jar

java使用Redis連接池 

jar包為 jedis-2.9.0.jar+commons-pool2-2.4.2.jar

jar下載地址

package com.test;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public  class RedisUtil {
    //Redis服務器IP
    private static String ADDR = "192.168.0.41";
    
    //Redis的端口號
    private static int PORT = 6379;
    
    //訪問密碼
    private static String AUTH = "admin";
    
    //可用連接實例的最大數目，默認值為8；
    //如果賦值為-1，則表示不限制；如果pool已經分配了maxActive個jedis實例，則此時pool的狀態為exhausted(耗盡)。
    private static int MAX_TOTAL = 8;
    
    //最小空閑連接數, 默認0
    private static int MIN_IDLE=0;
    
    //控制一個pool最多有多少個狀態為idle(空閑的)的jedis實例，默認值也是8。
    //最大空閑連接數, 默認8個
    private static int MAX_IDLE = 8;
    
    //獲取連接時的最大等待毫秒數(如果設置為阻塞時BlockWhenExhausted),如果超時就拋異常, 小於零:阻塞不確定的時間,  默認-1
    //等待可用連接的最大時間，單位毫秒，默認值為-1，表示永不超時。如果超過等待時間，則直接拋出JedisConnectionException；
    private static int MAX_WAIT = -1;
    
    private static int TIMEOUT = 10000;
    
    //連接耗盡時是否阻塞, false報異常,ture阻塞直到超時, 默認true
    private static boolean BLOCK_WHEN_EXHAUSTED = false;
    
    //設置的逐出策略類名, 默認DefaultEvictionPolicy(當連接超過最大空閑時間,或連接數超過最大空閑連接數)
    private static String EVICTION_POLICY_CLASSNAME="org.apache.commons.pool2.impl.DefaultEvictionPolicy";
    
    //是否啟用pool的jmx管理功能, 默認true
    private static boolean JMX_ENABLED=true;
   
    //MBean ObjectName = new ObjectName("org.apache.commons.pool2:type=GenericObjectPool,name=" + "pool" + i); 默認為"pool", JMX不熟,具體不知道是干啥的...默認就好.
    private static String JMX_NAME_PREFIX="pool";
    
    //是否啟用后進先出, 默認true
    private static boolean LIFO=true;
    
    //逐出連接的最小空閑時間 默認1800000毫秒(30分鍾)
    private static long MIN_EVICTABLE_IDLE_TIME_MILLIS=1800000L;
    
    //對象空閑多久后逐出, 當空閑時間>該值 且 空閑連接>最大空閑數 時直接逐出,不再根據MinEvictableIdleTimeMillis判斷  (默認逐出策略)   
    private static long SOFT_MIN_EVICTABLE_IDLE_TIME_MILLIS=1800000L;
    
    //每次逐出檢查時 逐出的最大數目 如果為負數就是 : 1/abs(n), 默認3
    private static int NUM_TESTS_PER_EVICYION_RUN=3;
    
    //在borrow一個jedis實例時，是否提前進行validate操作；如果為true，則得到的jedis實例均是可用的；
    //在獲取連接的時候檢查有效性, 默認false
    private static boolean TEST_ON_BORROW = false;
    
    //在空閑時檢查有效性, 默認false
    private static boolean TEST_WHILEIDLE=false;
    
    //逐出掃描的時間間隔(毫秒) 如果為負數,則不運行逐出線程, 默認-1
    private static long TIME_BERWEEN_EVICTION_RUNS_MILLIS=-1;
    
    private static JedisPool jedisPool = null;
    
    /**
     * 初始化Redis連接池
     */
    static {
        try {
            JedisPoolConfig config = new JedisPoolConfig();
            config.setBlockWhenExhausted(BLOCK_WHEN_EXHAUSTED);
            config.setEvictionPolicyClassName(EVICTION_POLICY_CLASSNAME); 
            config.setJmxEnabled(JMX_ENABLED);
            config.setJmxNamePrefix(JMX_NAME_PREFIX);
            config.setLifo(LIFO);
            config.setMaxIdle(MAX_IDLE);
            config.setMaxTotal(MAX_TOTAL);
            config.setMaxWaitMillis(MAX_WAIT);
            config.setMinEvictableIdleTimeMillis(MIN_EVICTABLE_IDLE_TIME_MILLIS);
            config.setMinIdle(MIN_IDLE);
            config.setNumTestsPerEvictionRun(NUM_TESTS_PER_EVICYION_RUN);
            config.setSoftMinEvictableIdleTimeMillis(SOFT_MIN_EVICTABLE_IDLE_TIME_MILLIS);
            config.setTestOnBorrow(TEST_ON_BORROW);
            config.setTestWhileIdle(TEST_WHILEIDLE);
            config.setTimeBetweenEvictionRunsMillis(TIME_BERWEEN_EVICTION_RUNS_MILLIS);
            
            jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 獲取Jedis實例
     * @return
     */
    public synchronized static Jedis getJedis() {
        try {
            if (jedisPool != null) {
                Jedis resource = jedisPool.getResource();
                return resource;
            } else {
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    /**
     * 釋放jedis資源
     * @param jedis
     */
    public static void close(final Jedis jedis) {
        if (jedis != null) {
            jedis.close();
        }
    }
}