haozu/delay-queue

基于Redis的延迟队列

v1.0.1 2018-07-27 10:31 UTC

This package is not auto-updated.

Last update: 2024-09-29 05:42:01 UTC


README

Downloads license Release

基于Redis实现的延迟队列,使用MsgPack编码数据,参考有赞延迟队列设计实现

应用场景

  • 订单超过30天内未回款,通知处理
  • 订单完成后,如果未评价,5天后自动好评
  • 房租剩余15天,到期前3天分别发送短信提醒续租等

支付宝异步通知实现

支付宝异步通知时间间隔是如何实现的(通知的间隔频率一般是:2m,10m,10m,1h,2h,6h,15h)

订单支付成功后,生成通知任务,放入消息队列中。
任务内容包含Array{0,0,2m,10m,10m,1h,2h,6h,15h}和通知到第几次N(这里N=1, 即第1次)。
消费者从队列中取出任务,根据N取得对应的时间间隔为0,立即发送通知。

第1次通知失败,N += 1 => 2
从Array中取得间隔时间为2m,添加一个延迟时间为2m的任务到延迟队列,任务内容仍包含Array和N

第2次通知失败,N += 1 => 3,取出对应的间隔时间10m,添加一个任务到延迟队列,同上
......
第7次通知失败,N += 1 => 8,取出对应的间隔时间15h,添加一个任务到延迟队列,同上
第8次通知失败,N += 1 => 9,取不到间隔时间,结束通知

实现原理

利用Redis的有序集合,member为JobId, score为任务执行的时间戳,
每秒扫描一次集合,取出执行时间小于等于当前时间的任务。

依赖

  • Redis MsgPack 扩展

下载

发布

Composer安装

composer require haozu/delay-queue

添加任务

DelayQueue::enqueue('order','Job\\Order\\GetOrder',3,10,['id'=>8008]);

参数说明

其他例子

  • 包装例子 demo/MyDelayQueueDemo.php
  • 添加例子 demo/AddDemo.php
  • worker例子 demo/BackstageDemo.php.php
  • job例子 demo/Job/JobDemo.php
  • 测试例子 test/DelayQueueTest.php