熔断器模式基础：状态机（Closed/Open/Half-Open）与故障隔离

3.3 状态机核心参数配置

熔断器的行为由一组可调参数控制。在金融压力测试中，这些参数需要根据业务容忍度与 SLA 进行精细调优：

3.4 故障隔离的层次与粒度

熔断器实现的故障隔离并非单一维度，在金融系统架构中通常分为三个层次：

1. 接口级隔离： 针对单个 API 端点（如 /api/account/balance）设置独立的熔断器，防止一个接口故障拖垮整个服务。
2. 服务级隔离： 针对下游微服务（如用户服务、交易服务）设置熔断器，隔离整个服务提供方的故障。
3. 连接池级隔离： 结合线程池隔离（Bulkhead），为熔断器关联独立的连接池或线程池，避免故障扩散到其他资源池。

下图展示了熔断器与线程池隔离的协同架构：

3.5 金融场景中的熔断策略对比

不同金融业务对熔断的敏感度不同，下表对比了三种典型策略：

3.6 代码示例：基于状态机的熔断器核心逻辑

以下是一个简化的熔断器状态机实现，展示了状态转换与计数逻辑：

public class CircuitBreaker {
    private State state = State.CLOSED;
    private int failureCount = 0;
    private int successCount = 0;
    private final int failureThreshold = 5;
    private final int successThreshold = 2;
    private final long timeoutMs = 30_000;
    private long lastOpenTime = 0;

    public enum State { CLOSED, OPEN, HALF_OPEN }

    public synchronized boolean allowRequest() {
        switch (state) {
            case CLOSED:
                return true;
            case OPEN:
                if (System.currentTimeMillis() - lastOpenTime > timeoutMs) {
                    state = State.HALF_OPEN;
                    successCount = 0;
                    return true;
                }
                return false;
            case HALF_OPEN:
                return true;
            default:
                return false;
        }
    }

    public synchronized void recordFailure() {
        failureCount++;
        if (state == State.HALF_OPEN) {
            state = State.OPEN;
            lastOpenTime = System.currentTimeMillis();
        } else if (state == State.CLOSED && failureCount >= failureThreshold) {
            state = State.OPEN;
            lastOpenTime = System.currentTimeMillis();
        }
    }

    public synchronized void recordSuccess() {
        if (state == State.HALF_OPEN) {
            successCount++;
            if (successCount >= successThreshold) {
                state = State.CLOSED;
                failureCount = 0;
                successCount = 0;
            }
        } else if (state == State.CLOSED) {
            failureCount = 0; // 成功时重置失败计数
        }
    }
}