问题介绍

在我的日常工作中，我主要负责开发一个庞大的金融应用程序。当客户发送请求时，我们使用他们的用户 ID 从第三方服务获取他们的帐户信息，保存交易并更新缓存中的详细信息。尽管整个流程看起来足够简单，但这些下游系统中的每一个都是不可靠的。我们必须在每一层上实现重试，并且我们必须以一种可以控制重试次数和每次重试之间的延迟的方式来实现，这样我们就不会超载下游系统。由于我无法共享实际代码，我会创建一个演示系统来做简单表示：

由于我们必须在每一层上实现重试，因此我们必须编写大量样板代码，这不仅容易出错，而且难以维护。由于每个下游系统都有自己的重试要求，因此我们最终添加了越来越多的代码，最终就像在现有垃圾之上添加垃圾一样。随着时间的推移，代码变得非常脆弱，即使是很小的变化也会破坏整个系统。

推荐博主开源的 H5 商城项目waynboot-mall，这是一套全部开源的微商城项目，包含三个项目：运营后台、H5 商城前台和服务端接口。实现了商城所需的首页展示、商品分类、商品详情、商品 sku、分词搜索、购物车、结算下单、支付宝/微信支付、收单评论以及完善的后台管理等一系列功能。技术上基于最新得 Springboot3.0、jdk17，整合了 MySql、Redis、RabbitMQ、ElasticSearch 等常用中间件。分模块设计、简洁易维护，欢迎大家点个 star、关注博主。

github 地址：https://github.com/wayn111/waynboot-mall

解决方案

为了解决这个问题我们决定使用 Spring Retry。

Spring Retry 项目地址：https://github.com/spring-projects/spring-retry

Spring Retry 是 Spring Batch 的一个子项目，它提供了一组注解和接口，我们可以使用它们向代码添加重试逻辑。它提供了一种向代码添加重试逻辑的声明性方法。

作为本文的一部分，我们将了解如何使用 Spring Retry 重写现有代码，以及它如何帮助我将代码库减少 1000 行。在展示新代码时，我将解释每个代码的注解和用例。

在研究重构的代码之前，让我们先了解一下在项目中设置 Spring 重试所涉及的步骤。

Let’s start hacking!

将以下依赖项添加到我们的 pom.xml 文件中：

<dependency>
   <groupId>org.springframework.retry</groupId>
   <artifactId>spring-retry</artifactId>
   <version>2.0.0</version>
</dependency>
<dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-aspects</artifactId>
   <version>5.2.8.RELEASE</version>
</dependency>

在 spring 配置上启用 Spring 重试，并使用以下注解：

@Configuration
@EnableRetry
public class ApplicationConfig { }

既然我们已经设置了 Spring Retry，那么让我们开始重构代码。

以下是一个查询用户全名的代码示例，左边是老代码，右边是使用了 Spring Retry 的新代码。

使用 @Retryable 注解，我们通过 retryFor 属性指定要重试的异常数组，使用 maxAttempts 属性，可以指定要重试的次数。

具有指数退避的缓存重试

一下图片是一个添加缓存的代码示例中，我指定要在 JedisConnectionException 上重试，每次重试之间的延迟应为 1000 毫秒，并且延迟应呈指数增长。

使用 @Retryable 注解，我们可以使用重试退避 backoff 属性，还可以指定每次重试之间的延迟 delay。

外部化重试配置

我们可以轻松地将重试配置外部化到属性文件中。当我们想要重用配置并更改它们而无需重新部署应用程序时，这非常有用。就我而言，我创建了一个 retry.properties 文件并添加了以下属性：

retry.maxAttempts=2

在我的 spring 配置中包含属性文件：

// <<Other annotations>>
@PropertySource("classpath:retryConfig.properties")
public class ApplicationConfig { }

以下图片是一个先获取 MySql 连接，再查数据的例子，我再代码中使用了该外部化配置属性：

消除错误时的重复操作，使用 RetryListenerSupport 重试

在前面的先获取 MySql 连接，再查数据的例子中，我想获取以下事件的指标：

连接 MySql 数据库时，发出指标
连接 MySql 数据库失败时，发出指标
当用尽所有重试次数时，发出指标

再 Spring Retry 中，我可以使用 RetryListenerSupport 将所有代码添加到一个位置，而不是在连接到 Mysql 数据库的所有代码的每个重试块中添加相同的代码。

使用 RetryTemplate 上的 registerListener 方法注册 RetryListenerSupport：

@Configuration
public class ApplicationConfig {

  @Bean
  public RetryTemplate installTemplate() {
     RetryTemplate retryTemplate = new RetryTemplate();
     retryTemplate.registerListener(new DefaultListenerSupport());
     return retryTemplate;
  }
}

RetryListenerSupport 提供了三种方法，我们可以重写它们来添加自定义逻辑：