Spring Boot 中的重试机制

@Retryable 注解简介

@Retryable 注解是 Spring Retry 模块提供的，用于自动重试可能会失败的方法。在微服务架构和分布式系统中，服务之间的调用可能会因为网络问题、服务繁忙等原因失败。使用 @Retryable 可以提高应用的稳定性和容错能力 1。

使用步骤

（1）添加依赖

首先，确保你的 Spring Boot 项目中包含了 spring-retry 依赖。如果使用 Maven，可以在 pom.xml 文件中添加以下依赖：

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

（2）启用重试

在 Spring Boot 应用的主类或配置类上添加 @EnableRetry 注解，启用重试功能 16。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.retry.annotation.EnableRetry;@SpringBootApplication
@EnableRetry
public class MyApplication {public static void main(String[] args) {SpringApplication.run(MyApplication.class, args);}
}

（3）使用 @Retryable 注解

在需要进行重试的方法上添加 @Retryable 注解。

import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;@Service
public class MyService {@Retryable(value = {MyNetworkException.class}, maxAttempts = 3)public String fetchDataFromRemote() {System.out.println("尝试调用远程服务...");// 模拟可能失败的远程调用if (Math.random() < 0.5) {throw new MyNetworkException("网络异常");}return "调用成功";}
}

在这个例子中，fetchDataFromRemote 方法在抛出 MyNetworkException 异常时会进行重试，最多重试 3 次。

@Retryable 注解的属性

@Retryable 注解提供了多个属性，用于配置重试策略 1。

• value / exception

  指定需要重试的异常类型。可以指定一个或多个异常类。

  @Retryable(value = {MyNetworkException.class, TimeoutException.class})
  public String fetchDataFromRemote() {// ...
  }

• maxAttempts

  指定最大重试次数，包括第一次调用。默认值为 3。

  @Retryable(value = MyNetworkException.class, maxAttempts = 5)
  public String fetchDataFromRemote() {// ...
  }

• backoff

  指定重试之间的退避策略。可以使用 @Backoff 注解配置退避策略。

  • delay：重试之间的延迟时间，单位为毫秒。
  • multiplier：延迟倍数，用于实现指数退避。
  • random：是否在延迟时间上增加一个随机值，以避免多个服务同时重试。

  import org.springframework.retry.annotation.Backoff;@Retryable(value = MyNetworkException.class, backoff = @Backoff(delay = 2000, multiplier = 1.5))
  public String fetchDataFromRemote() {// ...
  }

  在这个例子中，第一次重试延迟 2 秒，第二次重试延迟 3 秒 (2 * 1.5)，以此类推。

@Recover 注解

@Recover 注解用于指定重试失败后的恢复方法。恢复方法的参数必须与重试方法抛出的异常类型相匹配，并且必须在同一个类中。

import org.springframework.retry.annotation.Recover;@Service
public class MyService {@Retryable(value = {MyNetworkException.class}, maxAttempts = 3)public String fetchDataFromRemote() {System.out.println("尝试调用远程服务...");// 模拟可能失败的远程调用if (Math.random() < 0.5) {throw new MyNetworkException("网络异常");}return "调用成功";}@Recoverpublic String recover(MyNetworkException e) {System.out.println("重试失败，执行恢复逻辑...");// 处理异常的逻辑，例如返回默认值或记录日志return "默认值";}
}

在这个例子中，如果 fetchDataFromRemote 方法重试 3 次后仍然失败，会调用 recover 方法处理 MyNetworkException 异常。

• 第一个参数必须是 Throwable 类型或其子类型：

  • @Recover 方法的第一个参数必须是 Throwable 类型，或者 @Retryable 方法中声明的异常类型（或其父类）。
  • 这个参数用于接收 @Retryable 方法抛出的异常。

• 后续参数必须与 @Retryable 方法的参数类型和顺序一致：

  • @Recover 方法的后续参数必须与对应的 @Retryable 方法的参数类型和顺序完全一致。
  • 这些参数用于将 @Retryable 方法的参数传递给 @Recover 方法。

• 参数数量：

  • @Recover 方法的参数数量必须等于 @Retryable 方法的参数数量加 1（用于接收异常）。

当被 @Retryable 注解的方法经过多次重试都失败，并且成功调用了 @Recover 注解的恢复方法后，最初调用 @Retryable 方法的方法会拿到 @Recover 方法的返回值。

1. 初始调用： 外部方法调用被 @Retryable 注解的方法。
2. 重试失败： @Retryable 方法执行失败，并且经过配置的重试次数后仍然失败。
3. 调用 @Recover： Spring Retry 框架会自动查找并调用与 @Retryable 方法签名匹配的 @Recover 方法。
4. 返回结果： @Recover 方法执行完毕后，会将它的返回值返回给最初调用 @Retryable 方法的外部方法。

关键点：

• @Recover 方法的返回值类型必须与 @Retryable 方法的返回值类型相同，这样才能保证类型安全。
• 如果 @Recover 方法本身也抛出了异常，那么这个异常会直接抛给最初的调用者，不会再进行重试。

如果你没有定义 @Recover 注解的方法，并且 @Retryable 注解的方法在经过所有重试次数后仍然失败，那么最初调用 @Retryable 方法的地方会抛出 RetryException 异常。

具体流程如下：

1. 初始调用： 外部方法调用被 @Retryable 注解的方法。
2. 重试失败： @Retryable 方法执行失败，并且经过配置的重试次数后仍然失败。
3. 没有 @Recover 方法： Spring Retry 框架找不到与 @Retryable 方法签名匹配的 @Recover 方法。
4. 抛出 RetryException： Spring Retry 框架会抛出一个 RetryException 异常，该异常会传递给最初调用 @Retryable 方法的外部方法。