關於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的過程當中，會出現連接斷開的情況，導致無法新增成功，超過一定時間還沒有正常，就會出現連接超時的情況。
至於是什麼原因導致的斷開連接，暫時還沒有比較好思路，暫且把這個問題留著，等慢慢研究看是否能找到問題所在，若有大神指點，也感激不盡。
到此這篇關於Springboot2.x集成lettuce連接redis集群報超時異常Command timed out after 6 second(s)的文章就介紹到這瞭,更多相關Springboot連接redis超時內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！
推薦閱讀：
- 詳解springboot中各個版本的redis配置問題
- Spring Boot 2.7.6整合redis與低版本的區別
- SpringBoot淺析緩存機制之Redis單機緩存應用
- springboot 集成redis哨兵主從的實現
- SpringBoot詳解如何整合Redis緩存驗證碼