[發明專利]一種系統間消息通信的方法、設備、存儲介質

在審

• 申請號: 202010300915.X
• 申請日: 2020-04-16
• 公開（公告）號: CN111541667A
• 公開（公告）日: 2020-08-14
• 發明（設計）人: 沈漢標;王妙玉;童威云;吳寧泉;王倫
• 申請（專利權）人: 廣東好太太科技集團股份有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L29/08
• 代理公司: 廣州市越秀區哲力專利商標事務所(普通合伙) 44288
• 代理人: 畢曉萌

1.一種系統間消息通信的方法，其特征在于，

建立分布式框架，所述分布式框架包括服務器與客戶端；

建立通信協議，根據所述通信協議管理消息隊列；所述消息隊列通過安全網關接收所述服務器與客戶端的消息，實現系統間的消息通信；

所述消息隊列包括消息生產者、消息消費者與消息處理中心，所述消息生產者發布消息，并將消息發送至消息處理中心；

消息處理中心接收并保存所述消息生產者發送的消息，將所述消息轉發至消息消費者；

消息消費者訂閱所述消息處理中心的消息，并進行處理。

2.如權利要求1所述的一種系統間消息通信的方法，其特征在于，所述消息處理中心內將消息以文件組的形式保存，且文件組內的單個文件大小相同。

3.如權利要求2所述的一種系統間消息通信的方法，其特征在于，所述文件組內的文件基于消息處理中心接收的時間順序先后排列。

4.如權利要求1所述的一種系統間消息通信的方法，其特征在于，所述消息生產者發布消息，并將消息發送至消息處理中心包括以下步驟：

客戶端的消息生產者產生消息，發出發送消息請求；

服務端接收和處理客戶端的發布請求并返回響應、存儲消息生產者產生的消息；

客戶端接收和處理返回的響應，消息生產者發布消息成功。

5.如權利要求1所述的一種系統間消息通信的方法，其特征在于，消息消費者訂閱所述消息處理中心的消息，并進行處理包括以下步驟：

客戶端的消息消費者發出接收消息請求；

服務端接收和處理客戶端的訂閱請求并返回響應；

客戶端接收和處理來自服務端的消息，消息消費者訂閱消息成功，開始消費消息隊列的消息。

6.如權利要求1所述的一種系統間消息通信的方法，其特征在于，所述分布式框架為分布式應用程序協調框架Zookeeper。

7.如權利要求1所述的一種系統間消息通信的方法，其特征在于，所述客戶端與服務器通過所述安全網關實現消息互通。

8.一種設備，其特征在于，其包括處理器、存儲器及存儲于所述存儲器上并可在所述處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現權利要求1～7任一所述一種系統間消息通信的方法。

9.一種存儲介質，其特征在于，其上存儲有計算機程序，所述計算機程序被執行時實現權利要求1～7任一所述一種系統間消息通信的方法。