[發(fā)明專利]一種基于消息機制的企業(yè)服務總線系統(tǒng)

無效

• 申請?zhí)枺?/td>: 201210323447.3
• 申請日: 2012-09-04
• 公開（公告）號: CN102868608A
• 公開（公告）日: 2013-01-09
• 發(fā)明（設計）人: 施化吉;陳淵
• 申請（專利權）人: 江蘇大學
• 主分類號: H04L12/721
• 分類號: H04L12/721;H04L12/40;H04L12/58;H04L29/08
• 代理公司: 江蘇致邦律師事務所 32230
• 代理人: 樊文紅

技術領域

本發(fā)明屬于軟件的企業(yè)應用集成技術領域，尤其涉及一種基于消息機制的企業(yè)服務總線路由實現(xiàn)方法及系統(tǒng)。

背景技術

隨著企業(yè)信息化技術的不斷發(fā)展，企業(yè)信息系統(tǒng)變得越來越復雜。各種不同的系統(tǒng)結合在一起，它們之間的信息交換比較困難，這也就變成了一個個信息孤島。如何有效實現(xiàn)企業(yè)2內(nèi)部信息系統(tǒng)互相連接和資源共享，成為企業(yè)應用集成（EAI）的一大難題。

根據(jù)權威研究機構Forrester的研究報告表示，在當下云計算風靡IT領域的時候，大多數(shù)企業(yè)卻仍在使用SOA（service-oriented?architecture）實現(xiàn)其企業(yè)集成，并感到滿意。而支撐SOA的關鍵技術ESB（Enterprise?Service?Bus），由于其松散耦合、可擴展和平臺異構型等良好的特性，成為當前企業(yè)應用集成的主流技術。

目前，大多數(shù)企業(yè)服務總線中消息路由的實現(xiàn)方式仍是靜態(tài)的，當服務數(shù)量增加時，導致效率的低下以及可靠性的降低。而當前的一些動態(tài)路由模型中存在一定的不足，并沒有充分實現(xiàn)路由動態(tài)的特點。

有鑒于此，有必要提供一種基于消息機制的企業(yè)服務總線系統(tǒng)以解決上述問題。

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

本發(fā)明的目的在于克服現(xiàn)有技術的缺陷，提供一種充分實現(xiàn)路由動態(tài)的特點，服務效率和可靠性高的基于消息機制的企業(yè)服務總線系統(tǒng)。

實現(xiàn)本發(fā)明目的的技術方案是：.一種基于消息機制的企業(yè)服務總線系統(tǒng)，包括：消息通道，用于接受服務請求者發(fā)送的源服務消息請求，并通過消息總線將服務消息請求傳遞到消息聚合器；消息總線，為消息組件協(xié)同的總線結構；

所述基于消息機制的企業(yè)服務總線系統(tǒng)還包括：

消息聚合器，用于接收所述源服務消息請求，并識別出多個所述源服務消息請求中相關聯(lián)的特征，將具有相關聯(lián)的特征的源服務消息請求分別組合在一起，形成若干消息組，若干消息組組成整合服務請求消息；

消息分解器，用于將收到的所述整合服務請求消息中的每個服務請求分解出來，將具有相同的服務請求內(nèi)容的服務請求分別與各自date、ip、id對應在一起，形成若干新服務請求消息，并發(fā)送至消息重排器；

消息重排器，用于接受消息分解器發(fā)來的新服務請求消息，并給每個新服務請求消息添加消息標識碼，使服務消息請求能按指定的順序發(fā)送到固定的消息路由器上；

消息路由器，用于根據(jù)服務內(nèi)容將每條所述新服務消息請求發(fā)送給正確的服務提供者；

控制總線，用于對所述服務消息請求的傳遞進行控制以及監(jiān)測消息組件。

作為本發(fā)明的進一步改進，所述消息重排器和消息路由器之間還設有線路消息分接器，用于將所述新服務消息請求進行支路分開，傳遞給消息路由器和消息總線。

作為本發(fā)明的進一步改進，所述消息路由器針對所述服務消息請求中的服務名稱根據(jù)廣度優(yōu)先搜索算法尋找所述服務提供者。

作為本發(fā)明的進一步改進，所述控制總線還包括監(jiān)測所述服務消息請求是否發(fā)送至對應的所述服務提供者的單元。

作為本發(fā)明的進一步改進，所述基于消息機制的企業(yè)服務總線系統(tǒng)執(zhí)行下列步驟：

S1接收多個服務請求者發(fā)送的源消息服務請求；

S2.識別出多個所述源服務消息請求中相關聯(lián)的特征，將具有相關聯(lián)的特征的源服務消息請求分別組合在一起，形成若干消息組，若干消息組組成整合服務請求消息；

S3.將收到的所述整合服務請求消息中的每個服務請求分解出來，將具有相同的服務請求內(nèi)容的服務請求分別與各自date、ip、id對應在一起，形成若干新服務請求消息；

S4給每個新服務請求消息添加消息標識碼，使服務消息請求能按指定的順序發(fā)送；

S5.將接收的所述服務請求消息根據(jù)基于內(nèi)容的處理算法，找到對應的服務提供者，并發(fā)送所述新服務請求消息。

作為本發(fā)明的進一步改進，所述S5之后還包括：

S6.監(jiān)測服務提供者是否將服務發(fā)送給服務請求者。所述S6具體包括：

如果所述服務提供者在設定的系統(tǒng)時間內(nèi)成功返回響應消息，則表示本次服務調用成功，控制總線結束監(jiān)測過程，發(fā)送響應消息給所述服務請求者，本次服務調用結束；

如果控制總線沒有在設定的系統(tǒng)時間內(nèi)接受到第一個服務提供者返回的響應消息，則認為該服務提供者工作異常或失效，控制總線修改該服務單元在消息路由器中的工作狀態(tài)記錄，啟動下一個的服務監(jiān)測，直到接收到服務提供者返回的響應消息或服務器列表中的所有服務提供者全部調用完為止。