文章目录
Jedis连接池连接池建立步骤代码案例JedisPoolUtils工具类创建配置文件编写工具类编写测试代码Jedis连接池
连接池建立步骤
JedisPool的配置参数大部分是由JedisPoolConfig的对应项来赋值的，所以首先我们要设置JedisPoolConfig参数。
JedisPoolConfig的参数如下所示：
设置完配置之后我们就可以去创建jedis的连接池了，使用的是JedisPoo构造函数
其参数如下：
第一个参数连池的配置 JedisPoolConfig第二个参数 ip、域名或者主机名第三个参数 端口第四个连接的超时时间第五个参数连接的密码
代码案例
代码如下：
@Testpublic void JedisPoolTest(){//1.创建连接池配置JedisPoolConfig config = new JedisPoolConfig();config.setMaxTotal(30);config.setMaxIdle(10);//2.创建连接池对象//创建jedis的连接池//第一个参数连池的配置 JedisPoolConfig//第二个参数 ip、域名或者主机名//第三个参数 端口//第四个连接的超时时间//第五个参数连接的密码JedisPool jedisPool = new JedisPool(config, "localhost", Integer.parseInt("6379"), 1800);//3.建立连接Jedis jedis = jedisPool.getResource();//4.操作数据jedis.set("pooltest", "test");String value = jedis.get("pooltest");System.out.println(value);//关闭连接，将连接还入池中jedis.close();}
运行结果：
JedisPoolUtils工具类
创建配置文件
在resources创建jedis.properties配置文件
host=localhostport=6379password=maxTotal=30maxIdle=10
编写工具类
之后我们就可以通过getJedis获取连接池了
package com.yyl.firstdemo.utils;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;public class JedisPoolUtils {private static JedisPool jedisPool;static {//读取jedis.properties配置文件InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");//创建Properties对象Properties properties = new Properties();try {//加载输入流isproperties.load(is);} catch (IOException e) {e.printStackTrace();}//读取配置数据String host = properties.getProperty("host");String port = properties.getProperty("port");String password = properties.getProperty("password");String maxTotal = properties.getProperty("maxTotal");String maxIdle = properties.getProperty("maxIdle");//创建jedisPool对象//创建一个jedis连接配置对象 JedisPoolConfigJedisPoolConfig config = new JedisPoolConfig();//设置连接池最大的连接数量config.setMaxTotal(Integer.parseInt(maxTotal));//设置连接池空闲状态保持的连接数量config.setMaxIdle(Integer.parseInt(maxIdle));//创建jedis的连接池//第一个参数连池的配置 JedisPoolConfig//第二个参数 ip、域名或者主机名//第三个参数 端口//第四个连接的超时时间//第五个参数连接的密码jedisPool = new JedisPool(config, host, Integer.parseInt(port), 1800);}/*** 获取jedis对象** @return*/public static Jedis getJedis() {return jedisPool.getResource();}}
编写测试代码
@Testpublic void JedisPoolUtilTest(){//建立连接Jedis jedis = JedisPoolUtils.getJedis();//操作数据jedis.set("utilstest", "test");//获取数据String value = jedis.get("utilstest");System.out.println(value);//关闭连接jedis.close();}
运行结果如下：
