3. 熔断基础：熔断器状态机与核心概念

熔断器（Circuit Breaker）是限流熔断治理的核心模式，其设计灵感来源于电路中的断路器。当系统检测到下游服务或资源持续故障时，熔断器会“跳闸”，快速拒绝请求，防止故障级联扩散。本节深入剖析熔断器的三态状态机，并对比 Hystrix 与 Resilience4j 两大主流实现的核心概念。

3.1 熔断器三态状态机

熔断器维护三个关键状态：Closed（关闭）、Open（打开）、Half-Open（半开）。状态转换由预设的阈值和超时时间驱动，形成自动化的故障隔离与恢复闭环。

3.2 状态转换关键参数

熔断器的行为由一组可配置参数驱动，不同参数直接影响系统的容错能力与恢复速度。下表列出核心参数及其作用：

3.3 Hystrix 核心概念

Hystrix 是 Netflix 开源的熔断器库，虽然已进入维护模式，但其设计思想深刻影响了后续实现。Hystrix 的核心概念包括：

• HystrixCommand：封装对外部依赖的调用，通过继承或注解方式定义熔断逻辑。
• 线程池隔离：每个依赖使用独立的线程池，防止一个依赖耗尽所有线程。
• 信号量隔离：轻量级隔离方式，通过计数器限制并发数，不涉及线程切换。
• Fallback（降级）：当熔断、超时或资源不足时执行的备用逻辑，返回默认值或缓存数据。
• 请求缓存：在同一个请求上下文中缓存结果，减少重复调用。
• 请求折叠：将多个相同依赖的请求合并为批量调用，降低网络开销。

// HystrixCommand 示例：熔断 + 降级
public class RemoteServiceCommand extends HystrixCommand<String> {
    private final String param;

    public RemoteServiceCommand(String param) {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("RemoteGroup"))
                .andCommandKey(HystrixCommandKey.Factory.asKey("RemoteService"))
                .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("RemotePool"))
                .andCommandPropertiesDefaults(
                    HystrixCommandProperties.Setter()
                        .withCircuitBreakerEnabled(true)
                        .withCircuitBreakerRequestVolumeThreshold(20)
                        .withCircuitBreakerSleepWindowInMilliseconds(5000)
                        .withCircuitBreakerErrorThresholdPercentage(50)
                ));
        this.param = param;
    }

    @Override
    protected String run() throws Exception {
        // 实际远程调用
        return remoteApi.call(param);
    }

    @Override
    protected String getFallback() {
        // 降级逻辑：返回缓存或默认值
        return "fallback-result";
    }
}

3.4 Resilience4j 核心概念

Resilience4j 是轻量级、模块化的容错库，专为 Java 8 和函数式编程设计。相比 Hystrix，Resilience4j 不依赖第三方库，支持更灵活的组合使用。其核心模块包括：

// Resilience4j CircuitBreaker 配置示例（Java 配置方式）
CircuitBreakerConfig config = CircuitBreakerConfig.custom()
    .failureRateThreshold(50)                    // 失败率阈值 50%
    .waitDurationInOpenState(Duration.ofSeconds(30)) // 冷却时间 30 秒
    .slidingWindowSize(100)                      // 滑动窗口大小 100
    .minimumNumberOfCalls(10)                    // 最小调用数 10
    .permittedNumberOfCallsInHalfOpenState(5)    // 半开状态允许 5 个探测请求
    .automaticTransitionFromOpenToHalfOpenEnabled(true)
    .build();

CircuitBreaker circuitBreaker = CircuitBreaker.of("remoteService", config);

// 使用装饰器模式包装函数
Supplier<String> decoratedSupplier = CircuitBreaker
    .decorateSupplier(circuitBreaker, () -> remoteApi.call(param));

// 执行并处理降级
Try<String> result = Try.ofSupplier(decoratedSupplier)
    .recover(throwable -> "fallback-result");

3.5 Hystrix 与 Resilience4j 核心差异对比

下表从多个维度对比两个框架，帮助你在技术选型时做出决策：

3.6 熔断器在缓存一致性场景中的角色

在缓存一致性错误处理设计中，熔断器承担以下关键职责：

• 保护缓存数据源：当数据库或远程缓存服务（如 Redis）出现故障时，熔断器快速切断对故障源的调用，避免缓存击穿或雪崩。
• 触发降级策略：熔断后自动切换到备用缓存（如本地缓存）或返回过期缓存数据，保证系统基本可用。
• 防止缓存重建风暴：在缓存失效重建期间，若后端服务不稳定，熔断器可阻止大量重建请求涌入，保护后端。
• 配合一致性协议：在最终一致性场景中，熔断器可作为“故障感知”组件，通知一致性协议暂停同步或切换数据源。