关于Springboot2.x集成lettuce连接redis集群报超时异常Command timed out after 6 second(s)
背景：最近在对一新开发Springboot系统做压测，发现刚开始压测时，可以正常对redis集群进行数据存取，但是暂停几分钟后，接着继续用jmeter进行压测时，发现redis就开始突然疯狂爆出异常提示：Command timed out after 6 second(s)......
Caused by: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 6 second(s) at io.lettuce.core.ExceptionFactory.createTimeoutException(ExceptionFactory.java:51) at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:114) at io.lettuce.core.cluster.ClusterFutureSyncInvocationHandler.handleInvocation(ClusterFutureSyncInvocationHandler.java:123) at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:80) at com.sun.proxy.$Proxy134.mget(Unknown Source) at org.springframework.data.redis.connection.lettuce.LettuceStringCommands.mGet(LettuceStringCommands.java:119) ... 15 common frames omitted
我急忙检查redis集群，发现集群里的各节点都一切正常，且cpu和内存使用率还不到百分之二十，看着这一切，我突然陷入漫长的沉思，到底是哪里出现问题......百度一番，发现不少人都出现过类似情况的，有人说把超时timeout设置更大一些就可以解决了。我按照这样的解决方法，把超时timeout的值设置到更大后，依然没有解决该超时问题。
其中，springboot操作redis的依赖包是――
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
集群配置――
redis: timeout: 6000ms cluster: nodes: - xxx.xxx.x.xxx:6379 - xxx.xxx.x.xxx:6379 - xxx.xxx.x.xxx:6379 jedis: pool: max-active: 1000 max-idle: 10 min-idle: 5 max-wait: -1
点进spring-boot-starter-data-redis进去，发现里面包含了lettuce的依赖：
看到一些网友说，springboot1.x默认使用的是jedis，到了Springboot2.x就默认使用了lettuce。我们可以简单验证一下，在redis驱动加载配置类里，输出一下RedisConnectionFactory信息：
@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class Configuration {
@Bean
public StringRedisTemplate redisTemplate(RedisConnectionFactory factory) {
log.info("测试打印驱动类型:"+factory);
}
打印输出――
测试打印驱动类型:org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory@74ee761e
可见，这里使用正是是lettuce驱动连接，目前我暂时的解决办法，是当把它换成以前用的比较多的jedis驱动连接时，就没有再出现这个Command timed out after 6 second(s)问题了。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <exclusions> <exclusion> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>
那么问题来了，Springboot2.x是如何默认使用了lettuce，这得去研究下里面的部分代码。我们可以可进入到Springboot2.x自动装配模块的redis部分，其中有一个RedisAutoConfiguration类，其主要作用是对Springboot自动配置连接redis类：
@Configuration(
proxyBeanMethods = false
)
@ConditionalOnClass({RedisOperations.class})
@EnableConfigurationProperties({RedisProperties.class})
@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})
public class RedisAutoConfiguration {
public RedisAutoConfiguration() {
}
......省略
}
这里只需要关注里面的一行注解：
@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})
这就意味着使用spring-boot-starter-data-redis依赖时，可自动导入lettuce和jedis两种驱动，按理来说，不会同时存在两种驱动，这样没有太大意义，因此，这里的先后顺序就很重要了，为什么这么说呢？
分别进入到LettuceConnectionConfiguration.class与JedisConnectionConfiguration.class当中，各自展示本文需要涉及到的核心代码：
//LettuceConnectionConfiguration
@ConditionalOnClass({RedisClient.class})
class LettuceConnectionConfiguration extends RedisConnectionConfiguration {
......省略
@Bean
@ConditionalOnMissingBean({RedisConnectionFactory.class})
LettuceConnectionFactory redisConnectionFactory(ObjectProvider<LettuceClientConfigurationBuilderCustomizer> builderCustomizers, ClientResources clientResources) throws UnknownHostException {
LettuceClientConfiguration clientConfig = this.getLettuceClientConfiguration(builderCustomizers, clientResources, this.getProperties().getLettuce().getPool());
return this.createLettuceConnectionFactory(clientConfig);
}
}
//JedisConnectionConfiguration
@ConditionalOnClass({GenericObjectPool.class, JedisConnection.class, Jedis.class})
class JedisConnectionConfiguration extends RedisConnectionConfiguration {
......省略
@Bean
@ConditionalOnMissingBean({RedisConnectionFactory.class})
JedisConnectionFactory redisConnectionFactory(ObjectProvider<JedisClientConfigurationBuilderCustomizer> builderCustomizers) throws UnknownHostException {
return this.createJedisConnectionFactory(builderCustomizers);
}
}
可见，LettuceConnectionConfiguration.class与JedisConnectionConfiguration.class当中都有一个相同的注解 @ConditionalOnMissingBean({RedisConnectionFactory.class})，这是说，假如RedisConnectionFactory这个bean已经被注册到容器里，那么与它相似的其他Bean就不会再被加载注册，简单点说，对LettuceConnectionConfiguration与JedisConnectionConfiguration各自加上 @ConditionalOnMissingBean({RedisConnectionFactory.class})注解，两者当中只能加载注册其中一个到容器里，另外一个就不会再进行加载注册。
那么，问题就来了，谁会先被注册呢？
这就回到了上面提到的一句，@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})这一句里的先后顺序很关键，LettuceConnectionConfiguration在前面，就意味着，LettuceConnectionConfiguration将会被注册。
可见，Springboot默认是使用lettuce来连接redis的。
当我们引入spring-boot-starter-data-redis依赖包时，其实就相当于引入lettuce包，这时就会使用lettuce驱动，若不想使用该默认的lettuce驱动，直接将lettuce依赖排除即可。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <exclusions> <exclusion> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> </exclusion> </exclusions> </dependency>
然后再引入jedis依赖――
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>
这样，在进行RedisAutoConfiguration的导入注解时，因为没有找到lettuce依赖，故而这注解@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})的第二个位置上的JedisConnectionConfiguration就有效了，就可以被注册到容器了，当做springboot操作redis的驱动。
lettuce与jedis两者有什么区别呢？
lettuce：底层是用netty实现，线程安全，默认只有一个实例。
jedis：可直连redis服务端，配合连接池使用，可增加物理连接。
根据异常提示找到出现错误的方法，在下列代码里的LettuceConverters.toBoolean(this.getConnection().zadd(key, score, value))――
public Boolean zAdd(byte[] key, double score, byte[] value) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(value, "Value must not be null!");
try {
if (this.isPipelined()) {
this.pipeline(this.connection.newLettuceResult(this.getAsyncConnection().zadd(key, score, value), LettuceConverters.longToBoolean()));
return null;
} else if (this.isQueueing()) {
this.transaction(this.connection.newLettuceResult(this.getAsyncConnection().zadd(key, score, value), LettuceConverters.longToBoolean()));
return null;
} else {
return LettuceConverters.toBoolean(this.getConnection().zadd(key, score, value));
}
} catch (Exception var6) {
throw this.convertLettuceAccessException(var6);
}
}
LettuceConverters.toBoolean（）是将long转为Boolean，正常情况下，this.getConnection().zadd(key, score, value)如果新增成功话，那么返回1，这样LettuceConverters.toBoolean(1)得到的是true，反之，如果新增失败，则返回0，即LettuceConverters.toBoolean(0)，还有第三种情况，就是这个this.getConnection().zadd(key, score, value)方法出现异常，什么情况下会出现异常呢？
应该是，connection连接失败的时候。
这就意味着，以lettuce驱动连接redis的过程当中，会出现连接断开的情况，导致无法新增成功，超过一定时间还没有正常，就会出现连接超时的情况。
至于是什么原因导致的断开连接，暂时还没有比较好思路，暂且把这个问题留着，等慢慢研究看是否能找到问题所在，若有大神指点，也感激不尽。
上一篇：java实现系统多级文件夹复制
栏 目：JAVA代码
下一篇：泛谈Java中的不可变数据结构
本文标题：关于Springboot2.x集成lettuce连接redis集群报超时异常Command timed out after 6 second(s)
本文地址：http://www.codeinn.net/misctech/221505.html
