import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class RedisPoolUtils {
private static final JedisPool JEDIS_POOL;
static {
//设置Jedis连接池配置
JedisPoolConfig config=new JedisPoolConfig();
//最大连接数
config.setMaxTotal(5);
//空闲时连接数
config.setMaxIdle(2);
//设置连接池
JEDIS_POOL=new JedisPool(config, "192.168.117.128",6379);
}
//从连接池中获得Jedis对象
public static Jedis getJedis() {
Jedis jedis=JEDIS_POOL.getResource();
jedis.auth("yao");
return jedis;
}
public static void close(Jedis jedis) {
jedis.close();
}
}
测试
import org.junit.Test;
import redis.clients.jedis.Jedis;
public class redis {
public static void main(String[] args) {
// TODO Auto-generated method stub
Jedis js=new Jedis("192.168.117.128",6379);
js.auth("yao");
System.out.println(js.ping());
}
@Test
public void t2() {
Jedis jedis=RedisPoolUtils.getJedis();
String key="applicationName";
if(jedis.exists(key)) {
String result=jedis.get(key);
System.out.println("Redis中的数据为:"+result);
}else {
String sqlResult="从MySql查到了";
jedis.set(key, sqlResult);
System.out.println("Mysql中的数据为:"+sqlResult);
}
RedisPoolUtils.close(jedis);
}
}