CN112822267B

CN112822267B - Data processing method and device based on block chain

Info

Publication number: CN112822267B
Application number: CN202110009225.3A
Authority: CN
Inventors: 倪靖雄
Original assignee: Alipay Hangzhou Information Technology Co Ltd
Current assignee: Alipay Hangzhou Information Technology Co Ltd
Priority date: 2021-01-05
Filing date: 2021-01-05
Publication date: 2022-08-26
Anticipated expiration: 2041-01-05
Also published as: CN112822267A

Abstract

The present specification provides a data processing method and apparatus based on a blockchain, which is applied to a management platform for performing management on a consensus node of the blockchain, and includes: receiving a consensus node joining application sent by a target mechanism terminal; judging whether the credit score of the target mechanism reaches a preset admission threshold value or not based on the credit score corresponding to the target mechanism; if yes, triggering a consensus node to join the transaction to the blockchain so that the existing consensus node of the blockchain agrees with the consensus node to join the transaction; the consensus node joining transaction is used for representing that a target mechanism terminal is joined as the consensus node of the block chain; and when the consensus node joins the distributed database of which the transaction is recorded into the block chain through the consensus of the existing consensus node, setting the target mechanism terminal as the consensus node of the block chain.

Description

Data processing method and device based on block chain

Technical Field

One or more embodiments of the present disclosure relate to the field of network communications, and in particular, to a data processing method and apparatus based on a block chain.

Background

The block chain technology, also called distributed ledger technology, is an emerging technology in which several computing devices participate in "accounting" together, and a complete distributed database is maintained together. The blockchain technology has been widely applied in many fields due to its decentralized and transparent disclosure, the fact that each computing device can participate in database recording, and the data synchronization between the computing devices can be performed rapidly.

In the existing alliance chain mechanism, a node to be added is generally applied to a node with higher authority in an alliance chain by the node to be added, and the node with the higher authority manually opens the authority after manual review.

Disclosure of Invention

In view of this, one or more embodiments of the present specification provide a data processing method, apparatus, and computer device based on a block chain.

In order to achieve the above purpose, one or more embodiments of the present specification provide the following technical solutions:

according to a first aspect of one or more embodiments of the present specification, a data processing method based on a blockchain is provided, which is applied to a management platform that performs management on a consensus node of the blockchain, and includes:

receiving a consensus node joining application sent by a target mechanism terminal;

judging whether the credit score of the target mechanism reaches a preset admission threshold value or not based on the credit score corresponding to the target mechanism;

if yes, triggering a consensus node to join the transaction to the blockchain so that the existing consensus node of the blockchain agrees with the consensus node to join the transaction; the consensus node joining transaction is used for representing that a target mechanism terminal is joined as the consensus node of the block chain;

and when the consensus node joins the distributed database of which the transaction is recorded into the block chain through the consensus of the existing consensus node, setting the target mechanism terminal as the consensus node of the block chain.

According to a second aspect of one or more embodiments of the present specification, there is provided a data processing method based on a blockchain, which is applied to a node device of the blockchain, and includes:

receiving a consensus node joining transaction triggered by a management platform; the management platform is used for managing consensus nodes of the block chain, adding transactions into the consensus nodes to represent that a target mechanism terminal is added into the consensus nodes of the block chain, and judging by the management platform that the credit score corresponding to the target mechanism is larger than a preset admission threshold value;

and when the consensus node is added into the consensus of the existing consensus node of the block chain for transaction, adding the consensus node into the distributed database of the block chain for transaction recording so as to authenticate the target mechanism terminal as the consensus node of the block chain.

According to a third aspect of one or more embodiments of the present specification, a method for processing consensus of a blockchain is provided, where the method is applied to an existing consensus node of the blockchain, and includes:

acquiring the transaction to be identified sent by the accounting node of the block chain;

voting whether the transaction to be identified can be included in the blockchain; wherein the weight of the vote is positively correlated with the credit score of the organization user corresponding to the existing consensus node;

and when the sum of the weights of votes which are made by the existing consensus nodes of the block chain and indicate that the to-be-consensus transaction is agreed to be recorded into the block chain exceeds a preset threshold value, adding the consensus nodes into a distributed database for recording the transaction into the block chain.

According to a fourth aspect of one or more embodiments of the present specification, there is provided a blockchain-based data processing apparatus applied to a management platform that performs management on a consensus node of a blockchain, including:

the receiving unit is used for receiving a consensus node joining application sent by a target mechanism terminal;

the judging unit is used for judging whether the credit score of the target mechanism reaches a preset admission threshold value or not based on the credit score corresponding to the target mechanism;

if yes, triggering a consensus node to join the transaction to the block chain so that the existing consensus node of the block chain can perform consensus on the consensus node to join the transaction; the consensus node joining transaction is used for representing that a target mechanism terminal is joined as the consensus node of the block chain;

and the setting unit is used for setting the target mechanism terminal as the consensus node of the block chain when the consensus node joins the distributed database of which the transaction is recorded into the block chain through the consensus of the existing consensus node.

According to a fifth aspect of one or more embodiments of the present specification, there is provided a data processing apparatus based on a blockchain, applied to a node device of the blockchain, including:

the receiving unit is used for receiving the transaction of joining the consensus node triggered by the management platform; the management platform is used for managing the consensus nodes of the block chain, the consensus nodes are added into the transaction to represent that a target mechanism terminal is added as the consensus nodes of the block chain, and the credit score corresponding to the target mechanism is judged by the management platform to be larger than a preset admission threshold value;

and the recording unit is used for recording the added transaction of the common identification node into a distributed database of the block chain after the common identification node is added into the common identification of the existing common identification node of the block chain, so as to authenticate the target mechanism terminal as the common identification node of the block chain.

According to a sixth aspect of one or more embodiments of the present specification, there is provided a block chain-based consensus processing apparatus applied to an existing consensus node of a block chain, including:

