Method and apparatus for writing service data into block chain and method for determining service subset

• US 10,642,643 B2
• Filed: 08/07/2019
• Issued: 05/05/2020
• Est. Priority Date: 02/28/2017
• Status: Active Grant

• Current Assignee: Advanced New Technologies Company Limited (Ant Group Co., Ltd.)
• Original Assignee: Alibaba Group Holding Ltd.
• Inventors: Qiu, Honglin
• Primary Examiner(s): Zhao, Bing
• Application Number:
  US16/535,035
• Publication Number:
  US 20190361731A1
• Time in Patent Office: 272 Days
• Field of Search: None
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 9/28 Enhancement of operational speed, e.g. by using several microcontrol devices operating in parallel
• CPC Class Codes: G06F 9/466 Transaction processing
• CPC Class Codes: G06F 9/4837 time dependent
• CPC Class Codes: H04L 9/0637 Modes of operation, e.g. cipher block chaining [CBC], electronic codebook [ECB] or Galois/counter mode [GCM]

Abstract

Methods, systems, and apparatus, including computer programs encoded on computer storage media, for adding transaction data into a blockchain are provided. One of the methods includes: obtaining transaction data to be added into the blockchain, assigning the transaction data into transaction subsets, and executing the transaction subsets in parallel, and storing results of the execution into the blockchain. Pieces of the transaction data having at least one of: a same transaction type or an overlapping scope of data change are assigned into a same transaction subset, and pieces of the transaction data with different transaction types and with no overlapping scope of data change are assigned into different transaction subsets.

Claims

1. A method for adding transaction data into a blockchain, comprising:

obtaining a plurality of pieces of transaction data to be added into the blockchain;

assigning the plurality of pieces of transaction data into one or more transaction subsets according to one or more criteria,

wherein the one or more criteria comprise;

each of the one or more transaction subsets is assigned with transaction data having at least one of;

a same transaction type or an overlapping range of data change, and

different transaction subsets of the one or more transaction subsets are respectively assigned with transaction data having different transaction types and having no overlapping range of data change;

wherein the assigning the plurality of pieces of transaction data into one or more transaction subsets comprises;

assigning the plurality of pieces of transaction data into one or more level I transaction subsets according to the transaction type, and

for each of the one or more level I transaction subsets, assigning transaction data that is assigned under each of the one or more level I transaction subsets into one or more level II transaction subsets according to the range of data change, wherein pieces of transaction data with the overlapping range of data change are assigned in a same level II transaction subset, and pieces of the transaction data with no overlapping range of data change are assigned into different level II transaction subsets; and

executing the one or more level II transaction subsets in parallel, and storing results of the execution into the blockchain.

2. The method according to claim 1, wherein the executing the one or more level II transaction subsets in parallel comprises:

executing the pieces of the transaction data assigned into the different level II transaction subsets in parallel using multithreading or a machine cluster.

3. The method according to claim 1, wherein:

each piece of the plurality of pieces of transaction data corresponds to a timestamp; and

the executing the one or more level II transaction subsets in parallel comprises;

executing the pieces of the transaction data assigned into the same level II transaction subset in series according to a temporal order corresponding to the timestamps.

4. The method according to claim 1, wherein assigning the plurality of pieces of transaction data into the one or more level I transaction subsets according to the transaction type comprises:

assigning a portion of the plurality of pieces of transaction data with the same transaction type in a same level I transaction subset; and

assigning a portion of the plurality of pieces of transaction data with different transaction types into different level I transaction subsets.

5. The method according to claim 1, wherein assigning the transaction data that is assigned under each of the one or more level I transaction subsets into the one or more level II transaction subsets according to the range of data change comprises:

traversing a range of data change of each piece of transaction data in a first level I transaction subset;

in response to that a range of data change of a second piece of transaction data overlaps with a range of data change of a first level II transaction subset, adding the second piece of transaction data into the first level II transaction subset; and

in response to that the range of data change of the second piece of transaction data does not overlap with the range of data change of the first level II transaction subset, creating a second level II transaction subset and adding the second piece of transaction data into the second level II transaction subset.

6. A system for adding transaction data into a blockchain, comprising one or more processors and one or more non-transitory computer-readable memories coupled to the one or more processors and configured with instructions executable by the one or more processors to cause the system to perform operations comprising:

obtaining a plurality of pieces of transaction data to be added into the blockchain;

assigning the plurality of pieces of transaction data into one or more transaction subsets according to one or more criteria,

wherein the one or more criteria comprise;

each of the one or more transaction subsets is assigned with transaction data having at least one of;

