[發明專利]一種基于消息框架的應用集成方法

有效

• 申請號: 202111160630.1
• 申請日: 2021-09-30
• 公開（公告）號: CN113835909B
• 公開（公告）日: 2023-10-24
• 發明（設計）人: 楊旸;褚孔統;牟蘇斌;孟德鑫;耿嘉;楊柳靜
• 申請（專利權）人: 中國電子科技集團公司第二十八研究所
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/46
• 代理公司: 江蘇圣典律師事務所 32237
• 代理人: 胡建華

本發明公開了一種基于消息框架的應用集成方法，包括步驟1：構建分布式消息框架；步驟2：對消息通道進行描述；步驟3：使用消息框架的消息端點代碼生成工具生成消息端點代碼；步驟4：開發應用程序；步驟5：通過消息框架的通道管理中心注冊應用運行所需的消息通道；步驟6：應用程序通過通道管理中心獲取通道信息實現消息發送端與接收端的匹配，基于消息端點直接在消息發送應用和接收應用間交換消息，并向監控中心上報交互統計信息，通過消息網關與外部系統交換消息。本發明基于分布式消息框架實現基于消息的應用集成控制部分與交互部分的分離，實現服務化的消息集成，通過通道構建應用間的集成關系，實現對集成關系中交互信息的管理。

技術領域

本發明屬于軟件技術領域，特別是一種基于消息框架的應用集成方法。

背景技術

在分布式架構的計算機系統中，實現基于消息的應用集成可以分為2個部分，一個是控制部分，一個是交互部分。其中控制部分實現消息的提供者與消息的消費者的匹配邏輯，交互平面則基于控制平面的匹配結果將消息提供者發出的消息發送到適當的消息消費者。目前的廣泛應用的消息中間件主要有消息隊列和DDS(Data Distribution Service，數據分發服務)兩種，采用這種架構的兩種消息中間件在使用中存在的主要問題為：

消息隊列中間件普遍采用中心轉發的架構，在這種架構下，所有生成的消息均由消息處理服務器轉發，因此，消息處理服務器成為了整個消息集成系統的瓶頸，為了支持高吞吐量和高可用性，需要構建消息處理服務器集群并支持水平擴展，但控制和交互混合的架構使集群內的各節點間需要進行控制信息的同步以及消息的轉發，增大系統復雜性和消息的轉發時延，并使系統的水平擴展困難。

DDS采用無中心體系結構，其控制部分和交互部分集成在一起分布在每個節點上，這樣一方面由于需要在分布的節點間交換應用集成條件，增加了復雜性和節點額外的信息交換，另一方面每個節點都需要承擔消息的匹配邏輯，增大了節點的負載。DDS的主題間沒有關聯，在DDS中缺少能夠對應用間交互進行整體描述的方法，因此很難在應用消息集成的層面上對應用集成進行監視和管理；DDS的分發邏輯由消息消費者應用的訂閱條件決定，但在需要由消息生產者決定分發邏輯的場景中需要專門定義區分目的端的KEY并進行過濾，進而造成在消息的定義中嵌入額外的數據項，或者將同一數據結構定義成不同名字的主題，進而導致數據結構維護困難。

基于以上原因，迫切需要一種一方面對消息集成的控制部分與交互部分的分離，對控制部分采用中心模式，實現對集成邏輯的高效管理，對交互部分采用分布式的點到點模式，提高消息交互的性能和可用性；另一方面采用消息定義和消息通道相結合的方式實現服務化的消息集成的應用集成方法。但是現有技術中尚無相關報道。

發明內容

發明目的：本發明所要解決的技術問題是針對現有技術的不足，提供一種基于消息框架的應用集成方法。

為了解決上述技術問題，本發明公開了一種基于消息框架的應用集成方法，包括以下步驟：

步驟1：構建分布式消息框架，消息框架由消息端點代碼生成工具、消息端點、通道管理中心、監控中心和消息網關通過分布式遠程連接構成；

步驟2：基于應用系統內應用間消息交互的需要設計消息通道，對消息通道進行描述；

步驟3：基于消息通道描述，使用消息框架的消息端點代碼生成工具生成消息端點代碼；

步驟4：基于生成的消息端點代碼，開發應用程序；

步驟5：通過消息框架的通道管理中心注冊應用運行所需的消息通道；

步驟6：應用程序通過消息框架的通道管理中心獲取通道信息實現消息發送端與接收端的匹配，基于消息端點直接在消息發送應用和接收應用間交換消息，并向監控中心上報交互統計信息，通過消息網關與外部系統交換消息。