[發(fā)明專利]分布式系統(tǒng)的數(shù)據(jù)同步方法、裝置、介質(zhì)、電子設(shè)備

有效

• 申請?zhí)枺?/td>: 201910636195.1
• 申請日: 2019-07-15
• 公開（公告）號: CN110365768B
• 公開（公告）日: 2021-07-06
• 發(fā)明（設(shè)計(jì)）人: 劉攀
• 申請（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06F16/23;G06F16/27
• 代理公司: 深圳市隆天聯(lián)鼎知識產(chǎn)權(quán)代理有限公司 44232
• 代理人: 王鵬健

1.一種分布式系統(tǒng)的數(shù)據(jù)同步方法，其特征在于，所述分布式系統(tǒng)包括多個(gè)節(jié)點(diǎn)，所述數(shù)據(jù)同步方法包括：

獲取與目標(biāo)節(jié)點(diǎn)相連的鄰接節(jié)點(diǎn)的歷史數(shù)據(jù)同步信息；

根據(jù)所述歷史數(shù)據(jù)同步信息確定所述鄰接節(jié)點(diǎn)的選擇權(quán)重值，所述選擇權(quán)重值用于衡量所述鄰接節(jié)點(diǎn)向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的效率；

根據(jù)所述鄰接節(jié)點(diǎn)的選擇權(quán)重值，選擇用于向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的目標(biāo)鄰接節(jié)點(diǎn)，以將所述目標(biāo)鄰接節(jié)點(diǎn)中的目標(biāo)數(shù)據(jù)同步至所述目標(biāo)節(jié)點(diǎn)；

所述分布式系統(tǒng)包括區(qū)塊鏈系統(tǒng)，所述目標(biāo)數(shù)據(jù)包括區(qū)塊頭數(shù)據(jù)和完整區(qū)塊數(shù)據(jù)，所述根據(jù)所述鄰接節(jié)點(diǎn)的選擇權(quán)重值，選擇用于向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的目標(biāo)鄰接節(jié)點(diǎn)，以將所述目標(biāo)鄰接節(jié)點(diǎn)中的目標(biāo)數(shù)據(jù)同步至所述目標(biāo)節(jié)點(diǎn)，包括：

根據(jù)所述鄰接節(jié)點(diǎn)的選擇權(quán)重值，選擇用于向所述目標(biāo)節(jié)點(diǎn)同步所述區(qū)塊頭數(shù)據(jù)的第一目標(biāo)鄰接節(jié)點(diǎn)，以從所述第一目標(biāo)鄰接節(jié)點(diǎn)中同步所述區(qū)塊頭數(shù)據(jù)；

在同步所述區(qū)塊頭數(shù)據(jù)之后，根據(jù)所述鄰接節(jié)點(diǎn)的選擇權(quán)重值，選擇用于向所述目標(biāo)節(jié)點(diǎn)同步所述完整區(qū)塊數(shù)據(jù)的第二目標(biāo)鄰接節(jié)點(diǎn)，以從所述第二目標(biāo)鄰接節(jié)點(diǎn)中同步所述完整區(qū)塊數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)鄰接節(jié)點(diǎn)的選擇權(quán)重值，選擇用于向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的目標(biāo)鄰接節(jié)點(diǎn)，包括：

檢測與所述目標(biāo)節(jié)點(diǎn)相連的各個(gè)鄰接節(jié)點(diǎn)是否存在需要向所述目標(biāo)節(jié)點(diǎn)進(jìn)行同步的數(shù)據(jù)，得到需要向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的候選鄰接節(jié)點(diǎn)；

根據(jù)所述候選鄰接節(jié)點(diǎn)的選擇權(quán)重值，選擇用于向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的目標(biāo)鄰接節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，獲取與目標(biāo)節(jié)點(diǎn)相連的鄰接節(jié)點(diǎn)的歷史數(shù)據(jù)同步信息，包括：

