欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

Springboot2.x集成lettuce連接redis集群報超時異常怎么解決

本篇內(nèi)容主要講解“Springboot2.x集成lettuce連接redis集群報超時異常怎么解決”,感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷,實用性強。下面就讓小編來帶大家學(xué)習(xí)“Springboot2.x集成lettuce連接redis集群報超時異常怎么解決”吧!

防城港ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場景,ssl證書未來市場廣闊!成為成都創(chuàng)新互聯(lián)的ssl證書銷售渠道,可以享受市場價格4-6折優(yōu)惠!如果有意向歡迎電話聯(lián)系或者加微信:18980820575(備注:SSL證書合作)期待與您的合作!

背景:最近在對一新開發(fā)Springboot系統(tǒng)做壓測,發(fā)現(xiàn)剛開始壓測時,可以正常對redis集群進(jìn)行數(shù)據(jù)存取,但是暫停幾分鐘后,接著繼續(xù)用jmeter進(jìn)行壓測時,發(fā)現(xiàn)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集群,發(fā)現(xiàn)集群里的各節(jié)點都一切正常,且cpu和內(nèi)存使用率還不到百分之二十,看著這一切,我突然陷入漫長的沉思,到底是哪里出現(xiàn)問題……百度一番,發(fā)現(xiàn)不少人都出現(xiàn)過類似情況的,有人說把超時timeout設(shè)置更大一些就可以解決了。我按照這樣的解決方法,把超時timeout的值設(shè)置到更大后,依然沒有解決該超時問題。

其中,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

點進(jìn)spring-boot-starter-data-redis進(jìn)去,發(fā)現(xiàn)里面包含了lettuce的依賴:

 Springboot2.x集成lettuce連接redis集群報超時異常怎么解決

springboot1.x默認(rèn)使用的是jedis,到了Springboot2.x就默認(rèn)使用了lettuce。我們可以簡單驗證一下,在redis驅(qū)動加載配置類里,輸出一下RedisConnectionFactory信息:

  1 @Configuration  2 @AutoConfigureAfter(RedisAutoConfiguration.class)  3 public class Configuration {  4     @Bean  5     public StringRedisTemplate redisTemplate(RedisConnectionFactory factory) {  6         log.info("測試打印驅(qū)動類型:"+factory);  7 }

打印輸出——

測試打印驅(qū)動類型:org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory@74ee761e

可見,這里使用正是是lettuce驅(qū)動連接,因此,當(dāng)把它換成以前用的比較多的jedis驅(qū)動連接時,就沒有再出現(xiàn)這個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是如何默認(rèn)使用了lettuce,這得去研究下里面的部分代碼。我們可以可進(jìn)入到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 }

這里只需要關(guān)注里面的一行注解:

  1   2 @Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})  3

這就意味著使用spring-boot-starter-data-redis依賴時,可自動導(dǎo)入lettuce和jedis兩種驅(qū)動,按理來說,不會同時存在兩種驅(qū)動,這樣沒有太大意義,因此,這里的先后順序就很重要了,為什么這么說呢?

分別進(jìn)入到LettuceConnectionConfiguration.class與JedisConnectionConfiguration.class當(dāng)中,各自展示本文需要涉及到的核心代碼:

  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當(dāng)中都有一個相同的注解 @ConditionalOnMissingBean({RedisConnectionFactory.class}),這是說,假如RedisConnectionFactory這個bean已經(jīng)被注冊到容器里,那么與它相似的其他Bean就不會再被加載注冊,簡單點說,對LettuceConnectionConfiguration與JedisConnectionConfiguration各自加上 @ConditionalOnMissingBean({RedisConnectionFactory.class})注解,兩者當(dāng)中只能加載注冊其中一個到容器里,另外一個就不會再進(jìn)行加載注冊。

那么,問題就來了,誰會先被注冊呢?

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

可見,Springboot默認(rèn)是使用lettuce來連接redis的。

當(dāng)我們引入spring-boot-starter-data-redis依賴包時,其實就相當(dāng)于引入lettuce包,這時就會使用lettuce驅(qū)動,若不想使用該默認(rèn)的lettuce驅(qū)動,直接將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>

這樣,在進(jìn)行RedisAutoConfiguration的導(dǎo)入注解時,因為沒有找到lettuce依賴,故而這注解@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})的第二個位置上的JedisConnectionConfiguration就有效了,就可以被注冊到容器了,當(dāng)做springboot操作redis的驅(qū)動。

lettuce與jedis兩者有什么區(qū)別呢?

lettuce:底層是用netty實現(xiàn),線程安全,默認(rèn)只有一個實例。

jedis:可直連redis服務(wù)端,配合連接池使用,可增加物理連接。

根據(jù)異常提示找到出現(xiàn)錯誤的方法,在下列代碼里的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轉(zhuǎn)為Boolean,正常情況下,this.getConnection().zadd(key, score, value)如果新增成功話,那么返回1,這樣LettuceConverters.toBoolean(1)得到的是true,反之,如果新增失敗,則返回0,即LettuceConverters.toBoolean(0),還有第三種情況,就是這個this.getConnection().zadd(key, score, value)方法出現(xiàn)異常,什么情況下會出現(xiàn)異常呢?應(yīng)該是,connection連接失敗的時候。

到此,相信大家對“Springboot2.x集成lettuce連接redis集群報超時異常怎么解決”有了更深的了解,不妨來實際操作一番吧!這里是創(chuàng)新互聯(lián)網(wǎng)站,更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢,關(guān)注我們,繼續(xù)學(xué)習(xí)!

網(wǎng)頁題目:Springboot2.x集成lettuce連接redis集群報超時異常怎么解決
文章網(wǎng)址:http://aaarwkj.com/article16/peecdg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供企業(yè)建站網(wǎng)站內(nèi)鏈、營銷型網(wǎng)站建設(shè)、App設(shè)計微信小程序、

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

成都網(wǎng)頁設(shè)計公司
精品一区二区久久久久久| 国产精品自产在线观看一 | 亚洲午夜黄色生活片观看| 亚洲午夜一区二区不卡| 国产高潮呻吟久久av| 麻豆一区二区人妻网站| 国产亚洲加勒比久久精品| 97视频在线观看免费| 99久热在线精品视频| 久久96国产精品久久秘臀| 97精品久久九九中文字幕 | 爱高潮www亚洲精品| 日韩精品人妻一区二区网站| 色综合色很天天综合色| 亚洲一区二区三区久久精品| 国产av网站精品成人| 一区二区三区欧美日| 门国产av一区二区三区| 蜜臀av一区二区三区人妻| 亚洲av成人在线播放| 国产亚洲视频一区二区观看| 中国一区二区三区毛片| 亚洲一品道在线观看| 欧美日本一区二区四区| 成人av免费高清在线| 亚洲中文字幕在线不卡| 成人午夜三级在线观看| 麻豆视传媒官网免费观看| 欧美性做爰片免费视频网| 免费看真人性生活视频| 日韩精品熟妻人女亚洲一区| 亚洲精品国产熟女av| 欧美高清一区二区三区不卡| 国产精品久久久久精品爆| 可以免费看黄的网久久| 中文字幕日韩av综合在线| 国产精品一区二区综合亚洲| 日韩一二三区欧美四五区新| 神马久久午夜免费福利| 亚洲av资源一区二区| 中文有码人妻字幕在线|