百度面试:如何用Redis实现限流?
在Redis中实现限流通常使用Lua脚本与Redis提供的数据结构和命令结合使用。以下是一个简单的示例,展示了如何使用Lua脚本和Redis的INCR命令来实现一个简单的限流器:
-- Lua脚本实现限流
-- KEYS[1] 是用来存储计数器的键
-- ARGV[1] 是时间窗口的大小(例如,60表示60秒)
-- ARGV[2] 是允许的最大请求数(例如,100表示每秒最多100个请求)
-- 将key的值增加1
redis.call('INCR', KEYS[1])
-- 如果是第一次执行,初始化为0
if redis.call('EXISTS', KEYS[1]) == 0 then
redis.call('EXPIRE', KEYS[1], ARGV[1])
end
-- 获取当前计数
local count = redis.call('GET', KEYS[1])
-- 如果计数超过了限制,返回0,表示被限流
if count and tonumber(count) > tonumber(ARGV[2]) then
return 0
else
-- 如果没有超过限制,返回1,表示通过限流
return 1
end
在实际应用中,你可以通过Redis的EVAL
命令来运行这个Lua脚本。例如,如果你想要设置一个限制每秒钟不超过100个请求的限流器,可以这样使用:
redis-cli EVAL "$(cat script.lua)" 1 mykey:limit 60 100
这里mykey:limit
是用来存储计数器的键,60
是时间窗口,100
是允许的最大请求数。根据实际情况调整这些参数。脚本会返回1如果请求被允许,返回0如果请求被限流。
评论已关闭