redis java客户端Jedis 连接池实现

水莹儿

　　参考自：http://blog.iyunv.com/gjswxhb/article/details/21833551
　　


　　所用jar包
　　jedis-2.6.0.jar    commons-pool2-2.0.jar (jedis-2.6不支持 commons-pool 1.X了)
　　/*

*

* Jedis操作步骤如下：

* 1->获取Jedis实例需要从JedisPool中获取；

* 2->用完Jedis实例需要返还给JedisPool；

* 3->如果Jedis在使用过程中出错，则也需要还给JedisPool；

*

* */


　　


　　

package com.danny.jedisUtil;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/*
*
* Jedis操作步骤如下：
* 1->获取Jedis实例需要从JedisPool中获取；
* 2->用完Jedis实例需要返还给JedisPool；
* 3->如果Jedis在使用过程中出错，则也需要还给JedisPool；
*
* */
public class JedisPoolUtil {
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.setMaxTotal(500);
//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。
config.setMaxIdle(5);
//表示当borrow(引入)一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛出JedisConnectionException；
config.setMaxWaitMillis(1000 * 100);
//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
config.setTestOnBorrow(true);
pool = new JedisPool(config, "192.168.1.131", 6380);
}
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 {
//从jedisPool中获取jedis实例
pool = getPool();
jedis = pool.getResource();
value = jedis.get(key);
} catch (Exception e) {
//有exception,也要将jedis返回给jedisPool
//释放redis对象
pool.returnBrokenResource(jedis);
e.printStackTrace();
} finally {
//用完jedis 返还到连接池
returnResource(pool, jedis);
}
return value;
}
}