Synchronization processing method and related apparatus

Patent metadata

Field	Value
Publication number	US-12099482-B2
Application number	US-202217721231-A
Country	US
Kind code	B2
Filing date	Apr 14, 2022
Priority date	Mar 24, 2020
Publication date	Sep 24, 2024
Grant date	Sep 24, 2024

Abstract

Embodiments of this application provide a synchronization processing method, apparatus, and device, and a medium. The method includes obtaining a skeleton set and a synchronization task set, the skeleton set being used for storing M blocks to be synchronized by the first node device, the skeleton set comprising P skeletons, the synchronization task set comprising P synchronization tasks, the P skeletons being of a one-to-one correspondence to the P synchronization tasks, and M and P both being positive integers; selecting a second node device from the candidate node set, the second node device being a candidate node device in the candidate node set; concurrently transmitting synchronization tasks in the synchronization task set to the second node device, the second node device performing the synchronization tasks and returning the M blocks; and filling the M blocks into the skeletons in the skeleton set.

First claim

What is claimed is:

1. A synchronization processing method, performed by a first node device in a blockchain network, the blockchain network comprising a candidate node set, the candidate node set comprising a plurality of candidate node devices connected to the first node device, and the method comprising:
obtaining a skeleton set and a synchronization task set, the skeleton set being used for storing M blocks to be synchronized by the first node device, the skeleton set comprising P skeletons, the synchronization task set comprising P synchronization tasks, the P skeletons being of a one-to-one correspondence to the P synchronization tasks, and M and P both being positive integers;
selecting a second node device from the candidate node set, the second node device being a candidate node device in the candidate node set;
concurrently transmitting synchronization tasks in the synchronization task set to the second node device, comprising:
dividing the synchronization tasks in the synchronization task set into one or more batches and transmitting each batch concurrently according to a corresponding order of the M blocks;

obtaining the M blocks returned by the second node device; and
filling the M blocks into the skeletons in the skeleton set.

2. The method according to claim 1 , wherein a target skeleton is one of the P skeletons; and
the target skeleton comprises N data units, the N data units are configured to store N blocks to be synchronized by the first node device, the N blocks are of a one-to-one correspondence to the N data units, and N is a positive integer and N≤M.

3. The method according to claim 2 , wherein the N data units in the target skeleton are sequentially arranged, and the N blocks are consecutive blocks in the blockchain network;
an i th data unit among the N data units is configured to store an i th block among the N blocks; and i is a positive integer and 1≤i≤N.

4. The method according to claim 2 , wherein a plurality of second node devices is selected from the candidate node set and configured to perform the synchronization tasks, a target second node device is one of the second node devices; the target second node device is configured to perform a target synchronization task corresponding to the target skeleton, and return the N blocks to the first node device; and
for the target second node device, the filling the M blocks into the skeletons in the skeleton set comprises:
respectively filling the N blocks into the N data units of the target skeleton.

5. The method according to claim 4 , wherein further comprising:
reading the N blocks stored in the N data units from the target skeleton, and sequentially adding the read N blocks to a first blockchain locally stored in the first node device.

6. The method according to claim 1 , wherein the selecting a second node device from the candidate node set comprises:
obtaining trust degrees of the candidate node devices in the candidate node set; and
determining a candidate node device whose trust degree in the candidate node set is higher than a trust threshold as the second node device.

7. The method according to claim 1 , wherein the selecting a second node device from the candidate node set comprises:
obtaining processing performances of the candidate node devices in the candidate node set; and
determining a one candidate node device whose processing performance in the candidate node set is better than a performance threshold as the second node device.

8. The method according to claim 1 , wherein the selecting a second node device from the candidate node set comprises:
receiving block storage statements of the candidate node devices in the candidate node set; and
selecting a candidate node device from the candidate node set as the second node device according to the block storage statements of the candidate node devices in the candidate node set.

9. The method according to claim 1 , wherein the obtaining a skeleton set comprises:
obtaining a block height of a reference blockchain in the blockchain network, and obtaining a block height of a first blockchain locally stored in the first node device;
determining M blocks by which the block height of the reference blockchain and the block height of the first blockchain differ as blocks to be synchronized by the first node device; and
constructing the skeleton set according to the M blocks.

10. The method according to claim 1 , wherein the concurrently transmitting synchronization tasks to the second node device includes transmitting indication information, the indication information including a plurality of indexes of blocks corresponding to a first data unit and a last data unit of a target skeleton in the P skeletons.

11. The method according to claim 10 , wherein each index of the plurality of indexes comprises a hash value of a corresponding block, a generation timestamp of the corresponding block and a block height of the corresponding block.

12. A synchronization processing apparatus, disposed in a first node device in a blockchain network, the blockchain network comprising a candidate node set, the candidate node set comprising a plurality of candidate node devices connected to the first node device, and the synchronization processing apparatus comprising a memory and a processor coupled to the memory, the processor being configured to:
obtain a skeleton set and a synchronization task set, the skeleton set being used for storing M blocks to be synchronized by the first node device, the skeleton set comprising P skeletons, the synchronization task set comprising P synchronization tasks, the P skeletons being in a one-to-one correspondence to the P synchronization tasks, and M and P both being positive integers;
select a second node device from the candidate node set, the second node device being a candidate node device in the candidate node set; concurrently transmit synchronization tasks in the synchronization task set to the second node device comprising:
divide the synchronization tasks in the synchronization task set into one or more batches and transmit each batch concurrently according to a corresponding order of the M blocks;
obtain the M blocks returned by the second node device; and
fill the M blocks into the skeletons in the skeleton set.

13. The apparatus according to claim 12 , wherein a target skeleton is one of the P skeletons; and
the target skeleton comprises N data units, the N data units are configured to store N blocks to be synchronized by the first node device, the N blocks are of a one-to-one correspondence to the N data units, and N is a positive integer and N≤M.

14. A non-transitory computer readable medium storing computer instructions, the computer instructions, when executed by a computer, causing the computer to perform a synchronization processing method comprising:
obtaining a skeleton set and a synchronization task set, the skeleton set being used for storing M blocks to be synchronized by the first node device, the skeleton set comprising P skeletons, the synchronization task set comprising P synchronization tasks, the P skeletons being of a one-to-one correspondence to the P synchronization tasks, and M and P both being positive integers;
selecting a second node device from the candidate node set, the second node device being a candidate node device in the candidate node set;
concurrently transmitting synchronization tasks in the synchronization task set to the second node device, comprising:
dividing the synchronization tasks in the synchronization task set into one or more batches and transmitting each batch concurrently according to a correspon

Assignees

• Tencent Tech Shenzhen Co Ltd

Inventors

• Li Maocai
• Wang Zongyou
• Zhang Jinsong
• Zhou Kaiban
• Shi Yifang
• Huang Huankun
• Liu Qucheng
• Liu Pan
• Lan Hu
• Yang Changqing
• Zhu Gengliang
• Kong Li

Classifications

• G06F16/27

  Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor · CPC title

• G06Q2220/00

  Business processing using cryptography · CPC title

• G06Q40/04

  Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange · CPC title

• G06Q40/02

  Banking, e.g. interest calculation or account maintenance (credit or loans G06Q40/03) · CPC title

• G06Q30/06

  Buying, selling or leasing transactions · CPC title