如何快速实现“延时消息”？

快狗打车订单完成后&＃xff0c;如果用户一直不评价&＃xff0c;48小时后会将自动评价为5星。

怎么实现这类“48小时后自动评价为5星”需求呢&＃xff1f;

画外音&＃xff1a;这类“一段时间之后&＃xff0c;完成一个任务”的需求很常见。

cron是不是最容易想到的方案&＃xff1f;

启动一个cron定时任务&＃xff0c;每小时跑一次&＃xff0c;将完成时间超过48小时&＃xff0c;且仍未评价的订单取出&＃xff0c;置为5星&＃xff0c;并把评价状态置为已评价。

假设订单表的结构为&＃xff1a;

order(oid, finish_time, stars, status, …)

更具体的&＃xff0c;定时任务每隔一个小时会这么做一次&＃xff1a;

select oid from order where finish_time > 48 and status&＃61;0;

update order set stars&＃61;5 and status&＃61;1 where oid in[…];

如果数据量很大&＃xff0c;需要分页查询&＃xff0c;分页update&＃xff0c;这将会是一个for循环。

cron方案有什么不足&＃xff1f;

&＃xff08;1&＃xff09;轮询效率比较低&＃xff1b;

&＃xff08;2&＃xff09;每次扫库&＃xff0c;已经被执行过记录&＃xff0c;仍然会被扫描&＃xff08;只是不会出现在结果集中&＃xff09;&＃xff0c;有重复计算的嫌疑&＃xff1b;

&＃xff08;3&＃xff09;时效性不够好&＃xff0c;如果每小时轮询一次&＃xff0c;最差的情况下&＃xff0c;时间误差会达到1小时&＃xff1b;

&＃xff08;4&＃xff09;如果通过增加cron轮询频率来减少时间误差&＃xff0c;则轮询低效和重复计算的问题会进一步凸显&＃xff1b;

对于这类需要延时执行的任务&＃xff0c;如何保证效率的同时&＃xff0c;又保证实时性呢&＃xff1f;

答案是&＃xff1a;高效延时消息。

高效延时消息&＃xff0c;包含两个重要的数据结构&＃xff1a;

&＃xff08;1&＃xff09;环形队列&＃xff0c;例如可以创建一个包含3600个slot的环形队列&＃xff08;本质是个数组&＃xff09;&＃xff1b;

&＃xff08;2&＃xff09;任务集合&＃xff0c;环上每一个slot是一个Set&＃xff1b;

同时&＃xff0c;启动一个timer&＃xff1a;

&＃xff08;1&＃xff09;此timer每隔1s&＃xff0c;在环形队列中移动一格&＃xff1b;

&＃xff08;2&＃xff09;用一个Current Index来标识正在检测的slot&＃xff1b;

Task结构中有两个很重要的属性&＃xff1a;

&＃xff08;1&＃xff09;Cycle-Num&＃xff1a;当Current Index第几圈扫描到这个Slot时&＃xff0c;执行任务&＃xff1b;

&＃xff08;2&＃xff09;Task-Function&＃xff1a;需要执行的任务函数&＃xff1b;

如上图&＃xff0c;假设当前Current Index指向第一格&＃xff0c;当有延时消息到达之后&＃xff0c;例如希望3610秒之后&＃xff0c;触发一个延时消息任务&＃xff0c;只需&＃xff1a;

&＃xff08;1&＃xff09;计算这个Task应该放在哪一个slot&＃xff0c;现在指向1&＃xff0c;3610秒之后&＃xff0c;应该是第11格&＃xff0c;所以这个Task应该放在第11个slot的Set中&＃xff1b;

&＃xff08;2&＃xff09;计算这个Task的Cycle-Num&＃xff0c;由于环形队列是3600格&＃xff08;每秒移动一格&＃xff0c;正好1小时&＃xff09;&＃xff0c;这个任务是3610秒后执行&＃xff0c;所以应该绕3610/3600&＃61;1圈之后再执行&＃xff0c;于是Cycle-Num&＃61;1&＃xff1b;

Current Index不停的移动&＃xff0c;每秒移动一格&＃xff0c;当移动到一个新slot&＃xff0c;遍历这个slot中对应的Set&＃xff0c;每个Task看Cycle-Num是不是0&＃xff1a;

&＃xff08;1&＃xff09;如果不是0&＃xff0c;说明还需要多移动几圈&＃xff0c;将Cycle-Num减1&＃xff1b;

&＃xff08;2&＃xff09;如果是0&＃xff0c;说明马上要执行这个Task了&＃xff0c;取出Task-Funciton执行&＃xff0c;丢给工作线程执行&＃xff0c;并把这个Task从Set中删除&＃xff1b;

画外音&＃xff1a;注意&＃xff0c;不要用timer来执行任务&＃xff0c;否则timer会越来越不准。

使用了“延时消息”方案之后&＃xff0c;“订单48小时后关闭评价”的需求&＃xff0c;只需将在订单关闭时&＃xff0c;触发一个48小时之后的延时消息即可&＃xff1a;

&＃xff08;1&＃xff09;无需再轮询全部订单&＃xff0c;效率高&＃xff1b;

&＃xff08;2&＃xff09;一个订单&＃xff0c;任务只执行一次&＃xff1b;

&＃xff08;3&＃xff09;时效性好&＃xff0c;精确到秒&＃xff1b;

画外音&＃xff1a;控制timer移动频率可以控制精度。

“架构师之路”已经开通视频号&＃xff0c;你受邀内测了吗&＃xff1f;

扫码关注“架构师之路”视频号

上一期网友提问&＃xff1a;

“环境&＃xff0c;对一个人的发展&＃xff0c;究竟有多重要&＃xff1f;”

欢迎大家在视频号收听我的建议。

欢迎提问&＃xff0c;问题均会在视频号解答。

简易的“延时消息队列”&＃xff0c;你学会了吗&＃xff1f;

如果对文章和配图满意的话&＃xff0c;帮忙转发。