[發(fā)明專(zhuān)利]一種事務(wù)處理方法與裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201710113569.2
• 申請(qǐng)日: 2013-11-05
• 公開(kāi)（公告）號(hào): CN106997305B
• 公開(kāi)（公告）日: 2020-09-29
• 發(fā)明（設(shè)計(jì)）人: 方新
• 申請(qǐng)（專(zhuān)利權(quán)）人: 華為技術(shù)有限公司
• 主分類(lèi)號(hào): G06F9/46
• 分類(lèi)號(hào): G06F9/46;G06F9/50;G06F9/54
• 代理公司: 暫無(wú)信息
• 代理人: 暫無(wú)信息

1.一種事務(wù)處理方法，應(yīng)用于分布式存儲(chǔ)系統(tǒng)中的協(xié)調(diào)者，所述協(xié)調(diào)者和分布式存儲(chǔ)系統(tǒng)中的參與者通信連接，所述協(xié)調(diào)者、參與者都是對(duì)象存儲(chǔ)設(shè)備OSD，事務(wù)操作的對(duì)象由多個(gè)子對(duì)象組成，其中，一個(gè)所述子對(duì)象位于所述協(xié)調(diào)者中，其他所述子對(duì)象分別位于不同的所述參與者中，其特征在于，該方法包括：

所述協(xié)調(diào)者向各個(gè)參與者發(fā)送查詢(xún)消息，所述查詢(xún)消息中攜帶有事務(wù)ID、對(duì)象ID以及所述對(duì)象的變化信息，其中，所述事務(wù)ID用于標(biāo)記所述事務(wù)，所述對(duì)象ID用于標(biāo)記所述對(duì)象，所述變化信息與所述對(duì)象的內(nèi)容對(duì)應(yīng)，不同所述變化信息的所述對(duì)象的內(nèi)容不同；

所述協(xié)調(diào)者接收各個(gè)參與者對(duì)所述查詢(xún)消息的響應(yīng)消息；

所述協(xié)調(diào)者根據(jù)所述響應(yīng)消息得出結(jié)論，所述協(xié)調(diào)者執(zhí)行所述結(jié)論，并將所述結(jié)論發(fā)送給所述參與者，所述結(jié)論包括：

對(duì)操作類(lèi)型是新建或者修改的事務(wù)，如果任一參與者返回的信息指示了對(duì)象的變化信息相同，則結(jié)論是執(zhí)行事務(wù)。

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

所述事務(wù)是對(duì)所有所述子對(duì)象進(jìn)行讀取、對(duì)所有所述子對(duì)象刪除或者對(duì)所有所述子對(duì)象寫(xiě)入。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述協(xié)調(diào)者、所述參與者均與原協(xié)調(diào)者通信連接，所述原協(xié)調(diào)者無(wú)子對(duì)象，所述方法之前進(jìn)一步包括：

原協(xié)調(diào)者失效后，選擇原參與者中的一個(gè)作為所述協(xié)調(diào)者。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，原協(xié)調(diào)者失效之前，所述方法進(jìn)一步包括：

所述協(xié)調(diào)者接收原協(xié)調(diào)者發(fā)送所述事務(wù)ID、對(duì)象ID、對(duì)象的變化信息以及參與者清單。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，原協(xié)調(diào)者失效之前，所述方法進(jìn)一步包括：

所述原協(xié)調(diào)者發(fā)送操作請(qǐng)求給各個(gè)參與者，所述操作請(qǐng)求中攜帶有所述對(duì)象ID，操作類(lèi)型、協(xié)調(diào)者中記錄的對(duì)象的變化信息以及參與者清單，所述參與者清單中記錄有所述原參與者；

所述協(xié)調(diào)者發(fā)送準(zhǔn)備命令給各個(gè)參與者，命令中攜帶事務(wù)ID、對(duì)象ID、協(xié)調(diào)者中記錄的對(duì)象的變化信息，以及參與者清單，以使各個(gè)所述原參與者接收存儲(chǔ)參與者清單，并為事務(wù)分配資源。

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

所述對(duì)象的變化信息是對(duì)象的版本號(hào)。

7.一種事務(wù)處理裝置，與分布式存儲(chǔ)系統(tǒng)中的參與者通信連接，事務(wù)操作的對(duì)象由多個(gè)子對(duì)象組成，所述事務(wù)處理裝置執(zhí)行協(xié)調(diào)者的功能，其中，所述協(xié)調(diào)者、參與者都是對(duì)象存儲(chǔ)設(shè)備OSD，其中，一個(gè)所述子對(duì)象位于所述事務(wù)處理裝置中，其他所述子對(duì)象分別位于不同的所述參與者中，其特征在于，該裝置包括：

查詢(xún)模塊，用于向各個(gè)參與者發(fā)送查詢(xún)消息，所述查詢(xún)消息中攜帶有事務(wù)ID、對(duì)象ID以及所述對(duì)象的變化信息，其中所述事務(wù)ID用于標(biāo)記所述事務(wù)，所述對(duì)象ID用于標(biāo)記所述對(duì)象，所述變化信息與所述對(duì)象的內(nèi)容對(duì)應(yīng)，不同所述變化信息的所述對(duì)象的內(nèi)容不同；

接收模塊，用于接收各個(gè)參與者對(duì)所述查詢(xún)消息的響應(yīng)消息；

決策模塊，用于根據(jù)所述響應(yīng)消息得出結(jié)論，并將所述結(jié)論發(fā)送給所述參與者，所述結(jié)論包括：

對(duì)操作類(lèi)型是新建或者修改的事務(wù)，如果任一參與者返回的信息指示了對(duì)象的變化信息相同，則結(jié)論是執(zhí)行事務(wù)；

執(zhí)行模塊，用于執(zhí)行所述決策模塊的結(jié)論。

8.根據(jù)權(quán)利要求7所述的事務(wù)處理裝置，其特征在于：

所述事務(wù)是對(duì)所有所述子對(duì)象進(jìn)行讀取、對(duì)所有所述子對(duì)象刪除或者對(duì)所有所述子對(duì)象寫(xiě)入。

9.根據(jù)權(quán)利要求7或8所述的事務(wù)處理裝置，其特征在于，所述協(xié)調(diào)者、所述參與者均與原協(xié)調(diào)者通信連接，所述原協(xié)調(diào)者無(wú)子對(duì)象，所述接收模塊進(jìn)一步包括：

接收原協(xié)調(diào)者發(fā)送的所述事務(wù)ID、對(duì)象ID、對(duì)象的變化信息以及參與者清單給各個(gè)參與者。

10.根據(jù)權(quán)利要求7或8所述的事務(wù)處理裝置，其特征在于：

所述對(duì)象的變化信息是對(duì)象的版本號(hào)。