php 实现熔断

熔断机制简介

熔断是一种系统保护机制，当服务调用失败率达到阈值时，自动停止请求并快速失败，避免雪崩效应。常见于微服务架构中，如结合Hystrix、Resilience4j等库实现。PHP可通过以下方式实现基础熔断逻辑。

基础熔断器实现

通过状态标记和失败计数模拟熔断器：

class CircuitBreaker {
    private $failureThreshold = 3; // 失败阈值
    private $resetTimeout = 10;    // 重置时间（秒）
    private $failures = 0;         // 当前失败次数
    private $lastFailureTime = 0;  // 最后失败时间
    private $state = 'CLOSED';     // 状态：CLOSED/OPEN/HALF-OPEN

    public function execute(callable $serviceCall) {
        if ($this->state === 'OPEN') {
            // 检查是否达到重置时间
            if (time() - $this->lastFailureTime > $this->resetTimeout) {
                $this->state = 'HALF-OPEN';
            } else {
                throw new Exception('Circuit breaker is open');
            }
        }

        try {
            $result = $serviceCall();
            if ($this->state === 'HALF-OPEN') {
                $this->reset();
            }
            return $result;
        } catch (Exception $e) {
            $this->recordFailure();
            throw $e;
        }
    }

    private function recordFailure() {
        $this->failures++;
        $this->lastFailureTime = time();
        if ($this->failures >= $this->failureThreshold) {
            $this->state = 'OPEN';
        }
    }

    private function reset() {
        $this->failures = 0;
        $this->state = 'CLOSED';
    }
}

使用示例

$breaker = new CircuitBreaker();
try {
    $result = $breaker->execute(function() {
        // 模拟可能失败的服务调用
        if (rand(0, 1)) {
            throw new Exception('Service error');
        }
        return 'Success';
    });
    echo $result;
} catch (Exception $e) {
    echo 'Fallback: ' . $e->getMessage();
}

高级方案：结合Swoole或扩展

1. Swoole协程：利用协程定时器实现更精确的熔断控制。
2. Redis统计：通过Redis存储失败计数和状态，支持分布式场景。
3. 开源库：如league/pipeline结合中间件模式实现熔断流程。

关键优化点

• 动态阈值：根据系统负载动态调整失败阈值。
• 降级策略：熔断时返回缓存数据或默认值。
• 监控集成：上报熔断事件至Prometheus或StatsD。

通过上述方法，可在PHP中实现轻量级熔断逻辑，适用于高并发或微服务场景。