[發(fā)明專利]分布式事務(wù)的實(shí)現(xiàn)方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201810924100.1
• 申請(qǐng)日: 2018-08-14
• 公開（公告）號(hào): CN109325073B
• 公開（公告）日: 2021-08-17
• 發(fā)明（設(shè)計(jì)）人: 宋忠平
• 申請(qǐng)（專利權(quán)）人: 創(chuàng)新先進(jìn)技術(shù)有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/23;G06F11/14
• 代理公司: 北京博思佳知識(shí)產(chǎn)權(quán)代理有限公司 11415
• 代理人: 林祥

1.一種分布式事務(wù)的實(shí)現(xiàn)方法，應(yīng)用于嵌套有若干子事務(wù)的分布式主事務(wù)的事務(wù)處理，預(yù)先為每個(gè)所述子事務(wù)設(shè)置有事務(wù)狀態(tài)表，用于記錄所述子事務(wù)處理過的事務(wù)標(biāo)識(shí)及事務(wù)狀態(tài)，所述方法包括：

所述子事務(wù)在接收到所述主事務(wù)發(fā)送的事務(wù)標(biāo)識(shí)后，基于所述事務(wù)狀態(tài)表判斷所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)是否已提交成功；

若已提交成功，則向所述主事務(wù)返回提交成功的消息；

若未提交成功，則提交所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，所述判斷所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)是否已提交成功，包括：

在事務(wù)狀態(tài)表中查找所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)狀態(tài)；

若查找到的事務(wù)狀態(tài)是已提交，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)已提交成功；

若查找到的事務(wù)狀態(tài)是已回滾，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)未提交成功；

若所述事務(wù)狀態(tài)表中未記錄所述事務(wù)標(biāo)識(shí)，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)未提交成功。

3.根據(jù)權(quán)利要求2所述的方法，還包括：

在提交所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)后，根據(jù)提交結(jié)果和所述事務(wù)標(biāo)識(shí)更新所述事務(wù)狀態(tài)表。

4.根據(jù)權(quán)利要求2所述的方法，

所述事務(wù)狀態(tài)表中還記錄有事務(wù)狀態(tài)修改時(shí)間；

所述方法還包括：

當(dāng)所述事務(wù)狀態(tài)修改時(shí)間距今時(shí)長(zhǎng)超出預(yù)定時(shí)長(zhǎng)時(shí)，發(fā)送報(bào)警信息。

5.根據(jù)權(quán)利要求1所述的方法，還包括：

在目標(biāo)冪等數(shù)據(jù)表中插入所述事務(wù)標(biāo)識(shí)；

若插入失敗，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)已提交成功。

6.一種分布式事務(wù)的實(shí)現(xiàn)裝置，應(yīng)用于嵌套有若干子事務(wù)的分布式主事務(wù)的事務(wù)處理，預(yù)先為每個(gè)所述子事務(wù)設(shè)置有事務(wù)狀態(tài)表，用于記錄所述子事務(wù)處理過的事務(wù)標(biāo)識(shí)及事務(wù)狀態(tài)，所述裝置應(yīng)用于子事務(wù)參與者包括：

成功判斷單元，在接收到所述主事務(wù)發(fā)送的事務(wù)標(biāo)識(shí)后，基于所述事務(wù)狀態(tài)表判斷所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)是否已提交成功；

消息返回單元，若已提交成功，則向所述主事務(wù)返回提交成功的消息；

事務(wù)提交單元，若未提交成功，則提交所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)。

7.根據(jù)權(quán)利要求6所述的裝置，所述成功判斷單元：

在事務(wù)狀態(tài)表中查找所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)狀態(tài)；

若查找到的事務(wù)狀態(tài)是已提交，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)已提交成功；

若查找到的事務(wù)狀態(tài)是已回滾，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)未提交成功；

若所述事務(wù)狀態(tài)表中未記錄所述事務(wù)標(biāo)識(shí)，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)未提交成功。

8.根據(jù)權(quán)利要求7所述的裝置，還包括：

狀態(tài)更新單元，在提交所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)后，根據(jù)提交結(jié)果和所述事務(wù)標(biāo)識(shí)更新所述事務(wù)狀態(tài)表。

9.根據(jù)權(quán)利要求7所述的裝置，

所述事務(wù)狀態(tài)表中還記錄有事務(wù)狀態(tài)修改時(shí)間；

所述裝置還包括：

報(bào)警單元，當(dāng)所述事務(wù)狀態(tài)修改時(shí)間距今時(shí)長(zhǎng)超出預(yù)定時(shí)長(zhǎng)時(shí)，發(fā)送報(bào)警信息。

10.根據(jù)權(quán)利要求6所述的裝置，所述成功判斷單元：

在目標(biāo)冪等數(shù)據(jù)表中插入所述事務(wù)標(biāo)識(shí)；

若插入失敗，則確認(rèn)所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)已提交成功。

11.一種分布式事務(wù)的實(shí)現(xiàn)裝置，應(yīng)用于子事務(wù)參與者，包括：

處理器；

用于存儲(chǔ)機(jī)器可執(zhí)行指令的存儲(chǔ)器；

其中，通過讀取并執(zhí)行所述存儲(chǔ)器存儲(chǔ)的與分布式事務(wù)的實(shí)現(xiàn)邏輯對(duì)應(yīng)的機(jī)器可執(zhí)行指令，所述處理器被促使：

在接收到主事務(wù)發(fā)送的事務(wù)標(biāo)識(shí)后，基于所述子事務(wù)參與者對(duì)應(yīng)的事務(wù)狀態(tài)表判斷所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)是否已提交成功，所述事務(wù)狀態(tài)表用于記錄所述子事務(wù)參與者處理過的事務(wù)標(biāo)識(shí)及事務(wù)狀態(tài)；

若已提交成功，則向所述主事務(wù)返回提交成功的消息；

若未提交成功，則提交所述事務(wù)標(biāo)識(shí)對(duì)應(yīng)的事務(wù)。