the acquisition unit is used for acquiring the transaction to be identified sent by the accounting node of the block chain;

the voting unit is used for voting whether the transaction to be identified can be recorded into the block chain or not; wherein the weight of the vote is positively correlated with the credit score of the organization user corresponding to the existing consensus node;

and the recording unit is used for recording the transaction to be identified into a distributed database of the block chain when the sum of the weights of the votes which are made by the existing common identification nodes of the block chain and represent that the transaction to be identified is allowed to be recorded into the block chain exceeds a preset threshold value.

According to a seventh aspect of one or more embodiments of the present specification, there is provided a computer device comprising: a memory and a processor; the memory having stored thereon a computer program executable by the processor; and when the processor runs the computer program, executing the data processing method based on the block chain executed by the management platform.

According to an eighth aspect of one or more embodiments of the present specification, there is provided a computer apparatus comprising: a memory and a processor; the memory having stored thereon a computer program executable by the processor; and when the processor runs the computer program, executing the data processing method based on the block chain, which is executed by the common identification node of the block chain.

According to a ninth aspect of one or more embodiments of the present specification, there is provided a computer apparatus comprising: a memory and a processor; the memory having stored thereon a computer program executable by the processor; and when the processor runs the computer program, executing the block chain-based consensus processing method executed by the consensus node of the block chain.

Based on the block chain-based data processing method, device and computer equipment provided in each embodiment of the present specification, the management platform may set an admission threshold of a credit score for an organization corresponding to a consensus node, so as to add and filter the consensus nodes of the organizations that do not meet the admission threshold of the credit score, so that the existing consensus nodes on the federation chain process the consensus nodes whose credit score is higher than the admission threshold to add into a transaction; the transaction processing efficiency of the alliance chain is improved by filtering part of application data through the management platform, and the consensus nodes which are added into the alliance chain are all credible nodes because the credit score of the processed target organization reaches the admission threshold value, so that the credibility of the alliance chain is improved.

Drawings

FIG. 1 is a system architecture diagram of a blockchain provided by an exemplary embodiment.

Fig. 2 is a flowchart illustrating a joining method of a community node in a federation chain according to an exemplary embodiment.

Fig. 3 is a schematic diagram of a blockchain-based data blowing apparatus applied to a management platform according to an exemplary embodiment.

Fig. 4 is a schematic diagram of a block chain-based data processing apparatus applied to a node device side according to an exemplary embodiment.

Fig. 5 is a schematic diagram of a block chain-based consensus processing apparatus applied to a consensus node end according to an exemplary embodiment.

Fig. 6 is a hardware block diagram for implementing an embodiment of a block chain based data processing apparatus or a block chain based consensus processing apparatus provided in the present specification.

Detailed Description

Reference will now be made in detail to the exemplary embodiments, examples of which are illustrated in the accompanying drawings. When the following description refers to the accompanying drawings, like numbers in different drawings represent the same or similar elements unless otherwise indicated. The embodiments described in the following exemplary embodiments do not represent all embodiments consistent with one or more embodiments of the present specification. Rather, they are merely examples of apparatus and methods consistent with certain aspects of one or more embodiments of the specification, as detailed in the claims which follow.

It should be noted that: in other embodiments, the steps of the corresponding methods are not necessarily performed in the order shown and described herein. In some other embodiments, the methods may include more or less steps than those described herein. Moreover, a single step described in this specification may be divided into multiple steps for description in other embodiments; however, in other embodiments, multiple steps described in this specification may be combined into a single step for description.

The block chain technology, also called distributed ledger technology, is an emerging technology in which several computing devices participate in "accounting" together, and a complete distributed database is maintained together. The block chain or block chain network described in this specification may specifically refer to a P2P network system having a distributed data storage structure, where the account book data in the block chain is distributed in temporally consecutive blocks (blocks), and the latter block may contain a data summary of the former block, and according to the specific consensus mechanism (such as POW, POS, DPOS, or PBFT), a full backup of data of all or part of nodes is achieved.

Blockchains are generally divided into three types: public chain (Public Blockchain), Private chain (Private Blockchain), and federation chain (Consortium Blockchain). In addition, there may be a combination of the above types, such as private chain + federation chain, federation chain + public chain, and so on.

Among them, the most decentralized is the public chain. The public chain is represented by bitcoin and ether house, and participants (also called nodes in the block chain) joining the public chain can read data records on the chain, participate in transactions, compete for accounting rights of new blocks, and the like. Moreover, each node can freely join or leave the network and perform related operations.

Private chains are the opposite, with the network's write rights controlled by an organization or organization and the data read rights specified by the organization. Briefly, a private chain may be a weakly centralized system with strict restrictions on nodes and a small number of nodes. This type of blockchain is more suitable for use within a particular establishment.

A federation chain is a block chain between a public chain and a private chain, and "partial decentralization" can be achieved. Each node in a federation chain typically has a physical organization or organization corresponding to it; the nodes are authorized to join the network and form a benefit-related alliance, and block chain operation is maintained together.

Based on the basic characteristics of a blockchain, a blockchain is usually composed of several blocks. The time stamps corresponding to the creation time of the block are recorded in the blocks respectively, and all the blocks form a time-ordered data chain according to the time stamps recorded in the blocks strictly.

The real data generated by the physical world can be constructed into a standard transaction (transaction) format supported by a block chain, then is issued to the block chain, the node equipment in the block chain performs consensus processing on the received transaction, and after the consensus is achieved, the node equipment serving as an accounting node in the block chain packs the transaction into a block and performs persistent evidence storage in the block chain.

The consensus algorithm supported in the blockchain may include:

the first kind of consensus algorithm, namely the consensus algorithm that the node device needs to contend for the accounting right of each round of accounting period; consensus algorithms such as Proof of workload (Proof of Work, POW), Proof of equity of stock (Proof of post, POS), Proof of commission entitlement (DPOS), etc.;

