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

有效

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

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

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

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

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

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

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

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

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

2.根據權利要求1所述應用于集群處理的數據通信方法，其特征在于，所述判斷步驟包括：通過查詢目標服務主機的服務名稱是否注冊登記到Zookeeper模塊中判斷目標服務主機是否存在。

3.根據權利要求1所述應用于集群處理的數據通信方法，其特征在于，所述連接步驟之后還包括：

斷線步驟：當所述目標服務主機斷線時，通過Zookeeper模塊選擇源服務主機繼續等待所述目標服務主機的連接或斷開源服務主機與目標服務主機之間的連接；

檢測步驟：當選擇繼續等待所述目標服務主機的連接時，定時檢測Zookeeper模塊中各個服務主機的狀態進而判斷所述目標服務主機是否上線，若是，則執行建立連接步驟；

重新連接步驟：建立源服務主機與目標服務主機之間的連接，實現源服務主機與目標服務主機之間的數據通信。

4.根據權利要求3所述應用于集群處理的數據通信方法，其特征在于，所述重新連接步驟還包括：

當源服務主機與目標服務主機之間的TCP連接未斷開時，則源服務主機與目標服務主機通過該TCP連接進行數據通信；

當源服務主機與目標服務主機之間的TCP連接斷開時，通過ActiveMQ向所述目標服務主機發送新的請求建立連接的通知，并當系統接收到目標服務主機返回的確認通知后，在源服務主機與目標服務主機之間建立一條新的TCP連接，實現源服務主機與目標服務主機之間的數據通信。

5.根據權利要求3所述應用于集群處理的數據通信方法，其特征在于，所述檢測步驟包括：根據Zookeeper模塊中的服務主機的變化以及TCP連接的斷開來判斷是否繼續等待該目標服務主機的連接或斷開服務連接。