PHP实现防雪崩
PHP 防雪崩实现方法
防雪崩（Avalanche Prevention）通常指在高并发场景下，防止系统因瞬时流量激增而崩溃。以下是几种常见的PHP实现方案：
限流（Rate Limiting）
通过限制单位时间内的请求数量来保护系统。可以使用Redis实现计数器：
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$key = 'api_limit:' . $_SERVER['REMOTE_ADDR'];
$limit = 100; // 每分钟100次
$expire = 60; // 60秒
$current = $redis->get($key);
if ($current && $current >= $limit) {
header('HTTP/1.1 429 Too Many Requests');
exit;
}
$redis->multi()
->incr($key)
->expire($key, $expire)
->exec();熔断器模式（Circuit Breaker）
当错误率达到阈值时自动切断请求，避免连锁故障：
class CircuitBreaker {
private $failureThreshold = 3;
private $timeout = 30;
private $lastFailureTime = 0;
public function isAvailable() {
if ($this->lastFailureTime > 0 &&
time() - $this->lastFailureTime < $this->timeout) {
return false;
}
return true;
}
public function recordFailure() {
$this->lastFailureTime = time();
}
}队列缓冲
使用消息队列削峰填谷，如RabbitMQ实现：
$connection = new AMQPConnection(['host' => 'localhost']);
$channel = $connection->channel();
$channel->queue_declare('task_queue', false, true, false, false);
$msg = new AMQPMessage($_POST['data'], ['delivery_mode' => 2]);
$channel->basic_publish($msg, '', 'task_queue');缓存预热
提前加载热点数据到缓存，避免大量请求直接穿透到数据库：
$cache = new Memcached();
$cache->addServer('localhost', 11211);
$hotData = $db->query('SELECT * FROM hot_items LIMIT 100');
foreach ($hotData as $item) {
$cache->set('item_'.$item['id'], $item, 3600);
}服务降级
准备简化版方案应对高负载：
if ($load > 80) { // 系统负载过高时
$data = ['basic' => true]; // 返回简化数据
} else {
$data = fetchFullData(); // 正常业务流程
}
echo json_encode($data);实施建议
- 结合监控系统实时观察QPS、错误率等指标
- 分布式环境下需使用集中式存储（如Redis）管理状态
- 针对不同业务场景选择合适的策略组合
- 重要系统建议实现多级防护（全局限流+接口级限流）
