[發(fā)明專利]一種批量調(diào)度系統(tǒng)及方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202211057124.4
• 申請(qǐng)日: 2022-08-30
• 公開（公告）號(hào): CN115391012A
• 公開（公告）日: 2022-11-25
• 發(fā)明（設(shè)計(jì)）人: 彭建業(yè);帥紅波;謝煒琪;吳華東;柯星宇;黃顯超;陳戈;鄧亞麗
• 申請(qǐng)（專利權(quán)）人: 中國銀行股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 付麗

1.一種批量調(diào)度系統(tǒng)，其特征在于，所述系統(tǒng)包括：管理集群服務(wù)模塊、流程調(diào)度服務(wù)模塊、至少一個(gè)作業(yè)調(diào)度服務(wù)模塊、以及調(diào)度客戶端；

所述管理集群服務(wù)模塊，用于獲取產(chǎn)品的流程信息，并基于所述流程信息生成操作請(qǐng)求，向所述流程調(diào)度服務(wù)模塊發(fā)送所述操作請(qǐng)求；

所述流程調(diào)度服務(wù)模塊，用于響應(yīng)所述操作請(qǐng)求，解析所述產(chǎn)品的流程模型，得到所述產(chǎn)品的流程對(duì)應(yīng)的作業(yè)集合，并將所述作業(yè)集合中的作業(yè)發(fā)送給所述產(chǎn)品綁定的作業(yè)調(diào)度服務(wù)模塊；

所述作業(yè)調(diào)度服務(wù)模塊，用于接收所述流程調(diào)度服務(wù)模塊發(fā)送的作業(yè)，將所述作業(yè)放置在作業(yè)隊(duì)列中；響應(yīng)于所述調(diào)度客戶端發(fā)送的作業(yè)消費(fèi)請(qǐng)求，在所述作業(yè)隊(duì)列中查找與所述作業(yè)消費(fèi)請(qǐng)求對(duì)應(yīng)的作業(yè)，并將所述作業(yè)反饋給所述調(diào)度客戶端，以便所述調(diào)度客戶端關(guān)聯(lián)的作業(yè)執(zhí)行流程執(zhí)行所述作業(yè)。

2.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述作業(yè)調(diào)度服務(wù)模塊還用于：

將所述作業(yè)放置在所述作業(yè)隊(duì)列中后，將所述作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)設(shè)置為待執(zhí)行；

將所述作業(yè)反饋給所述調(diào)度客戶端后，將所述作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)設(shè)置為執(zhí)行中；

接收到所述調(diào)度客戶端返回的所述作業(yè)對(duì)應(yīng)的作業(yè)執(zhí)行結(jié)果后，將所述作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)設(shè)置為成功；并向所述流程調(diào)度服務(wù)模塊發(fā)送所述作業(yè)對(duì)應(yīng)的執(zhí)行成功通知信息，以便所述流程調(diào)度服務(wù)模塊向所述作業(yè)調(diào)度服務(wù)模塊發(fā)送所述作業(yè)集合中的下一作業(yè)。

3.根據(jù)權(quán)利要求2所述的系統(tǒng)，其特征在于，所述作業(yè)調(diào)度服務(wù)模塊還用于：

當(dāng)所述作業(yè)為分布式作業(yè)時(shí)，將所述分布式作業(yè)拆分為多個(gè)簡(jiǎn)單作業(yè)，將所述多個(gè)簡(jiǎn)單作業(yè)分別放置在所述作業(yè)隊(duì)列中；

當(dāng)所述多個(gè)簡(jiǎn)單作業(yè)各自對(duì)應(yīng)的作業(yè)狀態(tài)均設(shè)置為執(zhí)行成功時(shí)，向所述流程調(diào)度服務(wù)模塊發(fā)送所述作業(yè)對(duì)應(yīng)的執(zhí)行成功通知信息。

4.根據(jù)權(quán)利要求1或2所述的系統(tǒng)，其特征在于，所述流程調(diào)度服務(wù)模塊還用于：

根據(jù)所述流程對(duì)應(yīng)的作業(yè)集合中作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)，設(shè)置所述流程對(duì)應(yīng)的流程狀態(tài)，向所述管理集群服務(wù)模塊反饋所述流程狀態(tài)。

5.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述系統(tǒng)還包括：定時(shí)集群服務(wù)模塊；

所述定時(shí)集群服務(wù)模塊，用于接收所述管理服務(wù)集群模塊發(fā)送的所述產(chǎn)品的定時(shí)信息，并按照所述定時(shí)信息，向所述流程調(diào)度服務(wù)模塊發(fā)送所述操作請(qǐng)求。

6.一種批量調(diào)度方法，其特征在于，所述方法應(yīng)用于批量調(diào)度系統(tǒng)，所述系統(tǒng)包括：管理集群服務(wù)模塊、流程調(diào)度服務(wù)模塊、至少一個(gè)作業(yè)調(diào)度服務(wù)模塊、以及調(diào)度客戶端；所述方法包括：

所述管理集群服務(wù)模塊獲取產(chǎn)品的流程信息，并基于所述流程信息生成操作請(qǐng)求，向所述流程調(diào)度服務(wù)模塊發(fā)送所述操作請(qǐng)求；

所述流程調(diào)度服務(wù)模塊響應(yīng)所述操作請(qǐng)求，解析所述產(chǎn)品的流程模型，得到所述產(chǎn)品的流程對(duì)應(yīng)的作業(yè)集合，并將所述作業(yè)集合中的作業(yè)發(fā)送給所述產(chǎn)品綁定的作業(yè)調(diào)度服務(wù)模塊；

所述作業(yè)調(diào)度服務(wù)模塊接收所述流程調(diào)度服務(wù)模塊發(fā)送的作業(yè)，將所述作業(yè)放置在作業(yè)隊(duì)列中；響應(yīng)于所述調(diào)度客戶端發(fā)送的作業(yè)消費(fèi)請(qǐng)求，在所述作業(yè)隊(duì)列中查找與所述作業(yè)消費(fèi)請(qǐng)求對(duì)應(yīng)的作業(yè)，并將所述作業(yè)反饋給所述調(diào)度客戶端，以便所述調(diào)度客戶端關(guān)聯(lián)的作業(yè)執(zhí)行流程執(zhí)行所述作業(yè)。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述方法還包括：

所述作業(yè)調(diào)度服務(wù)模塊將所述作業(yè)放置在所述作業(yè)隊(duì)列中后，將所述作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)設(shè)置為待執(zhí)行；

所述作業(yè)調(diào)度服務(wù)模塊將所述作業(yè)反饋給所述調(diào)度客戶端后，將所述作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)設(shè)置為執(zhí)行中；

所述作業(yè)調(diào)度服務(wù)模塊接收到所述調(diào)度客戶端返回的所述作業(yè)對(duì)應(yīng)的作業(yè)執(zhí)行結(jié)果后，將所述作業(yè)對(duì)應(yīng)的作業(yè)狀態(tài)設(shè)置為執(zhí)行成功；并向所述流程調(diào)度服務(wù)模塊發(fā)送所述作業(yè)對(duì)應(yīng)的執(zhí)行成功通知信息，以便所述流程調(diào)度服務(wù)模塊向所述作業(yè)調(diào)度服務(wù)模塊發(fā)送所述作業(yè)集合中的下一作業(yè)。