a same transaction type or an overlapping range of data change, and

different transaction subsets of the one or more transaction subsets are respectively assigned with transaction data having different transaction types and having no overlapping range of data change;

wherein the assigning the plurality of pieces of transaction data into one or more transaction subsets comprises;

assigning the plurality of pieces of transaction data into one or more level I transaction subsets according to the transaction type, and

for each of the one or more level I transaction subsets, assigning transaction data that is assigned under each of the one or more level I transaction subsets into one or more level II transaction subsets according to the range of data change, wherein pieces of transaction data with the overlapping range of data change are assigned in a same level II transaction subset, and pieces of the transaction data with no overlapping range of data change are assigned into different level II transaction subsets; and

executing the one or more level II transaction subsets in parallel, and storing results of the execution into the blockchain.

7. The system according to claim 6, wherein the executing the one or more level II transaction subsets in parallel comprises:

executing the pieces of the transaction data assigned into the different level II transaction subsets in parallel using multithreading or a machine cluster.

8. The system according to claim 6, wherein assigning the plurality of pieces of transaction data into the one or more level I transaction subsets according to the transaction type comprises:

assigning a portion of the plurality of pieces of transaction data with the same transaction type in a same level I transaction subset; and

assigning a portion of the plurality of pieces of transaction data with different transaction types into different level I transaction subsets.

9. A non-transitory computer-readable storage medium configured with instructions executable by one or more processors to cause the one or more processors to perform operations comprising:

obtaining a plurality of pieces of transaction data to be added into the blockchain;

assigning the plurality of pieces of transaction data into one or more transaction subsets according to one or more criteria,

wherein the one or more criteria comprise;

each of the one or more transaction subsets is assigned with transaction data having at least one of;

a same transaction type or an overlapping range of data change, and

different transaction subsets of the one or more transaction subsets are respectively assigned with transaction data having different transaction types and having no overlapping range of data change;

wherein the assigning the plurality of pieces of transaction data into one or more transaction subsets comprises;

assigning the plurality of pieces of transaction data into one or more level I transaction subsets according to the transaction type, and

for each of the one or more level I transaction subsets, assigning transaction data that is assigned under each of the one or more level I transaction subsets into one or more level II transaction subsets according to the range of data change, wherein pieces of transaction data with the overlapping range of data change are assigned in a same level II transaction subset, and pieces of the transaction data with no overlapping range of data change are assigned into different level II transaction subsets; and

executing the one or more level II transaction subsets in parallel, and storing results of the execution into the blockchain.

10. A method for adding transaction data into a blockchain, comprising:

obtaining a plurality of pieces of transaction data to be added into the blockchain;

assigning the plurality of pieces of transaction data into one or more transaction subsets according to one or more criteria,

wherein the one or more criteria comprise;

each of the one or more transaction subsets is assigned with transaction data having at least one of;

a same transaction type or an overlapping range of data change, and

different transaction subsets of the one or more transaction subsets are respectively assigned with transaction data having different transaction types and having no overlapping range of data change;

wherein the assigning the plurality of pieces of transaction data into one or more transaction subsets comprises;

assigning the plurality of pieces of transaction data into one or more level I transaction subsets according to the range of data change, and

for each of the one or more level I transaction subsets, assigning transaction data that is assigned under each of the one or more level I transaction subsets into one or more level II transaction subsets according to the transaction type, wherein pieces of transaction data with the same transaction type are assigned in a same level II transaction subset, and pieces of the transaction data with the different transaction types are assigned into different level II transaction subsets; and

executing the one or more level II transaction subsets in parallel, and storing results of the execution into the blockchain.

11. The method according to claim 10, wherein assigning the plurality of pieces of transaction data into the one or more level I transaction subsets according to the range of data change comprises:

assigning a portion of the plurality of pieces of transaction data with the overlapping range of data change in a same level I transaction subset; and

assigning a portion of the plurality of pieces of transaction data with no overlapping range of data change into different level I transaction subsets.

12. The method according to claim 10, wherein assigning the transaction data that is assigned under each of the one or more level I transaction subsets into the one or more level II transaction subsets according to the transaction type comprises:

traversing a transaction type of each piece of transaction data in a first level I transaction subset;

in response to that a transaction type of a second piece of transaction data is the same as a transaction type of one or more pieces of transaction data of a first level II transaction subset, adding the second piece of transaction data into the first level II transaction subset; and

in response to that the transaction type of the second piece of transaction data is different from the transaction type of all pieces of transaction data of the first level II transaction subset, creating a second level II transaction subset and adding the second piece of transaction data into the second level II transaction subset.