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实现负载均衡
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,830评论 5 468
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 83,992评论 2 376
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,875评论 0 331
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,837评论 1 271
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,734评论 5 360
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,091评论 1 277
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,550评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,217评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,368评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,298评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,350评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,027评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,623评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,706评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,940评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,349评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,936评论 2 341

推荐阅读更多精彩内容