the second kind of consensus algorithm, namely the consensus algorithm which elects accounting nodes in advance for each accounting period (without competing for accounting right); for example, a consensus algorithm such as a Practical Byzantine Fault Tolerance (PBFT) is often used in a federation chain, and a consensus algorithm for electing a node with accounting right in advance is often used in the federation chain, so as to save system resources consumed by the node competing for accounting right.

In a blockchain network employing a first type of consensus algorithm, node devices competing for billing rights can execute a transaction upon receipt. One of the node devices competing for the accounting right may win the process of competing for the accounting right in the current round, and become the accounting node. The accounting node may package the received transaction with other transactions to generate a latest block and send the generated latest block or a block header of the latest block to other node devices for consensus.

In the block chain network adopting the second type of consensus algorithm, the node equipment with the accounting right is agreed before accounting in the current round. After generating the latest block, the accounting node may send the latest block or a block header of the latest block to other node devices for consensus.

As described above, regardless of which consensus algorithm is used by the blockchain, the accounting node of the current round may pack the received transaction to generate the latest block, and send the generated latest block or the block header of the latest block to other node devices for consensus verification. If no problem is verified after other node equipment receives the latest block or the block header of the latest block, the latest block can be added to the tail of the original block chain, so that the latest block is recorded in the distributed database of the block chain. The transaction contained in the block may also be performed by other nodes in verifying the new block or block header sent by the accounting node.

As described above, enterprises, organizations, and government agencies within an industry may build federation chains to share information and resources on the chains or to conduct business on the chains. Since the consensus node may participate in determining uplink information, authorization or admission to the consensus node in the federation chain generally adopts an audit scheme: in the existing alliance chain mechanism, a node to be added is generally used for submitting an application to a node with higher authority in the alliance chain from the node to be added, the node organization with the higher authority manually opens an consensus authority for the node to be added after manual review, the centralization degree of the process is higher, the manual mode is very inefficient, and the development of the alliance chain is limited.

Fig. 1 illustrates a system architecture diagram of a blockchain provided by an exemplary embodiment of the present specification. As shown in fig. 1, management platform 100 may be connected to the blockchain system 200 to manage the blockchain points 1, 2, … … i included in the blockchain system 200. The blockchain node may include a full node. The full node may download each blockchain and blockchain transaction and check against the consensus rules for the blockchain. Block link points may form a network by communicating one block link point with another block link point. The order and number of blockchain nodes shown in fig. 1 are merely examples for illustration. The blockchain node may be implemented in a server, a computer, or the like. For example, each blockchain node may be implemented in a server or a cluster of servers. The server cluster may employ load balancing. Each block link point may correspond to one or more physical hardware devices or virtual devices coupled together via various types of communication methods, such as TCP/IP. Depending on the classification, a block chain link point may also be referred to as a full node, a Geth node, a consensus node, etc.

In some embodiments, the blockchain user-side computing device may include a light node. The light node may not be able to download the complete blockchain, but may only download the blockhead to verify the authenticity of the blockchain transaction. The light nodes may be served by a full node (e.g., a blockchain node in a blockchain system) and effectively rely on the full node to access more functions of the blockchain. By installing appropriate software, the light nodes can be implemented in electronic devices such as laptops, mobile phones, etc. In one embodiment, the blockchain user-side computing device may send a blockchain transaction to the blockchain system 200 to be added to the blockchain.

In some embodiments, the management platform 100 may provide a blockchain as a service (BaaS) or referred to as a BaaS end. In one embodiment, BaaS is a cloud service model in which customers or developers outsource the behind-the-scenes aspects of Web or mobile applications. BaaS may provide pre-written software for activities that occur on the blockchain, such as subscriptions and notifications, user authentication, database management, and remote updates. The BaaS terminal may be implemented in a server, a server cluster, or other devices. In one embodiment, the BaaS terminal provides an enterprise-level platform service based on the blockchain technology. The service can help customers construct a secure and stable blockchain environment and easily manage deployment, operation, maintenance and development of blockchains.

Fig. 2 provides a method for joining a common node in a blockchain according to an exemplary embodiment of the present disclosure, which is applied to an environment including a management platform 100 and a blockchain system 200 as shown in fig. 1. The target mechanism terminal that raises the consensus node joining application may be an existing node that has not obtained the consensus right in the blockchain system 200, or may also be a server or a computer that has not joined the blockchain system 200, which is not limited in this embodiment.

It is contemplated that the method for joining a consensus node in a blockchain provided in the present specification is not limited to the kind of blockchain, for example, the blockchain system 200 may be a public chain, a federation chain, or a private chain, and since the federation chain is a preferred type of blockchain network for more enterprises, organizations, etc., the following embodiments describe the joining method of the consensus node in the blockchain in detail with the federation chain as a preferred embodiment.

Step 202, the management platform receives a consensus node join application sent by the target mechanism terminal so as to apply for the digital consensus node which becomes the alliance chain.

And 204, the management platform acquires the credit score corresponding to the target mechanism and judges whether the credit score of the target mechanism reaches a preset admission threshold value.

In the present embodiment, the manner of acquiring the credit score corresponding to the target institution by the management platform is not particularly limited. In an illustrated embodiment, the management platform is in communication connection with a third-party credit evaluation institution, and the consensus node joining application in step 202 includes an identifier of the target institution; the process of acquiring the credit score corresponding to the target institution by the management platform may include: sending the identification of the target institution to the third-party credit evaluation institution to inquire credit score of the target institution corresponding to the identification; and receiving the credit score of the target institution corresponding to the identification, which is sent by the third-party credit evaluation institution.

Or the target institution can separately apply for inquiring credit score from the third-party credit evaluation institution, and add the credit score given by the third-party credit evaluation institution into the application at the consensus node, and the digital signature of the third-party credit evaluation institution on at least the credit score based on the held private key; at this time, the process of the management platform acquiring the credit score corresponding to the target institution may include: verifying the digital signature based on a public key of the credit evaluation authority; and when the digital signature is verified, acquiring a credit score corresponding to the target organization contained in the joining application.

