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