(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210614760.6 (22)申请日 2022.05.30 (71)申请人 阿维塔科技 （重庆） 有限公司 地址 401121 重庆市渝北区金开大道西段 106号1幢1层24 号 (72)发明人 顾晶磊　 (74)专利代理 机构 北京金蓄专利代理有限公司 11544 专利代理师 程引 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/54(2006.01) G06F 16/2455(2019.01) G06F 16/28(2019.01) (54)发明名称 一种分布式任务处 理方法及系统 (57)摘要 本发明实施例涉及计算机应用技术领域， 公 开了一种分布式任务处理方法及系统， 该方法包 括： 轮询缓存数据库中的延迟任务， 得到至少一 个到期延 迟任务并发送至准备队列； 从准备队列 获取至少一个到期延迟任务； 将 至少一个到期延 迟任务分发至消息队列以进行处理。 应用本发明 的技术方案， 能够实现通过由多组件进行分布式 的部署方式来实现高可用、 高并发、 高吞吐的延 时队列。 权利要求书2页 说明书10页 附图6页 CN 114924861 A 2022.08.19 CN 114924861 A 1.一种分布式任务处 理方法， 其特 征在于， 包括： 轮询缓存数据库中的延迟 任务， 得到 至少一个到期 延迟任务并发送至准备队列； 从所述准备队列获取至少一个所述到期 延迟任务； 将至少一个所述到期 延迟任务分发至消息队列以进行处 理。 2.根据权利要求1所述的基于延迟队列的分布式任务处理方法， 其特征在于， 所述轮询 缓存数据库中的延迟任务， 得到至少一个到期延迟任务并发送至准备队列之前， 所述方法 还包括： 接收来自用户的延迟消息请求； 所述延迟消息请求中携带有时延信息； 根据所述延迟消息请求 生成所述延迟 任务； 基于所述时延信息将所述延迟 任务写入所述缓存数据库。 3.根据权利要求2所述的方法， 其特征在于， 所述根据所述延迟消息请求生成所述延迟 任务之后， 所述方法还 包括： 将所述延迟 任务写入关系数据库。 4.根据权利要求3所述的方法， 其特征在于， 在所述将所述延迟任务写入所述关系数据 库或所述缓存数据库之后， 所述方法还 包括： 输出所述延迟 任务对应的任务标识至所述用户。 5.根据权利要求3所述的方法， 其特征在于， 所述从所述准备队列获取至少一个所述到 期延迟任务并分发至消息队列以进行处 理， 具体包括： 从所述准备队列中获取待传送的至少一个所述到期 延迟任务至工作队列； 在所述工作队列中获取至少一个所述到期 延迟任务并分发至所述消息队列进行处 理。 6.根据权利要求5所述的方法， 其特征在于， 在所述工作队列中获取至少一个所述到期 延迟任务并分发至所述消息队列进行处 理之后， 还 包括： 更改所述缓存数据库和所述关系数据库中所述到期 延迟任务对应的任务状态。 7.根据权利要求1所述的方法， 其特征在于， 在所述从所述准备队列获取至少一个所述 到期延迟任务并分发至消息队列以进行处 理之前， 所述方法还 包括： 自注册至所述缓存数据库中； 按照预定间隔， 与所述缓存数据库通信， 以获取自身的工作状态。 8.根据权利要求7所述的的方法， 其特征在于， 所述自注册至所述缓存数据库中， 具体 包括： 判断所述缓存数据库中是否存在 宕机节点； 若是， 则接管 所述宕机节点； 若否， 则生成新节点， 并将所述 新节点注 册至所述缓存数据库中。 9.根据权利1所述的方法， 其特征在于， 若轮询缓存数据库中的延迟任务 时所述缓存数 据库宕机， 则所述方法还 包括： 从所述关系数据库中获取 所述缓存数据库宕机时丢失的所述到期 延迟任务； 将丢失的所述到期延迟任务发送至所述准备队列， 并执行所述从所述准备队列获取至 少一个所述到期 延迟任务的步骤。 10.一种基于延迟队列的分布式任务处理系统， 其特征在于， 所述系统包括： 轮询器、 缓 存数据库和工作节点；权　利　要　求　书 1/2 页 2 CN 114924861 A 2所述轮询器用于： 轮询所述缓存数据库中的延迟任务， 得到至少一个到期延迟任务并 发送至准备队列； 所述工作节点用于： 从所述准备队列获取至少一个所述到期延迟任务， 将至少一个所 述到期延迟任务分发至消息队列以进行处 理。 11.根据权利10所述的系统， 其特 征在于， 所述系统还 包括： 补偿器； 所述补偿器用于： 从所述关系数据库中获取所述缓存数据库宕机时丢失的所述到期延 迟任务， 并将丢失的所述到期 延迟任务发送至所述 准备队列。权　利　要　求　书 2/2 页 3 CN 114924861 A 3