熔断机制基础概念

熔断机制（Circuit Breaker）是微服务架构中防止级联故障的关键容错模式。在催收API场景中，当外部催收系统（如外呼平台、短信网关、第三方数据源）出现持续故障或响应超时时，熔断器能够快速切断调用链路，避免资源耗尽和雪崩效应。本节将深入剖析熔断器的核心状态机、与限流/降级的本质区别，以及关键监控指标。

2.1 熔断器状态机：Closed / Open / Half-Open

熔断器内部维护一个有限状态机，包含三个核心状态：Closed（关闭）、Open（打开） 和 Half-Open（半开）。状态转换由预设的阈值和超时时间驱动。

状态详解

2.2 熔断与限流/降级的区别

熔断、限流、降级是服务治理的“三驾马车”，但三者目标与作用域不同。很多开发者容易混淆，下面通过对比表格和架构图厘清边界。

2.3 熔断的核心指标

熔断器的决策依赖一组可配置的统计指标。这些指标通过滑动窗口（Sliding Window）在时间维度上聚合计算。以下是催收API场景下最关键的 5 个指标：

滑动窗口统计原理

熔断器不依赖全局计数器，而是使用滑动窗口将时间划分为多个桶（Bucket）。每个桶记录该时间片内的请求结果。窗口滑动时，旧桶数据被丢弃，新桶数据加入，实现实时滚动统计。

# 滑动窗口伪代码示例（Python）
class SlidingWindowCounter:
    def __init__(self, window_size_sec=30, bucket_count=10):
        self.bucket_duration = window_size_sec / bucket_count  # 每个桶3秒
        self.buckets = [{'success': 0, 'failure': 0, 'slow': 0} for _ in range(bucket_count)]
        self.current_bucket_index = 0
        self.last_rotate_time = time.time()

    def record(self, success=True, slow=False):
        self._rotate()
        bucket = self.buckets[self.current_bucket_index]
        if success:
            bucket['success'] += 1
        else:
            bucket['failure'] += 1
        if slow:
            bucket['slow'] += 1

    def get_failure_rate(self):
        self._rotate()
        total = sum(b['success'] + b['failure'] for b in self.buckets)
        failures = sum(b['failure'] for b in self.buckets)
        return failures / total if total > 0 else 0.0

    def _rotate(self):
        now = time.time()
        elapsed = now - self.last_rotate_time
        if elapsed >= self.bucket_duration:
            # 重置过期桶
            shift = int(elapsed // self.bucket_duration)
            for i in range(min(shift, len(self.buckets))):
                idx = (self.current_bucket_index + 1 + i) % len(self.buckets)
                self.buckets[idx] = {'success': 0, 'failure': 0, 'slow': 0}
            self.current_bucket_index = (self.current_bucket_index + shift) % len(self.buckets)
            self.last_rotate_time = now

核心指标组合决策逻辑

实际生产环境中，熔断器通常组合多个指标进行决策，避免单一指标误判。以下是一个典型的决策流程：

1. 检查最小请求数：如果窗口内总请求数 < 最小请求数，不触发熔断，避免冷启动误判。
2. 计算失败率：如果失败率 > 阈值，进入 Open 状态。
3. 计算慢调用比例：如果慢调用比例 > 阈值且失败率未超限，也进入 Open 状态（慢调用预警）。
4. 进入 Half-Open：Open 状态持续超时时间后，自动转为 Half-Open，放行探测请求。
5. 探测结果判定：如果探测请求全部成功，转为 Closed；否则回到 Open。