(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211329898.8 (22)申请日 2022.10.27 (71)申请人 北京慧友云商科技有限公司 地址 100000 北京市海淀区西直门北 大街 甲43号1号楼1层10 3A房间 (72)发明人 相飞　王鑫　王桐　邓丘　高航　 梁林娜　 (74)专利代理 机构 北京竟易和专利代理事务所 (特殊普通 合伙) 1610 3 专利代理师 李欣迎 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/48(2006.01) G06F 16/2455(2019.01) (54)发明名称 一种可定制化流程的分布式异步任务处理 方法及系统 (57)摘要 本发明公开一种可定制化流程的分布式异 步任务处理方法， 包括： 接收各个业务服务发送 的异步任务请求， 匹配业务流模板； 创建对应的 任务实例并持久化等待调度； 根据定义的业务流 模板及任务数据定位调度通道分片， 并将任务发 送至目标业务服务进行异步执行。 本发明还公开 一种可定制化流程的分布式异步任务处理系统。 本发明基于多协议的异步调用通路及提供业务 支撑的流程任务引擎， 实现可定制流程的分布式 异步处理， 将流程定制与异步任务相结合， 实现 了流程化异步调度业务任务及相关的数据、 调用 保障及调度管理。 权利要求书2页 说明书4页 附图1页 CN 115525451 A 2022.12.27 CN 115525451 A 1.一种可定制化 流程的分布式异步任务处 理方法， 其特 征在于， 包括： 接收各个业务服务发送的异步任务请求， 匹配业务流模板， 并将异步任务持久化到缓 存与数据库中； 获取任务， 创建对应的任务实例并持久化 等待调度； 根据定义的业务流模板及任务数据定位调度通道分片， 并将任务发送至目标业务服务 进行异步执 行。 2.根据权利要求1所述的一种可定制化流程的分布式异步任务处理方法， 其特征在于， 该方法之前还包括： 业务流程建模； 所述业务流程建模的过程包括： 业务系统根据自身业务逻辑定义创建业务流模板， 并 持久化到缓存与数据库中。 3.根据权利要求2所述的一种可定制化流程的分布式异步任务处理方法， 其特征在于， 所述业务流程建模之后还 包括： 异步任务定义； 所述异步任务定义的过程包括： 业务在各自的业务系统中声明任务实现逻辑， 并将任 务声明定义持久化到缓存与数据库中。 4.根据权利要求3所述的一种可定制化流程的分布式异步任务处理方法， 其特征在于， 调度通道支持HTTP异步调用、 消 息队列调用、 Dubbo异步调用， 且可接入第三方异步任务调 度服务。 5.根据权利要求4所述的一种可定制化流程的分布式异步任务处理方法， 其特征在于， 还包括： 业务服务执行任务完毕后， 将结果异步反馈至流程任务引擎， 流程任务引擎根据状态 及模型配置进行 下一步任务流驱动； 监控任务的执 行情况， 依据状态及数据的变化判断是否需要重试、 预警。 6.一种可定制化流程的分布式异步任务处理系统， 其特征在于， 包括： 业务服务、 调度 通道以及流 程任务引擎； 其中， 所述 流程任务引擎包括： 匹配模块， 用于接收各个所述业务服务发送的异步任务请求， 匹配业务流模板， 并将异 步任务持久化到缓存与数据库中； 创建模块， 用于获取任务， 创建对应的任务实例并持久化 等待调度； 集群分片模块， 用于根据定义的业务流模板及任务数据定位调度通道分片， 并将任务 发送至目标业 务服务进行异步执 行。 7.根据权利要求6所述的一种可定制化流程的分布式异步任务处理系统， 其特征在于， 所述流程任务引擎还包括： 业务建模模块， 用于业务系统根据自身业务逻辑定义创建业务 流模板， 并持久化到缓存与数据库中。 8.根据权利要求7所述的一种可定制化流程的分布式异步任务处理系统， 其特征在于， 所述流程任务引擎还包括： 任务定义模块， 用于业务在各自的业务系统中声明任务实现逻 辑， 并将任务声明定义持久化到缓存与数据库中。 9.根据权利要求8所述的一种可定制化流程的分布式异步任务处理系统， 其特征在于， 所述调度通道支持HTTP异步调用、 消息队列调用、 Dubbo异步调用， 且可接入第三方异步任 务调度服 务。 10.根据权利要求9所述的一种可定制化流程的分布式异步任务处理系统， 其特征在权　利　要　求　书 1/2 页 2 CN 115525451 A 2于， 所述流程任务引擎还 包括： 响应模块， 用于当业务服务执行任务完毕后， 接收反馈结果， 并根据状态及模型配置进 行下一步任务流驱动； 监控模块， 用于监控任务的执行情况， 依据状态及数据的变化判断是否需要重试、 预 警。权　利　要　求　书 2/2 页 3 CN 115525451 A 3