[發(fā)明專利]訂閱消息的發(fā)布方法及裝置

在審

• 申請?zhí)枺?/td>: 201610067479.X
• 申請日: 2016-01-29
• 公開（公告）號: CN107026878A
• 公開（公告）日: 2017-08-08
• 發(fā)明（設(shè)計）人: 嚴(yán)菊明
• 申請（專利權(quán)）人: 中興通訊股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京康信知識產(chǎn)權(quán)代理有限責(zé)任公司11240
• 代理人: 江舟,李靈潔

技術(shù)領(lǐng)域

本發(fā)明涉及通信領(lǐng)域，具體而言，涉及一種訂閱消息的發(fā)布方法及裝置。

背景技術(shù)

相關(guān)技術(shù)中，對于一個大型的分布式軟件系統(tǒng)來說，會有很多服務(wù)，或由很多功能模塊組成。這些服務(wù)之間就會存在相互交換信息的需求。通信組件需要完成的就是不同服務(wù)之間的信息傳遞需求。但是如果僅僅完成信息的傳遞，還遠(yuǎn)無法達(dá)到一個高效可擴(kuò)展系統(tǒng)的要求。通常會有很多問題需要解決，例如，如何盡可能降低發(fā)送者和接收者之間的耦合度、如何做到有效的負(fù)荷均衡、如何新增一個服務(wù)不影響原先運(yùn)行的服務(wù)。

相關(guān)技術(shù)中，基于發(fā)布/訂閱機(jī)制的消息隊列中間件為以異步方式實現(xiàn)構(gòu)造的分布式應(yīng)用提供了一種松耦合方法。它簡化應(yīng)用之間數(shù)據(jù)的傳輸，屏蔽底層異構(gòu)操作系統(tǒng)和網(wǎng)絡(luò)平臺，提供了一致的通信標(biāo)準(zhǔn)和應(yīng)用開發(fā)，確保分布式計算網(wǎng)絡(luò)環(huán)境下可靠的、跨平臺的信息傳輸和數(shù)據(jù)交換。

同時，相關(guān)技術(shù)中的消息發(fā)布訂閱系統(tǒng)都存在如下的問題：

1、標(biāo)準(zhǔn)的C/S架構(gòu)，所有消息發(fā)布方都需要先將消息發(fā)往服務(wù)器，由服務(wù)器再投遞給消息的接收方。對于一個有若干消息交互的業(yè)務(wù)流程，最終體現(xiàn)出時延大的缺點(diǎn)。

2、服務(wù)器在投遞消息的時候路由關(guān)系都是由客戶端通知服務(wù)器生成的，第三方很難進(jìn)行修改。某些場景需要修改報文的投遞路徑時，除非升級客戶端程序來重新生成路由關(guān)系，否則無所適從，大大限制了用戶的使用場景。

3、服務(wù)器在進(jìn)行報文投遞時，匹配算法也是簡單通過發(fā)布方的發(fā)布關(guān)鍵字和接收方的接收關(guān)鍵字進(jìn)行模糊匹配，缺乏更有效的基于業(yè)務(wù)數(shù)據(jù)自定義消息投遞路徑的支撐。

針對相關(guān)技術(shù)中存在的上述問題，目前尚未發(fā)現(xiàn)有效的解決方法。

發(fā)明內(nèi)容

本發(fā)明提供了一種訂閱消息的發(fā)布方法及裝置，以至少解決相關(guān)技術(shù)中在發(fā)送訂閱消息時使用服務(wù)器進(jìn)行中轉(zhuǎn)而導(dǎo)致時延過大的問題。

根據(jù)本發(fā)明的一個方面，提供了一種訂閱消息的發(fā)布方法，包括：接收消息發(fā)送方發(fā)送的用于發(fā)送訂閱消息的請求消息；指示所述消息發(fā)送方將所述訂閱消息直接發(fā)布給訂閱方。

進(jìn)一步地，所述指示所述消息發(fā)送方將所述訂閱消息直接發(fā)布給訂閱方包括：根據(jù)預(yù)存訂閱信息查找所述訂閱消息的訂閱方和發(fā)送所述訂閱消息的路由路徑；指示所述消息發(fā)送方將所述訂閱消息通過所述路由路徑直接發(fā)布給所述訂閱方。

進(jìn)一步地，在根據(jù)預(yù)存訂閱信息查找所述訂閱消息的訂閱方和發(fā)送所述訂閱消息的路由路徑之前，所述方法還包括：接收一個或多個所述訂閱方發(fā)送的訂閱信息，其中，所述訂閱信息包括以下至少之一：所述訂閱方需要接收的訂閱消息、所述訂閱方接收訂閱消息的路由路徑；保存所述訂閱信息作為所述預(yù)存訂閱信息。

進(jìn)一步地，在所述根據(jù)預(yù)存訂閱信息查找所述訂閱消息的訂閱方和發(fā)送所述訂閱消息的路由路徑之后，所述方法還包括：接收用于修改所述訂閱方和/或修改所述路由路徑的第一請求消息；根據(jù)所述第一請求消息修改所述訂閱方得到指定訂閱方和/或修改所述路由路徑得到指定路由路徑。將所述指定訂閱方和所述定路由路徑確定為所述訂閱消息的接收方和/或發(fā)布所述訂閱消息的路由路徑。

進(jìn)一步地，在所述指示所述消息發(fā)送方將所述訂閱消息直接發(fā)布給訂閱方之前，所述方法還包括：接收用于增加訂閱所述訂閱消息的第二請求消息；根據(jù)所述第二請求增加接收所述訂閱消息的指定訂閱方；指示所述消息發(fā)送方將所述訂閱消息發(fā)布給增加的所述指定訂閱方。

進(jìn)一步地，在所述根據(jù)所述第二請求增加接收所述訂閱消息的指定訂閱方之后，所述方法還包括：判斷所述第二請求是否指示對所述訂閱消息進(jìn)行分流后發(fā)送給所述訂閱方和所述指定訂閱方；在判斷結(jié)果為是時，將所述訂閱消息根據(jù)所述第二請求指示的權(quán)重值信息分流后發(fā)布給所述訂閱方和所述指定訂閱方。

進(jìn)一步地，接收通過命令行界面Cli或Web客戶端發(fā)送的所述第一請求消息和/或所述第二請求消息。

根據(jù)本發(fā)明的另一方面，提供了一種訂閱消息的發(fā)布裝置，包括：第一接收模塊，用于接收消息發(fā)送方發(fā)送的用于發(fā)送訂閱消息的請求消息；第一指示模塊，用于指示所述消息發(fā)送方將所述訂閱消息直接發(fā)布給訂閱方。

進(jìn)一步地，所述第一指示模塊包括：查找單元，用于根據(jù)預(yù)存訂閱信息查找所述訂閱消息的訂閱方和發(fā)送所述訂閱消息的路由路徑；指示單元，用于指示所述消息發(fā)送方將所述訂閱消息通過所述路由路徑直接發(fā)布給所述訂閱方。