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

程序员文章站 2023-12-13 09:48:40

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

springcloud重试机制配置

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

@bean
@loadbalanced
resttemplate resttemplate() {
  httpcomponentsclienthttprequestfactory httprequestfactory = new httpcomponentsclienthttprequestfactory();
  httprequestfactory.setreadtimeout(5000);
  httprequestfactory.setconnecttimeout(5000);
  return new resttemplate(httprequestfactory);
}

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

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

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:
 maxautoretries: 1
 maxautoretriesnextserver: 2
 oktoretryonalloperations: false