解決FeignClient重試機(jī)制造成的接口冪等性

更新時(shí)間：2021年07月05日 10:57:36 作者：doinbb

這篇文章主要介紹了解決FeignClient重試機(jī)制造成的接口冪等性問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

FeignClient重試機(jī)制造成的接口冪等性

Feign源碼分析，其實(shí)現(xiàn)類在 SynchronousMethodHandler，實(shí)現(xiàn)方法是public Object invoke(Object[] argv) ，它的代碼分析如下：

1.構(gòu)造請(qǐng)求數(shù)據(jù)，將對(duì)象轉(zhuǎn)換為json：

RequestTemplate template = buildTemplateFromArgs.create(argv);

2.發(fā)送請(qǐng)求進(jìn)行執(zhí)行（執(zhí)行成功會(huì)解碼響應(yīng)數(shù)據(jù)）：

executeAndDecode(template, options);

3. 執(zhí)行請(qǐng)求會(huì)有重試機(jī)制：

Retryer retryer = this.retryer.clone();
    while (true) {
      try {
        return executeAndDecode(template, options);
      } catch (RetryableException e) {
        try {
          retryer.continueOrPropagate(e);
        } catch (RetryableException th) {
          Throwable cause = th.getCause();
           // 重試結(jié)束 或則 不允許重試，則通過拋異常的形式終止 
          if (propagationPolicy == UNWRAP && cause != null) {
            throw cause;
          } else {
            throw th;
          }
        }
        if (logLevel != Logger.Level.NONE) {
          logger.logRetry(metadata.configKey(), logLevel);
        }
        continue;
      }
    }

4. Retryer是重試器，其實(shí)現(xiàn)方法有兩種

第一種是系統(tǒng)默認(rèn)實(shí)現(xiàn)方式，第二種是可以自定義重試器，一般少用，通過默認(rèn)實(shí)現(xiàn)重試類Default可以看到其構(gòu)造函數(shù)中的重試次數(shù)為5。

    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調(diào)用的冪等性問題最簡(jiǎn)單也就最常用的就是讓Feign不重試。

為FeignClient增加請(qǐng)求重試機(jī)制

spring cloud通過feign client進(jìn)行服務(wù)之間調(diào)用的時(shí)候，默認(rèn)不會(huì)進(jìn)行重試，這樣會(huì)有一個(gè)問題，比如你的服務(wù)在滾動(dòng)升級(jí)重啟的時(shí)候，feign的調(diào)用將直接失敗，但其實(shí)我是滾動(dòng)重啟，重啟了一個(gè)服務(wù)實(shí)例，還有另外一個(gè)服務(wù)實(shí)例是可用的，應(yīng)該允許自動(dòng)均衡策略重試請(qǐng)求發(fā)送到另外一個(gè)可用的服務(wù)實(shí)例上去。

要啟用重試機(jī)制，首先必須引入spring-retry依賴:

        <dependency>
            <groupId>org.springframework.retry</groupId>
            <artifactId>spring-retry</artifactId>
        </dependency>

然后通過注冊(cè)一個(gè)bean:

  /**
     *
     * 注冊(cè)一個(gè)重試Bean
     * 默認(rèn)FeignClient不會(huì)進(jìn)行重試，使用的是{@link feign.Retryer#NEVER_RETRY}
     *
     * @see FeignClientsConfiguration#feignRetryer()
     */
    @Bean
    public Retryer feignRetryer() {
        return new Retryer.Default();
    }

大功告成。

不過還有個(gè)前提就是，你的遠(yuǎn)程調(diào)用接口方法的必須是冪等的(比如GET方法認(rèn)為是冪等的，調(diào)用多少次結(jié)果都一樣，而POST方法有可能有重復(fù)提交問題)，不然還是不會(huì)重試的,因?yàn)槠渌鸋ttpMethod被認(rèn)為是非冪等的，不能重復(fù)執(zhí)行，因此不能被重試

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: