[發(fā)明專利]事務(wù)處理方法、裝置、設(shè)備、存儲(chǔ)介質(zhì)、數(shù)據(jù)庫(kù)

在審

• 申請(qǐng)?zhí)枺?/td>: 201910870661.2
• 申請(qǐng)日: 2019-09-16
• 公開（公告）號(hào): CN112596801A
• 公開（公告）日: 2021-04-02
• 發(fā)明（設(shè)計(jì)）人: 傅宇
• 申請(qǐng)（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號(hào): G06F9/445
• 分類號(hào): G06F9/445;G06F9/46;G06F16/18
• 代理公司: 北京太合九思知識(shí)產(chǎn)權(quán)代理有限公司 11610
• 代理人: 孫明子;劉戈

1.一種事務(wù)處理方法，其特征在于，包括：

接收分布式事務(wù)，所述分布式事務(wù)對(duì)應(yīng)有多個(gè)數(shù)據(jù)讀寫操作；

向所述多個(gè)數(shù)據(jù)讀寫操作各自對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)發(fā)送對(duì)應(yīng)的數(shù)據(jù)讀寫指令；

若所述多個(gè)數(shù)據(jù)讀寫操作涉及多個(gè)數(shù)據(jù)節(jié)點(diǎn)，則從所述多個(gè)數(shù)據(jù)節(jié)點(diǎn)中確定主數(shù)據(jù)節(jié)點(diǎn)和從數(shù)據(jù)節(jié)點(diǎn)；

向所述主數(shù)據(jù)節(jié)點(diǎn)發(fā)送事務(wù)日志寫入指令；

采用二階段提交協(xié)議控制所述從數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令，采用一階段提交協(xié)議控制所述主數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令和所述事務(wù)日志寫入指令。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述采用二階段提交協(xié)議控制所述從數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令，采用一階段提交協(xié)議控制所述主數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令和所述事務(wù)日志寫入指令，包括：

向所述從數(shù)據(jù)節(jié)點(diǎn)發(fā)送準(zhǔn)備提交指令；

若接收到所述從數(shù)據(jù)節(jié)點(diǎn)反饋的確認(rèn)信息，則向所述主數(shù)據(jù)節(jié)點(diǎn)發(fā)送所述事務(wù)日志寫入指令和提交指令，以使所述主數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令和所述事務(wù)日志寫入指令；

若接收到所述主數(shù)據(jù)節(jié)點(diǎn)反饋的確認(rèn)信息，則向所述從數(shù)據(jù)節(jié)點(diǎn)發(fā)送所述提交指令，以使所述從數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述向所述主數(shù)據(jù)節(jié)點(diǎn)發(fā)送所述事務(wù)日志寫入指令和提交指令，包括：

將所述事務(wù)日志寫入指令和提交指令封裝在一個(gè)數(shù)據(jù)報(bào)文中發(fā)送至所述主數(shù)據(jù)節(jié)點(diǎn)。

4.根據(jù)權(quán)利要求1至3中任一項(xiàng)所述的方法，其特征在于，所述從所述多個(gè)數(shù)據(jù)節(jié)點(diǎn)中確定主數(shù)據(jù)節(jié)點(diǎn)和從數(shù)據(jù)節(jié)點(diǎn)，包括：

根據(jù)所述多個(gè)數(shù)據(jù)讀寫操作的處理順序，確定最先處理的數(shù)據(jù)讀寫操作所對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)為主數(shù)據(jù)節(jié)點(diǎn)，其他的數(shù)據(jù)讀寫操作所對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)為從數(shù)據(jù)節(jié)點(diǎn)。

5.根據(jù)權(quán)利要求1至3中任一項(xiàng)所述的方法，其特征在于，所述從所述多個(gè)數(shù)據(jù)節(jié)點(diǎn)中確定主數(shù)據(jù)節(jié)點(diǎn)和從數(shù)據(jù)節(jié)點(diǎn)，包括：

隨機(jī)地從所述多個(gè)數(shù)據(jù)節(jié)點(diǎn)中選擇一個(gè)作為主數(shù)據(jù)節(jié)點(diǎn)，其他的數(shù)據(jù)節(jié)點(diǎn)作為從數(shù)據(jù)節(jié)點(diǎn)。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

若所述多個(gè)數(shù)據(jù)讀寫操作僅涉及一個(gè)數(shù)據(jù)節(jié)點(diǎn)，則采用一階段提交協(xié)議控制所述數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令。

7.一種事務(wù)處理裝置，其特征在于，包括：

接收模塊，用于接收分布式事務(wù)，所述分布式事務(wù)對(duì)應(yīng)有多個(gè)數(shù)據(jù)讀寫操作；

發(fā)送模塊，用于向所述多個(gè)數(shù)據(jù)讀寫操作各自對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)發(fā)送對(duì)應(yīng)的數(shù)據(jù)讀寫指令；

確定模塊，用于若所述多個(gè)數(shù)據(jù)讀寫操作涉及多個(gè)數(shù)據(jù)節(jié)點(diǎn)，則從所述多個(gè)數(shù)據(jù)節(jié)點(diǎn)中確定主數(shù)據(jù)節(jié)點(diǎn)和從數(shù)據(jù)節(jié)點(diǎn)；

所述發(fā)送模塊，還用于向所述主數(shù)據(jù)節(jié)點(diǎn)發(fā)送事務(wù)日志寫入指令；

提交模塊，用于采用二階段提交協(xié)議控制所述從數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令，采用一階段提交協(xié)議控制所述主數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令和所述事務(wù)日志寫入指令。

8.一種電子設(shè)備，其特征在于，包括：存儲(chǔ)器、處理器；其中，所述存儲(chǔ)器上存儲(chǔ)有可執(zhí)行代碼，當(dāng)所述可執(zhí)行代碼被所述處理器執(zhí)行時(shí)，使所述處理器執(zhí)行如權(quán)利要求1至6中任一項(xiàng)所述的事務(wù)處理方法。

9.一種非暫時(shí)性機(jī)器可讀存儲(chǔ)介質(zhì)，其特征在于，所述非暫時(shí)性機(jī)器可讀存儲(chǔ)介質(zhì)上存儲(chǔ)有可執(zhí)行代碼，當(dāng)所述可執(zhí)行代碼被電子設(shè)備的處理器執(zhí)行時(shí)，使所述處理器執(zhí)行如權(quán)利要求1至6中任一項(xiàng)所述的事務(wù)處理方法。

10.一種數(shù)據(jù)庫(kù)，其特征在于，包括：

多個(gè)數(shù)據(jù)節(jié)點(diǎn)以及數(shù)據(jù)庫(kù)服務(wù)；

所述數(shù)據(jù)庫(kù)服務(wù)，用于接收分布式事務(wù)，所述分布式事務(wù)對(duì)應(yīng)有多個(gè)數(shù)據(jù)讀寫操作；向所述多個(gè)數(shù)據(jù)讀寫操作各自對(duì)應(yīng)的數(shù)據(jù)節(jié)點(diǎn)發(fā)送對(duì)應(yīng)的數(shù)據(jù)讀寫指令；若所述多個(gè)數(shù)據(jù)讀寫操作涉及多個(gè)數(shù)據(jù)節(jié)點(diǎn)，則從所述多個(gè)數(shù)據(jù)節(jié)點(diǎn)中確定主數(shù)據(jù)節(jié)點(diǎn)和從數(shù)據(jù)節(jié)點(diǎn)，向所述主數(shù)據(jù)節(jié)點(diǎn)發(fā)送事務(wù)日志寫入指令；采用二階段提交協(xié)議控制所述從數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令，采用一階段提交協(xié)議控制所述主數(shù)據(jù)節(jié)點(diǎn)提交接收到的數(shù)據(jù)讀寫指令和所述事務(wù)日志寫入指令。