Blockchain-based data processing method and equipment

• US 10,545,794 B2
• Filed: 07/11/2019
• Issued: 01/28/2020
• Est. Priority Date: 03/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): Kessler, Gregory A
• Application Number:
  US16/508,715
• Publication Number:
  US 20190332430A1
• Time in Patent Office: 201 Days
• Field of Search: None
• CPC Class Codes: G06F 16/1837 Management specially adapted to peer-to-peer storage networks topology management mechanisms of peer-to-peer networks H04L67/1042
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• 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 16/9024 Graphs; Linked lists G06F16/9027 takes precedence
• CPC Class Codes: G06F 9/465 Distributed object oriented systems remote method invocation [RMI] G06F9/548
• CPC Class Codes: G06F 9/4881 Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
• CPC Class Codes: G06Q 20/223 based on the use of peer-to-peer networks
• CPC Class Codes: G06Q 2220/00 Business processing using cryptography postage metering system using cryptography G06Q2250/05
• CPC Class Codes: H04L 63/123 received data contents, e.g. message integrity
• CPC Class Codes: H04L 9/0637 Modes of operation, e.g. cipher block chaining [CBC], electronic codebook [ECB] or Galois/counter mode [GCM]
• CPC Class Codes: H04L 9/3239 involving non-keyed hash functions, e.g. modification detection codes [MDCs], MD5, SHA or RIPEMD
• CPC Class Codes: H04L 9/50 using hash chains, e.g. blockchains or hash trees

Abstract

A node in a blockchain network receives service data generated in a specified time period, where the service data comprises label information used to represent a processing priority of the service data. The node determines, when a new block is generated, a throughput that corresponds to the label information based on a predetermined mapping relationship between label information and a throughput. The node obtains service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput, where the service data is stored in the data processing set. The service data is stored in the new block.

Claims

1. A blockchain-based data processing method, comprising:

receiving, by a node in a blockchain network, service data generated in a specified time period, wherein the service data comprises label information used to represent a processing priority of the service data;

determining, by the node when a new block is generated, a throughput that corresponds to the label information based on a predetermined mapping relationship between label information and a throughput;

obtaining, by the node, service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput, wherein the service data is stored in the data processing set; and

storing the service data in the new block.

2. The blockchain-based data processing method according to claim 1, wherein establishing the predetermined mapping relationship between label information and a throughput comprises:

determining processing priorities of service data of different services;

determining mapping relationships between different processing priorities and label information;

determining throughputs that correspond to the processing priorities based on the processing priorities; and

establishing mapping relationships between label information that corresponds to the processing priorities and the throughputs.

3. The blockchain-based data processing method according to claim 2, wherein throughputs of the same service data are different in different time periods.

4. The blockchain-based data processing method according to claim 1, wherein obtaining, by the node, service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

determining an amount of service data that comprises the label information based on the throughput and a storage capacity of the new block; and

obtaining the amount of service data that comprises the label information from the data processing set.

5. The blockchain-based data processing method according to claim 1, wherein obtaining, by the node, service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

in response to determining that the service data does not comprise label information, obtaining, based on an idle capacity of the new block, service data that satisfies the idle capacity and does not comprise label information from the data processing set;

or

in response to determining that a throughput that corresponds to the label information is null, obtaining, based on an idle capacity of the new block, service data that satisfies the idle capacity and comprises the label information from the data processing set.

6. The blockchain-based data processing method according to claim 1, wherein when the node receives service data generated in the specified time period, the method further comprises:

determining the data processing set that corresponds to the label information based on the label information comprised in the service data; and

storing the service data in the data processing set.

7. The blockchain-based data processing method according to claim 6, wherein obtaining, by the node, service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

obtaining service data that satisfies the throughput based on the throughput and a timestamp of service data from the data processing set that corresponds to the label information.

8. The blockchain-based data processing method according to claim 6, wherein obtaining, by the node, service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

in response to determining that an amount of service data stored in the data processing set that corresponds to the label information is less than the throughput, obtaining the service data from the data processing set based on the amount of service data stored in the data processing set.

9. The blockchain-based data processing method according to claim 1, wherein the determining, by the node when a new block is generated, a throughput that corresponds to the label information based on a predetermined mapping relationship between label information and throughputs comprises:

when the new block is generated, in response to determining that service data corresponds to at least two different processing priorities, determining throughputs that correspond to label information of different processing priorities, wherein a sum of throughputs that correspond to different label information is less than or equal to a storage capacity of the new block.

10. A blockchain-based data processing device, comprising:

a receiving unit, configured to receive service data generated in a specified time period, wherein the service data comprises label information used to represent a processing priority of the service data;

a determining unit, configured to determine, when a new block is generated, a throughput that corresponds to the label information based on a predetermined mapping relationship between label information and throughputs;

an acquisition unit, configured to obtain service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput, wherein the service data is stored in the data processing set; and

a processing unit, configured to store the service data in the new block.

11. The blockchain-based data processing device according to claim 10, wherein the blockchain-based data processing device further comprises an establishment unit, wherein:

that the establishment unit establishes the predetermined mapping relationship between label information and throughputs comprises;

determining processing priorities of service data of different services;

determining mapping relationships between different processing priorities and label information;

determining throughputs that correspond to the processing priorities based on the processing priorities; and

establishing mapping relationships between label information that corresponds to the processing priorities and the throughputs.

12. The blockchain-based data processing device according to claim 11, wherein throughputs of the same service data are different in different time periods.

13. The blockchain-based data processing device according to claim 10, wherein that the acquisition unit obtains service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

determining an amount of service data that comprises the label information based on the throughput and a storage capacity of the new block; and

obtaining the amount of service data that comprises the label information from the data processing set.

14. The blockchain-based data processing device according to claim 10, wherein that the acquisition unit obtains service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

in response to determining that the service data does not comprise label information, obtaining, based on an idle capacity of the new block, service data that satisfies the idle capacity and does not comprise label information from the data processing set;

or

in response to determining that a throughput that corresponds to the label information is null, obtaining, based on an idle capacity of the new block, service data that satisfies the idle capacity and comprises the label information from the data processing set.

15. The blockchain-based data processing device according to claim 10, wherein when the receiving unit receives service data generated in the specified time period, a storage unit in the blockchain-based data processing device is configured to:

determine the data processing set that corresponds to the label information based on the label information comprised in the service data; and

store the service data in the data processing set.

16. The blockchain-based data processing device according to claim 15, wherein that the acquisition unit obtains service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

obtaining service data that satisfies the throughput based on the throughput and a timestamp of service data from the data processing set that corresponds to the label information.

17. The blockchain-based data processing device according to claim 15, wherein that the acquisition unit obtains service data that satisfies the throughput and that comprises the label information from a data processing set based on the throughput comprises:

in response to determining that an amount of service data stored in the data processing set that corresponds to the label information is less than the throughput, obtaining the service data from the data processing set based on the amount of service data stored in the data processing set.

18. The blockchain-based data processing device according to claim 10, wherein that the determining unit determines, when a new block is generated, a throughput that corresponds to the label information based on a predetermined mapping relationship between label information and throughputs comprises:

when the new block is generated, in response to determining that service data corresponds to at least two different processing priorities, determining throughputs that correspond to label information of different processing priorities, wherein a sum of throughputs that correspond to different label information is less than or equal to a storage capacity of the new block.