您好,登錄后才能下訂單哦!
小編給大家分享一下Spring Cloud Config Client超時(shí)及重試的示例分析,希望大家閱讀完這篇文章之后都有所收獲,下面讓我們一起去探討吧!
為 web 項(xiàng)目添加依賴
開啟客戶端重試功能需要兩個(gè)新依賴,spring-retry 和 spring-boot-starter-aop,把如下代碼添加到 web 項(xiàng)目的 pom.xml 文件中:
<dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> <version>1.2.2.RELEASE</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> </dependency>
然后在 bootstrap.yml 文件中添加如下配置:
spring: application: name: web-client cloud: config: uri: http://localhost:8888 fail-fast: true retry: initial-interval: 1000 max-attempts: 6 max-interval: 2000 multiplier: 1.1
首先把 spring.cloud.config.fail-fast 為true,即在獲取不到遠(yuǎn)程配置時(shí),立即失敗,但是用下邊的配置進(jìn)行重試。
spring.cloud.config.retry 所有子項(xiàng)均為默認(rèn)值:
initial-interval: 最初重試間隔為 1000 毫秒
max-attempts: 最多重試 6 次
max-interval: 最長(zhǎng)重試間隔為 2000 毫秒
multiplier: 每次重試失敗后,重試間隔所增加的倍數(shù)
測(cè)試
如果使用了本教程的項(xiàng)目,我們需要首先啟動(dòng) configserver 項(xiàng)目,然后再啟動(dòng) registry 項(xiàng)目開啟 eureka,因?yàn)?web 客戶端使用了 eureka 服務(wù),之后關(guān)閉 configserver,然后啟動(dòng) web 項(xiàng)目,會(huì)看到如下 log:
2018-05-15 16:04:58.421 INFO 2663 --- [ main] c.c.c.ConfigServicePropertySourceLocator : Fetching config from server at: http://localhost:8888
重試 6 次失敗后,客戶端啟動(dòng)失敗,如果中途開啟 configserver,則 web 客戶端啟動(dòng)成功。
細(xì)粒度控制重試
我們可以在代碼中實(shí)現(xiàn)更精細(xì)的控制重試機(jī)制,在 web 項(xiàng)目中創(chuàng)建一個(gè)新的 java 類 cn.zxuqian.configurations.RetryConfiguration,添加如下代碼:
package cn.zxuqian.configurations; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.retry.interceptor.RetryInterceptorBuilder; import org.springframework.retry.interceptor.RetryOperationsInterceptor; public class RetryConfiguration { private static Logger log = LoggerFactory.getLogger(RetryConfiguration.class); @Bean @ConditionalOnMissingBean(name = "configServerRetryInterceptor") public RetryOperationsInterceptor configServerRetryInterceptor() { log.info(String.format( "configServerRetryInterceptor: Changing backOffOptions " + "to initial: %s, multiplier: %s, maxInterval: %s", 1000, 1.2, 5000)); return RetryInterceptorBuilder .stateless() .backOffOptions(1000, 1.2, 5000) .maxAttempts(10) .build(); } }
這里我們定義了configServerRetryInterceptor方法用于 Spring Retry 使用我們自定義的重試攔截器。方法使用 RetryInterceptorBuilder 按要求創(chuàng)建了一個(gè) stateless 的 RetryOperationsInterceptor,并設(shè)置了初始重試間隔為 1000 毫秒,增加倍數(shù)為 1.2 倍,最大重試間隔為 5000 毫秒,最大重試次數(shù)為 10 次,builder 還提供了諸如配置重試機(jī)制之類的接口,有興趣的讀者可自行研究。
@ConditionalOnMissingBean 標(biāo)明當(dāng) BeanFactory 中沒(méi)有名為 configServerRetryInterceptor 的 bean 時(shí)才匹配此 Bean。
最后在 src/main/resources/META-INF/ (沒(méi)有可創(chuàng)建此文件夾) 新建一個(gè) spring.factories 文件,指定我們剛創(chuàng)建類為啟動(dòng)時(shí)的配置,以在獲取遠(yuǎn)程配置之前生效:
org.springframework.cloud.bootstrap.BootstrapConfiguration=cn.zxuqian.configurations.RetryConfiguration
測(cè)試
最后在關(guān)閉 configserver 的條件下啟動(dòng) web 項(xiàng)目,然后就會(huì)看到重試十次之后,項(xiàng)目啟動(dòng)失敗。
看完了這篇文章,相信你對(duì)“Spring Cloud Config Client超時(shí)及重試的示例分析”有了一定的了解,如果想了解更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。