java客户端Jedis操作Redis Sentinel 连接池

川长思鸟来 2024-02-18 15:03 54阅读 0赞

pom.xml配置  
  
<dependency>  
<groupId>org.springframework.data</groupId>  
<artifactId>spring-data-redis</artifactId>  
<version>1.0.2.RELEASE</version>  
</dependency>  
<dependency>  
<groupId>redis.clients</groupId>  
<artifactId>jedis</artifactId>  
<version>2.7.0</version>  
<type>jar</type>  
<scope>compile</scope>  
</dependency>  
  
public class JedisPoolUtil \{  
  
private static JedisSentinelPool pool = null;  
  
public static Properties getJedisProperties() \{  
  
Properties config = new Properties();  
InputStream is = null;  
try \{  
is = JedisPoolUtil.class.getClassLoader().getResourceAsStream("cacheConfig.properties");  
config.load(is);  
\} catch (IOException e) \{  
logger.error("", e);  
\} finally \{  
if (is != null) \{  
try \{  
is.close();  
\} catch (IOException e) \{  
logger.error("", e);  
\}  
\}  
\}  
return config;  
\}  
  
/\*\*  
\* 创建连接池  
\*  
\*/  
private static void createJedisPool() \{  
// 建立连接池配置参数  
JedisPoolConfig config = new JedisPoolConfig();  
Properties prop = getJedisProperties();  
// 设置最大连接数  
config.setMaxTotal(StringUtil.nullToInteger(prop.getProperty("MAX\_ACTIVE")));  
// 设置最大阻塞时间，记住是毫秒数milliseconds  
config.setMaxWaitMillis(StringUtil.nullToInteger(prop.getProperty("MAX\_WAIT")));  
// 设置空间连接  
config.setMaxIdle(StringUtil.nullToInteger(prop.getProperty("MAX\_IDLE")));  
// jedis实例是否可用  
boolean borrow = prop.getProperty("TEST\_ON\_BORROW") == "false" ? false : true;  
config.setTestOnBorrow(borrow);  
// 创建连接池  
// pool = new JedisPool(config, prop.getProperty("ADDR"), StringUtil.nullToInteger(prop.getProperty("PORT")), StringUtil.nullToInteger(prop.getProperty("TIMEOUT")));// 线程数量限制，IP地址，端口，超时时间  
//获取redis密码  
String password = StringUtil.nullToString(prop.getProperty("PASSWORD"));  
  
String masterName = "mymaster";  
Set<String> sentinels = new HashSet<String>();  
 sentinels.add("192.168.1.217:26379");  
sentinels.add("192.168.1.216:26380");  
sentinels.add("192.168.1.215:26381");  
pool = new JedisSentinelPool(masterName, sentinels, config);  
\}  
  
/\*\*  
\* 在多线程环境同步初始化  
\*/  
private static synchronized void poolInit() \{  
if (pool == null)  
createJedisPool();  
\}  
  
/\*\*  
\* 获取一个jedis 对象  
\*  
\* @return  
\*/  
public static Jedis getJedis() \{  
if (pool == null)  
poolInit();  
return pool.getResource();  
\}  
  
/\*\*  
\* 释放一个连接  
\*  
\* @param jedis  
\*/  
public static void returnRes(Jedis jedis) \{  
pool.returnResource(jedis);  
\}  
  
/\*\*  
\* 销毁一个连接  
\*  
\* @param jedis  
\*/  
public static void returnBrokenRes(Jedis jedis) \{  
pool.returnBrokenResource(jedis);  
\}  
  
  
public static void main(String\[\] args)\{  
Jedis jedis=getJedis();  
  
\}  
  
\}