[發明專利]應用于集群處理的數據通信方法、裝置及存儲介質

有效

• 申請號: 202010886007.3
• 申請日: 2020-08-28
• 公開（公告）號: CN112162868B
• 公開（公告）日: 2022-05-13
• 發明（設計）人: 肖京;王江林;肖浩威;劉國光;黃海鋒;閆志愿;郝志剛;劉星
• 申請（專利權）人: 廣州南方衛星導航儀器有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 廣州市越秀區哲力專利商標事務所(普通合伙) 44288
• 代理人: 王忠浩

本發明公開了應用于集群處理的數據通信方法，數據通信方法應用于通信組件，通信組件包括Redis服務模塊、ActiveMQ模塊和Zookeeper模塊；通過通信組件中的Zookeeper模塊、ActiveMQ模塊可實現源服務主機與目標服務主機之間的建立連接，然后通過ActiveMQ模塊創建的數據發送消息隊列和數據接收消息隊列以及Redis服務模塊創建的接收數據的通道實現數據通信，實現了集群處理系統中數據的及時通信，解決了現有技術中的集群處理系統中數據處理存在較大延遲等問題。本發明還提供了應用于集群處理的數據通信裝置及存儲介質。

技術領域

本發明涉及集群處理系統的消息中間件，尤其涉及應用于集群處理的數據通信方法、裝置及存儲介質。

背景技術

一般來說，在集群數據處理系統中，一般是通過消息中間件來實現數據的通信。但是，現有市面上存在的消息中間件，一般是通過對所有設備的消息進行集中處理，然后將處理后的消息派發給各個客戶端。這種消息中間件的處理方式優點在于集中處理、易于管理，但是其數據處理存在明顯的延遲。特別是在復雜網絡環境數據不好交互，處理數據的延遲就更明顯，比如數據交換間的設備存在防火墻、局域網部分設備只能互通而無法與其他設備通訊的情況下時，數據延遲很嚴重。

發明內容

為了克服現有技術的不足，本發明的目的之一在于提供應用于集群處理的數據通信方法，其能夠解決現有技術中集群處理系統通過消息中間進行數據處理時存在較大延遲等問題。

本發明的目的之二在于提供應用于集群處理的數據通信裝置，其能夠解決現有技術中集群處理系統通過消息中間進行數據處理時存在較大延遲等問題。

本發明的目的之三在于提供一種存儲介質，其能夠解決現有技術中集群處理系統通過消息中間進行數據處理時存在較大延遲等問題。

本發明的目的之一采用如下技術方案實現：

應用于集群處理的數據通信方法，所述數據通信方法應用于通信組件，所述通信組件包括Redis服務模塊、ActiveMQ模塊和Zookeeper模塊；其中，Zookeeper模塊用于注冊登記每個服務主機的登記信息；ActiveMQ模塊用于創建數據發送消息隊列和數據接收消息隊列；其中，數據發送消息隊列、數據接收消息隊列分別用于存儲發送的數據和接收的數據；Redis服務模塊用于創建數據接收的通道；所述數據通信方法包括：

注冊步驟：當通信組件啟動時，根據系統配置信息將每個服務主機的登記信息注冊登記到Zookeeper模塊中；所述登記信息包括服務主機的本機IP信息、服務名稱和服務端口；

創建隊列步驟：根據源服務主機的登記信息得出源服務主機的服務名稱，并將源服務主機登記注冊到ActiveMQ模塊中，從而創建源服務主機的數據發送消息隊列和數據接收隊列，用于存儲源服務主機發送的數據以及接收的數據；

服務注冊步驟：將所述源服務主機的服務名稱登記注冊到Redis服務模塊中，并根據根據Redis服務模塊以及所述源服務主機的服務端口創建數據接收的通道；

判斷步驟：通過Zookeeper模塊查詢目標服務主機是否存在，若存在，則執行連接建立步驟；

請求步驟：根據目標服務主機的登記信息通過ActiveMQ向目標服務主機發送請求建立連接的通知；

連接步驟：當系統接收到目標服務主機返回的確認通知后，在源服務主機與目標服務主機之間建立TCP連接；

數據通信步驟：將源服務主機發送的數據存儲數據發送消息隊列中，以便通過所述TCP連接將數據發送到目標服務主機；通過TCP連接，將源服務主機接收的數據存儲數據接收消息隊列中，并通過對應的數據接收的通道發送給源服務主機。

進一步地，所述判斷步驟包括：通過查詢目標服務主機的服務名稱是否注冊登記到Zookeeper模塊中判斷目標服務主機是否存在。