[發(fā)明專利]消息處理服務(wù)器及分布式消息處理方法和系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201310319636.8
• 申請日: 2013-07-26
• 公開（公告）號: CN103414638B
• 公開（公告）日: 2016-11-30
• 發(fā)明（設(shè)計）人: 關(guān)國鋒;方元;王云鵬
• 申請（專利權(quán)）人: 華為技術(shù)有限公司
• 主分類號: H04L12/721
• 分類號: H04L12/721;H04L12/751
• 代理公司: 北京三高永信知識產(chǎn)權(quán)代理有限責(zé)任公司 11138
• 代理人: 黃厚剛

1.一種消息處理服務(wù)器，用于接收和處理來自下屬子域的消息，其特征在于，包括：

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

查詢模塊：用于根據(jù)所述路由尋址請求消息從拓?fù)潢P(guān)系表中確定消息路由，并根據(jù)消息路由確定發(fā)送策略以向下屬子域發(fā)送路由策略更新命令；

發(fā)送模塊：根據(jù)所述查詢模塊的發(fā)送策略，向源地址對應(yīng)的源端返回路由尋址請求尋址結(jié)果。

2.根據(jù)權(quán)利要求1所述的消息處理服務(wù)器，其特征在于：所述查詢模塊確定的發(fā)送策略為：在發(fā)送策略更新命令開始計時的一段預(yù)設(shè)時間后，通過發(fā)送模塊向源地址對應(yīng)的源端返回路由尋址請求尋址結(jié)果。

3.根據(jù)權(quán)利要求1所述的消息處理服務(wù)器，其特征在于：所述查詢模塊確定的發(fā)送策略為：根據(jù)下屬子域響應(yīng)策略更新命令而上報給所述接收模塊的響應(yīng)消息，觸發(fā)所述發(fā)送模塊向源地址對應(yīng)的源端返回路由尋址請求尋址結(jié)果。

4.根據(jù)權(quán)利要求2或3所述的消息處理服務(wù)器，其特征在于：所述源地址包括源客戶端地址和/或源應(yīng)用程序地址；所述目的地址包括目的客戶端地址和/或源應(yīng)用程序地址。

5.根據(jù)權(quán)利要求2或3所述的消息處理服務(wù)器，其特征在于：所述查詢模塊還用于：通過拓?fù)潢P(guān)系表配置所有下屬子域的路由策略和所有下屬子域的負(fù)載統(tǒng)計數(shù)據(jù)監(jiān)控；根據(jù)所有下屬子域的路由策略以及負(fù)載性能監(jiān)控結(jié)果，確定消息路由。

6.根據(jù)權(quán)利要求1所述的消息處理服務(wù)器，其特征在于：所述下屬子域中的每個子域至少包括：客戶端、消息中間件和代理中間件；

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

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

7.根據(jù)權(quán)利要求1所述的消息處理服務(wù)器，其特征在于：其特征在于：所述代理中間件還用于，根據(jù)接收到消息中間件的路由尋址請求，優(yōu)先查詢所述代理中間件自有的路由表；如果沒有與路由尋址請求匹配的路由，代理中間件向所述接收模塊轉(zhuǎn)發(fā)路由尋址請求。

8.一種分布式消息處理系統(tǒng)，包括：服務(wù)器和下屬子域，其特征在于，服務(wù)器：用于接收下屬子域發(fā)送的路由尋址請求消息；所述路由尋址請求消息中攜帶：源地址標(biāo)識、源地址所在域的域名標(biāo)識，目的地址標(biāo)識，和目的地址所在域的域名標(biāo)識，以確定源地址和目的地址；根據(jù)路由尋址請求消息從服務(wù)器關(guān)聯(lián)的拓?fù)潢P(guān)系表中確定消息路由，并根據(jù)消息路由確定發(fā)送策略以向下屬子域發(fā)送路由策略更新命令；根據(jù)發(fā)送策略，向源地址對應(yīng)的源端返回路由尋址請求尋址結(jié)果。

9.根據(jù)權(quán)利要求8所述的分布式消息處理系統(tǒng)，其特征在于：所述下屬子域中的每個子域至少包括：客戶端、消息中間件和代理中間件；

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

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

10.根據(jù)權(quán)利要求9所述的分布式消息處理系統(tǒng)，其特征在于：所述服務(wù)器確定的發(fā)送策略為：在發(fā)送策略更新命令開始計時的一段預(yù)設(shè)時間后，向源地址對應(yīng)的源端返回路由尋址請求尋址結(jié)果。

11.根據(jù)權(quán)利要求9所述的分布式消息處理系統(tǒng)，其特征在于：所述服務(wù)器確定的發(fā)送策略為：根據(jù)下屬子域響應(yīng)策略更新命令而上報給所述服務(wù)器的響應(yīng)消息，觸發(fā)所述服務(wù)器向源地址對應(yīng)的源端返回路由尋址請求尋址結(jié)果。

12.根據(jù)權(quán)利要求10或11所述的分布式消息處理系統(tǒng)，其特征在于：所述源地址包括源客戶端地址和/或源應(yīng)用程序地址；所述目的地址包括目的客戶端地址和/或源應(yīng)用程序地址。