package jedis.util;

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;

/**

* @author ： CodeWater

* @create ：2022-04-30-20:56

* @Function Description ：封装jedis工具类

* <p>

* JedisPool工具类

* 加载配置文件，配置连接池的参数

* 提供获取连接的方法

*/

public class JedisPoolUtils {

private static JedisPool jedisPool;

static {

InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");

Properties pro = new Properties();

try {

pro.load(is);

} catch (IOException e) {

e.printStackTrace();

}

JedisPoolConfig config = new JedisPoolConfig();

config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));

config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));

// 初始化JedisPool

jedisPool = new JedisPool(config, pro.getProperty("host"), Integer.parseInt(pro.getProperty("port")));

}

// 获取连接的方法

public static Jedis getJedis() {

return jedisPool.getResource();

}

}