Redis使用zset有序集合做延迟队列

Question

如题所述

Answer 1

把所有需要在未来执行的任务都添加到有序集合里面，并将任务的执行时间设置为分值，另外再使用一个进程来查找有序集合里面是否存在可以立即执行的任务，如果有的话，就从有序集合里面移除那个任务，并将它添加到适当的任务队列里面。

--出自《Redis实战》

创建函数 addFutureJob，负责将延迟任务添加到有序集合job中。

有序集合里存储的元素，可以使用json格式保存。

内部结构可以类似如下这种：

参数：
$job: 存储延迟任务的有序集合的名字，叫job

$queue: 当任务到达执行时间时，转存到具体的队列里执行

$fun: 负责执行的函数名称或匿名函数

$time: 延迟任务执行的具体时间

$parameter: 传递的参数

执行脚本后，将存储到job 这个有序集合里

另一个脚本中，读取job集合，检查是否有需要执行的任务

这个函数getQueue()的基本流程是这样：
(1)根据分数从小到大排列，读取第一个元素。如果元素不存在返回false
(2) 如果元素任务存在，并且它的分数（执行时间）小于等于当前时间，说明这个任务可以执行了。
(3) json转化成数组，读取任务的queue参数，将它添加到指定的队列里，然后从job中删除这个任务。
(4) 上述转移操作时，如果成功，记录日志。while继续循环检查job有序集合
(5) 如果转移操作失败，返回false
(6) 后续没有要执行的任务时，停止循环，返回false

此处循环读取也可以使用zrangeByScore()函数，根据分数范围进行读取返回集合内的指定元素。