熔断器三种状态转换机制与状态机详解

熔断器（Circuit Breaker）是分布式系统中防止级联故障的关键模式。其核心是一个有限状态机，通过 Closed（关闭）、Open（断开）、Half-Open（半开） 三种状态的自动转换，实现对下游服务的保护与恢复。理解状态机的转换阈值与资源开销，是后续性能压测分析的基础。

状态定义与核心职责

状态转换机制详解

熔断器的状态转换由三个关键事件驱动：失败阈值达到、超时计时器到期、探测请求结果判定。下图展示了完整的状态机流转路径：

状态转换的触发条件与参数

每个状态转换都对应一组可配置的阈值参数。在性能压测中，这些参数直接决定了熔断器何时触发、何时恢复，进而影响系统的 QPS 拐点。

状态机内部计数器与资源开销

熔断器的每个状态都维护着特定的计数器和计时器，这些数据结构的内存占用与更新频率，是性能压测中不可忽视的资源开销来源。

• Closed 状态： 滑动窗口计数器（如环形缓冲区或时间轮），记录每个时间片的请求总数与失败数。窗口粒度越细，内存开销越大（如 10 个时间片 × 2 个计数器 = 20 个原子变量）。
• Open 状态： 仅维护一个超时计时器（通常为 ScheduledExecutorService 或时间轮任务），内存开销极低，但计时器精度影响恢复时机。
• Half-Open 状态： 维护探测请求计数器（成功/失败），以及一个短暂的超时计时器（防止探测请求卡死）。

状态机实现示例（伪代码）

以下是一个简化的熔断器状态机核心逻辑，展示了状态转换的判断流程：

// 熔断器状态机核心逻辑（伪代码）
class CircuitBreaker {
    State state = State.CLOSED;
    int failureCount = 0;
    int requestCount = 0;
    long openTime = 0;
    int halfOpenSuccess = 0;

    // 每次请求调用
    boolean allowRequest() {
        switch (state) {
            case CLOSED:
                // 滑动窗口统计，判断是否触发熔断
                if (failureCount / requestCount >= failureThreshold) {
                    state = State.OPEN;
                    openTime = System.currentTimeMillis();
                    return false;
                }
                return true;
            case OPEN:
                // 检查超时计时器
                if (System.currentTimeMillis() - openTime >= timeoutMs) {
                    state = State.HALF_OPEN;
                    halfOpenSuccess = 0;
                    return true; // 放行第一个探测请求
                }
                return false;
            case HALF_OPEN:
                // 限制探测请求数量
                if (halfOpenSuccess < maxHalfOpenRequests) {
                    return true;
                }
                return false;
        }
    }

    // 记录请求结果
    void recordResult(boolean success) {
        switch (state) {
            case CLOSED:
                requestCount++;
                if (!success) failureCount++;
                break;
            case HALF_OPEN:
                if (success) {
                    halfOpenSuccess++;
                    if (halfOpenSuccess >= maxHalfOpenRequests) {
                        state = State.CLOSED;
                        resetCounters();
                    }
                } else {
                    state = State.OPEN;
                    openTime = System.currentTimeMillis();
                }
                break;
        }
    }
}