Redis使用zset有序集合做延迟队列
最新回答
消失在我眼中
2024-07-27 00:07:34
--出自《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()函数，根据分数范围进行读取返回集合内的指定元素。
热门标签
