[發明專利]一種基于消息隊列的數據傳輸方法、服務器及系統

有效

• 申請號: 200810239601.2
• 申請日: 2008-12-12
• 公開（公告）號: CN101431476A
• 公開（公告）日: 2009-05-13
• 發明（設計）人: 伊勁松;王怡;殷明;趙子川
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L12/56
• 分類號: H04L12/56;H04L12/58
• 代理公司: 北京三友知識產權代理有限公司
• 代理人: 任默聞

技術領域

本發明關于計算機網絡的數據傳輸技術，具體的講是關于一種基于消息 隊列的數據傳輸方法、服務器及系統。

背景技術

對于具有分支機構的大型企業或單位而言，由于其業務種類繁多，因此 會存在各種不同的業務應用系統。為了實現各個分支結構之間的數據通信需 要一個復雜的網絡關系進行支撐，從而使網絡之間的消息數據能夠順利、可 靠的分發到相應的目的地。

在現有技術中，基于IP地址的消息數據轉發是常用的數據傳輸方式，也 有些應用系統之間是根據IP地址建立HTTP連接進行消息數據的傳遞和分發。 然而在實現本發明的過程中發明人發現，基于IP地址的消息數據轉發需要目 標與IP地址的一一對應關系的支持，也就是說相對于一個目標，發起方就需 要知道一個IP地址，這樣只能進行點對點的消息數據轉發；并且應用程序知 道目標后，需要對消息數據傳輸的可靠性進行控制，這樣便增加了應用程序 的負擔。而且，如果要修改或者新增應用系統，就需要重新部署調整應用布 局，導致靈活性和擴展性較差。

在現有技術中，基于中間件的消息數據轉發也是一種數據傳輸方式，這 種消息數據轉發一般這樣實現：當發送方應用程序將消息發送到中間件客戶 端后，中間件消息接收進程(MessageReceiver)執行消息接收操作 (MessageReceiving)。如果消息接收成功，與之合作的消息分發進程 (MessageDispatcher)通過消息通道將消息分發(MessageDispatching)到與之對 應的中間件服務器端。然而在實現本發明的過程中發明人發現，這種基于中 間件的分發方式將消息的可靠傳遞交給了中間件來完成，但是如何利用中間 件分發卻沒有完善的方案，只是簡單的利用中間件本身的特性進行分發，這 樣對于分發數量大、分支節點深的情況，中間件就無法完成。

發明內容

為了克服現有技術的缺陷，本發明實施例提供了一種基于消息隊列的數 據傳輸方法、服務器及系統。以提供一種可靠的消息數據包轉發機制，使消 息數據包能夠根據自身的一個路由屬性隨意分發和返回。

本發明實施例的目的之一是：提供一種基于消息隊列的數據傳輸服務器， 該服務器包括：消息隊列單元，用于接收應用設備端或者其他數據傳輸服務 器發送的消息數據包，所述消息數據包由包頭和包體組成；所述的包體包括 消息數據內容，所述的包頭包括目的地區號、目的應用號、源地區號和源應 用號；其中，所述消息數據包的包頭中還包含隨機生成的能夠識別返回信息 的消息標識ID字段；其中，所述消息隊列單元包括：傳輸隊列和緩沖隊列； 所述傳輸隊列用于接收其他數據傳輸服務器發來的消息數據包；所述緩沖隊 列用于接收應用設備端發來的消息數據包；數據包獲取單元，用于從所述的 消息隊列中獲取所述的消息數據包；數據包處理單元，用于根據所述消息數 據包的地址信息和預存儲的路由配置信息對所述的消息數據包進行路由配 置；所述的消息隊列單元通過發送消息隊列將路由配置后的消息數據包傳輸 給目的應用端。

本發明實施例的目的之一是：提供一種基于消息隊列的數據傳輸系統， 該系統包括：源應用設備、數據傳輸服務器和目的應用設備，所述的數據傳 輸服務器分別與所述的源應用設備和目的應用設備相連接；所述的源應用設 備生成消息數據包，并將該消息數據包發送給所述的數據傳輸服務器，所述 消息數據包由包頭和包體組成；所述的包體包括消息數據內容，所述的包頭 包括目的地區號、目的應用號、源地區號和源應用號；其中，所述消息數據 包的包頭中還包含隨機生成的能夠識別返回信息的消息標識ID字段；所述的 數據傳輸服務器包括：消息隊列單元，用于接收所述源應用設備發送的消息 數據包；其中，所述消息隊列單元包括：傳輸隊列和緩沖隊列；所述傳輸隊 列用于接收其他數據傳輸服務器發來的消息數據包；所述緩沖隊列用于接收 所述源應用設備發來的消息數據包；數據包獲取單元，用于從所述的消息隊 列中獲取所述的消息數據包；數據包處理單元，用于根據所述消息數據包的 地址信息和預存儲的路由配置信息對所述的消息數據包進行路由配置；所述 的消息隊列單元通過發送消息隊列將路由配置后的消息數據包傳輸給目的應 用設備；所述的目的應用設備從所述的發送消息隊列獲取所述的路由配置后 的消息數據包。