(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211069769.X (22)申请日 2022.09.02 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 卞嘉骏　唐成山　陈军　 (74)专利代理 机构 中原信达知识产权代理有限 责任公司 1 1219 专利代理师 郝红玉　张春晓 (51)Int.Cl. G06F 9/48(2006.01) G06F 8/30(2018.01) G06F 16/27(2019.01) G06F 11/30(2006.01) G06F 11/07(2006.01)G06F 11/14(2006.01) G06Q 40/02(2012.01) (54)发明名称 一种任务处 理方法和装置 (57)摘要 本发明公开了一种任务处理方法和装置， 涉 及数据处理及网络安全领域。 该方法的一具体实 施方式包括： 接收对设备的停机指令， 确定当前 执行状态为执行中的任务， 查询处理任务的线 程， 以获取线程的执行代码； 在执行代码中添加 对数据库和分布式锁的依赖代码， 将优雅停机标 志设置为第一预设值 以及将全局控制开关设置 为关闭状态， 使得线程不新增处理任务， 并继续 连接数据库处理任务； 监控线程的执行状态， 响 应于执行状态 为执行完成、 或在达到预设等待时 长时执行状态 为未完成， 断开线程与数据库的连 接并释放分布式锁， 以执行对设备的停机操作。 该实施方式在任务不同阶段均可实现优雅停机， 使得线程尽可能的将任务处理完毕， 尽量减少处 于中间态的情况。 权利要求书4页 说明书15页 附图4页 CN 115437766 A 2022.12.06 CN 115437766 A 1.一种任务处 理方法， 其特 征在于， 包括： 接收对设备的停机指令， 确定当前执行状态为执行中的任务， 查询处理所述任务的线 程， 以获取 所述线程的执 行代码； 在所述执行代码中添加对数据库和分布式锁的依赖代码， 将优雅停机标志设置为第 一 预设值以及将全局控制开关设置为关闭状态， 使得所述线程不新增处理任务， 并继续连接 所述数据库处 理所述任务； 监控所述线程的执行状态， 响应于执行状态为执行完成、 或在达到预设等待时长时执 行状态为未完成， 断开所述线程与所述数据库的连接并释放分布式锁， 以执行对所述设备 的停机操作。 2.根据权利要求1所述的方法， 其特征在于， 所述预设等待时长通过预设停机等待次数 和预设停机等待时间 间隔确定， 所述 监控所述线程的执 行状态， 包括： 基于预设停机等待次数、 预设停机等待时间 间隔和当前时间点， 创建多个监控时间点； 响应于达到第一个监控时间点， 获取所述任务当前的执行状态， 若执行状态为执行完 成则停止， 否则继续 监控直至执 行状态为执 行完成或达到最后一个监控时间点停止； 在获取到所述任务的执 行状态为执 行完成的情况 下， 确定所述线程执 行完成； 或 在最后一个监控时间点获取到所述任务的执行状态为执行中的情况下， 确定所述线程 在达到所述预设等待时长时未 执行完成。 3.根据权利要求2所述的方法， 其特征在于， 所述基于预设停机等待次数、 预设停机等 待时间间隔和当前时间点， 创建多个监控时间点， 包括： 以当前时间点为起点、 与第 一个停机等待次数对应的第 一预设停机等待时间间隔为步 长， 创建第一个监控时间点； 以所述第一个监控时间点为起点、 与第 二个停机等待次数对应的第 二预设停机等待时 间间隔为步长， 创建第二个监控时间点； 重复上述确定起 点和步长操作， 得到所述预设停机等待次数个监控时间点。 4.根据权利要求1 ‑3中任一项所述的方法， 其特征在于， 所述全局控制开关为全局分发 控制开关， 所述全局分发控制开关用以控制任务的分发； 所述线程 为巡检线程， 用以将任务从高频调度装置分发到中间件。 5.根据权利要求1 ‑3中任一项所述的方法， 其特征在于， 所述全局控制开关为全局消费 控制开关， 所述全局 消费控制开关用以控制中间件中任务的消费； 所述线程 为消息消费线程， 用以消费所述中间件中的任务。 6.根据权利要求1所述的方法， 其特征在于， 在所述执行对所述设备的停机操作之后， 还包括： 接收对设备的重启指令， 调用启动检查器， 以加载设备停机前执行状态为执行中的任 务； 其中， 所述启动检查器仅在设备启动时执 行且只执 行一次； 确定所述任务当前所处节点， 调用与所述节点对应的重启处理程序， 以对所述任务进 行再处理， 在处理完毕后将所述任务的执 行状态更新 为执行完成。 7.根据权利要求6所述的方法， 其特征在于， 在所述接收对设备的重启指令之后， 还包 括： 将所述执行代码中的所述优雅停机标志设置为第 二预设值， 以及将所述全局控制开关权　利　要　求　书 1/4 页 2 CN 115437766 A 2设置为开启状态。 8.根据权利要求6或7所述的方法， 其特征在于， 所述任务包括预处理执行中的主任务、 处理执行中的子任务、 后处 理执行中的主任务中的至少一种， 主任务被 拆分为多个子任务； 所述调用与所述节点对应的重启处 理程序， 以对所述任务进行 再处理， 包括： 对于预处理执行中的主任务， 做重处理操作， 以重新读取所述主任务中的内容并覆盖 写入数据库中； 对于处理执行中的子任务， 确定断点并续跑； 对于后处理执行中的主任务， 做重处理操作， 以基于对应的多个子任务的执行状态， 重 新生成成功失败清单文件。 9.根据权利要求8所述的方法， 其特征在于， 所述对于处理中的子任务， 确定断点并续 跑， 包括： 获取对所述子任务的处理流水， 确定所述流水的流水号， 发送流水号查询报文给下游 系统， 以接收下游系统返回的所述 流水的执 行状态报文； 响应于所述执 行状态报文为成功或失败， 则将成功或失败写入数据库中； 或 响应于所述执行状态报文为未找到所述流水号， 则确定在 设备关机之前未向下游系统 发出对所述子任务的处理请求报文， 重新发送对所述子任务的处理请求报文给下游系统， 使得下游系统 处理所述子任务。 10.根据权利要求1所述的方法， 其特征在于， 高频调度装置 中配置多个设备， 每个设备 用于处理任务， 所述方法还 包括： 对于异常宕机设备， 若在预设时长内未成功虚拟出与所述异常宕机设备同IP地址的虚 拟设备， 则确定所述异常宕机设备在异常宕机时执 行状态为执 行中的任务； 触发应急命令， 将所述执行状态为执行中的任务， 推送给高频调度装置剩余设备中的 任一个设备进行处 理。 11.一种任务处 理装置， 其特 征在于， 包括： 接收模块， 用于接收对设备的停机指令， 确定当前执行状态为执行中的任务， 查询处理 所述任务的线程， 以获取 所述线程的执 行代码； 处理模块， 用于在所述执行代码中添加对数据库和分布式锁的依赖代码， 将优雅停机 标志设置为第一预设值以及将全局控制开关设置为关闭状态， 使得所述线程不新增处理任 务， 并继续连接所述数据库处 理所述任务； 监控模块， 用于监控所述线程的执行状态， 响应于执行状态为执行完成、 或在达到预设 等待时长时执行状态为未完成， 断开所述线程与所述数据库的连接并释放分布式锁， 以执 行对所述设备的停机操作。 12.根据权利要求11所述的装置， 其特征在于， 所述预设等待时长通过预设停机等待次 数和预设停机等待时间 间隔确定， 所述 监控模块， 用于： 基于预设停机等待次数、 预设停机等待时间 间隔和当前时间点， 创建多个监控时间点； 响应于达到第一个监控时间点， 获取所述任务当前的执行状态， 若执行状态为执行完 成则停止， 否则继续 监控直至执 行状态为执 行完成或达到最后一个监控时间点停止； 在获取到所述任务的执 行状态为执 行完成的情况 下， 确定所述线程执 行完成； 或 在最后一个监控时间点获取到所述任务的执行状态为执行中的情况下， 确定所述线程权　利　要　求　书 2/4 页 3 CN 115437766 A 3