In yet another illustrative embodiment, a plurality of enterprises or organizations, etc. may conduct business in the federation chain system when the above-described administration platform provides the Baas service, and the above-described administration platform may collect business data, etc. of the related businesses in which each organization participates to extract computing data for credit rating (e.g., may include business status of the organization, corporate information, organization basic information, fulfillment history, user ratings, etc.); and importing the calculation data into a credit evaluation model established on a management platform, and performing credit evaluation calculation on each mechanism to generate a credit score corresponding to each mechanism. In this case, the process of the management platform acquiring the credit score corresponding to the target institution may include: and calling a credit evaluation model constructed by the management platform, and performing credit evaluation calculation on the target mechanism based on the identification of the target mechanism to generate a credit score corresponding to the target mechanism.

A credit evaluation model is built on the management platform, the credit score of each enterprise or organization is evaluated in a multi-dimensional mode, and credit evaluation service can be provided for the Baas user, so that the user can be helped to eliminate business risks in cooperation with the credit losing enterprise.

When the credit score of the target mechanism does not reach the preset admission threshold value, the management platform can send back a notification message for refusing the target mechanism to join the consensus node to the target mechanism terminal.

And step 206, when the credit score of the target institution reaches a preset admission threshold value, the management platform triggers a consensus node to join the transaction to the alliance chain, so that the existing consensus node of the block chain agrees the consensus node to join the transaction.

The management platform triggers the specific process of joining the transaction to the consensus node from the alliance chain, and the specific process can be different according to different specific formats of the consensus node joining application. When the target enterprise terminal is used as a node device of the alliance chain system or a user side computer device of the alliance chain system, the consensus node joining application in step 202 may be a transaction format packaged by the target enterprise terminal, and after the management platform judges that the credit score corresponding to the target enterprise reaches a preset admission threshold, the management platform may forward the consensus node joining application (i.e., consensus node joining transaction) in the transaction format sent by the target enterprise terminal to the alliance chain system, so that the consensus node of the alliance chain carries out consensus on the consensus node transaction.

When the target enterprise terminal is an off-link computing device which has not joined the alliance link system, the consensus node joining application may not be represented in a transaction format approved by the alliance link system; after the management platform judges that the credit score corresponding to the target institution reaches the preset admission threshold value, the management platform can generate a consensus node join transaction in a standard transaction format approved by the alliance chain system based on a consensus node join application sent by the target institution terminal, and send the generated consensus node join transaction to the alliance chain system, so that the existing consensus node of the alliance chain can agree with the consensus node join transaction.

And the consensus node joining transaction is used for indicating that the target mechanism terminal is joined as the consensus node of the alliance chain. The transaction joining by the consensus node can include identification information of a target mechanism, credit score information, hardware configuration information of a target mechanism terminal and other information, so that the existing consensus node can check the credibility of the target mechanism and the hardware configuration of the target mechanism terminal, and whether the target mechanism terminal is agreed to be used as the consensus node of the alliance chain or not can be voted.

Specifically, the process of the existing consensus node of the block chain for consensus on the addition of the consensus node into the transaction may include:

and S1, determining a consensus node (hereinafter referred to as a "accounting node") for obtaining the accounting right of the current round based on a preset accounting right consensus algorithm. The aforementioned accounting authority consensus algorithm includes, but is not limited to, workload certification (Proof of Work, POW), equity certification (Proof of stamp, POS), commission entitlement certification (DPOS), Practical Byzantine Fault Tolerance (PBFT), and the like. In the embodiment shown, the aforementioned billing right node may adopt a consensus algorithm that elects a billing right node in advance for each billing period (without competing for billing right) in advance.

The embodiment is not particularly limited with respect to the election rule for the billing node. For example, a rotation system can be adopted, and the existing consensus nodes in the federation chain are selected as accounting nodes in turn; alternatively, a random selection system can be adopted, and the accounting node is randomly selected from the existing consensus nodes in the federation chain based on a random algorithm.

In the random algorithm, the probability of each existing consensus node being selected is generally the same. In order to further enhance the credibility of the alliance chain, a random algorithm which takes the credit score of each existing consensus node user as a calculation parameter can be designed, and based on the random algorithm, the consensus nodes with higher credit scores can have higher selected probability, so that a high-quality trusted authority can more dominate the accounting process of the alliance chain, the safety of the alliance chain is ensured, and the possibility of bad account is reduced.

And S2, the existing consensus node of the alliance chain acquires the consensus node sent by the accounting node to join the transaction.

For example, the accounting node may obtain a plurality of transactions including the joint transaction of the consensus node from the transaction pool, package the transactions into a candidate block, and broadcast the candidate block in the alliance chain, so that after obtaining the candidate block, other existing consensus nodes in the alliance chain may perform consensus verification on the transactions included in the candidate block. The process of consensus verification of a transaction by a consensus node in a federation chain may be considered as a voting process whether the consensus node agrees to include the transaction to a distributed database of the federation chain: if the consensus node considers a transaction within the candidate block to be illegal (e.g., the content or format of the transaction is illegal), or the consensus node does not agree with the outcome of the execution of the transaction, a vote may be made to disagree with the listing of the transaction to the federation chain.

S3, existing consensus nodes of the alliance chain vote whether the existing consensus nodes can be introduced into the alliance chain for joining in the transaction; the voting results performed by each consensus node (i.e. whether agreed or not) can be sent to the aforementioned accounting node or broadcast within the consensus nodes of the federation chain.

And S4, when the voting weight of the consensus node which agrees that the target institution is authenticated as a consensus node exceeds a preset threshold value, the existing consensus node adds the consensus node into the transaction and records the transaction in the distributed database of the block chain.

