[發(fā)明專利]一種分布式版本管理方法、裝置和系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110414611.0
• 申請(qǐng)日: 2021-04-16
• 公開(kāi)（公告）號(hào): CN113076304A
• 公開(kāi)（公告）日: 2021-07-06
• 發(fā)明（設(shè)計(jì)）人: 趙力
• 申請(qǐng)（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F16/21
• 分類號(hào): G06F16/21;G06F16/23
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 宗磊;趙迪

1.一種分布式版本管理方法，其特征在于，包括：

從消息隊(duì)列中獲取消息；其中，所述消息是當(dāng)前業(yè)務(wù)節(jié)點(diǎn)執(zhí)行業(yè)務(wù)子流程生成的，包括所述當(dāng)前業(yè)務(wù)節(jié)點(diǎn)的節(jié)點(diǎn)標(biāo)識(shí)和局部消息版本；

根據(jù)所述節(jié)點(diǎn)標(biāo)識(shí)，從內(nèi)存存儲(chǔ)的統(tǒng)一版本信息中截取與所述節(jié)點(diǎn)標(biāo)識(shí)對(duì)應(yīng)的版本字段，得到全局消息版本；其中，所述統(tǒng)一版本信息包括多個(gè)業(yè)務(wù)節(jié)點(diǎn)的消息對(duì)應(yīng)的版本字段，且所述多個(gè)業(yè)務(wù)節(jié)點(diǎn)用于完成同一業(yè)務(wù)；

將所述局部消息版本與所述全局消息版本進(jìn)行比較，如果所述局部消息版本高于所述全局消息版本，則更新所述統(tǒng)一版本信息，將所述消息寫入數(shù)據(jù)庫(kù)；如果所述局部消息版本低于或等于所述全局消息版本，則刪除所述消息。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述版本字段為設(shè)定步長(zhǎng)的二進(jìn)制數(shù)值；

所述根據(jù)所述節(jié)點(diǎn)標(biāo)識(shí)，從內(nèi)存存儲(chǔ)的統(tǒng)一版本信息中截取與所述節(jié)點(diǎn)標(biāo)識(shí)對(duì)應(yīng)的版本字段，得到全局消息版本，包括：

根據(jù)所述節(jié)點(diǎn)標(biāo)識(shí)和所述步長(zhǎng)，確定所述消息對(duì)應(yīng)的版本字段在統(tǒng)一版本信息中占據(jù)的位置；

使用位運(yùn)算，從所述統(tǒng)一版本信息中截取所述位置的二進(jìn)制數(shù)值，將截取的所述二進(jìn)制數(shù)值作為所述全局消息版本。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述使用位運(yùn)算，從所述統(tǒng)一版本信息中截取所述位置的二進(jìn)制數(shù)值，包括：

生成二進(jìn)制字符串；其中，所述二進(jìn)制字符串的位數(shù)與所述統(tǒng)一版本信息的位數(shù)相同，且所述二進(jìn)制字符串中與所述位置對(duì)應(yīng)二進(jìn)制位的取值為1，其余二進(jìn)制位的取值為0；

將所述統(tǒng)一版本信息與所述二進(jìn)制字符串進(jìn)行按位與運(yùn)算，得到所述位置的二進(jìn)制數(shù)值。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述消息包括主鍵；

所述從內(nèi)存存儲(chǔ)的統(tǒng)一版本信息中截取與所述節(jié)點(diǎn)標(biāo)識(shí)對(duì)應(yīng)的版本字段的步驟之前，所述方法還包括：

根據(jù)設(shè)定的關(guān)聯(lián)關(guān)系，查找所述主鍵對(duì)應(yīng)的統(tǒng)一版本信息，確定查找失敗；其中，所述關(guān)聯(lián)關(guān)系用于記錄所述主鍵和所述統(tǒng)一版本信息之間的對(duì)應(yīng)關(guān)系；

根據(jù)所述節(jié)點(diǎn)標(biāo)識(shí)和所述局部消息版本，生成所述統(tǒng)一版本信息，將所述統(tǒng)一版本信息存儲(chǔ)到內(nèi)存。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述根據(jù)所述節(jié)點(diǎn)標(biāo)識(shí)和所述局部消息版本，生成所述統(tǒng)一版本信息，包括：

根據(jù)設(shè)定步長(zhǎng)，將所述局部消息版本轉(zhuǎn)換為對(duì)應(yīng)的二進(jìn)制數(shù)值；

將所述二進(jìn)制數(shù)值填充到所述節(jié)點(diǎn)標(biāo)識(shí)對(duì)應(yīng)的版本字段，將剩余的版本字段填充為0，得到所述統(tǒng)一版本信息。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述消息隊(duì)列用于存儲(chǔ)來(lái)自所述多個(gè)業(yè)務(wù)節(jié)點(diǎn)的、具有相同主鍵的消息；所述消息是根據(jù)預(yù)設(shè)的哈希函數(shù)和所述主鍵，分發(fā)到所述消息隊(duì)列的。

7.根據(jù)權(quán)利要求1至6的任一項(xiàng)所述的方法，其特征在于，所述方法還包括：

將更新后的所述統(tǒng)一版本信息同步到遠(yuǎn)程數(shù)據(jù)庫(kù)中，更新所述消息隊(duì)列的偏移量。

8.一種分布式版本管理裝置，其特征在于，包括：

消息獲取模塊，用于從消息隊(duì)列中獲取消息；其中，所述消息是當(dāng)前業(yè)務(wù)節(jié)點(diǎn)執(zhí)行業(yè)務(wù)子流程生成的，包括所述當(dāng)前業(yè)務(wù)節(jié)點(diǎn)的節(jié)點(diǎn)標(biāo)識(shí)和局部消息版本；

版本截取模塊，用于根據(jù)所述節(jié)點(diǎn)標(biāo)識(shí)，從內(nèi)存存儲(chǔ)的統(tǒng)一版本信息中截取與所述節(jié)點(diǎn)標(biāo)識(shí)對(duì)應(yīng)的版本字段，得到全局消息版本；其中，所述統(tǒng)一版本信息包括多個(gè)業(yè)務(wù)節(jié)點(diǎn)的消息對(duì)應(yīng)的版本字段，且所述多個(gè)業(yè)務(wù)節(jié)點(diǎn)用于完成同一業(yè)務(wù)；

比較處理模塊，用于將所述局部消息版本與所述全局消息版本進(jìn)行比較，如果所述局部消息版本高于所述全局消息版本，則更新所述統(tǒng)一版本信息，將所述消息寫入數(shù)據(jù)庫(kù)；如果所述局部消息版本低于或等于所述全局消息版本，則刪除所述消息。

9.一種分布式版本管理系統(tǒng)，其特征在于，包括：如權(quán)利要求8所述的分布式版本管理裝置和消息中間件；其中，

所述消息中間件，用于接收來(lái)自多個(gè)業(yè)務(wù)節(jié)點(diǎn)的消息，根據(jù)預(yù)設(shè)的哈希函數(shù)和所述消息的主鍵，將所述消息分發(fā)至對(duì)應(yīng)的消息隊(duì)列。