(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210684796.1 (22)申请日 2022.06.17 (71)申请人 北京结慧科技有限公司 地址 100041 北京市石景山区实兴大街3 0 号院3号楼 2层A-1151 (72)发明人 李廷　唐健　 (74)专利代理 机构 北京正理专利代理有限公司 11257 专利代理师 张帆 (51)Int.Cl. G06F 11/30(2006.01) G06F 11/32(2006.01) G06F 9/48(2006.01) G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 针对定时任务的监控方法及系统、 计算机设 备及存储介质 (57)摘要 本发明实施例公开一种针对定时任务的监 控方法及系统、 计算机设备及存储介质， 其中， 所 述监控方法包括： S10： 设置kafka消息队列， 配置 相关信息， 使得业务系统能够在定时任务调度前 后通过所述kafka消息队列发送定时任务调度信 息， 其中， 每次发送的定时任务调度信息均包含 唯一任务执行ID； S20： 设置定时巡检系统从 kafka消息队列提取定时任务调度信息以实现对 定时任务的监控和异常告警。 通过定时巡检系统 监测定时任务是否正常执行， 若执行失败或没有 执行时则进行异常告警， 实现了定时任务的实时 监控， 使得服务人员能够在第一时间处理异常问 题， 提高了对异常问题的处 理效率。 权利要求书2页 说明书7页 附图4页 CN 115168137 A 2022.10.11 CN 115168137 A 1.一种针对定时任务的监控方法， 其特 征在于， 包括： S10： 设置kafka消息队列， 配置相关信息， 使得业务系统能够在定时任务调度前后通过 所述kafka消息队列发送定时任务调 度信息， 其中， 每次发送的定时任务调度信息均包含唯 一任务执 行ID； S20： 设置定时巡检系统从kafk a消息队列提取所述定时任务调度信息以实现对定时任 务的监控和异常告警， 其中， 所述定时巡检系统还能够通过Zookeeper  watch机制 监控定时任务 的Zookeeper节点 变化， 并从所述 业务系统中拉取定时任务调度信息 。 2.根据权利要求1所述的方法， 其特 征在于， 所述定时巡检系统的巡检流 程包括： S201： 清空所有需执 行的监控 任务记录并查询配置表中所有监控的定时任务； S202： 循环检查S201中查询到的已配置的定时任务， 确定其是否存在需执行的记录， 若 不存在需执 行的记录， 则暂不 监控， 否则跳转至下一 步； S203： 判断所述已配置的定时任务是否 部署多台服 务器进行 跑批； 若仅部署一台服 务器， 则跳转至步骤S204； 若部署多台服 务器进行 跑批， 则跳转至步骤S20 5； S204： 根据任务名称和上一次执行时间查询执行记录表， 并判断查询结果数是否小于 1； 若查询结果数小于1， 则间隔预定时长进行二 次查询， 根据二次查询的结果判断是否 需 要告警， 若需要告警则发送邮件与企业微信至服务维护人员， 若不需要告警则继续执行下 一个任务 监控； S205： 根据任务名称和上一次执行时间查询所述执行记录表， 若查询结果数小于所需 服务器的台数， 则间隔预定时长进行二次查询， 若二次查询的结果数小于所需服务器的台 数则发送邮件或企业 微信至服 务维护人员， 否则继续执 行下一任务的监控。 3.根据权利要求1所述的方法， 其特 征在于， 所述定时巡检系统在检查到任务异常后将自动存 储记录异常任务的任务信息 。 4.根据权利要求1或2所述的方法， 其特 征在于， 所述配置表包括预先设置的需监控的任务信 息， 若所述业务系统发送的定时任务调度 信息不在所述预 先设置的需监控的任务信息范围内， 则拒绝 监控。 5.根据权利要求2所述的方法， 其特 征在于， 所述定时任务调度信息包括 开始调度信息和结束调度信息， 其中， 所述开始调度信息包括任务名称、 任务描述、 项目名称、 任务执行ID、 cron表达式、 开始 时间、 结束时间以及开始调度标识； 所述结束调度信息包括任务名称、 任务描述、 项目名称、 任务执行ID、 cron表达式、 开始 时间、 结束时间以及调度成功标识或调度失败标识。 6.一种针对定时任务的监控系统， 其特 征在于， 包括： 任务配置单 元、 消息传输单 元、 定时巡检单 元以及告警记录管理单 元， 其中， 所述任务配置单元被设置为响应于用户的操作接收其输入的任务信息以添加业务至权　利　要　求　书 1/2 页 2 CN 115168137 A 2监控队列； 所述消息传输单元被设置为接收业务系统发送的定时任务调度信息并将其传输至所 述定时巡检单 元； 所述定时巡检单元被设置为根据所述定时任务调度信息以及任务信息进行指定定时 任务的任务状态的监控并在发现异常时进行异常告警； 所述告警记录管理单 元被设置为自动记录异常告警信息 。 7.根据权利要求6所述的系统， 其特 征在于， 所述消息传输单 元采用kafka进行信息流管理； 所述定时巡检系统响应于业务系统通过kafka消息队列发送的定时任务调度信息开启 线程， 对定时任务调度信息中指定的任务的执 行状态进行监控： S201： 清空所有需执 行的监控 任务记录并查询配置表中所有监控的定时任务； S202： 循环检查S201中查询到的已配置的定时任务， 确定其是否存在需执行的记录， 若 不存在需执 行的记录， 则暂不 监控， 否则跳转至下一 步； S203： 判断所述已配置的定时任务是否 部署多台服 务器进行 跑批； 若仅部署一台服 务器， 则跳转至步骤S204； 若部署多台服 务器进行 跑批， 则跳转至步骤S20 5； S204： 根据任务名称和上一次执行时间查询执行记录表， 并判断查询结果数是否小于 1； 若查询结果数小于1， 则间隔预定时长进行二 次查询， 根据二次查询的结果判断是否 需 要告警， 若需要告警则发送邮件与企业微信至任务负责人， 若不需要告警则继续执行下一 个任务监控； S205： 根据任务名称和上一次执行时间查询所述执行记录表， 若查询结果数小于所需 服务器的台数， 则间隔预定时长进行二次查询， 若二次查询的结果数小于所需服务器的台 数则发送邮件或企业 微信至服 务维护人员， 否则继续执 行下一任务的监控。 8.根据权利要求6所述的系统， 其特 征在于， 所述定时业务巡检系统还能够通过Zookeeper  watch机制监控定时任务的Zookeeper 节点变化， 并从所述 业务系统中拉取 所述定时任务调度信息； 所述告警记录管理单 元能够响应于用户的操作进行异常告警信息的查询。 9.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述程序时实现如权利要求1 ‑5任一项所述的方 法。 10.一种计算机存储介质， 其上存储有计算机程序， 其特征在于， 该程序被处理器执行 时实现如权利要求1 ‑5中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115168137 A 3