feign源码解读

对于feign的接口请求失败的重试配置可通过如下自定义配置文件实现(一般不建议配置）

@Configuration
public class FeignConfig {
    @Bean
    public Retryer feignRetryer() {
        return new Retryer.Default(100, SECONDS.toMillis(1), 5);
    }
}

当然，也可使用默认的retry配置文件,下方是feign.Retryer的源码

// 类的全路径是feign.Retryer
    public Default() {
      // 默认是重试的间隔是100ms,最大重试间隔是1秒，最大重试次数是5次
      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;
    }
    
    public void continueOrPropagate(RetryableException e) {
      // 如果重试的次数大于最大重试次数，抛异常
      if (attempt++ >= maxAttempts) {
        throw e;
      }
      long interval;
      if (e.retryAfter() != null) {
        interval = e.retryAfter().getTime() - currentTimeMillis();
        // 如果重试间隔大于最大间隔，则取最大间隔
        if (interval > maxPeriod) {
          interval = maxPeriod;
        }
        if (interval < 0) {
          return;
        }
      } else {
        // 如果重试间隔没有明确，则调用nextMaxInterval获取
        interval = nextMaxInterval();
      }
      try {
        // sleep一定时间后再去重试
        Thread.sleep(interval);
      } catch (InterruptedException ignored) {
        Thread.currentThread().interrupt();
      }
      // sleptForMillis变量是总的重试间隔
      sleptForMillis += interval;
    }

    /**
     * 下一次重试的间隔，间隔时间每一次重试都是1.5倍递增，直到最大间隔
     **/
    long nextMaxInterval() {
      long interval = (long) (period * Math.pow(1.5, attempt - 1));
      return interval > maxPeriod ? maxPeriod : interval;
    }

spring cloud中的feign整合了ribbon,但feign和ribbon都有重试功能，springcloud统一了两者的行为，将feign的重试策略设置成永不重试，如果要使用feign的重试功能，只需要设置ribbon的重试配置即可,所以一般不建议配置feign的重试策略

feign默认不配置重试策略是会重试的

ribbon默认配置如下

ribbon:
  # 同一实例最大重试次数，不包括首次调用。默认值为0
  MaxAutoRetries: 0
  # 同一个微服务其他实例的最大重试次数，不包括第一次调用的实例。默认值为1
  MaxAutoRetriesNextServer: 1
  # 是否所有操作（GET、POST等）都允许重试。默认值为false
  OkToRetryOnAllOperations: false

**默认情况下,GET方式请求无论是连接异常还是读取异常,都会进行重试

非GET方式请求,只有连接异常时,才会进行重试**

如此看来，如果同一个微服务只有一个实例是不会进行重试的，但事实并非如此

分析一下源码，feign的重试是在org.springframework.retry.support.RetryTemplate中的doExecute方法中进行中

protected <T, E extends Throwable> T doExecute(RetryCallback<T, E> retryCallback,RecoveryCallback<T> recoveryCallback, RetryState state) throws E, ExhaustedRetryException {
    ......
    while (canRetry(retryPolicy, context) && !context.isExhaustedOnly()) {
    try {
        if (this.logger.isDebugEnabled()) {
            this.logger.debug("Retry: count=" + context.getRetryCount());
        }
        // Reset the last exception, so if we are successful
        // the close interceptors will not think we failed...
        lastException = null;
        return retryCallback.doWithRetry(context);
    }
    ......
}

上方的canRetry是关键

最后一行policy.canRetryNextServer是能否选择下一个实例进行重试

而lbContext.getRetryHandler().getMaxRetriesOnNextServer()就是变量retryNextServer

retryNextServer的值就是来源于MaxAutoRetriesNextServer，默认是1，所以canRetry在返回的是true，所以调用了二次

解决办法就是要进行如下配置

ribbon:
  # 同一实例最大重试次数，不包括首次调用。默认值为0
  MaxAutoRetries: 0
  # 同一个微服务其他实例的最大重试次数，不包括第一次调用的实例。默认值为1
  MaxAutoRetriesNextServer: 0
  # 是否所有操作（GET、POST等）都允许重试。默认值为false
  OkToRetryOnAllOperations: false

FeignRibbonClient的自动配置类

可以看出，其默认使用LoadBalancerFeignClient的配置

查看其DEFAULT_OPTIONS可知道默认连接超时时间是10s，读取超时是6s

默认的网络请求框架是HttpURLConnection

如要更换相应的网络请求框架，只需要添加相应的pom依赖即可

查看负载均衡怎么做的，查看executeWithLoadBalancer

查看其submit任务

其方法selectServer就是负载均衡的关键

Feign的流程如下

1. 通过@EnableFeignClients开启feign
2. 根据要远程调用的接口添加@FeignClient
3. 程序扫描特定包下的FeignClient注解并注入Ioc容器
4. 当feign接口被调用时，通过jdk代理生成相应的RequestTemplate
5. 根据RequestTemplate生成相应的Request
6. Request交给类Client去调用，Client可以是HttpClient,Okhttp或HttpUrlConnection
7. 最后Client被封装到LoadBalanceClient,这个类结合ribbon实现负载均衡