[發明專利]一種批量調度系統及方法

在審

• 申請號: 202211057124.4
• 申請日: 2022-08-30
• 公開（公告）號: CN115391012A
• 公開（公告）日: 2022-11-25
• 發明（設計）人: 彭建業;帥紅波;謝煒琪;吳華東;柯星宇;黃顯超;陳戈;鄧亞麗
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 付麗

本申請公開了一種批量調度系統及方法，可應用于云計算領域或金融領域。該系統包括：管理集群服務模塊用于獲取產品的流程信息，基于流程信息生成操作請求，向流程調度服務模塊發送操作請求；流程調度服務模塊用于響應該操作請求，解析產品的流程模型，得到產品流程對應的作業集合，將作業集合中的作業發送給產品綁定的作業調度服務模塊；作業調度服務模塊用于接收流程調度服務模塊發送的作業，將作業放置在作業隊列中；響應于調度客戶端發送的作業消費請求，在作業隊列中查找與該作業消費請求對應的作業，將該作業反饋給調度客戶端。該系統能夠解決現有的批量調度系統存在的性能下降的問題，實現調度能力的動態擴展。

技術領域

本申請涉及計算機技術領域，具體涉及一種批量調度系統及方法。

背景技術

現有的批量調度系統，將所有使用產品的批量流程和批量作業的解析、執行、監控等調度功能全部集中于調度服務架構中。隨著使用調度的產品越來越多(通常達到幾百甚至上千個)，產品的流程將達到上萬級別，所包括的作業數量達到百萬級別，加上執行時由分布式作業拆分出的簡單作業，調度系統每天所需執行的作業的數量達到千萬甚至億級別。

在現有的批量調度系統下，所有產品流程和作業的調度均集中在一個調度集群中彼此影響，當數據量較大時，調度系統的性能將會下降，當產品數量和產品流程數量達到一定量級后，此類調度系統將無法滿足百萬、千萬、甚至億級別的流程和作業的調度，調度能力無法因接入產品的增加而橫向擴展。

發明內容

本申請實施例提供了一種批量調度系統及方法，能夠解決現有的批量調度系統中因產品流程和作業數據量龐大而導致的性能下降的問題，并且能夠實現調度能力的動態擴展。

有鑒于此，本申請第一方面提供了一種批量調度系統，所述系統包括：管理集群服務模塊、流程調度服務模塊、至少一個作業調度服務模塊、以及調度客戶端；

所述管理集群服務模塊，用于獲取產品的流程信息，并基于所述流程信息生成操作請求，向所述流程調度服務模塊發送所述操作請求；

所述流程調度服務模塊，用于響應所述操作請求，解析所述產品的流程模型，得到所述產品的流程對應的作業集合，并將所述作業集合中的作業發送給所述產品綁定的作業調度服務模塊；

所述作業調度服務模塊，用于接收所述流程調度服務模塊發送的作業，將所述作業放置在作業隊列中；響應于所述調度客戶端發送的作業消費請求，在所述作業隊列中查找與所述作業消費請求對應的作業，并將所述作業反饋給所述調度客戶端，以便所述調度客戶端關聯的作業執行流程執行所述作業。

可選的，所述作業調度服務模塊還用于：

將所述作業放置在所述作業隊列中后，將所述作業對應的作業狀態設置為待執行；

將所述作業反饋給所述調度客戶端后，將所述作業對應的作業狀態設置為執行中；

接收到所述調度客戶端返回的所述作業對應的作業執行結果后，將所述作業對應的作業狀態設置為成功；并向所述流程調度服務模塊發送所述作業對應的執行成功通知信息，以便所述流程調度服務模塊向所述作業調度服務模塊發送所述作業集合中的下一作業。

可選的，所述作業調度服務模塊還用于：

當所述作業為分布式作業時，將所述分布式作業拆分為多個簡單作業，將所述多個簡單作業分別放置在所述作業隊列中；

當所述多個簡單作業各自對應的作業狀態均設置為執行成功時，向所述流程調度服務模塊發送所述作業對應的執行成功通知信息。

可選的，所述流程調度服務模塊還用于：

根據所述流程對應的作業集合中作業對應的作業狀態，設置所述流程對應的流程狀態，向所述管理集群服務模塊反饋所述流程狀態。

可選的，所述系統還包括：定時集群服務模塊；