(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211182005.1 (22)申请日 2022.09.27 (71)申请人 天翼数字生活科技有限公司 地址 200000 上海市 静安区万 荣路1256、 1258号1423室 (72)发明人 赵杰生　吴凯迪　高保庆　崔伟　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 黄忠 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) G06F 16/2455(2019.01) G06F 16/2458(2019.01) G06F 16/28(2019.01) (54)发明名称 异地多活架构下的任务调度方法、 装置、 介 质及相关 设备 (57)摘要 本申请提供的异地多活架构下的任务调度 方法、 装置、 介质及相关设备， 当检测到部署在不 同地区的机房对应的调度中心均达到任务触发 条件时， 可以获取成功触发调度任务的当前调度 中心及当前机房， 这样可以避免多个调度中心同 时向数据库查询调度任务导致数据库访问量过 高， 运行缓慢的现象发生； 接着， 本申请可以监测 当前调度中心的动作， 当监测到当前调度中心向 数据库查询本次调度任务时， 可以判断当前调度 中心是否存在已注册的目标执行器， 由于目标执 行器中包含当前机房的机房标识， 若当前调度中 心存在已注册的目标执行器， 说明当前调度中心 已经接入了注册服务， 此时， 可 以继续监测当前 调度中心的下一 步动作。 权利要求书2页 说明书11页 附图5页 CN 115454606 A 2022.12.09 CN 115454606 A 1.一种异地多活架构下的任务调度方法， 其特 征在于， 所述方法包括： 当检测到部署在不同地 区的机房对应的调度中心均达到任务触发条件时， 获取成功触 发调度任务的当前调度中心及当前机房； 在监测到所述当前调度中心向数据库查询本次调度任务 时， 判断所述当前调度中心是 否存在已注册的目标执行器， 所述目标执行器为包含所述当前机房的机房标识的执行器节 点； 若存在， 则在监测到所述当前调度中心将查询到的调度任务发送至所述目标执行器， 并在所述目标执行器对所述当前机房执行所述调度任务时， 判断所述目标执行器中包含的 机房标识是否为所述当前机房的机房标识； 若是， 则允许 所述目标 执行器对所述当前机房执 行所述调度任务； 否则， 不允许 所述目标 执行器对所述当前机房执 行所述调度任务； 若不存在， 则对所述当前调度中心及所述当前机房进行切换， 并在切换后返回执行在 所述当前调 度中心向数据库查询本次调 度任务时， 判断所述当前调 度中心是否存在已注册 的目标执行器的步骤。 2.根据权利要求1所述的异地多活架构下的任务调度方法， 其特征在于， 所述执行器节 点的注册过程， 包括： 当监测到任意一个执行器节点根据预先配置的调度中心地址向对应的调度中心进行 注册时， 拦截所述执 行器节点注 册时上报的sql语句； 在所述sql语句中添加待注册 的调度中心 的机房对应的机房标识， 以使所述执行器节 点利用添加机房标识后的sql语句向所述待注 册的调度中心进行注 册。 3.根据权利要求2所述的异地多活架构下的任务调度方法， 其特征在于， 所述在所述 sql语句中添加待注 册的调度中心的机房对应的机房标识， 包括： 判断所述sql语句中是否存在机房标识； 若不存在， 则在所述sql语句中插 入待注册的调度中心的机房对应的机房标识； 若存在， 则判断所述机房标识是否为所述待注 册的调度中心的机房对应的机房标识； 若是， 则允许 所述执行器节点向所述待注 册的调度中心进行注 册； 否则， 根据所述待注 册的调度中心的机房对应的机房标识对所述机房标识进行 更新。 4.根据权利要求1所述的异地多活架构下的任务调度方法， 其特征在于， 所述判断所述 当前调度中心是否存在已注 册的目标 执行器， 包括： 拦截所述当前调度中心向所述数据库查询本次调度任务 时发送的任务列表查询语句， 并获取所述数据库保存的注 册表中的node字段； 确定所述任务列表查询语句中是否包 含所述node字段； 若包含， 则确定所述当前调度中心存在已注 册的目标 执行器； 若不包含， 则确定所述当前调度中心不存在已注 册的目标 执行器。 5.根据权利要求1 ‑4中任一项所述的异地多活架构下的任务调度方法， 其特征在于， 所 述获取成功触发调度任务的当前调度中心及当前机房， 包括： 确定部署在不同地区的机房对应的调度中心中成功抢占数据库锁的调度中心及对应 的机房， 并将成功抢占数据库锁的调度中心及 对应的机房作为成功触发调 度任务的当前调 度中心及当前机房。权　利　要　求　书 1/2 页 2 CN 115454606 A 26.根据权利要求5所述的异地多活架构下的任务调度方法， 其特征在于， 所述允许所述 目标执行器对所述当前机房执 行所述调度任务之后， 还 包括： 在监测到所述目标执行器完成调度任务 时， 对数据库发送的下次任务调度时间进行更 新， 并释放所述数据库锁。 7.根据权利要求1所述的异地多活架构下的任务调度方法， 其特征在于， 所述对所述当 前调度中心及所述当前机房进行切换， 包括： 将所述当前调度中心成功触发调度任务 时抢占的数据库锁进行释放， 并重新获取部署 在不同地区的机房对应的调度中心中成功抢占所述数据库锁的调度中心及对应的机房； 将所述当前调度中心及所述当前机房切换为本轮成功抢占数据库锁的调度中心及对 应的机房。 8.一种异地多活架构下的任务调度装置， 其特 征在于， 包括： 获取模块， 用于当检测到部署在不同地区的机房对应的调度中心均达到任务触发条件 时， 获取成功触发调度任务的当前调度中心及当前机房； 第一判断模块， 用于在监测到所述当前调度中心向数据库查询本次调度任务时， 判断 所述当前调 度中心是否存在已注册的目标执行器， 所述目标执行器为包含 所述当前机房的 机房标识的执 行器节点； 第二判断模块， 用于若存在， 则在监测到所述当前调度中心将查询到的调度任务发送 至所述目标执行器， 并在所述 目标执行器对所述当前机房执行所述调度任务时， 判断所述 目标执行器中包 含的机房标识是否为所述当前机房的机房标识； 第一调度模块， 用于若是， 则允许 所述目标 执行器对所述当前机房执 行所述调度任务； 第二调度模块， 用于 否则， 不允许 所述目标 执行器对所述当前机房执 行所述调度任务； 切换模块， 用于若不存在， 则对所述当前调度中心及所述当前机房进行切换， 并在切换 后返回执行在所述当前调度中心向数据库查询本次调度任务时， 判断所述当前调度中心是 否存在已注 册的目标 执行器的步骤。 9.一种存储介质， 其特征在于： 所述存储介质中存储有计算机可读指令， 所述计算机可 读指令被一个或多个处理器执行时， 使得一个或多个处理器执行如权利要求 1至7中任一项 所述异地多活架构下的任务调度方法的步骤。 10.一种计算机设备， 其特 征在于， 包括： 一个或多个处 理器， 以及存 储器； 所述存储器中存储有计算机可读指令， 所述计算机可读指令被所述一个或多个处理器 执行时， 执行如权利要求1至7中任一项所述异地多活架构下的任务调度方法的步骤。权　利　要　求　书 2/2 页 3 CN 115454606 A 3