当前位置：首页 > PHP

php 实现熔断

2026-02-28 13:18:22PHP

熔断机制简介

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

基础熔断器实现

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

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();
}