Resilience4j 熔断机制详解

Resilience4j 是 Java 微服务架构中轻量级的容错库，其熔断机制（Circuit Breaker）通过监控服务调用失败率，在系统过载时自动切断请求路径，防止级联故障。核心原理如下：

1. 熔断器状态机

• 关闭状态（CLOSED）
  正常处理请求，持续监控失败率。
  当失败率超过阈值 $f > f_{\text{threshold}}$ 时（例如 50%），触发熔断。

• 开启状态（OPEN）
  所有请求立即拒绝，直接返回 fallback 结果。
  持续 $t_{\text{wait}}$ 时间（例如 5 秒）后进入半开状态。

• 半开状态（HALF_OPEN）
  允许有限数量 $n_{\text{test}}$ 的试探请求通过：

  • 若成功率 $\geq s_{\text{threshold}}$，关闭熔断器
  • 否则保持开启状态

2. 关键配置参数

CircuitBreakerConfig config = CircuitBreakerConfig.custom()
  .failureRateThreshold(50)          // 失败率阈值（%）
  .slidingWindowType(COUNT_BASED)     // 滑动窗口类型：COUNT_BASED/TIME_BASED
  .slidingWindowSize(10)              // 窗口大小（请求数/秒数）
  .waitDurationInOpenState(Duration.ofSeconds(5)) // OPEN→HALF_OPEN等待时间
  .permittedNumberOfCallsInHalfOpenState(3) // HALF_OPEN状态允许的请求数
  .build();

3. 代码实现示例

// 创建熔断器
CircuitBreaker circuitBreaker = CircuitBreaker.of("serviceA", config);

// 使用熔断器包装服务调用
Supplier<String> decoratedSupplier = CircuitBreaker
    .decorateSupplier(circuitBreaker, () -> remoteService.call());

// 执行请求（自动触发熔断逻辑）
try {
    String result = Try.ofSupplier(decoratedSupplier)
        .recover(throwable -> "Fallback Result")  // 熔断时返回兜底值
        .get();
} catch (CallNotPermittedException e) {
    // 处理熔断拒绝的请求
}

4. 熔断监控指标

通过 Micrometer 暴露监控数据：

• 状态切换次数：resilience4j_circuitbreaker_state_changes_total
• 当前状态：resilience4j_circuitbreaker_state（0=关闭, 1=开启, 2=半开）
• 失败率：$f = \frac{\text{失败请求数}}{\text{总请求数}} \times 100%$

最佳实践

• 结合 @CircuitBreaker 注解实现声明式熔断
• 与 Retry 模块组合使用：先重试失败请求，再触发熔断
• 通过事件监听器 onStateTransition 记录状态变更日志

熔断机制有效解决了服务雪崩问题，当依赖服务 $S_B$ 故障时，通过快速失败保护服务 $S_A$ 的资源不被耗尽，保障系统整体韧性。