In a conventional PBFT consensus mechanism, the voting weight of each consensus node is the same, and when the accounting node receives at least 2N/3 votes for "agreement" of the transaction to be agreed (N is the total number of the current consensus nodes in the federation chain), the transaction to be agreed can be considered to pass the consensus verification of the federation chain, and can be legally recorded in a distributed database of the federation chain. The federation chain in this embodiment may also use the voting mechanism described above, and when at least 2N/3 (where N is the total number of current consensus nodes in the federation chain) of existing consensus nodes agree that the target enterprise terminal can be authenticated as a consensus node in the federation chain, the consensus node join transaction may be recorded in the distributed database of the federation chain.

In a further illustrated embodiment, in order to further improve the credibility of the decision of the federation chain, when the voting results of the consensus transaction to be treated by the existing consensus nodes of the federation chain are counted, a corresponding weight may be set for the vote made by each existing consensus node based on the credit score of the enterprise user corresponding to each existing consensus node. In this way, when the consensus node (e.g., the accounting node) of the federation chain counts the voting result of the existing consensus node on the target enterprise terminal that can be authenticated as the consensus node of the federation chain (i.e., the consensus result of whether the consensus node can be received into the federation chain for joining a transaction), the weight of the vote made by each existing consensus node is positively correlated with the credit score of the enterprise user corresponding to the existing consensus node.

E.g. k ₁ ，k ₂ ，……k _N For the voting weight, k, corresponding to the existing N consensus nodes ₁ +k ₂ +……+k _N 1 is ═ 1; wherein k is _i ＝C _i /(C ₁ +C ₂ +……+C _N ) And Ci is the credit score for node i.

When m consensus nodes numbered from 1 to m join a transaction vote agreement to the consensus node, the voting result can be expressed as follows:

P＝k ₁ +k ₂ +……+k _m ；

if P is greater than a predetermined consensus threshold (e.g., 2/3), the consensus node is passed through by existing consensus nodes of the federation chain.

The vote counting mechanism gives higher voting weight to the consensus node with higher credit score, thereby strengthening the decision weight of high credit institutions in the alliance chain, improving the execution efficiency of the alliance chain (for example, only a few institutions with high weight can complete consensus), and further ensuring the security of the alliance chain.

In one or more of the consensus processes shown above, including voting of the accounting node, voting of the consensus node, and counting of votes, the federation chain needs to obtain credit scores of the existing consensus nodes to perform a corresponding random algorithm or voting weight calculation. The credit scores of the existing consensus nodes may be recorded in a distributed database of the federation chain for use in the calculation of the consensus process. Since the credit score of the organization usually changes along with the operation condition of the organization, the federation chain can update the credit score of the existing consensus node stored in the federation chain every preset period by interacting with the management platform.

Or, before the league chain performs the election of the accounting node each time, acquiring a current credit score corresponding to an existing consensus node of the league chain by interacting with the management platform, so as to perform random elections of the accounting node based on the current credit score (the elected probability corresponding to each existing consensus node is updated based on the current credit score), and/or vote calculation of the consensus node to treat consensus transaction (the voting weight corresponding to each existing consensus node is updated based on the current credit score); thereby ensuring that the above-mentioned decision-making of the federation chain is based on the current credit scores of the current federation members. It should be noted that the consensus process of the federation chains described in S1 to S4 in this specification can be applied to consensus on any transaction in the federation chain, in addition to consensus on the above-mentioned consensus node to join the transaction, as a general consensus method related to credit score of the consensus node, to improve the credibility of the data included in the above-mentioned federation chain.

It should be noted that, in order to further improve the credibility of the federation chain, a dynamic consensus node exit mechanism may be set in the consensus protocol of the federation chain, for example, before the federation chain performs election of a billing node each time, after a current credit score corresponding to an existing consensus node of the federation chain is obtained through interaction with the management platform, if the current credit score corresponding to any existing consensus node is smaller than an exit threshold preset by the consensus protocol, the consensus protocol of the federation chain may cancel the consensus authority of any existing consensus node, so that the any existing consensus node cannot participate in the selection and voting process of the billing node.

The exit mechanism agreed by the consensus protocol provides a dynamic consensus node set for the alliance chain, so that consensus nodes for deciding data included in the alliance chain are all in a trusted state higher than the exit threshold, and the credibility of the data in the alliance chain is further improved.

And 208, when the consensus node joins the distributed database of which the transaction is recorded in the block chain through the consensus of the existing consensus nodes, setting the target mechanism terminal as the consensus node of the block chain by the management platform.

The management platform may monitor the data included in the federation chain to learn that the consensus node join transaction is included in the distributed database of the federation chain. The specific process of the management platform setting the target mechanism terminal as the consensus node of the block chain may include: and sending the consensus protocol interface address of the alliance chain to the target mechanism terminal so that the target mechanism terminal can access the consensus protocol interface address, and installing the consensus protocol on the target mechanism terminal to form a consensus node of the alliance chain.

In one or more embodiments provided in this specification, the management platform may set an admission threshold of a credit score for an organization corresponding to the consensus node, so as to filter out the consensus node joining applications of the organizations that do not meet the admission threshold of the credit score, so that existing consensus nodes on the federation chain process the consensus node joining transactions whose credit score is higher than the admission threshold; the transaction processing efficiency of the alliance chain is improved by filtering part of application data through the management platform, and the consensus nodes which are added into the alliance chain are all credible nodes because the credit score of the processed target organization reaches the admission threshold value, so that the credibility of the alliance chain is improved.

It should be noted that the above-mentioned embodiments of step 202 to step 208 are implemented by a management platform that manages a consensus device of a blockchain, however, the method provided by the present specification is not limited thereto, for example, in a blockchain system without a management platform, the specific steps described in the above-mentioned steps 202 to 208 may be implemented by any node device of the blockchain, or by a designated node in the blockchain that has an authority to determine whether the credit score of the user reaches a preset admission threshold, and therefore, the present specification does not limit the identity of the implemented entity of the data processing method based on the blockchain provided by the above-mentioned real-time method.

