redis滑动窗口流量控制

基于Redis的滑动窗口流量控制算法可以通过Redis的ZSET数据结构实现。具体实现步骤如下：

1. 定义一个时间窗口，例如1分钟，将这个时间窗口分成多个小时间片，例如每秒一个时间片。

2. 每个时间片对应一个ZSET，ZSET中的元素为请求的时间戳，分值为1。

3. 当有请求到达时，将请求的时间戳作为元素插入到当前时间片对应的ZSET中。

4. 统计整个时间窗口内的请求总数，可以通过遍历所有时间片对应的ZSET并累加元素数量得到。

5. 如果请求总数超过了限流阈值，则拒绝本次请求。

6. 为了避免ZSET无限增长，需要定期清理过期的时间片。

下面是一个PHP实现的示例代码：

class SlidingWindow
{
    private $redis;
    private $windowSize;
    private $limit;

    public function __construct($redis, $windowSize, $limit)
    {
        $this->redis = $redis;
        $this->windowSize = $windowSize;
        $this->limit = $limit;
    }

    public function hit()
    {
        $now = microtime(true);
        $key = $this->getKey($now);
        $this->redis->zAdd($key, $now, $now);
        $this->redis->expire($key, $this->windowSize);
        $count = $this->getCount();
        if ($count > $this->limit) {
            throw new Exception('Rate limit exceeded');
        }
    }

    private function getKey($now)
    {
        $start = floor($now / $this->windowSize) * $this->windowSize;
        $end = $start + $this->windowSize - 1;
        return "sliding_window:{$start}:{$end}";
    }

    private function getCount()
    {
        $now = microtime(true);
        $start = floor($now / $this->windowSize) * $this->windowSize;
        $end = $start + $this->windowSize - 1;
        $keys = [];
        for ($i = $start; $i <= $end; $i += 1) {
            $keys[] = $this->getKey($i);
        }
        $this->redis->zUnion($key, $keys);
        $this->redis->expire($key, $this->windowSize);
        return $this->redis->zCard($key);
    }
}

// 使用示例
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$windowSize = 60; // 时间窗口为60秒
$limit = 100; // 限流阈值为100个请求
$slidingWindow = new SlidingWindow($redis, $windowSize, $limit);
try {
    $slidingWindow->hit();
    echo 'Request accepted';
} catch (Exception $e) {
    echo 'Request rejected: ' . $e->getMessage();
}