使用时间轮实现“延时任务”

使用时间轮实现“延时任务”比如现在游标在1, 现在有个业务是7219s后执行,首先找游标, % 3600 = 20, 那就是插入下标 = 20 的槽 对应的队列, cyc

欢迎大家来到IT世界,在知识的湖畔探索吧!

延时任务,顾名思义:过一段时间后才执行的任务。例如用户开启计划后 24 小时发一条推送,提醒用户坚持练习;电商业务中,成单后72 小时未评价,自动打5分等场景。那么这些 延时任务怎么优雅的实现呢?

首先我们想到的是 crontab: 启动一个crontab定时任务,每小时跑一次,给开启计划超过24小于25小时的用户发送push。

$userList = select uid from program_schedule where create_time >= now_time - 25 * 3600 and create_time < now_time - 24 * 3600;
foreach ($userList as $uid)  {
      (new Service_Push())->sendPush($uid, '练习提醒', '亲,今天记得练习,不要偷懒哦 ^^');
}

欢迎大家来到IT世界,在知识的湖畔探索吧!

优点:

简单、快速实现

缺点:1、数据量大的时候,效率比较低。

2、每次需要全量查询一次,可能会重复计算

3、时效性不够,因为是一个小时一次,极端情况,这个用户就是当前小时的第一秒开启的,那就要延迟一个小时收到推送。当然可以通过修改 crontab 的轮询频次(改成一分钟或者1秒钟),这样放大了 1、2 步的缺点。

所以这类业务一定要保证时效性,可以采用时间轮实现:

不太会用画图工具,只能采用农耕文明的手段了,哈哈,凑合看。

使用时间轮实现“延时任务”

包括两个数据结构:1、环形队列:一个小时对应 3600秒,一秒一个槽,避免转的过快和过慢

2、任务队列: 环上每个槽都是一个 队列

当前指针就是 当前时间戳 % 3600, 每个槽都是一个队列,队列的每个cell包含两个数据结构:1. cycle_num: 循环次数,表示第几圈,比如 48 小时后执行,那 cycle_num = 47 (下标从 0 开始)

2. data: 自定义参数,包含任务名称(task_function_name)和参数列表(params)

比如现在游标在1, 现在有个业务是7219s后执行,首先找游标,(7219 + 1) % 3600 = 20, 那就是插入下标 = 20 的槽 对应的队列, cycle_num : floor((7219 + 1) / 3600) = 2

数据插入后,启用 crontab 或者 go cron 实现 一个 timer,轮询频率是 一秒一次, 每次取当前秒对应的时间槽,这是一个队列,从队列中取 cycle_num =0 的 cell, 解析数据后, 直接扔给 对应的 task 执行,timer 不涉及具体的业务逻辑,然后 修改 其他的 cell, cycle_num -= 1, 表示转了一圈了, 依次循环执行下去。

demo: 使用redis 队列作为存储

欢迎大家来到IT世界,在知识的湖畔探索吧!//产生时间轮:
private function createTimerData() {
    //一天 24 个小时    
    for ($i = 0; $i < 23; $i++) {
        //一个小时按秒算        
        for ($j = 0; $j < 3600; $j++) {
            $key = 'task_' . $j;
            $data = [
                'method' => 'send_msg',
                'params' => [
                    'uid' => $i .'--'.$j,
                    'msg' => 'No:' . $i .'--'.$j
                ],
                'cycle_num' => $i
            ];
            Util::redisRPush($key, json_encode($data));
        }
    }
}
 
//timer:
private function executeTask() {
    for ($i = 0; $i < 3600; $i++) {
        $key = 'task_' . $i;
        $len =  Util::redisLLen($key);
        for ($j = 0; $j < $len; $j++) {
            $data = Util::redisLIndex($key, $j);
            $data = json_decode($data, true);
            if ($data['cycle_num'] == 0) {
                //调用 svr-task 处理具体业务
                //从列表中删除此下标数据                
                Util::redisLSet($key, $j, 'delete');
            } else {
                --$data['cycle_num'];
                Util::redisLSet($key, $j, json_encode($data));
            }
        }
        
        Util::redisLRem($key, 0, 'delete');
    }
}

这里使用了 redis 实现,为了保证数据一致性,可以落盘到数据库, redis 重启后,从数据库 loading 到 redis 。

ps: 还有个小惊喜, redis 队列不支持 按照对应下标删除,用了两个命令实现

1. 将队列中待删除的下标的值 标记为 特殊字符串

$redis->lSet($key, $index, 'delete');

2. 删除此字符串对应的下标

欢迎大家来到IT世界,在知识的湖畔探索吧!$redis->lRem($key, 0, 'delete');
lrem(key, count, value)
根据参数 count 的值,移除列表中与参数 value 相等的元素。

count 的值可以是以下几种:

count > 0 : 从表头开始向表尾搜索,移除与 value 相等的元素,数量为 count 。

count < 0 : 从表尾开始向表头搜索,移除与 value 相等的元素,数量为 count 的绝对值。

count = 0 : 移除表中所有与 value 相等的值。

免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://itzsg.com/32323.html

(0)

相关推荐

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

联系我们YX

mu99908888

在线咨询: 微信交谈

邮件:itzsgw@126.com

工作时间:时刻准备着!

关注微信