(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210452053.1 (22)申请日 2022.04.27 (71)申请人 泽拓科技 （深圳） 有限责任公司 地址 518110 广东省深圳市宝安区新 安街 道海滨社区N26区宝兴路21号万骏经 贸大厦509 (72)发明人 赵伟　张金冬　吴夏　王潮杰　 何革新　盛欢　刘良城　张世伟　 黄远芳　刘永松　 (74)专利代理 机构 深圳中细软知识产权代理有 限公司 4 4528 专利代理师 徐春祺 (51)Int.Cl. H04L 67/10(2022.01) H04L 67/1095(2022.01)H04L 67/133(2022.01) G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 分布式任务协调方法、 装置、 设备和介质 (57)摘要 本发明公开了一种分布式任务协调方法、 装 置、 设备和介质， 包括： 首先每当获取到前端下发 的分布式任务时， 异步地对分布式任务进行内部 初始化， 再通过通知下发框架将初始化后的分布 式任务下发至等待队列， 以等待响应。 接着集群 管理组件通过通知下发框架将等待队列中的分 布式任务异步地下发至多个协程。 最后通过多个 协程同步地获取连接的设备节 点所反馈的应答， 以响应分布式任务。 远程过程调用技术采用 “请 求‑应答”模式， 该模式具有2次握手的通知 协议， 能够准确的感知下游服务是否能成功接收到相 关信息并获取到应答反馈， 从而满足高吞吐分布 式任务协调的实际需求。 权利要求书2页 说明书7页 附图2页 CN 114760312 A 2022.07.15 CN 114760312 A 1.一种分布式任务协调方法， 其特征在于， 应用于包含多个设备节点的分布式数据库 集群， 所述方法包括： 每当集群管理组件获取到前端下发的分布式任务 时， 异步地对所述分布式任务进行内 部初始化， 及通过通知下发框架将初始 化后的分布式任务下发至等待队列， 以等待响应； 其 中， 所述通知下发框架基于远程过程调用技 术构建基础框架； 所述集群管理组件通过所述通知下发框架将所述等待队列中的分布式任务异步地下 发至多个协程， 并通过所述多个协程同步地获取连接的设备节点所反馈的应答， 以响应所 述分布式任务。 2.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 将与所述分布式任务相关联的内部事 件进行缓存。 3.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 基于所述 通知下发框架， 通过域名解析协议或负载均衡的策略扩展所述设备节点。 4.根据权利要求1所述的方法， 其特征在于， 所述异步地对所述分布式任务进行内部初 始化之前， 还 包括： 同步地对所述分布式任务的逻辑进行合法性校验， 基于校验结果向前端发送应答。 5.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 每当获取到传参请求时， 生成对应的请求实体； 经过串行同步执行的准备阶段、 同步等待应答的执行阶段及面向全局的收尾阶段， 来 执行所述请求实体。 6.根据权利要求5所述的方法， 其特 征在于， 所述方法还 包括： 获取为每一个设备节点预先设定的通道， 当基于单设备的远程过程调用技术实现远程 任务时， 添加与所述远程任务匹配的通道并执 行， 及初始化与所述远程任务相关的参数； 当基于多设备的远程过程调用技术实现远程任务 时， 多次添加与所述远程任务匹配的 通道并执 行， 及初始化与所述远程任务相关的参数。 7.根据权利要求6所述的方法， 其特 征在于， 所述方法还 包括： 通过编排请求实体的处理过程及远程任务的处理过程， 以执行涉及到多个阶段， 或涉 及到多个节点设备同时执 行相关指令的目标任务。 8.一种分布式任务协调装置， 其特征在于， 应用于包含多个设备节点的分布式数据库 集群， 所述装置包括： 等待响应模块， 用于每当集群管理组件获取到前端下发的分布式任务时， 异步地对所 述分布式任务进 行内部初始 化， 及通过通知下发框架将初始 化后的分布式任务下发至等待 队列， 以等待响应； 其中， 所述 通知下发框架基于远程过程调用技 术构建基础框架； 任务协调模块， 用于所述集群管理组件通过所述通知下发框架将所述等待队列中的分 布式任务异 步地下发至多个协程， 并通过所述多个协程同步地获取连接的设备节点所反馈 的应答， 以响应所述分布式任务。 9.一种计算机可读存储介质， 存储有计算机程序， 其特征在于， 所述计算机程序被处理 器执行时， 使得 所述处理器执行如权利要求1至7中任一项所述方法的步骤。 10.一种分布式任务协调设备， 包括存储器和处理器， 其特征在于， 所述存储器存储有 计算机程序， 所述计算机程序被所述处理器执行时， 使得所述处理器执行如权利要求1至7权　利　要　求　书 1/2 页 2 CN 114760312 A 2中任一项所述方法的步骤。权　利　要　求　书 2/2 页 3 CN 114760312 A 3