檢測與所述目標(biāo)節(jié)點(diǎn)相連的各個(gè)鄰接節(jié)點(diǎn)是否存在需要向所述目標(biāo)節(jié)點(diǎn)進(jìn)行同步的數(shù)據(jù)，得到需要向所述目標(biāo)節(jié)點(diǎn)同步數(shù)據(jù)的候選鄰接節(jié)點(diǎn)；

獲取所述候選鄰接節(jié)點(diǎn)的歷史數(shù)據(jù)同步信息。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述分布式系統(tǒng)包括區(qū)塊鏈系統(tǒng)，所述目標(biāo)數(shù)據(jù)包括區(qū)塊數(shù)據(jù)，

所述檢測與所述目標(biāo)節(jié)點(diǎn)相連的各個(gè)鄰接節(jié)點(diǎn)是否存在需要向所述目標(biāo)節(jié)點(diǎn)進(jìn)行同步的數(shù)據(jù)，包括：

獲取目標(biāo)節(jié)點(diǎn)中區(qū)塊鏈賬本的第一區(qū)塊頭高度；

獲取與目標(biāo)節(jié)點(diǎn)相連的鄰接節(jié)點(diǎn)中區(qū)塊鏈賬本的第二區(qū)塊頭高度；

比較所述第一區(qū)塊頭高度與所述第二區(qū)塊頭高度的大小，以檢測與所述目標(biāo)節(jié)點(diǎn)相連的各個(gè)鄰接節(jié)點(diǎn)是否存在需要向所述目標(biāo)節(jié)點(diǎn)進(jìn)行同步的數(shù)據(jù)。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述歷史數(shù)據(jù)同步信息包括目標(biāo)節(jié)點(diǎn)與所述鄰接節(jié)點(diǎn)在歷史上同步數(shù)據(jù)過程中的出錯(cuò)次數(shù)，

根據(jù)所述歷史數(shù)據(jù)同步信息確定所述鄰接節(jié)點(diǎn)的選擇權(quán)重值，包括：

檢測出所述出錯(cuò)次數(shù)未超過出錯(cuò)次數(shù)閾值的鄰接節(jié)點(diǎn)；

根據(jù)所述歷史數(shù)據(jù)同步信息確定所述出錯(cuò)次數(shù)未超過所述出錯(cuò)次數(shù)閾值的鄰接節(jié)點(diǎn)的選擇權(quán)重值。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述歷史數(shù)據(jù)同步信息包括歷史數(shù)據(jù)傳輸速度和歷史數(shù)據(jù)請求時(shí)刻，

根據(jù)所述歷史數(shù)據(jù)同步信息確定所述鄰接節(jié)點(diǎn)的選擇權(quán)重值包括：通過以下公式計(jì)算所述鄰接節(jié)點(diǎn)的選擇權(quán)重值：

其中，W_i表示第i個(gè)鄰接節(jié)點(diǎn)的選擇權(quán)重值；j表示目標(biāo)節(jié)點(diǎn)與第i個(gè)鄰接節(jié)點(diǎn)在歷史上第j次進(jìn)行數(shù)據(jù)同步；m表示目標(biāo)節(jié)點(diǎn)與第i個(gè)鄰接節(jié)點(diǎn)在歷史上第m次進(jìn)行數(shù)據(jù)同步；n表示目標(biāo)節(jié)點(diǎn)與第i個(gè)鄰接節(jié)點(diǎn)在歷史上最近n次進(jìn)行數(shù)據(jù)同步的次數(shù)；S_j表示目標(biāo)節(jié)點(diǎn)與第i個(gè)鄰接節(jié)點(diǎn)在歷史上第j次進(jìn)行數(shù)據(jù)同步過程中的歷史數(shù)據(jù)傳輸速度；t_j表示目標(biāo)節(jié)點(diǎn)與第i個(gè)鄰接節(jié)點(diǎn)在歷史上第j次進(jìn)行數(shù)據(jù)同步時(shí)的歷史數(shù)據(jù)請求時(shí)刻；t表示計(jì)算所述第i個(gè)鄰接節(jié)點(diǎn)選擇權(quán)重值時(shí)的時(shí)刻。