示例
示例
ZADD delay:jobs 1700000001 job1 1700000002 job2
ZPOPMIN delay:jobs # 1700000001 job1(弹出最小分数)
ZPOPMAX delay:jobs 2 # 一次弹两个最大分
# 延时队列消费循环(到期即弹):
ZRANGEBYSCORE delay:jobs -inf $(date +%s) LIMIT 0 1
ZPOPMIN delay:jobs| 返回 | 成员与分数交替的数组 |
|---|---|
| count | 一次弹多个(6.2+) |
| 阻塞版 | BZPOPMIN/BZPOPMAX 等待元素出现 |
延时队列 = score 存到期时间戳,ZPOPMIN 弹到期的;多消费者竞争需要 Lua 保证「判断+弹出」原子。