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

有效

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

1.一種分布式批量框架通訊系統，其特征在于，所述系統包含：分布式批量控制器、分布式通訊服務器集群和分布式批量執行器集群；

所述分布式通訊服務器集群用于構建作業消息目錄和消息處理目錄，通過所述作業消息目錄存放接收到的批量作業信息，通過所述消息處理目錄存放接收到的處理結果；

所述分布式批量控制器用于監聽所述作業消息目錄獲取批量作業信息，根據所述批量作業信息 中的各作業信息的作業名和預存排程信息分析獲得執行所述作業名的分布式批量執行器信息；根據所述分布式批量執行器信息和作業信息于所述分布式通訊服務器集群中建立監聽子節點；以及，監聽所述消息處理目錄，根據所述消息處理目錄中的處理結果刪除對應的批量作業信息；

所述分布式批量執行器集群包含多個分布式批量執行器，所述分布式批量執行器用于監聽所述監聽子節點獲得對應的作業信息，并調用對應的作業邏輯代碼對所述作業信息執行作業處理，將處理結果存放至所述消息處理目錄。

2.根據權利要求1所述的分布式批量框架通訊系統，其特征在于，所述分布式批量控制器包含控制器注冊模塊、解析消息模塊、刪除消息模塊、批量調度模塊、發送指令模塊和執行器管理模塊；

所述控制器注冊模塊用于監聽所述作業消息目錄和所述消息處理目錄，當所述作業消息目錄新增批量作業信息時，獲取新增的批量作業信息；

所述解析消息模塊用于根據預設消息格式解析所述批量作業信息獲得多個作業信息及對應的批量作業名、日期、場次號信息；

所述批量調度模塊用于根據所述批量作業信息 中的各作業信息的作業名和預存排程信息分析獲得執行所述作業名的分布式批量執行器信息；

所述發送指令模塊用于根據所述作業信息、批量作業名、日期、場次號信息及預設指令格式拼接生成指令字符串，根據所述指令字符串和所述分布式批量執行器信息于所述分布式通訊服務器集群中建立監聽子節點；

所述刪除消息模塊用于根據所述消息處理目錄中的處理結果刪除對應的批量作業信息；

所述執行器管理模塊用于監聽所述監聽子節點的刪除情況，根據所述刪除情況獲取所述作業消息目錄中對應的下線監聽子節點，通過下線監聽子節點獲得對應的作業信息，將所述作業信息的作業名提供至所述批量調度模塊。

3.根據權利要求2所述的分布式批量框架通訊系統，其特征在于，所述分布式批量執行器包含執行器注冊模塊、指令解析模塊、指令刪除模塊、作業執行模塊和發送消息模塊；

所述執行器注冊模塊用于監聽所述監聽子節點獲取所述指令字符串；

所述指令解析模塊用于解析所述指令字符串獲得批量作業名、日期、場次號信息和指令類型；

所述指令刪除模塊用于根據處理結果刪除對應的監聽子節點；

所述作業執行模塊用于根據所述指令類型調用對應的作業邏輯代碼對所述作業信息執行作業處理，生成處理結果；

所述發送消息模塊用于根據所述處理結果和所述作業信息，通過預設消息格式組裝消息字符串，根據所述消息字符串在所述作業消息目錄中建立下線監聽子節點。

4.根據權利要求1所述的分布式批量框架通訊系統，其特征在于，所述系統還包含批量調度控制臺，所述批量調度控制臺用于遍歷所述分布式通訊服務器集群內的所有監聽子節點，解析所述監聽子節點獲得作業信息對應的作業名并顯示輸出；以及，獲取所述作業消息目錄中所述批量作業信息，解析獲得所述批量作業信息內所有作業信息的作業名并顯示輸出。

5.根據權利要求4所述的分布式批量框架通訊系統，其特征在于，所述批量調度控制臺包含指令查看模塊和消息查看模塊；

所述指令查看模塊用于遍歷所述分布式通訊服務器集群內的所有監聽子節點，解析所述監聽子節點獲得作業信息對應的作業名并顯示輸出；

所述消息查看模塊用于獲取所述作業消息目錄中所述批量作業信息，解析獲得所述批量作業信息內所有作業信息的作業名并顯示輸出。

6.根據權利要求1至5中任一項所述的分布式批量框架通訊系統，其特征在于，所述分布式通訊服務器集群包含多臺zookeeper服務器，通過所述zookeeper服務器構建作業消息目錄和消息處理目錄，通過所述作業消息目錄存放接收到的批量作業信息，通過所述消息處理目錄存放接收到的處理結果。