英文:
Redis Connection Issue with jedis
问题
我正在使用这段代码，但遇到连接问题：
JedisConnectionFactory jedisConnectionFactory() {
JedisConnectionFactory jedisConnectionFactory = null;
try {
RedisStandaloneConfiguration redisStandAloneConfiguration = new RedisStandaloneConfiguration(hostName,
port);
// 使 jedis 连接工厂在多线程环境中线程安全
JedisClientConfiguration jedisClientConfiguration = JedisClientConfiguration.builder().usePooling().build();
jedisConnectionFactory = new JedisConnectionFactory(redisStandAloneConfiguration, jedisClientConfiguration);
// jedisConnectionFactory 默认使用连接池，但最大连接数为 8
jedisConnectionFactory.getPoolConfig().setMaxTotal(50);
jedisConnectionFactory.getPoolConfig().setMaxIdle(50);
jedisConnectionFactory.afterPropertiesSet();
} catch (RedisConnectionFailureException e) {
LOGGER.error("RedisConnector 类中的 RedisConnectionFailureException，与 JEDIS 的连接中断：" +
e.getMessage());
}
return jedisConnectionFactory;
}
注意：我已经忽略了代码部分，只提供了代码的翻译部分。
英文:
I am using this code but getting connection issue:
JedisConnectionFactory jedisConnectionFactory() {
JedisConnectionFactory jedisConnectionFactory = null;
try {
RedisStandaloneConfiguration redisStandAloneConfiguration = new RedisStandaloneConfiguration(hostName,
port);
// make jedis connection factory thread safe (for multi-threaded
// environment)
JedisClientConfiguration jedisClientConfiguration = JedisClientConfiguration.builder().usePooling().build();
jedisConnectionFactory = new JedisConnectionFactory(redisStandAloneConfiguration, jedisClientConfiguration);
// jedisConnectionFactory uses connection pool by default but with
// max total of 8
jedisConnectionFactory.getPoolConfig().setMaxTotal(50);
jedisConnectionFactory.getPoolConfig().setMaxIdle(50);
jedisConnectionFactory.afterPropertiesSet();
} catch (RedisConnectionFailureException e) {
LOGGER.error("RedisConnectionFailureException in RedisConnector class, Connection break with JEDIS " +
e.getMessage());
}
return jedisConnectionFactory;
}
专注分享java语言的经验与见解，让所有开发者获益！
评论