Spring Cloud Circuitbreaker中如何配置Resilience4j的Retry与RateLimiter模块

首先明确：Spring Cloud CircuitBreaker 官方封装的 spring-cloud-starter-circuitbreaker-reactor-resilience4j 仅原生支持对 CircuitBreaker、TimeLimiter、Bulkhead 三个组件的配置与 ReactiveCircuitBreakerFactory 托管，没有内置对 Retry、RateLimiter 模块的封装，无法直接通过工厂类统一管理这两个组件的配置与实例。

方案1：单独配置 Retry、RateLimiter 原生组件（推荐） #

该 starter 已经传递引入了 Resilience4j 的 Retry、RateLimiter 核心依赖，不需要额外引入其他包，直接使用原生配置方式即可：

• 配置文件中直接沿用 Resilience4j 官方的配置规则，示例：

resilience4j:
  retry:
    instances:
      myRetry:
        maxAttempts: 3
        waitDuration: 100ms
  rate-limiter:
    instances:
      myRateLimiter:
        limitForPeriod: 10
        limitRefreshPeriod: 1s
        timeoutDuration: 0

• 代码中直接注入 RetryRegistry、RateLimiterRegistry 获取对应实例，和反应式链路组合使用即可，示例：

@Autowired
private RetryRegistry retryRegistry;
@Autowired
private ReactiveCircuitBreakerFactory circuitBreakerFactory;

public Mono<String> testService() {
    Retry retry = retryRegistry.retry("myRetry");
    return yourReactiveService.call()
        .transformDeferred(RetryOperator.of(retry)) // 先执行重试
        .transformDeferred(circuitBreakerFactory.create("myCircuitBreaker")::run) // 再执行熔断
        ;
}

方案2：自定义工厂定制器，将Retry/RateLimiter织入熔断执行链 #

如果希望两个组件的逻辑和熔断逻辑绑定，统一由 ReactiveCircuitBreakerFactory 管理，可以自定义 ReactiveResilience4JCircuitBreakerFactory 的全局定制器，将对应逻辑嵌入执行链路：

@Bean
public Customizer<ReactiveResilience4JCircuitBreakerFactory> defaultCustomizer(RetryRegistry retryRegistry) {
    return factory -> factory.configureDefault(id -> {
        Retry retry = retryRegistry.retry(id); // 按熔断ID匹配对应的重试实例
        return new Resilience4JConfigBuilder(id)
            .circuitBreakerConfig(CircuitBreakerConfig.ofDefaults())
            .timeLimiterConfig(TimeLimiterConfig.ofDefaults())
            // 这里可以扩展添加Retry、RateLimiter的装饰逻辑
            .build();
    });
}

该方案需要自行维护实例ID的对应关系，灵活度低于方案1，复杂度更高，非特殊场景不推荐使用。

内容的提问来源于stack exchange，提问作者Sancho