[發明專利]一種基于發布訂閱的路由服務實現方法

在審

• 申請號: 201711292454.0
• 申請日: 2017-12-07
• 公開（公告）號: CN108199865A
• 公開（公告）日: 2018-06-22
• 發明（設計）人: 呂廣喆;邸海濤;任曉瑞;劉建軍;甄超;李明娟
• 申請（專利權）人: 中國航空工業集團公司西安航空計算技術研究所
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/06
• 代理公司: 中國航空專利中心 11008
• 代理人: 杜永保

本發明屬于計算機系統軟件專業技術領域，提供一種基于發布訂閱的路由服務實現方法。在分布式網絡環境中涉及到多種網絡協議，不同協議間不能直接進行通訊。本發明在發布訂閱機制的基礎上，設計了路由服務，能夠基于發布訂閱機制進行消息轉發，能夠實現不同協議之間的消息轉換，并提供有效的擴展機制支持不同的協議。解決了跨網絡系統間消息交互的問題，有效地提高了應用軟件的開發效率，減少了軟件系統升級過程中新老系統兼容所面臨的問題。本發明的特點是基于發布訂閱的消息路由機制，實現有效的數據轉發；不同協議間的消息轉換；靈活、可擴展的協議適配模型，能夠有支持多種不同的網絡傳輸協議。

技術領域

本發明屬于計算機系統軟件專業技術領域，提供一種基于發布訂閱的路由服務實現方法。

背景技術

在分布式系統環境中，系統的構建過程中涉及到多種網絡，系統間的消息傳遞不能直接進行，需要進行消息轉發和消息轉換，由于網絡資源的多樣性，消息轉發和消息轉換缺少一種統一的方式，開發出的具備消息轉發和消息轉換功能的軟件可移植性差、復用度低。據此，提出了一種基于發布訂閱的路由服務實現方法，提供了基于發布訂閱的消息路由機制；實現了不同協議間的消息轉換；具備靈活、可擴展的協議適配模型，可支持多種網絡協議。

發明內容

本發明的目的是設計一種基于發布訂閱方式的路由服務，消息轉發采用發布訂閱的模式實現，基于統一的消息結構實現不同協議間的消息轉換，支持網絡協議的擴展，為分布式系統間的信息交互提供統一的路由服務，減少系統信息融合的工作量，降低分布式應用程序的開發難度，提升軟件開發效率。

本發明的具體技術解決方案如下：

一種基于發布訂閱的路由服務實現方法，包括以下步驟：

步驟1、確定配置數據。使用該方法進行消息交互時，需要配置數據指定路由服務與應用之間建立連接所使用的網絡協議、網絡連接參數，以及消息路由信息。網絡協議是指JMS、TCP、DDS等具體的協議類型；網絡連接參數是指建立連接所需要的參數，例如：當底層網絡是以太網時，需要IP地址、端口建立連接；消息路由信息包括消息名稱、消息類型名、源、目的屬性。

步驟2、實現路由服務相關對象。針對不同網絡的特點，設計了適配器、連接、流讀者、流寫者四個對象用于支持不同網絡協議的轉換。適配器作為一個管理對象，提供創建連接、流讀者、流寫者等對象的接口。連接對象提供創建連接、銷毀連接的接口，用于建立路由服務與發送端、接收端的網絡連接。流讀者提供讀操作接口，路由服務用它從發送端獲取輸入消息。流寫者提供寫操作接口，路由服務用它將消息發送到接收端。

步驟3、消息轉換。不同網絡協議對消息的組織形式不同，為了實現多種協議之間的轉換，需要建立統一的消息格式，所有的消息由兩部分組成，消息頭和消息內容。消息頭包括：消息名稱、消息結構信息、消息成員屬性。消息名稱是消息的邏輯標識；消息結構信息是對消息結構體的描述，包括消息類型名稱、消息結構體中成員個數，消息對應的內存大?。幌⒊蓡T屬性包括消息結構體中每一個成員的類型，對應的內存大小。消息內容是實際消息體。

步驟4、消息轉發。當路由服務從發送端接收到消息后，對消息進行解析獲取消息名稱，消息類型名稱，從配置數據中查找訂閱該消息的接收端信息，向所有訂閱該消息的接收端發送消息。

本發明具有的優點：

該發明有效支持了分布式系統間的消息轉發，為應用程序提供基于發布訂閱的路由服務，采用發布訂閱機制進行消息交互的應用程序不需要考慮網絡協議對發布訂閱機制的支持與否，都可以通過路由服務進行消息的發布訂閱。

該發明有效支持了不同協議間的消息轉換，為應用程序提供透明的消息轉換機制，應用程序不再考慮網絡協議的差異，有效降低了應用軟件的設計復雜度。