努力学习的PHPER
讨论数量:
用Go实现该推送的简单思路：
启动推送系统->从数据库读取恢复推送任务到推送链表->启动推送定时器->协程分发推送符合时间要求的推送任务
->若推送成功，则从推送链表剔除并更新数据库。
->若推送失败，则恢复到推送链表。
另外。推送系统提供rpc接口，接收推送任务，将其加入到推送链表，并落盘到数据库。
大概思路就是这样，感觉比单纯的队列有个好处就是，推送会比较及时，使用协程并发及时把消息推送出去，而使用队列的话，如果队列处理时间比较久，可能推送会延迟。
如果失败，self::dispatch()->dely();
关于 LearnKu
粤公网安备 44030502004330号
推荐文章：