[發(fā)明專利]事務(wù)消息處理方法、裝置、設(shè)備及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201610709666.3
• 申請日: 2016-08-23
• 公開（公告）號: CN107766080B
• 公開（公告）日: 2021-11-09
• 發(fā)明（設(shè)計(jì)）人: 姜宇
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F9/38
• 分類號: G06F9/38
• 代理公司: 北京同立鈞成知識產(chǎn)權(quán)代理有限公司 11205
• 代理人: 宋揚(yáng);劉芳

本申請?zhí)峁┮环N事務(wù)消息處理方法、裝置、設(shè)備及系統(tǒng)。本申請的事務(wù)消息處理系統(tǒng)包括客戶端設(shè)備和事務(wù)協(xié)調(diào)器所在節(jié)點(diǎn)設(shè)備；客戶端設(shè)備確定業(yè)務(wù)消息對應(yīng)的事務(wù)消息，判斷事務(wù)消息否包括回滾指示信息；若事務(wù)消息包括回滾指示信息，記錄回滾指示信息；事務(wù)協(xié)調(diào)器所在節(jié)點(diǎn)設(shè)備接收客戶端設(shè)備發(fā)送的事務(wù)消息對應(yīng)的事務(wù)的處理結(jié)果；根據(jù)處理結(jié)果確定事務(wù)消息對應(yīng)的事務(wù)是否處理成功；若事務(wù)消息對應(yīng)的事務(wù)存在未處理成功的事務(wù)，則向客戶端設(shè)備發(fā)送事務(wù)回滾請求消息；客戶端設(shè)備還根據(jù)記錄的回滾指示信息對事務(wù)消息對應(yīng)的事務(wù)進(jìn)行回滾。本申請可提高分布式事務(wù)系統(tǒng)的吞吐量，提高事務(wù)處理效率。

技術(shù)領(lǐng)域

本申請涉及互聯(lián)網(wǎng)技術(shù)，尤其涉及一種事務(wù)消息處理方法、裝置、設(shè)備及系統(tǒng)。

背景技術(shù)

隨著網(wǎng)絡(luò)技術(shù)的發(fā)展，網(wǎng)絡(luò)中業(yè)務(wù)系統(tǒng)間的數(shù)據(jù)操作越來越頻繁，處于業(yè)務(wù)系統(tǒng)間的不同數(shù)據(jù)庫中數(shù)據(jù)的一致性。不同數(shù)據(jù)庫中數(shù)據(jù)的一致性則需使得對不同數(shù)據(jù)庫的數(shù)據(jù)操作具有原子性、一致性、隔離性以及持久性(Atomicity Consistency IsolationDurability，簡稱ACID)，即要求進(jìn)行分布式事務(wù)處理，且，事務(wù)處理需在多個(gè)事務(wù)資源間實(shí)現(xiàn)。事務(wù)作為數(shù)據(jù)庫的最小操作單元，所有的操作要么都成功，要么都失敗。

在分布式事務(wù)系統(tǒng)中，為解決不同事務(wù)并發(fā)處理同一數(shù)據(jù)而發(fā)生沖突的問題，可在針對一個(gè)事務(wù)對數(shù)據(jù)進(jìn)行處理的過程中，對該數(shù)據(jù)進(jìn)行鎖定，以不允許其他事務(wù)對該數(shù)據(jù)進(jìn)行處理，而在該一個(gè)事務(wù)處理完成后對該一個(gè)數(shù)據(jù)放鎖，繼而針對另一事務(wù)對該數(shù)據(jù)進(jìn)行處理。

然而，鎖定數(shù)據(jù)進(jìn)行事務(wù)處理，可使得分布式事務(wù)系統(tǒng)的吞吐量受到限制，從而使得事務(wù)處理效率受到限制。

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

本申請?zhí)峁┮环N事務(wù)消息處理方法、裝置、設(shè)備及系統(tǒng)，以提高事務(wù)處理效率。

第一方面，本申請?zhí)峁┮环N事務(wù)消息處理系統(tǒng)，包括：客戶端設(shè)備和事務(wù)協(xié)調(diào)器所在節(jié)點(diǎn)設(shè)備；客戶端設(shè)備與事務(wù)協(xié)調(diào)器所在節(jié)點(diǎn)設(shè)備連接；

客戶端設(shè)備，用于確定業(yè)務(wù)消息對應(yīng)的事務(wù)消息；判斷事務(wù)消息否包括回滾指示信息；若事務(wù)消息包括回滾指示信息，記錄回滾指示信息；回滾指示信息用以對事務(wù)消息對應(yīng)的事務(wù)進(jìn)行回滾；

事務(wù)協(xié)調(diào)器所在節(jié)點(diǎn)設(shè)備，用于接收客戶端設(shè)備發(fā)送的事務(wù)消息對應(yīng)的事務(wù)的處理結(jié)果；根據(jù)處理結(jié)果確定事務(wù)消息對應(yīng)的事務(wù)是否處理成功；若事務(wù)消息對應(yīng)的事務(wù)存在未處理成功的事務(wù)，則向客戶端設(shè)備發(fā)送事務(wù)回滾請求消息；

客戶端設(shè)備，還用于根據(jù)記錄的回滾指示信息對事務(wù)消息對應(yīng)的事務(wù)進(jìn)行回滾。

該事務(wù)消息處理系統(tǒng)中客戶端設(shè)備在接收到事務(wù)協(xié)調(diào)器所在節(jié)點(diǎn)設(shè)備發(fā)送的事務(wù)回滾請求消息后，可根據(jù)記錄的回滾指示信息進(jìn)行回滾，無需等待其他事務(wù)消息處理完成，也無需進(jìn)行數(shù)據(jù)鎖定，可使得針對同一數(shù)據(jù)的事務(wù)處理可并行進(jìn)行，提高分布式事務(wù)系統(tǒng)的吞吐量，提高事務(wù)處理效率。

第二方面，本申請?zhí)峁┮环N事務(wù)消息處理方法，包括：

確定業(yè)務(wù)消息對應(yīng)的事務(wù)消息；

判斷事務(wù)消息否包括回滾指示信息；

若事務(wù)消息包括回滾指示信息，記錄回滾指示信息；回滾指示信息用以對事務(wù)消息對應(yīng)的事務(wù)進(jìn)行回滾。

該方法中，可記錄事務(wù)消息包括的用以進(jìn)行回滾的回滾指示信息，因而對事務(wù)消息對應(yīng)的事務(wù)進(jìn)行處理時(shí)，無需等待其他事務(wù)消息處理完成，也無需進(jìn)行數(shù)據(jù)鎖定，可使得針對同一數(shù)據(jù)的事務(wù)處理可并行進(jìn)行，提高分布式事務(wù)系統(tǒng)的吞吐量，提高事務(wù)處理效率。

同時(shí)，該方法可針對同一數(shù)據(jù)的事務(wù)處理并行進(jìn)行，突破針對熱點(diǎn)數(shù)據(jù)的事務(wù)處理的性能瓶頸，提高針對熱點(diǎn)數(shù)據(jù)的處理效率。并且，該方法無需記錄事務(wù)處理前的數(shù)據(jù)以及處理后的數(shù)據(jù)，僅需記錄該回滾指示信息便可，因而，還可節(jié)省記錄數(shù)據(jù)的開銷。