首頁 > 資料庫 > Redis > 主體

Springboot2.x整合lettuce連接redis集群報超時異常怎麼解決

PHPz
發布: 2023-05-27 19:43:05
轉載
1918 人瀏覽過

背景:最近在對一新開發Springboot系統做壓測,發現剛開始壓測時,可以正常對redis集群進行數據訪問,但是暫停幾分鐘後,接著繼續用jmeter進行壓測時,發現redis就開始突然瘋狂爆出異常提示:Command timed out after 6 second(s)……

  1 Caused by: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 6 second(s)  2     at io.lettuce.core.ExceptionFactory.createTimeoutException(ExceptionFactory.java:51)  3     at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:114)  4     at io.lettuce.core.cluster.ClusterFutureSyncInvocationHandler.handleInvocation(ClusterFutureSyncInvocationHandler.java:123)  5     at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:80)  6     at com.sun.proxy.$Proxy134.mget(Unknown Source)  7     at org.springframework.data.redis.connection.lettuce.LettuceStringCommands.mGet(LettuceStringCommands.java:119)  8     ... 15 common frames omitted
登入後複製

我急忙檢查redis集群,發現集群裡的各節點都一切正常,且cpu和內存使用率還不到百分之二十,看著這一切,我突然陷入漫長的沉思,到底是哪裡出現問題……百度一番,發現不少人都出現過類似情況的,有人說把超時timeout設置更大一些就可以解決了。我按照這樣的解決方法,把超時timeout的值設定到更大後,還是沒有解決這個超時問題。

其中,springboot操作redis的依賴套件是-

  1 <dependency>  2     <groupId>org.springframework.boot</groupId>  3     <artifactId>spring-boot-starter-data-redis</artifactId>  4 </dependency>
登入後複製

叢集配置-

  1 redis:  2   timeout: 6000ms  3   cluster:  4     nodes:  5       - xxx.xxx.x.xxx:6379  6       - xxx.xxx.x.xxx:6379  7       - xxx.xxx.x.xxx:6379  8   jedis:  9     pool: 10       max-active: 1000 11       max-idle: 10 12       min-idle: 5 13       max-wait: -1
登入後複製

點進spring-boot-starter-data-redis進去,發現裡面包含了lettuce的依賴:

 Springboot2.x整合lettuce連接redis集群報超時異常怎麼解決

springboot1.x預設使用的是jedis,到了Springboot2.x就預設使用了lettuce。我們可以簡單驗證一下,在redis驅動載入組態類別裡,輸出一下RedisConnectionFactory資訊:

  1 @Configuration  2 @AutoConfigureAfter(RedisAutoConfiguration.class)  3 public class Configuration {  4     @Bean  5     public StringRedisTemplate redisTemplate(RedisConnectionFactory factory) {  6         log.info("测试打印驱动类型:"+factory);  7 }
登入後複製

列印輸出-

测试打印驱动类型:org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory@74ee761e
登入後複製

可見,這裡使用正是lettuce驅動連接,因此,當把它換成以前用的比較多的jedis驅動連接時,就沒有再出現這個Command timed out after 6 second(s)問題了。

  1 <dependency>  2     <groupId>org.springframework.boot</groupId>  3     <artifactId>spring-boot-starter-data-redis</artifactId>  4     <exclusions>  5         <exclusion>  6             <groupId>io.lettuce</groupId>  7             <artifactId>lettuce-core</artifactId>  8         </exclusion>  9     </exclusions> 10 </dependency> 11 <dependency> 12     <groupId>redis.clients</groupId> 13     <artifactId>jedis</artifactId> 14 </dependency>
登入後複製

那麼問題來了,Springboot2.x是如何預設使用了lettuce,這得去研究下裡面的部分程式碼。我們可以可進入到Springboot2.x自動組裝模組的redis部分,其中有一個RedisAutoConfiguration類,其主要作用是對Springboot自動配置連接redis類:

  1 @Configuration(  2     proxyBeanMethods = false  3 )  4 @ConditionalOnClass({RedisOperations.class})  5 @EnableConfigurationProperties({RedisProperties.class})  6 @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})  7 public class RedisAutoConfiguration {  8     public RedisAutoConfiguration() {  9    } 10    ......省略 11 }
登入後複製

這裡只需要關注裡面的一行註解:

  1   2 @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})  3
登入後複製

