Spring Boot/Spring Cloud中Redis报错Connection reset

素颜马尾好姑娘i 2022-11-29 11:41 301阅读 0赞

***[点此查看全部文字教程、视频教程、源代码][Link 1]***

### 本文目录 ###

*  1. 现象
 *  2. 思路
 *  3. 实现
 *  4. 实验

# 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. 实现 #

首先引入相关依赖：

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-redis</artifactId>
    		</dependency>
    		
    		<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. 实验 #

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

[Link 1]: https://studyingpanda.blog.csdn.net/article/details/105329926