摘 要： 基于企業(yè)服務(wù)總線實施系統(tǒng)集成過程中，配置基于消息的監(jiān)控平臺，并添加基于消息的事務(wù)處理及異常干預(yù)補償機制。當(dāng)傳輸通道中出現(xiàn)異常消息時，補償機制根據(jù)捕捉到的異常信息進(jìn)行參數(shù)匹配后基于消息進(jìn)行補償處理并存儲在緩存隊列中，根據(jù)需要可以對緩存隊列中的消息重新獲取和發(fā)送，避免異常消息丟失，確保了集成數(shù)據(jù)傳輸?shù)目煽啃院汪敯粜浴?br /> 關(guān)鍵詞： 企業(yè)服務(wù)總線；監(jiān)控平臺；消息補償
在基于企業(yè)服務(wù)總線系統(tǒng)集成平臺中，配置消息監(jiān)控平臺對消息流進(jìn)行實時監(jiān)控，針對每個消息傳輸步驟都有明確可視化的狀態(tài)變化數(shù)據(jù), 包括消息數(shù)據(jù)運行情況統(tǒng)計、出錯信息查看、傳輸數(shù)據(jù)歷史溯源，可以通過監(jiān)控平臺展示出來。在消息監(jiān)控平臺中采用消息跟蹤法捕捉異常，并根據(jù)異常消息的反饋信息進(jìn)行情景參數(shù)配置，對可預(yù)料范圍內(nèi)的異常進(jìn)行糾正、事物回滾，實現(xiàn)消息補償，預(yù)料外的異常消息也會存儲到中間件緩存隊列中，根據(jù)需要經(jīng)人工干預(yù)對消息可以重新獲取、重新發(fā)送，避免出現(xiàn)異常后消息丟失。消息補償機制主要采用消息跟蹤、消息補償、異常干預(yù)三種方法實現(xiàn)。
1 消息跟蹤
制定“CQSF-XML”的數(shù)據(jù)交換模型作為統(tǒng)一的消息報文格式，規(guī)范系統(tǒng)間消息通信標(biāo)準(zhǔn)，結(jié)構(gòu)化數(shù)據(jù)便于消息跟蹤功能的實現(xiàn)，同時體現(xiàn)了系統(tǒng)集成的契約原則。CQSF-XML消息報文主要格式[1]如下：
<?xml version="1.0" encoding="UTF-8"?>
<TradeData>
<BaseInfo>
<TradeSeq>信息傳輸交易序列號</TradeSeq>
<ActionCode>操作編碼</ActionCode>
<TradeTime>信息傳輸交易時間</TradeTime>
<SourceSys>信息傳輸源系統(tǒng)名稱</SourceSys>
<Target>信息傳輸源系統(tǒng)名稱</Target>
<ResultCode>應(yīng)答碼</ResultCode>
<ResultMsg>返回消息</ResultMsg>
<ExceptionMsg>錯誤信息描述</ExceptionMsg>
</BaseInfo>
<SwitchMsg>業(yè)務(wù)信息</SwitchMsg>
</TradeData>
消息報文內(nèi)容分為報文頭信息(BaseInfo)和業(yè)務(wù)數(shù)據(jù)信息(SwitchMsg)，報文頭信息中包含傳輸控制管理信息和一些消息實時狀態(tài)標(biāo)識。其中ResultCode（應(yīng)答碼）描述消息錯誤級別。主要應(yīng)答碼定義如表1所示。
在企業(yè)服務(wù)總線消息傳輸過程中，數(shù)據(jù)在每個節(jié)點都會發(fā)生變化，將這一系列的信息變化記錄下來就組成信息交換過程中的監(jiān)控記錄，包括系統(tǒng)的整體運行狀況。另外，對監(jiān)控記錄劃分級別，可實現(xiàn)動態(tài)更改消息監(jiān)控深度，從而可以根據(jù)不同的需要實現(xiàn)不同級別的信息監(jiān)控。消息跟蹤架構(gòu)[2]示意圖如圖1所示。
2 消息補償
消息補償架構(gòu)示意圖如圖2所示。源系統(tǒng)通過企業(yè)服務(wù)總線同時向系統(tǒng)B和系統(tǒng)C發(fā)送數(shù)據(jù)，請求服務(wù)信息被放在緩存中，作為事務(wù)處理機制提交，一旦系統(tǒng)C請求調(diào)用失敗，就會觸發(fā)異常處理程序。異常處理程序根據(jù)消息報文進(jìn)行事務(wù)回滾處理，依次調(diào)用系統(tǒng)B和系統(tǒng)C中已注冊的事務(wù)補償處理程序回滾業(yè)務(wù)數(shù)據(jù)，業(yè)務(wù)數(shù)據(jù)被存儲在MQ中，等待重新發(fā)送。
3 異常干預(yù)
系統(tǒng)實時檢查事件庫中的異常信息，根據(jù)預(yù)先在WMB中配置的E-mail節(jié)點自動向指定人員發(fā)送異常通知郵件。維護(hù)人員通過異常干預(yù)控制界面定位異常信息，并從預(yù)先配置的異常干預(yù)措施中選擇解決方案。異常干預(yù)功能提供跟蹤處理，支持消息重傳、批處理過程重做等操作，可以對異常干預(yù)結(jié)果進(jìn)行查看。異常干預(yù)融合在監(jiān)控平臺之中。例如當(dāng)某個消息出現(xiàn)異常而中斷時，可以在監(jiān)控平臺中查詢到這個異常中斷的服務(wù)，同時查詢界面中會顯示能夠處理該異常的一些可行的異常干預(yù)措施(例如再運行該任務(wù)等)。異常干預(yù)架構(gòu)示意圖如圖3所示。
企業(yè)服務(wù)總線消息補償處理機制，采用系統(tǒng)化方法保證消息傳輸正確，及時準(zhǔn)確定位錯誤原因，在出現(xiàn)異常時進(jìn)行事務(wù)回滾，確保消息的可靠性傳輸，提高了我公司企業(yè)服務(wù)總線運行的健壯性。
參考文獻(xiàn)
[1] 丁躍潮，張濤.XML實用教程(第1版)[M].北京：北京大學(xué)出版社，2006.
[2] 張瀟毅，鄧波，丁鯤.一種基于事件流處理引擎的企業(yè)服務(wù)總線平臺[J].解放軍理工大學(xué)學(xué)報，2010，11（2）：178-183.