Redis第17讲——Redis zset结构实现滑动窗口限流

import redis
import time
 
# 连接Redis
r = redis.Redis(host='localhost', port=6379, db=0)
 
# 滑动窗口限流的实现
def is_rate_limited(key, max_requests, window_size):
    # 窗口结束时间
    window_end = time.time() + window_size
    # 窗口开始时间
    window_start = window_end - window_size
 
    # 在Redis中，使用有序集合(zset)记录请求次数，其中成员是key，分数是请求时间戳
    requests = r.zrangebyscore(key, window_start, window_end)
 
    # 如果请求数超过限制，则返回True表示被限流
    if len(requests) > max_requests:
        return True
    else:
        # 将新的请求加入到zset中
        r.zadd(key, {str(time.time()): time.time()})
        return False
 
# 使用示例
key = 'user_requests:123'  # 假设用户的ID是123
max_requests = 10  # 时间窗口内最多允许10个请求
window_size = 60  # 时间窗口大小为60秒
 
if is_rate_limited(key, max_requests, window_size):
    print("被限流了")
else:
    print("通过了限流")

这段代码首先连接到Redis，然后定义了一个is_rate_limited函数，该函数使用Redis的有序集合(zset)来实现滑动窗口限流。每次请求时，它会检查在指定时间窗口内的请求次数是否超过了限制。如果超过了，则返回True表示被限流；否则，将这次请求记录在zset中，并返回False表示未被限流。