------------------------------------------------------------------------------------------------------慢慢来,一切都来得及
Redis 4.0 提供了一个限流 Redis 模块,它叫 redis-cell。该模块也使用了漏斗算法,并提供了原子的限流指令。该模块只有 1 条指令 cl.throttle,它的参数和返回值都略显复杂。
上面这个指令的意思是允许的频率为每
60s
最多
30
次
(
漏水速率),漏斗的初始容量为
15
,也就是说一开始可以连续回复
15
个帖子,然后才开始受漏水速率的影响。我们看到这个指令中漏水速率变成了 2
个参数,替代了之前的单个浮点数。用两个参数相除的结果来表达漏水速率相对单个浮点数要更加直观一些。
> cl.throttle laoqian:reply 15 30 60
1) (integer) 0
# 0 表示允许,1 表示拒绝
2) (integer) 15
# 漏斗容量 capacity
3) (integer) 14
# 漏斗剩余空间 left_quota
4) (integer) -1
# 如果拒绝了,需要多长时间后再试(漏斗有空间了,单位秒)
5) (integer) 2
# 多长时间后,漏斗完全空出来(left_quota==capacity,单位秒)
在执行限流指令时,如果被拒绝了,就需要丢弃或重试。
cl.throttle
指令考虑的非常周到,连重试时间都帮你算好了,直接取返回结果数组的第四个值进行 sleep
即可,如果不想阻塞线程,也可以异步定时任务来重试。