解决FeignClient重试机制造成的接口幂等性

 更新时间:2021年07月05日 10:57:36   作者:doinbb  
这篇文章主要介绍了解决FeignClient重试机制造成的接口幂等性问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

FeignClient重试机制造成的接口幂等性

Feign源码分析,其实现类在 SynchronousMethodHandler,实现方法是public Object invoke(Object[] argv) ,它的代码分析如下:

1.构造请求数据,将对象转换为json:

RequestTemplate template = buildTemplateFromArgs.create(argv);

2.发送请求进行执行(执行成功会解码响应数据):

executeAndDecode(template, options);

3. 执行请求会有重试机制:

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();
           // 重试结束 或则 不允许重试,则通过抛异常的形式终止 
          if (propagationPolicy == UNWRAP && cause != null) {
            throw cause;
          } else {
            throw th;
          }
        }
        if (logLevel != Logger.Level.NONE) {
          logger.logRetry(metadata.configKey(), logLevel);
        }
        continue;
      }
    }

4. Retryer是重试器,其实现方法有两种

第一种是系统默认实现方式,第二种是可以自定义重试器,一般少用,通过默认实现重试类Default可以看到其构造函数中的重试次数为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调用的幂等性问题最简单也就最常用的就是让Feign不重试。

为FeignClient增加请求重试机制

spring cloud通过feign client进行服务之间调用的时候,默认不会进行重试,这样会有一个问题,比如你的服务在滚动升级重启的时候,feign的调用将直接失败,但其实我是滚动重启,重启了一个服务实例,还有另外一个服务实例是可用的,应该允许自动均衡策略重试请求发送到另外一个可用的服务实例上去。

要启用重试机制,首先必须引入spring-retry依赖:

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

然后通过注册一个bean:

  /**
     *
     * 注册一个重试Bean
     * 默认FeignClient不会进行重试,使用的是{@link feign.Retryer#NEVER_RETRY}
     *
     * @see FeignClientsConfiguration#feignRetryer()
     */
    @Bean
    public Retryer feignRetryer() {
        return new Retryer.Default();
    }

大功告成。

不过还有个前提就是,你的远程调用接口方法的必须是幂等的(比如GET方法认为是幂等的,调用多少次结果都一样,而POST方法有可能有重复提交问题),不然还是不会重试的,因为其他HttpMethod被认为是非幂等的,不能重复执行,因此不能被重试

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • java实现图片转base64字符串 java实现base64字符串转图片

    java实现图片转base64字符串 java实现base64字符串转图片

    这篇文章主要为大家详细介绍了java实现图片转base64字符串,java实现base64字符串转图片,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-02-02
  • SpringCloud客户端报错:- was unable to send heartbeat!的解决

    SpringCloud客户端报错:- was unable to send&nb

    这篇文章主要介绍了SpringCloud客户端报错:- was unable to send heartbeat!的问题及解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-05-05
  • SpringBoot Service和Dao的编写详解

    SpringBoot Service和Dao的编写详解

    这篇文章主要介绍了SpringBoot Service和Dao的编写详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • lombok中@Data使用常见的小坑及解决

    lombok中@Data使用常见的小坑及解决

    在Java中使用Lombok库的@Data注解时,布尔类型属性可能导致生成的get方法不符合预期,对于非is开头的布尔属性,Lombok生成的方法会添加is前缀,导致原本期待的get方法不存在,例如,对于属性private boolean active,Lombok会生成方法名为isActive而不是getActive
    2024-10-10
  • 透过Spring源码查看Bean的命名转换规则图文详解

    透过Spring源码查看Bean的命名转换规则图文详解

    Java Bean是一种 Java 编程语言编写的可重用软件组件,包括符合一定规范的Java 类、属性和方法,用于描述和处理应用程序中的数据对象,下面这篇文章主要给大家介绍了关于透过Spring源码查看Bean的命名转换规则的相关资料,需要的朋友可以参考下
    2023-06-06
  • IDEA中的maven没有dependencies解决方案

    IDEA中的maven没有dependencies解决方案

    这篇文章主要介绍了IDEA中的maven没有dependencies解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-05-05
  • Java虚拟机装载和初始化一个class类代码解析

    Java虚拟机装载和初始化一个class类代码解析

    这篇文章的主要内容是Java虚拟机装载和初始化一个class类的代码解析,包括介绍了装载和初始化的时机与方式,需要的朋友可以参考下。
    2017-09-09
  • SpringBoot项目实战之加载和读取资源文件

    SpringBoot项目实战之加载和读取资源文件

    在项目的开发中,我们知道的是SpringBoot框架大大减少了我们的配置文件,但是还是留下了一个application.properties文件让我们可以进行一些配置,下面这篇文章主要给大家介绍了关于SpringBoot项目实战之加载和读取资源文件的相关资料,需要的朋友可以参考下
    2021-10-10
  • Spring Boot集成MinIO对象存储服务器操作步骤

    Spring Boot集成MinIO对象存储服务器操作步骤

    通过Spring Boot集成MinIO,你可以在应用中方便地进行文件的存储和管理,本文给大家分享Spring Boot集成MinIO对象存储服务器详细操作步骤,感兴趣的朋友一起看看吧
    2024-01-01
  • java编程实现优先队列的二叉堆代码分享

    java编程实现优先队列的二叉堆代码分享

    这篇文章主要介绍了java编程实现优先队列的二叉堆代码分享,具有一定参考价值,需要的朋友可以了解下。
    2017-11-11

最新评论