(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211271946.2 (22)申请日 2022.10.18 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 阎钢　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 郝博　陶海萍 (51)Int.Cl. G06Q 40/02(2012.01) G06F 9/50(2006.01) G06F 9/48(2006.01) (54)发明名称 分布式工作流调度系统及方法 (57)摘要 本发明提供了一种分布式工作流调度系统 及方法， 应用于分布式技术领域， 该系统包括： 至 少一个工作节 点， 用于向注册节 点发送服务接口 注册指令， 向管控节点提交工作流任务， 接收管 控节点分配的子任务并执行； 注册节点， 用于在 接收到服务接口注册指令后， 注册工作节点的服 务接口， 并将注册的工作节点的服务接口信息发 送至管控节点； 管控节点， 用于接收工作节点的 服务接口信息； 接收至少一个工作节 点的工作流 任务， 确定执行每个子任务的工作节点， 并将该 子任务通过该工作节点的服务接口发送至该工 作节点； 在获得工作流任务的执行结果后通过该 工作流任务对应的工作节点的服务接口进行反 馈。 本发明可 以实现分布式工作流调度， 提升复 杂业务的处理速度。 权利要求书3页 说明书6页 附图4页 CN 115511610 A 2022.12.23 CN 115511610 A 1.一种分布式工作流调度系统， 其特 征在于， 包括： 至少一个工作节点， 用于向注册节点发送服务接口注册指令， 向管控节点提交工作流 任务， 接收管控节点分配的子任务并执 行； 注册节点， 用于在接收到工作节点的服务接口注册指令后， 注册工作节点的服务接口， 并将注册的工作节点的服 务接口信息发送至管控节点； 管控节点， 用于接收工作节点的服务接口信 息； 接收至少一个工作节点的工作流任务， 根据所有工作流任务中子任务的执行顺序和执行状态， 确定执行每个子任务的工作节点， 并将该子任务通过该工作 节点的服务接口发送至该工作 节点； 在获得工作流任务的执行结 果后通过 该工作流任务对应的工作节点的服 务接口进行反馈 。 2.如权利要求1所述的系统， 其特 征在于， 管控节点包括： 管理模块， 用于对工作流任务进行子任务拆分， 并管理所有子任务的执行状态和执行 进度； 决策模块， 用于根据所有工作流任务中子任务的执行顺序和执行状态， 确定执行每个 子任务的工作节点； 通信模块， 用于与注册节点和工作节点进行通信， 接收工作节点的服务接口信 息； 接收 至少一个工作节点的工作流任务； 将子任务通过工作节点的服务接口发送至工作节点； 将 工作流任务的执 行结果通过工作流任务对应的工作节点的服 务接口进行反馈； 执行模块， 用于根据子任务的执行顺序和执行状态， 通过通信模块将当前需要执行的 子任务发送至该子任务对应的工作节点； 在接 收到所述对应的工作节点反馈的执行结果， 记录该子任务的执 行状态， 确定下一个需要执 行的子任务。 3.如权利要求2所述的系统， 其特 征在于， 工作节点还用于： 定期向管控节点发送系统信息， 所述系统信 息包括cpu利用率、 网络连接数及内存利用 率中的其中一种或任意组合 管控节点还 包括系统信息收集模块， 用于通过通信模块采集注 册节点的系统信息； 决策模块还用于： 根据所有工作流任务中子任务的执行顺序和执行状态， 以及注册节 点的系统信息， 确定执 行每个子任务的工作节点。 4.如权利要求3所述的系统， 其特征在于， 管控节点还包括存储模块， 用于存储系统信 息、 工作节点的服 务接口信息、 子任务的执 行顺序和执 行状态。 5.如权利要求2所述的系统， 其特征在于， 管控节点还包括web界面模块， 用于展示工作 流任务的执 行情况及进度。 6.如权利要求2所述的系统， 其特征在于， web界面模块还用于： 接收用户的点击操作指 令， 所述点击操作指令包括子任务取消指令、 子任务触发指令或子任务重新执 行指令； 通信模块还用于： 在点击操作指令为子任务取消指令时， 向执行该子任务的工作节点 发送该子任务停止指令； 在点击操作指令为子任务触发指令时， 向执行该子任务的工作节 点发送该子任务启动指令； 在点击操作指令为子任务重新执行指令时， 向执行该子任务的 工作节点发送该子任务重新启动指令 。 7.如权利要求1所述的系统， 其特征在于， 管控节点还包括工作节点状态管理模块， 用 于： 通过心跳 机制监测工作节点的状态， 在工作节点的状态 异常时， 生成提醒信息 。 8.如权利要求1所述的系统， 其特 征在于， 所述管控节点 集成工作流引擎。权　利　要　求　书 1/3 页 2 CN 115511610 A 29.如权利要求1所述的系统， 其特 征在于， 注 册中心为zo okeeper。 10.如权利要求1所述的系统， 其特征在于， 注册中心在工作节点的服务接口有变化 时， 通知到管控 模块进行服 务接口信息的更新。 11.一种分布式工作流调度方法， 其特 征在于， 包括： 接收工作节点的服务接口信息， 其中， 工作节点的服务接口信息是注册中心在接收到 工作节点的服 务接口注 册指令后， 注 册工作节点的服 务接口后发送的； 接收至少一个工作节点的工作流任务； 根据所有工作流任务中子任务的执行顺序和执行状态， 确定执行每个子任务的工作节 点； 将该子任务通过该工作节点的服务接口发送至该工作节点， 其中， 该工作节点接收到 该子任务后进行 执行； 在获得工作流任务的执行结果后， 通过该工作流任务对应的工作节点的服务接口进行 反馈。 12.如权利要求11所述的方法， 其特征在于， 在接收至少一个工作节点的工作流任务之 后， 还包括： 对工作流任务进行子任务拆分， 并管理所有子任务的执 行状态和执 行进度； 在将该子任务 通过该工作节点的服 务接口发送至该工作节点之后， 还 包括： 在接收到所述对应的工作节点反馈的执行结果， 记录该子任务的执行状态， 确定下一 个需要执 行的子任务。 13.如权利要求12所述的方法， 其特 征在于， 还 包括： 定期采集注册节点的系统信息， 所述系统信 息包括cpu利用率、 网络连接数及内存利用 率中的其中一种或任意组合； 根据所有工作流任务中子任务的执行顺序和执行状态， 确定执行每个子任务的工作节 点， 包括： 根据所有工作流任务中子任务的执行顺序和执行状态， 以及注册节点的系统信息， 确 定执行每个子任务的工作节点。 14.如权利要求13所述的方法， 其特 征在于， 还 包括： 存储系统信息、 工作节点的服 务接口信息、 子任务的执 行顺序和执 行状态。 15.如权利要求12所述的方法， 其特征在于， 还包括： 展示工作流任务的执行情况及进 度。 16.如权利要求12所述的方法， 其特 征在于， 还 包括： 接收用户的点击操作指令， 所述点击操作指令包括子任务取消指令、 子任务触发指令 或子任务重新执 行指令； 在点击操作指令为子任务取消指令时， 向执行该子任务的工作节点发送该子任务停止 指令； 在点击操作指令为子任务触发指令时， 向执行该子任务的工作节点发送该子任务启 动指令； 在点击操作指令为子任务重新执行指令时， 向执行该子任务的工作节点发送该子 任务重新启动指令 。 17.如权利要求1 1所述的方法， 其特 征在于， 还 包括： 通过心跳 机制监测工作节点的状态， 在工作节点的状态 异常时， 生成提醒信息 。权　利　要　求　书 2/3 页 3 CN 115511610 A 3