package com.juzhi.common;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class RedisTest {
private static JedisPool pool;
private static void initPool(){
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(20);//最大连接数
jedisPoolConfig.setMaxIdle(20);//最大空闲状况数量
jedisPoolConfig.setMinIdle(20);//最小空闲状况数量
jedisPoolConfig.setTestOnBorrow(true);//在borrow一个jedis实列的时候,是否进行验证操作,如果赋值伟true,则得到的jedis肯定是可以用的
jedisPoolConfig.setTestOnReturn(true);//在return一个jedis实列的时候,是否进行验证操作,如果赋值伟true,则得到的jedis肯定是可以用的
pool = new JedisPool(jedisPoolConfig,"127.0.0.1",6379,1000*2);
}
static {
initPool();
}
public static Jedis getJedis(){
return pool.getResource();
}
public static void returnBrokenResource(Jedis jedis){
pool.returnBrokenResource(jedis);
}
public static void returnResource(Jedis jedis){
pool.returnResource(jedis);
}
public static void main(String[] args) {
Jedis jedis = pool.getResource();
jedis.set("test","testaaa");
returnResource(jedis);
pool.destroy();
System.out.println("end");
}
}