PHP API限流：Redis滑动窗口算法与HTTP 429状态码

class RedisRateLimiter
{
    private $redis;
    public function __construct($redisHost = '127.0.0.1', $redisPort = 6379)
    {
        $this->redis = new Redis();
        $this->redis->connect($redisHost, $redisPort);
    }
    /**
     * 滑动窗口限流检查
     * @param string $apiKey 限流标识（如用户ID、IP）
     * @param int $limit 窗口内允许的最大请求数
     * @param int $windowTime 窗口时间（秒）
     * @return bool 是否允许通过
     */
    public function isAllowed($apiKey, $limit, $windowTime)
    {
        $now = microtime(true);
        $key = "rate_limit:{$apiKey}";
        
        // 开启Redis事务，保证原子性
        $this->redis->multi();
        
        // 移除窗口时间之前的所有请求记录
        $this->redis->zRemRangeByScore($key, 0, $now - $windowTime);
        
        // 获取当前窗口内的请求数量
        $this->redis->zCard($key);
        
        // 添加当前请求记录，score和value都使用当前时间戳（加随机数防重复）
        $this->redis->zAdd($key, $now, $now . ':' . uniqid());
        
        // 设置键的过期时间，防止冷数据长期占用内存
        $this->redis->expire($key, $windowTime);
        
        $result = $this->redis->exec();
        
        // 获取zCard的结果（数组索引为1）
        $currentCount = $result[1];
        
        return $currentCount < $limit;
    }
}

$limiter = new RedisRateLimiter();
$apiKey = 'user_123';
$limit = 100;
$window = 60;

if (!$limiter->isAllowed($apiKey, $limit, $window)) {
    header('HTTP/1.1 429 Too Many Requests');
    header('X-RateLimit-Limit: ' . $limit);
    header('X-RateLimit-Remaining: 0');
    header('X-RateLimit-Reset: ' . (time() + $window));
    
    echo json_encode([
        'error' => 'Too Many Requests',
        'message' => '请求频率超限，请稍后再试。'
    ]);
    exit;
}