[發(fā)明專利]一種分布式事務(wù)處理的方法、裝置、系統(tǒng)和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011251444.4
• 申請日: 2020-11-10
• 公開（公告）號: CN113760566A
• 公開（公告）日: 2021-12-07
• 發(fā)明（設(shè)計）人: 李鵬程
• 申請（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司;北京京東世紀貿(mào)易有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/2455;G06F16/27;G06F16/28
• 代理公司: 北京德琦知識產(chǎn)權(quán)代理有限公司 11018
• 代理人: 鄭紅娟;宋志強

本申請公開了一種分布式事務(wù)處理的方法、裝置、系統(tǒng)和存儲介質(zhì)，包括：在接收到用戶的業(yè)務(wù)請求時，第一業(yè)務(wù)系統(tǒng)將產(chǎn)生的業(yè)務(wù)數(shù)據(jù)進行保存，并將業(yè)務(wù)數(shù)據(jù)的狀態(tài)設(shè)置為未完成的狀態(tài)；第一業(yè)務(wù)系統(tǒng)發(fā)送由消息隊列(MQ)消息體組成的業(yè)務(wù)消息，在接收到業(yè)務(wù)回執(zhí)時，將業(yè)務(wù)數(shù)據(jù)的狀態(tài)設(shè)置為已完成的狀態(tài)。應(yīng)用本申請方法實施例方案，由于將業(yè)務(wù)消息和業(yè)務(wù)回執(zhí)利用MQ消息體的格式，采用異步方式傳輸，降低了第一業(yè)務(wù)系統(tǒng)和第二業(yè)務(wù)系統(tǒng)之間的耦合性；且，第一業(yè)務(wù)系統(tǒng)為業(yè)務(wù)數(shù)據(jù)設(shè)置了狀態(tài)，并根據(jù)業(yè)務(wù)消息的執(zhí)行情況變更其業(yè)務(wù)數(shù)據(jù)的狀態(tài)，從而在不引入事務(wù)協(xié)調(diào)者的情況下，仍然可以保證分布式系統(tǒng)中數(shù)據(jù)的一致性，降低了系統(tǒng)的復(fù)雜性。

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

本申請涉及計算機技術(shù)領(lǐng)域，尤其涉及一種分布式事務(wù)處理的方法、一種分布式事務(wù)處理的裝置、一種分布式事務(wù)處理的系統(tǒng)、一種計算機可讀存儲介質(zhì)以及一種電子設(shè)備。

背景技術(shù)

隨著業(yè)務(wù)系統(tǒng)復(fù)雜性的增加，單臺計算機或服務(wù)器已經(jīng)很難單獨進行處理，需要由多臺計算機或服務(wù)器協(xié)作處理。為了增強在多臺機器上運行的系統(tǒng)的可擴展性、穩(wěn)定性和執(zhí)行效率，通常將多臺機器采用分布式系統(tǒng)的結(jié)構(gòu)來組織。

由于同一業(yè)務(wù)分布在不同的機器節(jié)點上實現(xiàn)，為了保證數(shù)據(jù)的一致性，就需要分布式系統(tǒng)采用某種機制進行分布式事務(wù)管理。現(xiàn)有技術(shù)可以采用兩階段提交(2PC，Two-phase Commit)方案和補償事務(wù)(TCC，Try-Confirm-Cancel)方案來保證數(shù)據(jù)的一致性。不管是2PC方案，還是TCC方案，都需要引入事務(wù)協(xié)調(diào)者，由事務(wù)協(xié)調(diào)者確定各個階段的同步工作，大大增加了系統(tǒng)的復(fù)雜性。

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

針對上述現(xiàn)有技術(shù)，本申請?zhí)峁┮环N分布式事務(wù)處理的方法，可以克服現(xiàn)有技術(shù)引入事務(wù)協(xié)調(diào)者導(dǎo)致的增加系統(tǒng)復(fù)雜性的問題，達到無需引入事務(wù)協(xié)調(diào)者就可以保證數(shù)據(jù)一致性的目的。

本申請方法實施例提出的一種分布式事務(wù)處理的方法，具體包括：

在接收到用戶的業(yè)務(wù)請求時，第一業(yè)務(wù)系統(tǒng)將產(chǎn)生的業(yè)務(wù)數(shù)據(jù)進行保存，并將所述業(yè)務(wù)數(shù)據(jù)的狀態(tài)設(shè)置為未完成的狀態(tài)，所述業(yè)務(wù)數(shù)據(jù)為針對所述用戶的業(yè)務(wù)請求所產(chǎn)生的數(shù)據(jù)；

所述第一業(yè)務(wù)系統(tǒng)發(fā)送由消息隊列(MQ)消息體組成的業(yè)務(wù)消息，所述業(yè)務(wù)消息為針對所述用戶的業(yè)務(wù)請求所產(chǎn)生的需要由第二業(yè)務(wù)系統(tǒng)執(zhí)行的消息；

所述第一業(yè)務(wù)系統(tǒng)接收由MQ消息體組成的業(yè)務(wù)回執(zhí)時，將所述業(yè)務(wù)數(shù)據(jù)的狀態(tài)設(shè)置為已完成的狀態(tài)，所述業(yè)務(wù)回執(zhí)為所述第二業(yè)務(wù)系統(tǒng)執(zhí)行完所述業(yè)務(wù)消息后反饋的消息，所述第一業(yè)務(wù)系統(tǒng)和所述第二業(yè)務(wù)系統(tǒng)構(gòu)成分布式系統(tǒng)。

進一步地，

所述第一業(yè)務(wù)系統(tǒng)發(fā)送由MQ消息體組成的業(yè)務(wù)消息的步驟包括：所述第一業(yè)務(wù)系統(tǒng)將由所述MQ消息體組成的業(yè)務(wù)消息發(fā)送給中間件隊列服務(wù)器，所述中間件隊列服務(wù)器將所述MQ業(yè)務(wù)放置于消息隊列中，由所述第二業(yè)務(wù)系統(tǒng)從所述消息隊列中獲取所述業(yè)務(wù)消息；

所述第一業(yè)務(wù)系統(tǒng)接收由MQ消息體組成的業(yè)務(wù)回執(zhí)的步驟包括：所述第一業(yè)務(wù)系統(tǒng)從所述中間件隊列服務(wù)器的消息隊列中獲取所述業(yè)務(wù)回執(zhí)，所述業(yè)務(wù)回執(zhí)為所述第二業(yè)務(wù)系統(tǒng)執(zhí)行完所述業(yè)務(wù)消息后發(fā)送給所述中間件隊列服務(wù)器的。

進一步地，

所述第一業(yè)務(wù)系統(tǒng)將產(chǎn)生的業(yè)務(wù)數(shù)據(jù)進行保存的步驟包括：

所述第一業(yè)務(wù)系統(tǒng)先將產(chǎn)生的業(yè)務(wù)數(shù)據(jù)保存在業(yè)務(wù)數(shù)據(jù)庫中；

所述第一業(yè)務(wù)系統(tǒng)再將所述業(yè)務(wù)數(shù)據(jù)保存在中間件緩存服務(wù)器；

所述將業(yè)務(wù)數(shù)據(jù)的狀態(tài)設(shè)置為已完成的狀態(tài)的步驟之后，該方法進一步包括：所述第一業(yè)務(wù)系統(tǒng)刪除所述中間件緩存服務(wù)器中的所述業(yè)務(wù)數(shù)據(jù)。

進一步地，

所述第一業(yè)務(wù)系統(tǒng)再將所述業(yè)務(wù)數(shù)據(jù)保存在中間件緩存服務(wù)器之后，該方法進一步包括：