天天看点

Spring Cloud Feign 重试配置

配置

默认是重试策略为

Retryer.NEVER_RETRY

;

可以修改为

Retryer

默认实现

Retryer.Default

;

或者实现

Retryer

接口自定义实现逻辑.

在Feign重试行为中,它将自动重试IOException,将它们视为与网络临时相关的异常,以及从ErrorDecoder抛出的任何RetryableException。
  • 这里可以在

    ErrorDecoder

    自定义逻辑根据是否抛出

    RetryableException

    异常来自定义重试逻辑,nice的一比。

方式一

@Configuration
@EnableFeignClients("com.laker.zuul.feign")
public class FeignConfig {
    @Configuration
    public class FooConfiguration {
        @Bean
        Logger.Level feignLoggerLevel() {
            return Logger.Level.BASIC;
        }

    }

    @Bean
    public Retryer feignRetryer() {
        //最大请求次数为5,初始间隔时间为100ms,下次间隔时间1.5倍递增,重试间最大间隔时间为1s,
        return new Retryer.Default();
    }
}
           

方式二

feign:
  client:
    config:
      feignName:
        connectTimeout: 5000
        readTimeout: 5000
        loggerLevel: full
        errorDecoder: com.example.SimpleErrorDecoder
        retryer: com.example.SimpleRetryer

           

源码分析

Feign自带的重试机制

首先,在Spring Cloud OpenFeign中,入口为

FeignClient

,源码如下:

Spring Cloud Feign 重试配置

FeignClient

所有属性性中,只有

configuration

看着跟重试有点关系,再看到

javadoc

提示的

@see FeignClientsConfiguration for the defaults

,该配置为

Feign

的默认配置,源码如下:

Spring Cloud Feign 重试配置

FeignClientsConfiguration

终于见到

Retryer

本尊,可以看到,当容器中缺少实现

Retryer

接口的

Bean

时则自动生成实例并注入(

@ConditionalOnMissingBean

的功劳),这里注入的是

Retryer.NEVER_RETRY

,一个不进行重试的

Retryer

实现类。实现为:

Spring Cloud Feign 重试配置

Retryer

Retryer

有2个方法,重点放在

continueOrPropagate(RetryableException e)

上,从方法签名上看,要么等待下一次重试,要么将异常Propagate(传播)出去,通俗点就是抛异常。

大家应该都知道,

Feign

底层使用的是动态代理,才能实现如此简单易用的使用体验。这里主要讲一个类:

SynchronousMethodHandler

,该类动态代理的主要类,所以它的属性跟

Feign

的参数很相似,主要源码如下:

Spring Cloud Feign 重试配置

SynchronousMethodHandler and Feign

invoke(Object[] argv)

方法中,当捕获

RetryableException

异常时,会调用

Retryer

continueOrPropagate

方法,根据执行结果,该重试的重试,该抛异常的抛异常。

而根据

NERVER_RETRY

的源码,就是直接抛异常,不进行重试。

参考:

  • https://www.jianshu.com/p/c863556f8de1

继续阅读