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 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",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使用的是 Spring Cloud意识到了此问题,因此做了改进,将Feign的重试改为 ribbon: MaxAutoRetries: 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.routes.<routename>.retryable=true 局部配置优先级更高。 基于HTTP响应码重试 clientName: ribbon: retryableStatusCodes: 404,502 注意点: Hystrix的超时时间必须大于超时的时间,否则,一旦Hystrix超时,就没办法继续重试了。 一般来说,不建议将 总结 以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对编程小技巧的支持。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |