SpringBoot 微服务重试机制：主流方案对比与实战集成

Retryer 是一个函数式接口，允许你定义重试策略（如最大重试次数、等待时间）以及判断哪些异常需要重试。

3.2.2 Guava Retryer 适用场景

适用于对性能要求极高、不希望引入额外 Spring 依赖，或者需要在复杂逻辑中动态决定重试策略的场景。

3.3 自定义注解 + AOP 实现方案

当现有框架无法满足特定需求（如统一日志记录、动态配置重试次数）时，可以通过自定义注解结合 AOP 切面来实现。

这种方式灵活性最高，可以封装通用的重试模板，让业务代码只需关注核心逻辑。

3.4 Resilience4j 重试实现方案

Resilience4j 是 Circuit Breaker 领域的新一代库，旨在替代 Hystrix。它不仅支持重试，还集成了熔断器、限流等功能。

3.4.1 Resilience4j 是什么

一个轻量级的容错库，专为微服务设计，强调高性能和非阻塞特性。

3.4.2 Resilience4j 核心模块

主要包括 retry（重试）、circuitbreaker（熔断）、ratelimiter（限流）等模块。

3.4.3 Resilience4j 使用场景

适合构建高可用、弹性强的微服务系统，尤其是需要统一治理所有容错策略的场景。

四、几种核心重试组件的具体集成和使用

下面我们通过代码演示如何在实际项目中落地这些方案。

4.1 Spring-Retry 集成和使用过程

4.1.1 导入依赖

在 pom.xml 中添加 Spring Boot Starter AOP 即可，它默认包含了 Spring Retry 的支持。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

4.1.2 启用重试功能

Spring Boot 会自动扫描并启用重试，无需额外配置。如果需要全局配置，可以在 application.yml 中调整默认行为。

4.1.3 创建一个服务类并使用@Retryable

这里我们模拟一个可能偶尔失败的远程调用服务。

@Service
public class OrderService {

    private int failCount = 0;

    @Retryable(
        value = {Exception.class}, // 捕获所有异常
        maxAttempts = 3,           // 最多重试 3 次
        backoff = @Backoff(delay = 1000) // 每次间隔 1 秒
    )
    public void createOrder() throws Exception {
        if (failCount++ < 2) {
            throw new RuntimeException("模拟网络波动");
        }
        System.out.println("订单创建成功");
    }

    @Recover
    public void recover(Exception e) {
        System.err.println("重试失败，执行兜底逻辑：通知运维人员");
    }
}

注意：@Retryable 只能作用于公共方法，且不能是自调用。

4.1.4 增加一个测试接口

为了验证效果，我们可以编写一个简单的 Controller 来触发服务方法。

@RestController
@RequestMapping("/api")
public class TestController {
    @Autowired
    private OrderService orderService;

    @GetMapping("/create")
    public String test() {
        try {
            orderService.createOrder();
            return "Success";
        } catch (Exception e) {
            return "Failed: " + e.getMessage();
        }
    }
}

4.1.5 效果测试

启动应用后访问 /api/create，控制台会打印出重试日志。前两次调用抛出异常，第三次成功，随后输出'订单创建成功'。如果三次都失败，则进入 recover 方法。

4.2 Resilience4j 集成与使用

4.2.1 导入依赖

Resilience4j 需要单独引入对应的 Spring Boot Starter。

<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-spring-boot2</artifactId>
</dependency>

4.2.2 增加配置文件

Resilience4j 的配置通常放在 application.yml 中，结构清晰。

resilience4j:
  retry:
    instances:
      apiCall:
        maxAttempts: 3
        waitDuration: 1s
        enableExponentialBackoff: true
        exponentialBackoffMultiplier: 2

4.2.3 增加一个模拟重试的业务方法

使用 @Retry 注解绑定配置名称。

@Service
public class PaymentService {

    @Retry(name = "apiCall")
    public void pay() {
        // 业务逻辑
    }
}

4.2.4 增加一个测试接口

同样提供一个 Controller 入口。

@RestController
public class PaymentController {
    @Autowired
    private PaymentService paymentService;

    @PostMapping("/pay")
    public String pay() {
        paymentService.pay();
        return "Paid";
    }
}

4.2.5 效果验证

观察日志，可以看到 Resilience4j 会根据配置自动处理等待时间和重试次数，并且支持指数退避策略。

4.3 Guava Retryer 集成与使用

4.3.1 导入核心依赖

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>31.1-jre</version>
</dependency>

4.3.2 创建重试工具类

利用 RetryerBuilder 构建重试实例。

public class RetryUtils {
    public static <T> Retryer<T> createRetryer() {
        return RetryerBuilder.<T>newBuilder()
                .retryIfExceptionOfType(IOException.class)
                .withWaitStrategy(WaitStrategies.exponentialBackoff(2, Duration.ofSeconds(1)))
                .withStopStrategy(StopStrategies.stopAfterAttempt(3))
                .build();
    }
}

4.3.3 业务方法中使用重试工具类

手动调用 call 方法。

public void doWork() {
    Retryer<String> retryer = RetryUtils.createRetryer();
    try {
        String result = retryer.call(() -> {
            // 可能失败的操作
            return "Done";
        });
        System.out.println(result);
    } catch (ExecutionException | InterruptedException e) {
        e.printStackTrace();
    }
}

4.3.4 增加一个测试接口

直接在 Service 中调用即可，无需 Spring 容器管理。

4.3.5 效果测试

Guava 的重试逻辑完全由开发者控制，灵活性高，但需要手动处理异常捕获。

4.4 自定义注解 + AOP 实现

4.4.1 添加自定义注解

定义一个 @MyRetry 注解。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface MyRetry {
    int maxAttempts() default 3;
}

4.4.2 添加自定义切面类

在切面中解析注解属性，使用 AopContext 或反射执行重试逻辑。

4.4.3 使用自定义注解

@MyRetry(maxAttempts = 5)
public void customMethod() {}

4.4.4 增加一个测试接口

4.4.5 效果测试

此方案适合团队内部统一规范，但开发成本较高，维护需谨慎。

4.5 几种方案的对比

五、写在文末

重试机制是微服务稳定性建设中的一块基石。选择哪种方案取决于你的技术栈和业务复杂度。如果是标准的 Spring Boot 项目，Spring Retry 足够好用；如果需要更强的容错能力，Resilience4j 是更好的选择。记住，无论选哪种，都要确保业务逻辑具备幂等性，这才是重试成功的根本保障。