Spring Cloud重試機制與各組件的重試總結(jié)
SpringCloud重試機制配置
首先聲明一點,這里的重試并不是報錯以后的重試,而是負載均衡客戶端發(fā)現(xiàn)遠程請求實例不可到達后,去重試其他實例。

@Bean
@LoadBalanced
RestTemplate restTemplate() {
HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory();
httpRequestFactory.setReadTimeout(5000);
httpRequestFactory.setConnectTimeout(5000);
return new RestTemplate(httpRequestFactory);
}

feign重試機制
feign默認是通過自己包下的Retryer進行重試配置,默認是5次
package feign;
import static java.util.concurrent.TimeUnit.SECONDS;
/**
* Cloned for each invocation to {@link Client#execute(Request, feign.Request.Options)}.
* Implementations may keep state to determine if retry operations should continue or not.
*/
public interface Retryer extends Cloneable {
/**
* if retry is permitted, return (possibly after sleeping). Otherwise propagate the exception.
*/
void continueOrPropagate(RetryableException e);
Retryer clone();
public static class Default implements Retryer {
private final int maxAttempts;
private final long period;
private final long maxPeriod;
int attempt;
long sleptForMillis;
public Default() {
this(100, SECONDS.toMillis(1), 5);
}
public Default(long period, long maxPeriod, int maxAttempts) {
this.period = period;
this.maxPeriod = maxPeriod;
this.maxAttempts = maxAttempts;
this.attempt = 1;
}
feign取消重試
@Bean
Retryer feignRetryer() {
return Retryer.NEVER_RETRY;
}
feign請求超時設置
@Bean
Request.Options requestOptions(ConfigurableEnvironment env){
int ribbonReadTimeout = env.getProperty("ribbon.ReadTimeout", int.class, 6000);
int ribbonConnectionTimeout = env.getProperty("ribbon.ConnectTimeout", int.class, 3000);
return new Request.Options(ribbonConnectionTimeout, ribbonReadTimeout);
}
Spring Cloud中各組件的重試
最近挺多童鞋問我如何配置Spring Cloud xxx組件的重試。本篇進行一個總結(jié)。
Spring Cloud中的重試機制應該說是比較混亂的,不同的版本有一定區(qū)別,實現(xiàn)也不大一樣,好在Spring Cloud Camden之后已經(jīng)基本穩(wěn)定下來,Dalston中又進行了一些改進,詳情暫且不表。
下面我們來詳細探討。
筆者使用的版本是 Spring Cloud Dalston SR4 ,同樣適應于Edgware 以及更高版本,對于Dalston 此前的版本,本文不做討論,大家可自行研究。
Ribbon+RestTemplate的重試
對于整合了Ribbon的RestTemplate,例如一個RestTemplate添加了@LoadBalanced 注解:
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
SimpleClientHttpRequestFactory simpleClientHttpRequestFactory = new SimpleClientHttpRequestFactory();
simpleClientHttpRequestFactory.setConnectTimeout(1000);
simpleClientHttpRequestFactory.setReadTimeout(1000);
return new RestTemplate(simpleClientHttpRequestFactory);
}
在此基礎上,使用如下配置,即可實現(xiàn)重試:
spring: cloud: loadbalancer: retry: enabled: true ribbon: # 同一實例最大重試次數(shù),不包括首次調(diào)用 MaxAutoRetries: 1 # 重試其他實例的最大重試次數(shù),不包括首次所選的server MaxAutoRetriesNextServer: 2 # 是否所有操作都進行重試 OkToRetryOnAllOperations: false
Feign的重試
Feign本身也具備重試能力,在早期的Spring Cloud中,F(xiàn)eign使用的是 feign.Retryer.Default#Default() ,重試5次。但Feign整合了Ribbon,Ribbon也有重試的能力,此時,就可能會導致行為的混亂。
Spring Cloud意識到了此問題,因此做了改進,將Feign的重試改為 feign.Retryer#NEVER_RETRY ,如需使用Feign的重試,只需使用Ribbon的重試配置即可。因此,對于Camden以及以后的版本,F(xiàn)eign的重試可使用如下屬性進行配置:
ribbon: MaxAutoRetries: 1 MaxAutoRetriesNextServer: 2 OkToRetryOnAllOperations: false
相關(guān)Issue可參考:https://github.com/spring-cloud/spring-cloud-netflix/issues/467
Zuul的重試
配置:
zuul: # 開啟Zuul的重試 retryable: true ribbon: MaxAutoRetries: 1 MaxAutoRetriesNextServer: 2 OkToRetryOnAllOperations: false
上面我們使用 zuul.retryable=true 對Zuul全局開啟了重試,事實上,也可對指定路由開啟/關(guān)閉重試:
zuul.routes.<routename>.retryable=true
局部配置優(yōu)先級更高。
基于HTTP響應碼重試
clientName: ribbon: retryableStatusCodes: 404,502
注意點:
Hystrix的超時時間必須大于超時的時間,否則,一旦Hystrix超時,就沒辦法繼續(xù)重試了。
一般來說,不建議將ribbon.OkToRetryOnAllOperations 設為true。因為一旦啟用該配置,則表示重試任何操作,包括POST請求,而由于緩存了請求體,此時可能會影響服務器的資源。
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對腳本之家的支持。
相關(guān)文章
SpringBoot+Email發(fā)送郵件的實現(xiàn)示例
Spring?Boot提供了簡單而強大的郵件發(fā)送功能,本文主要介紹了SpringBoot+Email發(fā)送郵件的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下2024-03-03
Java畢業(yè)設計實戰(zhàn)之健身俱樂部管理系統(tǒng)的實現(xiàn)
這是一個使用了java+SSM+Mysql+Jsp開發(fā)的健身俱樂部管理系統(tǒng),是一個畢業(yè)設計的實戰(zhàn)練習,具有俱樂部管理該有的所有功能,感興趣的朋友快來看看吧2022-02-02
springMVC使用ajaxFailUpload上傳圖片的方法
這篇文章主要介紹了springMVC使用ajaxFailUpload上傳圖片的相關(guān)知識,代碼簡單易懂,非常不錯,具有一定的參考借鑒價值,需要的朋友可以參考下2018-06-06
Java中使用json與前臺Ajax數(shù)據(jù)交互的方法
這篇文章主要為大家詳細介紹了Java中使用json與前臺Ajax數(shù)據(jù)交互的方法,分享Ajax獲取顯示Json數(shù)據(jù)的一種方法,感興趣的小伙伴們可以參考一下2016-06-06

