Spring Boot/Spring Cloud中Redis报错Connection reset

1. 现象

Spring Cloud项目，使用的JRedis连接池，日志里面经常会发现报错信息如下：

Caused by: redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketException: Connection reset

at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:202)

at redis.clients.util.RedisInputStream.readByte(RedisInputStream.java:40)

at redis.clients.jedis.Protocol.process(Protocol.java:153)

at redis.clients.jedis.Protocol.read(Protocol.java:218)

at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:341)

at redis.clients.jedis.Connection.getStatusCodeReply(Connection.java:240)

at redis.clients.jedis.BinaryJedis.quit(BinaryJedis.java:256)

at org.springframework.data.redis.connection.jedis.JedisConnection.close(JedisConnection.java:298)

... 38 common frames omitted

Caused by: java.net.SocketException: Connection reset

at java.net.SocketInputStream.read(Unknown Source)

at java.net.SocketInputStream.read(Unknown Source)

at java.net.SocketInputStream.read(Unknown Source)

at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:196)

Connection reset表示连接被重置，具体含义是服务器端因为某些原因关闭了Connection，这肯定是跟连接的数量、超时时间等相关。

2. 思路

网上查询相关资料，了解到JRedis在多线程情况下共享一个实例是不安全的，所以是一个很大的隐患。而且JRedis也不能较好的支持较多的连接数。

所以问题应该是出在连接池上，JRedis在多线程高并发的情况下，是一个定时炸弹，竟然如此，换掉就是了。

继续查询资料，找到了基于Netty的Lettuce，看到Netty就放心了，有点资历的程序猿都知道是高性能高并发的绝佳带盐。

3. 实现

首先引入相关依赖：

<!-- redis -->

 <dependency>

  <groupId>org.springframework.boot</groupId>

  <artifactId>spring-boot-starter-data-redis</artifactId>

 </dependency>

 <!-- lettuce pool 缓存连接池 -->

 <dependency>

  <groupId>org.apache.commons</groupId>

  <artifactId>commons-pool2</artifactId>

 </dependency>

然后配置连接参数：

spring:

 # redis配置信息

 redis:

   # redis数据库索引（默认为0）

   database:  0

   # redis服务器地址  

   host:  192.168.20.214

   # redis服务器连接端口  

   port:  6379

   password:

   lettuce:

     pool:

       max-total: 100

       max-active: 100

       max-wait:  1000

       max-idle:  20

       min-idle:  0

最后使用配置类：

/**

* redis配置类

*/

@Configuration

@EnableCaching

public class RedisConfig extends CachingConfigurerSupport {

@Bean

public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {

 RedisTemplate<String, Object> template = new RedisTemplate<>();

 // 连接工厂

 template.setConnectionFactory(factory);

 // 使用Jackson2JsonRedisSerializer

 Jackson2JsonRedisSerializer<Object> jacksonSeial = new Jackson2JsonRedisSerializer<Object>(Object.class);

 ObjectMapper om = new ObjectMapper();

 // 指定要序列化的域

 om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

 // 指定序列化输入的类型

 om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

 jacksonSeial.setObjectMapper(om);

 // 值采用json序列化

 template.setValueSerializer(jacksonSeial);

 // 使用StringRedisSerializer

 template.setKeySerializer(new StringRedisSerializer());

 // 设置hash序列化模式

 template.setHashKeySerializer(new StringRedisSerializer());

 template.setHashValueSerializer(jacksonSeial);

 template.afterPropertiesSet();

 return template;

}

}

4. 实验

修改后重新启动项目，发现比较稳定，后续有问题再反馈吧。