[發明專利]WEB端控制的消息中間件系統及其數據傳送方法

有效

• 申請號: 201610027711.7
• 申請日: 2016-01-15
• 公開（公告）號: CN105472042B
• 公開（公告）日: 2018-09-21
• 發明（設計）人: 張昊;鄧瓏;楊會龍;王亞智;潘志國
• 申請（專利權）人: 中煤電氣有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京正理專利代理有限公司 11257
• 代理人: 付生輝;謝小延

本發明公開一種WEB端控制的消息中間件系統及其數據傳送方法，數據傳送方法包括如下步驟：S1、初始化WEB端控制的消息中間件系統；S2、根據發送客戶端的設置，利用WEB端控制的消息中間件系統采用推送或拉取的方式從發送客戶端接收數據并將該數據轉換為JSON格式的消息；S3、根據接收客戶端的設置，利用WEB端控制的消息中間件系統將對應的接收客戶端所需消息轉換為對應的接收客戶端指定的格式并采用推送或拉取的方式向對應的接收客戶端發送數據。本發明所述技術方案可實現企業內或企業間各個異構系統、不同的數據存儲格式之間進行數據相互交換。

技術領域

本發明涉及數據交換領域。更具體地，涉及一種WEB端控制的消息中間件系統及其數據傳送方法。

背景技術

隨著企業信息化不斷完善，解決系統與系統之間的數據共享與數據及時性、避免信息孤島越來越為企業所重視。

現有的中間件技術大部分以java語言作為編程平臺，基于消息隊列或消息傳送的方式，主要功能是在應用程序之間提供可靠的消息傳送，這些消息可以在不同的網絡協議、不同的計算機系統和不同的應用軟件之間傳遞。具體設計如下：

1)發送端開發：按照不同數據來源編寫不同的客戶端程序，通過把不同數據轉換成為統一的傳輸內容，通過消息隊列或者消息發送給服務端。但是因為客戶端往往涉及大量的邏輯處理，修改數據來源內容對應就要修改客戶端內容。

2)服務端開發：服務端接收到數據以后，對應尋找訂閱者也就是接收端，如果接收端狀態是可以連接，將數據推送給訂閱的接收端，否則將數據緩存在服務端。

3)接收端開發：接收端程序接收到服務端推送來的消息數據，按照指定規則進行解析，按照不同的業務邏輯進行處理。同樣如果發送端數據內容或者協議修改了，接收端數據處理的環節對應需要修改。

但現有的中間件技術存在如下問題：

1)需要客戶端程序部署，運行維護復雜。

2)功能擴展能力不足，不能實現功能插拔。

3)大多沒有斷點續傳功能，信息的完整性無法保障

因此，需要提供一種WEB端控制的消息中間件系統及其數據傳送方法。

發明內容

本發明的目的在于提供一種WEB端控制的消息中間件系統及其數據傳送方法，在通過消息中間件進行數據交換的過程中實現數據斷點續傳；不需要部署客戶端程序，在WEB端進行發布訂閱從而方便維護與管理；采用可插拔的功能單元，在最大程度上實現中間件的擴展性與可伸縮性；采用推拉結合的數據傳送方式以確保數據的及時有效性；最終實現企業內或企業間各個異構系統、不同的數據存儲格式之間進行數據相互交換，從而實現實時同步。

為達到上述目的，本發明采用下述技術方案：

一種WEB端控制的消息中間件系統，該系統通過發布/訂閱架構方式，在WEB端實現發布/訂閱控制，實現數據發布端和數據訂閱端在空間、時間、數據處理過程三個維度實現解耦，該系統包括：

至少一個與發送客戶端一一對應的發布模塊，根據對應的發送客戶端的設置，采用推送或拉取的方式從對應的發送客戶端接收數據并將該數據轉換為JSON格式的消息；

至少一個與接收客戶端一一對應的訂閱模塊，根據對應的接收客戶端的設置，將對應的接收客戶端所需消息轉換為對應的接收客戶端指定的格式并采用推送或拉取的方式向對應的接收客戶端發送數據；

消息隊列模塊，生成數據傳送兩端的一組發送客戶端與接收客戶端的消息隊列，消息隊列模塊缺省集成ActiveMQ一個第三方消息隊列工具，在整體設計上為保證系統的可伸縮性，也可以搭載其它消息隊列產品，實現消息隊列工具解耦；