[發明專利]一種分布式批量框架通訊系統及方法

有效

• 申請號: 202110250368.3
• 申請日: 2021-03-08
• 公開（公告）號: CN113037839B
• 公開（公告）日: 2022-11-29
• 發明（設計）人: 何啟承;鄭思慧;丘威;林嘉婷
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L67/10
• 分類號: H04L67/10;H04L67/60
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 任默聞;王濤

一種分布式批量框架通訊系統及方法，涉及計算機應用系統領域，可用于金融領域和其他領域，所述系統包含：分布式通訊服務器集群構建作業消息目錄和消息處理目錄；分布式批量控制器監聽作業消息目錄獲取批量作業信息，根據批量作業消息中的各作業信息的作業名和預存排程信息分析獲得執行作業名的分布式批量執行器信息；根據分布式批量執行器信息和作業信息于分布式通訊服務器集群中建立監聽子節點；根據消息處理目錄中的處理結果刪除對應的批量作業信息；分布式批量執行器集群包含多個分布式批量執行器，分布式批量執行器獲得對應的作業信息，并調用對應的作業邏輯代碼對作業信息執行作業處理，將處理結果存放至消息處理目錄。

技術領域

本發明涉及計算機應用系統技術領域，可應用于金融領域和其他領域，尤指一種分布式批量框架通訊系統及方法。

背景技術

當前技術中，很多應用都使用了分布式批量框架，即為平臺應用批量開發的一種框架，主要實現功能：批量作業按時開啟(傳統批量由Entegor控制)，實現批量內部各作業步之間的調度，控制臺對批量進行可視化控制(傳統批量由Entegor控制)，調度執行器執行作業邏輯。針對該框架，還存在以下問題：指令傳輸單向性，無法回傳調度，其次針對分布式構架通信過程中，指令發送較為復雜無法批量高效調度。

發明內容

本發明目的在于提供一種分布式批量框架通訊系統及方法，予以克服現有技術中分布式批量框架通訊負載，調度繁瑣的問題。

為達上述目的，本發明所提供的分布式批量框架通訊系統，具體包含：分布式批量控制器、分布式通訊服務器集群和分布式批量執行器集群；所述分布式通訊服務器集群用于構建作業消息目錄和消息處理目錄，通過所述作業消息目錄存放接收到的批量作業信息，通過所述消息處理目錄存放接收到的處理結果；所述分布式批量控制器用于監聽所述作業消息目錄獲取批量作業信息，根據所述批量作業消息中的各作業信息的作業名和預存排程信息分析獲得執行所述作業名的分布式批量執行器信息；根據所述分布式批量執行器信息和作業信息于所述分布式通訊服務器集群中建立監聽子節點；以及，監聽所述消息處理目錄，根據所述消息處理目錄中的處理結果刪除對應的批量作業信息；所述分布式批量執行器集群包含多個分布式批量執行器，所述分布式批量執行器用于監聽所述監聽子節點獲得對應的作業信息，并調用對應的作業邏輯代碼對所述作業信息執行作業處理，將處理結果存放至所述消息處理目錄。

在上述分布式批量框架通訊系統中，優選的，所述分布式批量控制器包含控制器注冊模塊、解析消息模塊、刪除消息模塊、批量調度模塊、發送指令模塊和執行器管理模塊；所述控制器注冊模塊用于監聽所述作業消息目錄和所述消息處理目錄，當所述作業消息目錄新增批量作業信息時，獲取新增的批量作業信息；所述解析消息模塊用于根據預設消息格式解析所述批量作業信息獲得多個作業信息及對應的批量作業名、日期、場次號信息；所述批量調度模塊用于根據所述批量作業消息中的各作業信息的作業名和預存排程信息分析獲得執行所述作業名的分布式批量執行器信息；所述發送指令模塊用于根據所述作業信息、批量作業名、日期、場次號信息及預設指令格式拼接生成指令字符串，根據所述指令字符串和所述分布式批量執行器信息于所述分布式通訊服務器集群中建立監聽子節點；所述刪除消息模塊用于根據所述消息處理目錄中的處理結果刪除對應的批量作業信息；所述執行器管理模塊用于監聽所述監聽子節點的刪除情況，根據所述刪除情況獲取所述作業消息目錄中對應的下線監聽子節點，通過下線監聽子節點獲得對應的作業信息，將所述作業信息的作業名提供至所述批量調度模塊。

在上述分布式批量框架通訊系統中，優選的，所述分布式批量執行器包含執行器注冊模塊、指令解析模塊、指令刪除模塊、作業執行模塊和發送消息模塊；所述執行器注冊模塊用于監聽所述監聽子節點獲取所述指令字符串；所述指令解析模塊用于解析所述指令字符串獲得批量作業名、日期、場次號信息和指令類型；所述指令刪除模塊用于根據處理結果刪除對應的監聽子節點；所述作業執行模塊用于根據所述指令類型調用對應的作業邏輯代碼對所述作業信息執行作業處理，生成處理結果；所述發送消息模塊用于根據所述處理結果和所述作業信息，通過預設消息格式組裝消息字符串，根據所述消息字符串在所述作業消息目錄中建立下線監聽子節點。