In yet another illustrated embodiment, an intelligent contract for identity management of consensus nodes of a blockchain may be deployed in the blockchain to maintain identity information of current consensus nodes of the blockchain within the intelligent contract. In this embodiment, the setting the target institution terminal as the consensus node of the block chain in step 208 may include: initiating a call transaction of the intelligent contract, so that the node equipment of the block chain responds to the call transaction to call the intelligent contract, and adding the identity information of the target mechanism into a current consensus node list of the block chain.

In addition, the blockchain client or the node device having the user credit score calculation or management authority may periodically send, to the blockchain, a call transaction for the intelligent contract, where the call transaction includes a credit score corresponding to a current consensus node user of the blockchain, so that the node device of the blockchain, in response to the call transaction, deletes a consensus node having a credit score lower than the admission threshold value from the current consensus node list based on the credit score corresponding to the current consensus node user, and/or calculates a corresponding consensus voting weight for the current consensus node based on the credit score corresponding to the current consensus node user, so as to update the current consensus node list in the blockchain, and/or update the consensus voting weight corresponding to the current consensus node.

Therefore, the identity or voting weight of the consensus node is managed and calculated through the intelligent contract, and compared with the situation that corresponding identity updating or voting weight calculation logic is arranged in the consensus protocol, the method has better flexibility and visibility and has the advantage of being convenient to develop.

Based on the consensus node adding method in each embodiment, a centralized decision mode for adding the consensus node in the traditional block chain is avoided, the block chain expansion efficiency is improved, and a large-scale trusted alliance chain is favorably and quickly established.

In correspondence with the above flow implementation, the embodiments of the present specification also provide the data processing apparatuses 30 and 40 based on the block chain, and the consensus processing apparatus 50 based on the block chain. The means 30, 40 and 50 may be implemented by software, or by hardware, or by a combination of both. Taking a software implementation as an example, the logical device is formed by reading a corresponding computer program instruction into a memory for running through a Central Processing Unit (CPU) of the device. In terms of hardware, the device in which the apparatus is located generally includes other hardware such as a chip for transmitting and receiving wireless signals and/or other hardware such as a board for implementing a network communication function, in addition to the CPU, the memory, and the storage shown in fig. 6.

As shown in fig. 3, the present specification provides a block chain-based data processing apparatus 30 comprising:

a receiving unit 302, configured to receive a consensus node join application sent by a target mechanism terminal;

a determining unit 304, configured to determine whether the credit score of the target mechanism reaches a preset admission threshold value based on the credit score corresponding to the target mechanism;

a sending unit 306, if yes, triggering a consensus node joining transaction to the blockchain, so that an existing consensus node of the blockchain agrees on the consensus node joining transaction; the consensus node joining transaction is used for representing that a target mechanism terminal is joined as the consensus node of the block chain;

a setting unit 308, configured to set the target institution terminal as a consensus node of the blockchain when the consensus node joins the distributed database in which the transaction is included through the consensus of the existing consensus nodes.

In a further illustrated embodiment, the apparatus 30 is applied to a management platform for performing management on a consensus node of a block chain, the management platform is connected with a credit evaluation mechanism, and the join application contains an identifier of the target mechanism;

the sending unit 306 is further configured to send the identifier of the target institution to the credit evaluation institution to query a credit score of the target institution corresponding to the identifier;

the receiving unit 302 is further configured to receive the credit score of the target institution, which is sent by the credit evaluation institution and corresponds to the identifier.

In yet another illustrated embodiment, the join application includes a credit score corresponding to the target organization, and a digital signature made by a credit evaluation organization on at least the credit score based on a held private key;

the device 30 further comprises:

a verification unit that verifies the digital signature based on a public key of the credit evaluation organization;

and the acquisition unit is used for acquiring the credit score corresponding to the target organization contained in the joining application when the digital signature is verified.

In yet another illustrated embodiment, the consensus node joining the transaction by the existing consensus node of the blockchain comprises:

any existing consensus node acquires the consensus node sent by the accounting node to join in the transaction;

voting whether the consensus node join transaction can be included in the blockchain; so that the accounting node performs result calculation on votes performed by existing consensus nodes of the block chain; the weight of the votes cast by any one existing consensus node is positively correlated with the credit score of the organization user corresponding to any one existing consensus node;

and when the sum of the weights, executed by the existing consensus nodes of the block chain, of votes which agree to the consensus node to join a transaction and are recorded into the block chain exceeds a preset threshold value, the consensus node is added into the transaction and recorded into a distributed database of the block chain.

In another illustrated embodiment, before the existing consensus node of the blockchain agrees on the consensus node joining the transaction, the method further includes:

and the existing consensus nodes acquire credit scores of the organization users corresponding to each existing consensus node.

In yet another illustrated embodiment, the accounting node is selected from the existing consensus nodes based on a preset random algorithm, and the selected probability of each existing consensus node is positively correlated with the credit score of the organization user corresponding to each existing consensus node.

The implementation process of the functions and actions of each unit in the device 30 is specifically described in the implementation process of the corresponding step in the block chain-based data processing method executed by the management platform, and relevant points may be referred to the partial description of the method embodiment, which is not described herein again.

As shown in fig. 4, the present specification further provides a data processing apparatus 40 based on a blockchain, which is applied to a node device of the blockchain, and includes:

a receiving unit 402, configured to receive a consensus node joining transaction triggered by a management platform; the management platform is used for managing consensus nodes of the block chain, adding transactions into the consensus nodes to represent that a target mechanism terminal is added into the consensus nodes of the block chain, and judging by the management platform that the credit score corresponding to the target mechanism is larger than a preset admission threshold value;

