Spring Cloud重试机制与各组件的重试总结

Spring Cloud重试机制与各组件的重试总结

SpringCloud重试机制配置

首先声明一点，这里的重试并不是报错以后的重试，而是负载均衡客户端发现远程请求实例不可到达后，去重试其他实例。

@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 periodtGcpzLUc, 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组件的重试。本篇进行一个总结。

Spring Cloud中的重试机制应该说是比较混乱的，不同的版本有一定区别，实现也不大一样，好在Spring Cloud Camden之后已经基本稳定下来，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);

}

在此基础上，使用如下配置，即可实现重试：

spring:

cloud:

loadbalancer:

retry:

enabled: true

ribbon:

# 同一实例最大重试次数，不包括首次调用

MaxAutoRetries: 1

# 重试其他实例的最大重试次数，不包括首次所选的server

MaxAutoRetriesNextServer: 2

# 是否所有操作都进行重试

OkToRetryOnAllOperations: false

Feign的重试

Feign本身也具备重试能力，在早期的Spring Cloud中，Feign使用的是 feign.Retryer.Default#Default()  ，重试5次。但Feign整合了Ribbon，Ribbon也有重试的能力，此时，就可能会导致行为的混乱。

Spring Cloud意识到了此问题，因此做了改进，将Feign的重试改为 feign.Retryer#NEVER_RETRY  ，如需使用Feign的重试，只需使用Ribbon的重试配置即可。因此，对于Camden以及以后的版本，Feign的重试可使用如下属性进行配置：

ribbon:

MaxtGcpzLUcAutoRetries: 1

MaxAutoRetriesNextServer: 2

OkToRetryOnAllOperations: false

相关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全局开启了重试，事实上，也可对指定路由开启/关闭重试：

zuul.routes..retryable=true

局部配置优先级更高。

基于HTTP响应码重试

clientName:

ribbon:

retryableStatusCodes: 404,502

注意点：

Hystrix的超时时间必须大于超时的时间，否则，一旦Hystrix超时，就没办法继续重试了。

一般来说，不建议将ribbon.OkToRetryOnAllOperations 设为true。因为一旦启用该配置，则表示重试任何操作，包括POST请求，而由于缓存了请求体，此时可能会影响服务器的资源。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对我们的支持。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。