(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210541507.2 (22)申请日 2022.05.17 (71)申请人 贝壳找房 （北京） 科技有限公司 地址 100085 北京市海淀区西二 旗西路2号 院35号楼01层102-1 (72)发明人 缪桓举　赵谦　 (74)专利代理 机构 北京路浩知识产权代理有限 公司 11002 专利代理师 谢志超 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/48(2006.01) (54)发明名称 分布式定时任务调度方法、 系统、 存储介质 及程序产品 (57)摘要 本发明提供一种分布式定时任务调度方法、 系统、 存储介质及程序产品， 该方法包括： 调度服 务器定时从数据库拉取未来预设时段内要执行 的任务， 并将到达执行时间的任务分别在zk任务 队列目录节 点下创建对应的临时目录节点； 分布 式服务节 点处于空闲状态的线程排队获取锁， 所 述线程获取锁后到所述zk任务队列目录节点取 走一个所述临时目录节点对应的任务， 释放锁， 并在执行所述任务后重新排队获取锁。 本发明提 供的分布式定时任务调度方法、 系统、 存储介质 及程序产品， 可避免对数据库的过度访问， 减少 对数据库的访问压力； 可避免任务积压， 确保分 布式服务器资源高可用。 权利要求书2页 说明书9页 附图2页 CN 115185673 A 2022.10.14 CN 115185673 A 1.一种分布式定时任务调度方法， 其特 征在于， 包括： 调度服务器定时从数据库拉取未来预设时段内要执行的任务， 并将到达执行时间的任 务分别在zk任务队列目录节点下创建对应的临时目录节点； 分布式服务节点处于空闲状态的线程排队获取锁， 所述线程获取锁后到所述zk任务队 列目录节点取走一个所述临时目录节点对应的任务， 释放锁， 并在执行所述任务后重新排 队获取锁。 2.根据权利要求1所述的分布式定时任务调度方法， 其特 征在于， 所述方法还 包括： 所述分布式服 务节点上线后在zk节点列表目录节点下创建对应的临时目录节点； 所述调度服务器监听所述zk节点列表目录节点下创建的临时目录节点的状态， 响应于 获取到所述分布式服务节点下线的信息， 获取下线的所述分布式服务节点未完成的任务， 并将下线的所述分布式服务节点未完成的任务重新分别在所述zk任务队列目录节点下创 建对应的临时目录节点。 3.根据权利要求1所述的分布式定时任务调度 方法， 其特征在于， 所述zk任务队列目录 节点下创建的临时目录节点 为临时顺序编号目录节点； 所述线程获取锁后到所述zk任务队列目录节点取走一个所述临时目录节点对应的任 务， 包括： 所述线程获取锁后根据所述临时目录节点的序号到所述zk任务队列目录节点取 走一个所述临时目录节点对应的任务。 4.根据权利要求2所述的分布式定时任务调度方法， 其特征在于， 所述方法还包括： 所 述分布式服务节点在所述线程取走任务后及执行所述任务后更新数据库中相 应任务的状 态； 在所述将下线的所述分布式服务节点未完成的任务重新分别在所述zk任务队列目录 节点下创建对应的临时目录节点之前， 所述方法还包括： 根据所述下线的所述分布式服务 节点的信息查询所述数据库获取 所述未完成的任务。 5.根据权利要求1所述的分布式定时任务调度方法， 其特征在于， 所述分布式服务节点 处于空闲状态的线程 排队获取锁， 包括： 所述分布式服务节点处于空闲状态的线程在zk线程队列目录节点下创建对应的临时 顺序编号目录节点； 所述线程获取所述zk线程队列目录节点下其他的所述临时顺序编号目录节点的序号， 若所述线程对应的所述临时顺序编号目录节点的序号 最小则获取锁。 6.根据权利要求1所述的分布式定时任务调度方法， 其特征在于， 在 分布式服务节点处 于空闲状态的线程 排队获取锁后， 所述方法还 包括： 响应于所述zk任务队列目录节点下的临时目录节点为空， 则所述线程监听所述zk任务 队列目录节点。 7.一种分布式定时任务调度系统， 其特征在于， 包括调度服务器、 zookeeper服务器和 分布式服 务节点集群， 所述分布式服 务器节点 集群包括至少一个分布式服 务节点， 其中： 所述调度服务器用于： 定时从数据库拉取未来预设时段内要执行的任务， 并将到达执 行时间的任务分别在zk任务队列目录节点下创建对应的临时目录节点； 所述分布式服务节点用于： 处于空闲状态的线程排队获取锁， 所述线程获取锁后到所 述zk任务队列目录节点取走一个所述临时目录节点对应的任务， 释放锁， 并在执行所述任权　利　要　求　书 1/2 页 2 CN 115185673 A 2务后重新 排队获取锁。 8.一种电子设备， 包括存储器、 处理器及存储在所述存储器上并可在所述处理器上运 行的计算机程序， 其特征在于， 所述处理器执行所述程序时实现如权利要求1至6任一项所 述分布式定时任务调度方法中调度服 务器或分布式服 务节点所 执行的步骤。 9.一种非暂态计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机 程序被处理器执行时实现如权利要求1至6任一项所述分布式定时任务调度方法中调度服 务器或分布式服 务节点所 执行的步骤。 10.一种计算机程序产品， 包括计算机程序， 其特征在于， 所述计算机程序被处理器执 行时实现如权利要求1至6任一项所述分布式定时任务调度方法中调度服务器或分布式服 务节点所 执行的步骤。权　利　要　求　书 2/2 页 3 CN 115185673 A 3