a receiving and recording unit 404, configured to receive and record the common knowledge node in the transaction to the distributed database of the block chain after the common knowledge node joins the common knowledge of the existing common knowledge nodes of the block chain for the transaction, so as to authenticate the target institution terminal as the common knowledge node of the block chain.

In another illustrated embodiment, the consensus process of the existing consensus node of the blockchain for joining the transaction to the consensus node includes:

the existing consensus node of the block chain acquires the consensus node sent by the accounting node to join the transaction;

voting whether the consensus node join transaction can be included in the blockchain or not so that the accounting node calculates voting results of existing consensus nodes of the blockchain; the weight of the votes cast by the existing consensus node is positively correlated with the credit score of the organization user corresponding to the existing consensus node;

and when the sum of the weights, executed by the existing consensus nodes of the block chain, of votes which agree to the consensus node to join the transaction and are recorded in the block chain exceeds a preset threshold value, the consensus node joins the consensus of the transaction passing through the block chain.

In yet another illustrated embodiment, the accounting nodes are selected from existing consensus nodes of the block chain based on a preset random algorithm, and the selected probability of each existing consensus node is positively correlated with the credit score of the organization user corresponding to each existing consensus node.

In another illustrated embodiment, before selecting the accounting node from the existing consensus nodes of the blockchain based on a preset random algorithm, the method further includes:

and acquiring the credit score of the organization user corresponding to the existing consensus node from the management platform.

The implementation process of the function and the action of each unit in the apparatus 40 is specifically described in detail in the implementation process of the corresponding step in the data processing method based on the block chain executed by the node device of the block chain, and relevant points may be referred to part of the description of the method embodiment, which is not described herein again.

As shown in fig. 5, the present specification further provides a block chain-based consensus processing apparatus 50, applied to an existing consensus node of a block chain, including:

an obtaining unit 502, configured to obtain the transaction to be identified sent by the accounting node of the block chain;

a voting unit 504, configured to vote whether the transaction to be identified can be included in the blockchain, so that the accounting node calculates a voting result of an existing identification node of the blockchain; wherein the weight of the vote is positively correlated with the credit score of the organization user corresponding to the existing consensus node;

a recording unit 506, configured to record the transaction to be identified commonly into a distributed database of the block chain when a sum of weights, which are made by existing common identification nodes of the block chain and indicate that the transaction to be identified commonly is agreed to be recorded into votes of the block chain, exceeds a preset threshold, so as to indicate that the transaction to be identified commonly passes through the block chain.

In yet another illustrated embodiment, the obtaining unit 502 is further configured to obtain, from the management platform, a credit score of an organization user corresponding to an existing consensus node before the accounting node is selected from the existing consensus nodes in the block chain based on a preset random algorithm.

The specific details of the implementation process of the functions and actions of each unit in the apparatus 50 are described in the implementation process of the corresponding step in the block chain-based consensus processing method executed by the consensus node of the block chain, and relevant points may be referred to part of the description of the method embodiment, which is not described herein again.

The above-described embodiments of the apparatus are merely illustrative, and the units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical modules, may be located in one place, or may be distributed on a plurality of network modules. Some or all of the units or modules can be selected according to actual needs to achieve the purpose of the solution in the specification. One of ordinary skill in the art can understand and implement it without inventive effort.

The apparatuses, units and modules described in the above embodiments may be implemented by a computer chip or an entity, or by a product with certain functions. A typical implementation device is a computer, which may take the form of a personal computer, laptop computer, cellular telephone, camera phone, smart phone, personal digital assistant, media player, navigation device, email messaging device, game console, tablet computer, wearable device, or a combination of any of these devices.

Corresponding to the above method embodiments, embodiments of the present specification also provide a computer device, as shown in fig. 6, including a memory and a processor. Wherein the memory has stored thereon a computer program executable by the processor; the processor, when executing the stored computer program, performs the steps of the blockchain-based data processing method performed by the management platform in the embodiments of the present specification. For a detailed description of each step of the block chain-based data processing method executed by the management platform, please refer to the previous contents, and it is not repeated.

Corresponding to the above method embodiments, embodiments of the present specification also provide a computer device, as shown in fig. 6, including a memory and a processor. Wherein the memory has stored thereon a computer program executable by the processor; the processor, when executing the stored computer program, executes each step of the block chain-based data processing method executed by the node device of the block chain in the embodiments of the present specification. For a detailed description of each step of the data processing method based on the block chain executed by the node device, please refer to the previous contents, and it is not repeated.

Corresponding to the above method embodiments, embodiments of the present specification also provide a computer device, as shown in fig. 6, including a memory and a processor. Wherein the memory has stored thereon a computer program executable by the processor; the processor executes, when running the stored computer program, the respective steps of the block chain-based consensus processing method executed by the consensus node of the block chain in the embodiments of the present specification. For detailed descriptions of the steps of the block chain-based consensus processing method performed by the consensus node, please refer to the previous contents, which are not repeated.

The above description is only for the purpose of illustrating the preferred embodiments of the present disclosure and should not be taken as limiting the present disclosure, and any modifications, equivalents, improvements and the like made within the spirit and principle of the present disclosure should be included in the scope of the present disclosure.

In a typical configuration, a computing device includes one or more processors (CPUs), input/output interfaces, network interfaces, and memory.

The memory may include forms of volatile memory in a computer readable medium, Random Access Memory (RAM) and/or non-volatile memory, such as Read Only Memory (ROM) or flash memory (flash RAM). Memory is an example of a computer-readable medium.

Computer-readable media, including both non-transitory and non-transitory, removable and non-removable media, may implement information storage by any method or technology. The information may be computer readable instructions, data structures, modules of a program, or other data.

