[發(fā)明專利]分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法及裝置

在審

• 申請?zhí)枺?/td>: 201911226123.6
• 申請日: 2019-12-04
• 公開（公告）號: CN111045839A
• 公開（公告）日: 2020-04-21
• 發(fā)明（設(shè)計）人: 賀詩浩;何鑫堯;張強;劉小齊;雷鳴;王趙羿;劉廣宇;杜方舉
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司;建信金融科技有限責任公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 趙平;周永君

1.一種分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，所述方法包含：

獲取待處理的事務的消息類型；

當所述事務的消息類型為順序敏感類型時，獲得各節(jié)點所處理的事務消息的處理時序的序列鍵；

接收節(jié)點輸出的準備消息，將所述準備消息緩存至本地后，反饋準備消息響應至對應節(jié)點；

接收節(jié)點輸出的確認消息，根據(jù)所述確認消息獲得緩存在本地的所述準備消息中的事務消息；

將所述事務消息與所述序列鍵所對應的事務消息進行比較；

當所述事務消息在所述序列鍵中所處位置符合預設(shè)規(guī)定時，將所述確認消息中的處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點。

2.根據(jù)權(quán)利要求1所述的分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，所述接收節(jié)點輸出的確認消息之前還包含：

當接收到所述準備消息后，預定周期內(nèi)未接收到所述確認消息時，根據(jù)所述準備消息獲得對應的節(jié)點信息，向所述節(jié)點信息對應節(jié)點發(fā)起查詢請求。

3.根據(jù)權(quán)利要求1所述的分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，所述接收節(jié)點輸出的確認消息之前還包含：

接收節(jié)點輸出的事務消息處理失敗的取消消息，根據(jù)所述取消消息刪除本地緩存的所述準備消息。

4.根據(jù)權(quán)利要求1所述的分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，當所述事務消息在所述序列鍵中所處位置符合預設(shè)規(guī)定時，將所述確認消息中的處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點還包含：當所述事務消息在所述序列鍵中所處位置不符合預設(shè)規(guī)定時，將所述確認消息中的處理結(jié)果緩存至本地；待所述事務消息在所述序列鍵中所處位置符合預設(shè)規(guī)定時，再將所述確認消息中的處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點。

5.根據(jù)權(quán)利要求1所述的分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，當所述事務消息在所述序列鍵中所處位置符合預設(shè)規(guī)定時，將所述確認消息中的處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點還包含：

根據(jù)前次將處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點的到達時長和預設(shè)的配額時長建立發(fā)送緩存監(jiān)測進程；

通過所述緩存監(jiān)測進程控制所述處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點，當輸出實際用時與配額時長差距較大時，動態(tài)調(diào)整配額時長。

6.一種分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，所述方法包含：

獲得待處理的事務消息，根據(jù)所述事務消息生成準備消息并將所述準備消息發(fā)送至聚合消息隊列；

根據(jù)聚合消息隊列反饋的準備消息響應，對所述事務消息進行預設(shè)規(guī)則處理，獲得處理結(jié)果；

根據(jù)所述處理結(jié)果生成確認消息，將所述確認消息發(fā)送至所述聚合消息隊列。

7.根據(jù)權(quán)利要求6所述的分布式環(huán)境下基于兩階段事務消息的順序調(diào)用方法，其特征在于，根據(jù)所述處理結(jié)果生成確認消息，將所述確認消息發(fā)送至所述聚合消息隊列還包含：

當所述處理結(jié)果為所述事務消息處理失敗時，生成取消消息；

將所述取消消息發(fā)送至所述聚合消息隊列。

8.一種分布式環(huán)境下基于兩階段事務消息的順序調(diào)用裝置，其特征在于，所述裝置包含接收模塊、判斷模塊、分析模塊和比較輸出模塊；

所述接收模塊用于獲取待處理的事務的消息類型；

所述判斷模塊用于當所述事務的消息類型為順序敏感類型時，獲得各節(jié)點所處理的事務消息的處理時序的序列鍵；

所述分析模塊用于接收節(jié)點輸出的準備消息，將所述準備消息緩存至本地后，反饋準備消息響應至對應節(jié)點；以及，接收節(jié)點輸出的確認消息，根據(jù)所述確認消息獲得緩存在本地的所述準備消息中的事務消息；

所述比較輸出模塊用于將所述事務消息與所述序列鍵所對應的事務消息進行比較；當所述事務消息在所述序列鍵中所處位置符合預設(shè)規(guī)定時，將所述確認消息中的處理結(jié)果輸出至分布式事務處理鏈的下游節(jié)點。