這表示使用spring-boot-starter-data-redis依賴時,可自動導入lettuce和jedis兩種驅動,按理來說,不會同時存在兩種驅動,這樣沒有太大意義,因此,這裡的先後順序就很重要了,為什麼這麼說呢?

分別進入LettuceConnectionConfiguration.class與JedisConnectionConfiguration.class當中,各自展示本文需要涉及到的核心程式碼:

  1 //LettuceConnectionConfiguration  2 @ConditionalOnClass({RedisClient.class})  3 class LettuceConnectionConfiguration extends RedisConnectionConfiguration {  4    ......省略  5     @Bean  6     @ConditionalOnMissingBean({RedisConnectionFactory.class})  7     LettuceConnectionFactory redisConnectionFactory(ObjectProvider<LettuceClientConfigurationBuilderCustomizer> builderCustomizers, ClientResources clientResources) throws UnknownHostException {  8         LettuceClientConfiguration clientConfig = this.getLettuceClientConfiguration(builderCustomizers, clientResources, this.getProperties().getLettuce().getPool());  9         return this.createLettuceConnectionFactory(clientConfig); 10    } 11 } 12 //JedisConnectionConfiguration 13 @ConditionalOnClass({GenericObjectPool.class, JedisConnection.class, Jedis.class}) 14 class JedisConnectionConfiguration extends RedisConnectionConfiguration { 15    ......省略 16     @Bean 17     @ConditionalOnMissingBean({RedisConnectionFactory.class}) 18     JedisConnectionFactory redisConnectionFactory(ObjectProvider<JedisClientConfigurationBuilderCustomizer> builderCustomizers) throws UnknownHostException { 19         return this.createJedisConnectionFactory(builderCustomizers); 20    } 21 } 22
登入後複製

可見,LettuceConnectionConfiguration.class與JedisConnectionConfiguration.class當中都有一個相同的註解@ConditionalOnMissingBean({RedisConnectionFactory.class}),這是說,假如RedisConnectionFactory這個bean已經被註冊到容器裡,那麼與它相似的其他Bean就不會再被加載註冊,簡單點說,對LettuceConfiguration與JedisConnectionConfiguration各自加上@ConditionalOnMissingBean({RedisConnectionFactory.class})註解,兩者當中只能載入註冊其中一個到容器裡,另外一個就不會再進行載入註冊。

那麼,問題就來了,誰會先被註冊呢?

這就回到了上面提到的一句,@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})這一句裡的先後順序很關鍵,LettuceConnectionConfiguration在前面,就意味著,LettuceConnectionConfiguration將會被註冊。

可見,Springboot預設是使用lettuce來連接redis的。

當我們引入spring-boot-starter-data-redis依賴包時,其實就相當於引入lettuce包,這時就會使用lettuce驅動,若不想使用該預設的lettuce驅動,直接將lettuce依賴排除即可。

  1 <dependency>  2     <groupId>org.springframework.boot</groupId>  3     <artifactId>spring-boot-starter-data-redis</artifactId>  4     <exclusions>  5         <exclusion>  6             <groupId>io.lettuce</groupId>  7             <artifactId>lettuce-core</artifactId>  8         </exclusion>  9     </exclusions> 10 </dependency>
登入後複製

然後再引入jedis依賴-

  1 <dependency>  2     <groupId>redis.clients</groupId>  3     <artifactId>jedis</artifactId>  4 </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))-

  1 public Boolean zAdd(byte[] key, double score, byte[] value) {  2     Assert.notNull(key, "Key must not be null!");  3     Assert.notNull(value, "Value must not be null!");  4   5     try {  6         if (this.isPipelined()) {  7             this.pipeline(this.connection.newLettuceResult(this.getAsyncConnection().zadd(key, score, value), LettuceConverters.longToBoolean()));  8             return null;  9        } else if (this.isQueueing()) { 10             this.transaction(this.connection.newLettuceResult(this.getAsyncConnection().zadd(key, score, value), LettuceConverters.longToBoolean())); 11             return null; 12        } else { 13             return LettuceConverters.toBoolean(this.getConnection().zadd(key, score, value)); 14        } 15    } catch (Exception var6) { 16         throw this.convertLettuceAccessException(var6); 17    } 18 }
登入後複製

#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連線失敗的時候。

以上是Springboot2.x整合lettuce連接redis集群報超時異常怎麼解決的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:yisu.com
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板