1、jedis连接池: jedisPool
使用:
1、创建JedisPool连接池对象
2、调用方法getResource()方法获取Jedis链接
Jedis的配置
详细配置项 jedispool的使用
//4、关闭,归还到连接池
jedis.close();
2、Jedis连接池工具类
测试类package cn.dayJedis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
/*
JedisPool工具类
加载配置文件,配置连接池的参数
提供获取连接的方法
*/
public class JedisPoolUtil {
private static JedisPool jedisPool;
static {
//1、读取配置文件
InputStream is = JedisPoolUtil.class.getClassLoader().getResourceAsStream("jedis.properties");
//2、创建properties对象
Properties pro = new Properties();
//3、关联文件
try {
pro.load(is);
} catch (IOException e) {
e.printStackTrace();
}
//获取数据,设置到JedisPoolConfigue中
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));
config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));
//初始化JedisPool
JedisPool jedisPool1 = new JedisPool(config, pro.getProperty("host"), Integer.parseInt(pro.getProperty("port")));
}
/*
获取连接的方法
*/
public static Jedis getJedis(){
return jedisPool.getResource();
}
}
测试类
package cn.dayJedis;
import redis.clients.jedis.Jedis;
public class JedisTest {
public static void main(String[] args) {
new JedisTest().test();
}
public void test(){
//通过连接池工具类获取
Jedis jedis = JedisPoolUtil.getJedis();
//使用
jedis.set("hh","ee");
}
}
网友评论