Examples of computer storage media include, but are not limited to, phase change memory (PRAM), Static Random Access Memory (SRAM), Dynamic Random Access Memory (DRAM), other types of Random Access Memory (RAM), Read Only Memory (ROM), Electrically Erasable Programmable Read Only Memory (EEPROM), flash memory or other memory technology, compact disc read only memory (CD-ROM), Digital Versatile Discs (DVD) or other optical storage, magnetic cassettes, magnetic tape magnetic disk storage or other magnetic storage devices, or any other non-transmission medium that can be used to store information that can be accessed by a computing device. As defined herein, a computer readable medium does not include a transitory computer readable medium such as a modulated data signal and a carrier wave.

It should also be noted that the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other like elements in a process, method, article, or apparatus that comprises the element.

As will be appreciated by one skilled in the art, embodiments of the present description may be provided as a method, system, or computer program product. Accordingly, embodiments of the present description may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, embodiments of the present description may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and so forth) having computer-usable program code embodied therein.

Claims

1. A data processing method based on a block chain is applied to a management platform for managing common nodes of the block chain, and comprises the following steps:

2. The method of claim 1, the management platform connected to a credit evaluation agency, the join application including an identification of the target agency;

the method further comprises the following steps:

sending the identification of the target mechanism to the credit evaluation mechanism to inquire the credit score of the target mechanism corresponding to the identification;

and receiving the credit score of the target institution corresponding to the identification, which is sent by the credit evaluation institution.

3. The method of claim 1, wherein the join application comprises a credit score corresponding to the target institution, and a digital signature of at least the credit score is made by a credit evaluation institution based on a held private key;

the method further comprises the following steps:

verifying the digital signature based on a public key of the credit evaluation authority;

and when the digital signature is verified, acquiring a credit score corresponding to the target organization contained in the joining application.

4. The method of any one of claims 1 to 3, existing consensus nodes of the blockchain consensus the consensus node join transaction, comprising:

voting whether the consensus node joining transaction can be recorded into the block chain or not so that the accounting node performs result statistics on votes performed by existing consensus nodes of the block chain; the weight of the votes cast by any one existing consensus node is positively correlated with the credit score of the organization user corresponding to any one existing consensus node;

5. The method of claim 4, further comprising, prior to the existing consensus node of the blockchain agreeing on the consensus node to join the transaction:

6. The method according to claim 4, wherein the accounting nodes are selected from the existing consensus nodes based on a preset random algorithm, and the selected probability of each existing consensus node is positively correlated with the credit score of the organization user corresponding to each existing consensus node.

7. A data processing method based on a block chain is applied to node equipment of the block chain and comprises the following steps:

and when the consensus node is added into the consensus of the existing consensus node of the block chain for transaction, adding the consensus node into the distributed database of the block chain for transaction recording so that the block chain authenticates the target mechanism terminal as the consensus node.

8. The method of claim 7, wherein the existing consensus node of the blockchain joins the consensus process of the transaction with the consensus node, comprising:

voting whether the consensus node joining transaction can be recorded into the block chain or not so that the accounting node performs result statistics on votes performed by existing consensus nodes of the block chain; the weight of the votes cast by the existing consensus node is positively correlated with the credit score of the organization user corresponding to the existing consensus node;

9. The method of claim 8, wherein the accounting nodes are selected from existing consensus nodes of the block chain based on a preset random algorithm, and the selected probability of each existing consensus node is positively correlated with the credit score of the organization user corresponding to each existing consensus node.

10. The method of claim 9, further comprising, before selecting the accounting node among existing consensus nodes of the blockchain based on a preset stochastic algorithm:

11. A blockchain-based data processing apparatus comprising:

a sending unit, if yes, triggering a consensus node to join the transaction to the blockchain, so that the existing consensus node of the blockchain agrees with the consensus node to join the transaction; the consensus node joining transaction is used for representing that a target mechanism terminal is joined as the consensus node of the block chain;

12. The apparatus of claim 11, applied to a management platform for managing consensus nodes of a blockchain, the management platform being connected to a credit evaluation organization, the join application including an identifier of the target organization;

the sending unit is further used for sending the identification of the target mechanism to the credit evaluation mechanism so as to inquire the credit score of the target mechanism corresponding to the identification;

the receiving unit is further configured to receive a credit score of a target institution, which is sent by the credit evaluation institution and corresponds to the identifier.

13. The apparatus of claim 11, the join application comprising a credit score corresponding to the target institution, and a digital signature of at least the credit score by a credit evaluation institution based on a held private key;

the device further comprises:

14. The apparatus of any one of claims 11 to 13, an existing consensus node of the blockchain agreeing on the consensus node to join a transaction, comprising:

voting whether the consensus node joining transaction can be recorded into the block chain or not so that the accounting node performs result calculation on the voting performed by the existing consensus nodes of the block chain; wherein the weight of the vote cast by any one existing consensus node is positively correlated with the credit score of the organization user corresponding to the any existing consensus node;

15. The apparatus of claim 14, further comprising, prior to an existing consensus node of the blockchain agreeing on the consensus node to join a transaction:

16. The apparatus of claim 14, wherein the accounting node is selected from the existing consensus nodes based on a preset random algorithm, and the selected probability of each existing consensus node is positively correlated with the credit score of the organization user corresponding to each existing consensus node.

17. A data processing device based on a block chain is applied to a node device of the block chain, and comprises:

18. The apparatus of claim 17, an existing consensus node of the blockchain joining a consensus process for a transaction to the consensus node, comprising:

19. The apparatus of claim 18, wherein the billing node is selected from existing consensus nodes of the block chain based on a preset random algorithm, and the selected probability of each existing consensus node is positively correlated with the credit score of the organization user corresponding to each existing consensus node.

20. The apparatus of claim 19, further comprising, before selecting the accounting node among existing consensus nodes of the blockchain based on a preset stochastic algorithm:

21. A computer device, comprising: a memory and a processor; the memory having stored thereon a computer program executable by the processor; the processor, when executing the computer program, performs the method of any of claims 1 to 6.

22. A computer device, comprising: a memory and a processor; the memory having stored thereon a computer program executable by the processor; the processor, when executing the computer program, performs the method of any of claims 7 to 10.