[發明專利]一種管理消息中間件的方法

在審

• 申請號: 201710772443.6
• 申請日: 2017-08-31
• 公開（公告）號: CN107592215A
• 公開（公告）日: 2018-01-16
• 發明（設計）人: 殷武爍;袁鵬飛
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/08
• 代理公司: 北京集佳知識產權代理有限公司11227
• 代理人: 羅滿

技術領域

本發明涉及通信領域，特別是涉及一種管理消息中間件的方法。

背景技術

現今，越來越多的企業使用分布式集群系統架構，面臨著各種各樣的系統集成和數據整合，因此各種基于面向消息的中間件應運而生，它們主要利用高效可靠的消息傳遞機制進行數據交流，并基于數據通信來進行分布式集群系統的集成。因此，在集群系統傳遞消息的過程中，消息中間件起了至關重要的作用。

現有技術中，通常在一個包含多個服務器和多個客戶端的系統中，選擇一臺服務器安裝消息中間件，作為在服務器和客戶端之間傳遞消息的橋梁。但是由于消息中間件負責連接系統中的所有服務，若消息中間件所在的機器出現軟硬件故障或者網絡故障就會造成消息丟失，因此消息傳輸可靠性難以保證。而且由于消息傳輸量越來越大，消息中間件負載了非常大的工作壓力，使得傳輸效率比較低。

因此，如何保證系統消息傳輸的可靠性，提高消息傳遞效率，是本領域技術人員需要解決的技術問題。

發明內容

本發明的目的是提供一種管理消息中間件的方法，用于保證系統消息傳輸的可靠性，提高消息傳輸效率。

為解決上述技術問題，本發明提供一種管理消息中間件的方法，用于包含多個服務器和多個客戶端的系統中，包括：

實時檢測各個所述消息中間件的運行狀態；

當所述消息中間件出現故障時，將所述出現故障的消息中間件切換至另一個運行正常的消息中間件以完成所述出現故障的消息中間件的所述傳遞任務；

所述消息中間件用于實現所述服務器和所述客戶端之間的待處理消息的傳遞任務。

優選地，還包括：

實時檢測各個所述消息中間件的資源占有率；

當接收到所述待處理消息時，將所述待處理消息發送至資源占有率最低的消息中間件。

優選地，所述將所述出現故障的消息中間件切換至另一個運行正常的消息中間件具體為：

將所述出現故障的消息中間件切換至資源占有率最低的所述運行正常的消息中間件。

優選地，所述消息中間件之間采用集群通道進行通信。

優選地，所述消息中間件以隊列的形式處理所述待處理消息。

優選地，所述消息中間件以隊列的形式處理所述待處理消息具體為：

所述消息中間件按所述待處理消息到達所述消息中間件的時間的先后順序，以隊列的形式保存所述待處理消息，并從所述隊列的首端開始處理所述待處理消息。

優選地，所述消息中間件以隊列的形式保存所述待處理消息具體為：

所述消息中間件按所述待處理消息的質量的優劣順序，以隊列的形式保存所述待處理消息，并從所述隊列的首端開始處理所述待處理消息。

優選地，還包括：

保存所述待處理消息和已處理消息。

優選地，所述消息中間件在所述服務器和所述客戶端之間采用發布訂閱的方式傳遞所述待處理消息。

優選地，還包括：

所述服務器或所述客戶端在獲取所述待處理消息后，向所述消息中間件發送已接收的信號。

本發明所提供的管理消息中間件的方法，用于包含多個服務器和多個客戶端的系統中，包括：實時檢測各個消息中間件的運行狀態；當消息中間件出現故障時，將出現故障的消息中間件切換至另一個運行正常的消息中間件以完成出現故障的消息中間件的傳遞任務；其中，消息中間件用于實現服務器和客戶端之間的待處理消息的傳遞任務。對比現有技術中采用一個消息中間件完成傳遞任務，采用多個消息中間件不僅在一個消息中間件出現故障時，可以采用其他的消息中間件完成傳遞任務，還可以分擔傳遞待處理消息的工作壓力，從而既保證消息傳輸的可靠性，又提高了消息傳輸效率。

附圖說明

為了更清楚的說明本發明實施例或現有技術的技術方案，下面將對實施例或現有技術描述中所需要使用的附圖作簡單的介紹，顯而易見地，下面描述中的附圖僅僅是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。

圖1為本發明實時里提供的第一種管理消息中間件的方法的流程圖；

圖2為本發明實施例提供的第二種管理消息中間件的方法的流程圖；

圖3為本發明實施例提供的第三種管理消息中間件的方法的流程圖；

圖4為本發明實施例提供的第四種管理消息中間件的方法的流程圖。

具體實施方式