(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210895439.X (22)申请日 2022.07.26 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 黄子卿　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 马小青 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) (54)发明名称 一种基于数据库的批处理作业的处理方法 及装置 (57)摘要 本申请提供了一种基于数据库的批处理作 业的处理方法及装置， 可应用于计算机技术领域 或金融领域。 在执行所述方法时， 先将批处理作 业信息录入 数据库； 然后根据数据库数据计算各 应用节点处理批处理作业的概率； 最后将所述批 处理作业分发给概率最大的应用节点处理所述 批处理作业。 这样， 通过根据数据库数据计算出 各应用节 点处理批处理作业的概率， 然后将批处 理作业分发给概率最大的应用节 点执行， 相比于 现有技术中集群新增节点时需要将定时任务进 行重启， 会导致任务中断， 本申请的方案中无需 重启定时任务， 进 而避免了任务中断。 权利要求书2页 说明书7页 附图4页 CN 115168496 A 2022.10.11 CN 115168496 A 1.一种基于数据库的批处 理作业的处 理方法， 其特 征在于， 所述方法包括： 将批处理作业信息 录入数据库； 根据数据库数据计算各应用节点处 理批处理作业的概 率； 将所述批处 理作业分发给概 率最大的应用节点处 理所述批处 理作业。 2.根据权利要求1所述的方法， 其特征在于， 所述根据数据库 数据计算各应用节点处理 批处理作业的概 率， 具体包括： 根据数据库数据， 利用预设公式计算各应用节点处理批处理作业的概率； 所述预设公 式为： (1‑应用节点当前运行作业数/各应用节点当前运行作业数总和)*0.5+(1 ‑应用节点总 作业数/各应用节点总作业数总和)* 0.5。 3.根据权利要求1所述的方法， 其特征在于， 在所述根据 数据库数据计算各应用节点处 理批处理作业的概 率之前， 所述方法还 包括： 通过乐观锁机制确定领导者； 所述领导者用于计算各应用节点处理批处理作业的概 率。 4.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 根据所述批处 理作业的状态更新所述数据库。 5.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 对待处理 的批处理作业进行排序； 录入所述数据库的时间早的批处理作业的处理顺序 早于录入所述数据库的时间晚的批处 理作业。 6.一种基于数据库的批处理作业的处理装置， 其特征在于， 所述装置包括： 录入模块、 计算模块和发送模块； 所述录入 模块， 用于将批处 理作业信息 录入数据库； 所述计算模块， 用于根据数据库数据计算各应用节点处 理批处理作业的概 率； 所述发送模块， 用于将所述批处理作业分发给概率最大的应用节点处理所述批处理作 业。 7.根据权利要求6所述的装置， 其特 征在于， 所述计算模块， 具体用于： 根据数据库数据， 利用预设公式计算各应用节点处理批处理作业的概率； 所述预设公 式为： (1‑应用节点当前运行作业数/各应用节点当前运行作业数总和)*0.5+(1 ‑应用节点总 作业数/各应用节点总作业数总和)* 0.5。 8.根据权利要求6所述的装置， 其特征在于， 所述装置还包括确定模块， 所述确定模块 具体用于： 通过乐观锁机制确定领导者； 所述领导者用于计算各应用节点处理批处理作业的概 率。 9.根据权利要求6所述的装置， 其特征在于， 所述装置还包括更新模块， 所述更新模块 具体用于： 根据所述批处 理作业的状态更新所述数据库。 10.根据权利要求6所述的装置， 其特征在于， 所述装置还包括排序模块， 所述排序模块 具体用于：权　利　要　求　书 1/2 页 2 CN 115168496 A 2对待处理 的批处理作业进行排序； 录入所述数据库的时间早的批处理作业的处理顺序 早于录入所述数据库的时间晚的批处 理作业。权　利　要　求　书 2/2 页 3 CN 115168496 A 3