当前位置: 首页 > news >正文

Spring Cloud中怎么使用Resilience4j Retry对OpenFeign进行重试

在微服务架构中,服务之间的通信是非常频繁的。而使用OpenFeign可以极大简化微服务之间的HTTP通信。但在复杂的分布式系统中,服务之间的调用可能会因为网络问题、服务故障等原因而失败。因此,实现服务调用的重试机制显得尤为重要。Resilience4j是一个功能强大的库,它提供了多种容错机制,包括重试(Retry)、熔断(CircuitBreaker)、限流(RateLimiter)等。本篇文章将详细介绍如何在Spring Cloud中使用Resilience4j Retry对OpenFeign进行重试。

一、Resilience4j Retry原理 

Resilience4j的Retry模块允许在调用失败时进行自动重试。它支持以下几种特性:

  • 自定义重试次数:可以配置最大重试次数。
  • 自定义等待时间:可以配置每次重试之间的等待时间。
  • 重试条件:可以配置哪些异常类型触发重试。

Resilience4j Retry的工作流程如下:

  1. 方法调用:对目标方法进行调用。
  2. 异常捕获:如果目标方法抛出配置的异常,则捕获该异常。
  3. 重试判断:判断是否满足重试条件以及重试次数是否已达到上限。
  4. 重试等待:如果满足重试条件且重试次数未达到上限,则等待配置的时间后再次尝试调用。
  5. 降级处理:如果重试次数达到上限,依然无法成功调用,则执行降级处理逻辑。

 二、项目准备

首先,确保你的Spring Cloud项目中已经引入了必要的依赖,包括Spring Cloud OpenFeign和Resilience4j。

1. 引入依赖

pom.xml中添加以下依赖:

<!--resilience4j-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
</dependency>
<!-- 由于resilience4j需要AOP的包,所以必须导入AOP包 -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2. 启用Feign Clients

确保你的Spring Boot应用程序主类上或者配置类上有@EnableFeignClients注解:

@Configuration
@EnableFeignClients(basePackages = "com.springcloud.sample.service")
@Import(FeignClientsConfiguration.class)
public class FeignConfiguration {/*** Set the Feign specific log level to log client REST requests.*/@Beanfeign.Logger.Level feignLoggerLevel() {return feign.Logger.Level.BASIC;}
}

三、配置Resilience4j Retry 

在你的application.ymlapplication.properties文件中配置Resilience4j的Retry策略。例如:

resilience4j.retry:configs:default:maxRetryAttempts: 3waitDuration: 2sretryExceptions:- org.springframework.web.client.HttpServerErrorException- java.io.IOException- feign.FeignException

解释:

  • maxRetryAttempts: 最大重试次数,这里设置为3次。
  • waitDuration: 每次重试之间的等待时间,这里设置为2秒。
  • retryExceptions: 配置哪些异常类型触发重试,这里包括HttpServerErrorExceptionIOException和FeignException

四、创建Feign客户端接口

创建一个Feign客户端接口来定义服务间的调用。例如:

@FeignClient("pay-service")
public interface PayService {@GetMapping("/pay/{id}")String payOrder(@PathVariable("id") Integer id);}

五、使用Retry注解

在调用Feign客户端的方法上添加@Retry注解,并创建一个fallback方法,用于定义服务调用失败后的降级处理逻辑。例如:

@RestController
public class OrderController {private static final Logger log = LoggerFactory.getLogger(OrderController.class);@Autowiredprivate PayService payService;@GetMapping("/order/{id}")@Retry(name = "paymentService", fallbackMethod = "fallback")public String order(@PathVariable("id") Integer id){log.info("Request Pay For Order id: {}", id);//通过open feign远程调用支付服务return payService.payOrder(id);}//fallback就是服务降级后的兜底处理方法public String fallback(Integer id,Throwable t) {log.info("Pay Service invoke failed for order ID: {}", id);log.error("Error: {}", t.getMessage());return "Pay Service Was Busy Now. Please try again later!";}
}

通过上述步骤,当payOrder方法调用失败时,Resilience4j的Retry机制将自动进行重试。如果重试次数超过配置的最大重试次数,Fallback类中的降级逻辑将会被执行。

六、测试

我我们通过关闭目标服务(pay-service)来测试重试机制是否正常工作。在目标服务不可用的情况下,请求/order/1接口,应该会看到系统进行多次重试,然后返回降级信息。

1. 在浏览器中访问order接口

http://localhost:8082/order/1

在访问以上地址后,浏览器并没有立刻返回结果,应该正在进行重试。因为我们已经关闭了目标服务,在等待几秒之后,浏览器返回了降级后的结果。如下:

2. 在控制台中验证是否重试过 

从上面的log中我们可以看出,一共请求了3次,和我们配置的maxRetryAttempts:3 一致,每次请求间隔2s,是我们在配置文件中指定的。并且,在最后一次重试任然失败后,走到了降级的方法 fallback中去,返回默认的降级结果。和我们预期的一样,retry能够正常工作。并且在retryExceptions中我们可以选择下游返回哪些异常时进行重试,我们在进行业务逻辑处理时可以灵活应用。

七、总结

通过上述配置和代码示例,我们在Spring Cloud项目中成功集成了Resilience4j的Retry机制,为OpenFeign的服务调用提供了自动重试功能。Resilience4j提供的灵活配置使得我们可以根据实际需求,精细控制重试策略,从而提高系统的可靠性和稳定性。

希望这篇文章能帮助你更好地理解和使用Resilience4j Retry对OpenFeign进行重试。如果你有任何问题或建议,欢迎在评论区留言交流。

http://www.lryc.cn/news/412480.html

相关文章:

  • 【Redis 进阶】事务
  • Linux的防火墙
  • 跟张良均老师学大数据人工智能-批量集训营开班中
  • 2024年音频剪辑必备:五大最佳音频编辑软件精选!
  • Native Programs(本机程序)
  • RisingWave 1.10 发布!新增用户自定义聚合函数
  • Modbus通讯协议
  • fal.ai发布超分辨率模型——AuraSR V2
  • SYD88xx代码复位不成功和解决办法
  • 加油,为Vue3提供一个可媲美Angular的ioc容器
  • RS485 CAN SPI IIC UART RS232这些通信协议传输距离、传输速度对比给出比较顺序-笔记(面试必备)
  • 高频JMeter软件测试面试题
  • iptables netfilter
  • 如何使用Python自动发送邮件?
  • C#中读写INI配置文件
  • 深入解析Spring中的@RequestMapping注解
  • Python:lambda函数
  • MySQL查询语句
  • 远程连接服务
  • 系统架构设计师——软件开发方法分类
  • 《看漫画学Python》全彩PDF教程,495页深度解析,零基础也能轻松上手!
  • 用户画像系列——Spark任务调优实践
  • 前端面试宝典【HTML篇】【4】
  • 【UbuntuDebian安装MySQL】在线安装MySQL8
  • PDF翻译神器:这四款可以实现一键搞定,留学党必备!
  • 精心准备的高水平的博客【点评语】,来抄啊!
  • gitlab汉化
  • SSH访问控制:精确管理你的服务器门户
  • Java中的SSL/TLS安全通信实现
  • 2959. 关闭分部的可行集合数目