[發明專利]消息處理服務器及分布式消息處理方法和系統

有效

• 申請號: 201310319636.8
• 申請日: 2013-07-26
• 公開（公告）號: CN103414638B
• 公開（公告）日: 2016-11-30
• 發明（設計）人: 關國鋒;方元;王云鵬
• 申請（專利權）人: 華為技術有限公司
• 主分類號: H04L12/721
• 分類號: H04L12/721;H04L12/751
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 黃厚剛

【技術領域】

本發明涉及通信領域，尤其涉及一種消息處理服務器及分布式消息處理方法和系統。

【背景技術】

隨著計算機與網絡技術的飛速發展，企業計算環境已從傳統的集中式變為分布式。許多行業及企業的消息系統在地理上分布廣泛，使分布式系統越來越受到重視，并逐漸應用到許多行業中。消息中間件作為解決復雜的大型分布式系統的各個組成部分之間通信以及多個分布式系統之間通信問題的關鍵技術，在許多關系國計民生的行業關鍵應用中都扮演至關重要的角色，比如銀行、證券、電子商務、交通、政府、能源、郵政、公安等。如，在政務行業省、市、縣多級數據傳遞交換匯總；金融行業，中國人民銀行的全國票交影像交換系統和小額支付系統；在交通行業，海事局的船舶與船員管理系統；在能源行業，國家電網公司消息化工程一體化企業級消息集成平臺。

由于分布式系統的規模越來越龐大，復雜程度也越來越高，有的行業，如銀行，郵政等，其消息系統在地理上分布廣泛，可以大到全國各省市的鄉鎮，這就要求消息系統的消息中間件具有極高的可擴展性，并能適應復雜的網絡環境，保證消息的傳輸可靠性以及高效性。

請參考圖1，現有的消息中間件技術中，解決消息中間件可擴展性的技術主要是采用具有層次拓撲結構的消息中間件系統及消息傳遞方法。

其中，系統中的所有消息中間件分為一個以上的域，每個域具有至少一個消息中間件及一個橋中間件。客戶端通過消息中間件在其所在的域內傳遞消息，并進一步通過橋中間件與其它域的消息中間件傳遞消息。同一個域內的消息中間件通過對等方式傳遞消息，不同域的消息中間件之間通過各自域的消息中間件傳遞消息，不同域的橋中間件之間通過對等方式傳遞消息。因此系統中所有的消息中間件一般需要保存有全局同步的路由表，且該路由表需要由各個域的橋中間件之間進行同步；當橋中間件與另一橋中間之間某一路徑不同時，通過橋中間件動態選取其他路徑。

【發明內容】

有鑒于此，本發明實施例提供了一種消息處理服務器及分布式消息處理方法和系統。

第一方面，本發明實施例提供的消息處理服務器，用于接收和處理來自下屬子域的消息，包括：

接收模塊：用于接收下屬子域的發送的路由尋址請求消息；所述路由尋址請求消息中攜帶：源地址標識、源地址所在域的域名標識，目的地址標識，和目的地址所在域的域名標識；

查詢模塊：用于根據路由尋址請求消息從服務器關聯的拓撲關系表中確定消息路由，并根據消息路由確定發送策略以向下屬子域發送路由策略更新命令；

發送模塊：根據查詢模塊的發送策略，向源地址對應的源端返回路由尋址請求尋址結果

在第一方面的第一種可能的實現方式中，查詢模塊確定的發送策略為：在發送策略更新命令開始計時的一段預設時間后，通過發送模塊向源地址對應的源端返回路由尋址請求尋址結果。

在第一方面的第二種可能的實現方式中，查詢模塊確定的發送策略也可以為：根據下屬子域響應策略更新命令而上報給所述接收模塊的響應消息，觸發所述發送模塊向源地址對應的源端返回路由尋址請求尋址結果。

結合第一方面的第一種可能或第二種可能的實現方式，所述源地址包括源客戶端地址和/或源應用程序地址；所述目的地址包括目的客戶端地址和/或源應用程序地址。

結合第一方面或第一方面的兩種可能的實現方式，所述查詢模塊還用于：通過拓撲關系表配置所有下屬子域的路由策略和所有下屬子域的負載統計數據監控；根據所有下屬子域的路由策略以及負載性能監控結果，確定消息路由。

結合第一方面或第一方面的兩種可能的實現方式，所述下屬子域中的每個子域至少包括：客戶端、消息中間件和代理中間件；

所述客戶端用于：傳輸路由尋址請求消息；

所述消息中間件用于：收發和檢查客戶端的尋址請求消息隊列，從中取出源地址標識、源地址所在域的域名標識，目的地址標識，和目的地址所在域的域名標識；并通過內設路由表，判斷是否是域內的尋址請求；如是域內的尋址請求，則建立域內客戶端連接；如果不是域內的尋址請求，則通過代理中間件將尋址請求發送至所述消息處理服務器的接收模塊。

結合第一方面或第一方面的兩種可能的實現方式，所述代理中間件還用于，根據接收到消息中間件的路由尋址請求，優先查詢所述代理中間件自有的路由表；如果沒有與路由尋址請求匹配的路由，代理中間件向所述接收模塊轉發路由尋址請求。

第二方面，本發明實施例提供的分布式消息處理方法，包括以下步驟：