[發(fā)明專利]一種報文存儲、轉發(fā)方法、裝置及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201210140440.8
• 申請日: 2012-05-08
• 公開（公告）號: CN103391257A
• 公開（公告）日: 2013-11-13
• 發(fā)明（設計）人: 陳小流
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L12/863
• 分類號: H04L12/863
• 代理公司: 北京同達信恒知識產權代理有限公司 11291
• 代理人: 郭潤湘

技術領域

本申請涉及網(wǎng)絡數(shù)據(jù)通信技術領域，尤其涉及一種報文存儲、轉發(fā)方法、裝置及系統(tǒng)。

背景技術

報文，是計算機系統(tǒng)之間交換信息的載體。報文存儲轉發(fā)，是一種信息交換技術，是指在計算機系統(tǒng)間交換信息之前（或者交換信息失敗以后）將報文進行持久化存儲，并且在合適的時間從持久化存儲的報文中取出相應報文進行交換（或者重新發(fā)送）。報文存儲轉發(fā)系統(tǒng)是指在網(wǎng)絡通信節(jié)點中，對需要交換轉發(fā)的報文，完成邏輯判決與緩沖存儲的功能，并在適當時機再把報文發(fā)送出去，這種先接收后存儲再轉發(fā)的工作方式稱為報文存儲轉發(fā)工作方式。

如圖1所示，報文存儲轉發(fā)系統(tǒng)包括至少兩個計算機系統(tǒng)（如圖1中的企業(yè)應用系統(tǒng)和外部應用系統(tǒng))，兩個計算機系統(tǒng)之間通過負責計算機系統(tǒng)之間通訊的通訊前置系統(tǒng)連接。其中，在業(yè)務鏈路上，通訊前置系統(tǒng)通常介于不同業(yè)務域的計算機系統(tǒng)之間，負責在計算機系統(tǒng)之間進行信息交換。在兩個計算機系統(tǒng)之間進行報文交換，存在至少兩種情況，一種情況是：對于同一個報文，允許多次交換。另一種情況是，對于同一個報文，只允許唯一交換一次。對于同一個報文，只允許唯一交換一次的情況下，現(xiàn)有技術中報文存儲轉發(fā)的方式通常是基于消息隊列來完成的，對于一個報文來說，其處理過程如下：

步驟一：企業(yè)應用系統(tǒng)將待交換的報文寫入到待交換報文隊列中存儲。

步驟二：通訊前置系統(tǒng)在待交換報文隊列中獲取報文，將獲取的報文轉發(fā)給外部應用系統(tǒng)。

步驟三：外部應用系統(tǒng)接收由通訊前置系統(tǒng)發(fā)來的報文，并對該報文進行處理，在完成對該報文的處理之后，通過通訊前置系統(tǒng)發(fā)送響應報文。

步驟四：通訊前置系統(tǒng)將接收到的響應報文存儲到響應報文隊列中，企業(yè)應用系統(tǒng)可以在響應報文隊列中獲得與交換報文對應的響應報文。

下面以銀行ATM設備中的一筆跨行轉賬業(yè)務為例，來進一步闡述現(xiàn)有技術中報文存儲轉發(fā)的過程，如圖2所示：

步驟201，ATM設備將用戶發(fā)來的跨行轉賬請求，發(fā)送至本行業(yè)務系統(tǒng)中。

步驟202，本行業(yè)務系統(tǒng)處理轉賬請求，生成跨行轉賬消息，并將生成的跨行轉賬消息寫入請求隊列中存儲。

步驟203，跨行通訊前置系統(tǒng)從請求隊列中取出跨行轉賬消息。

步驟204，跨行通訊前置系統(tǒng)根據(jù)取出的跨行轉賬消息通過金融網(wǎng)絡向對應的銀行發(fā)起轉賬請求。

步驟205，金融網(wǎng)絡將接收到的他行發(fā)來的轉賬結果發(fā)送給跨行通訊前置系統(tǒng)。

步驟206，跨行通訊前置系統(tǒng)將轉賬結果寫入到響應隊列中存儲。

步驟207，本行業(yè)務系統(tǒng)從響應隊列中取出存儲的轉賬結果。

步驟208，本行業(yè)務系統(tǒng)將取出的轉賬結果反饋給ATM設備，并在ATM設備上向用戶展示相應信息。

由上述處理過程可知，現(xiàn)有技術中報文存儲、轉發(fā)方法，在報文存儲轉發(fā)過程中，如果計算機系統(tǒng)硬件或者軟件出現(xiàn)故障，在存儲過程中會使得一條消息被多次寫入，浪費系統(tǒng)的存儲資源，并且在處理過程中，也可能存在一條消息被多次轉發(fā)，造成中央處理器（CPU）處理資源的浪費，進而影響了系統(tǒng)的處理性能。

發(fā)明內容

本申請實施例提供一種報文存儲方法及裝置，能夠較好地節(jié)省系統(tǒng)的存儲資源。

相應地，本申請實施例提供一種報文轉發(fā)方法及裝置，能夠較好的節(jié)省CPU處理資源，提高系統(tǒng)的處理性能。

相應地，本申請實施例提供一種報文存儲轉發(fā)系統(tǒng)和裝置，能夠保證在至少兩個不同的計算機系統(tǒng)之間進行報文通訊時，同一個報文只被存儲和轉發(fā)一次。

本申請實施例技術方案如下：

一種報文存儲方法，包括：接收待存儲的報文；在接收的待存儲報文中確定用于唯一標識所述報文的關鍵要素值；確定關鍵要素值存儲區(qū)中是否寫入有確定的所述關鍵要素值，其中所述關鍵要素值存儲區(qū)中存儲有數(shù)據(jù)庫中已存儲報文分別對應的關鍵要素值；如果是，則將接收到的待存儲報文丟棄；如果否，則將接收的待存儲報文存儲至數(shù)據(jù)庫中，并將確定的關鍵要素值寫入所述關鍵要素值存儲區(qū)中。

一種報文轉發(fā)方法，包括：在數(shù)據(jù)庫存儲的報文中獲得待轉發(fā)的報文；在獲得的報文中確定用于唯一標識所述報文的關鍵要素值；確定冪等性控制存儲區(qū)中是否寫入有確定的關鍵要素值，其中所述冪等性控制存儲區(qū)中存儲有數(shù)據(jù)庫中已轉發(fā)報文分別對應的關鍵要素值；如果是，則將獲得的報文丟棄；如果否，則將獲得的報文轉發(fā)。