WO2021114627A1

WO2021114627A1 - Distributed transaction-based data processing method, device, terminal, and storage medium

Info

Publication number: WO2021114627A1
Application number: PCT/CN2020/099295
Authority: WO
Inventors: 张伟
Original assignee: 平安科技（深圳）有限公司
Priority date: 2020-05-28
Filing date: 2020-06-30
Publication date: 2021-06-17
Also published as: CN111694852B; CN111694852A

Abstract

Provided are a distributed transaction-based data processing method, device, terminal, and storage medium, relating to the technical field of blockchain, said method comprising: when a block height verification request is received, obtaining a database identifier carried in the block height verification request (S11); according to the database identifier, determining a target database used for performing a block height verification operation (S12); monitoring the height of a first block of the target database and the height of a second block of the original database (S13); detecting whether the height of the first block is consistent with the height of the second block (S14); if the result of detection is that the heights are inconsistent, then calculating the block height difference between the target database and the original database and retrieving transaction data corresponding to the block height difference from the original database (S15); determining the transaction type of transaction data and matching the target data of the corresponding attribute according to the transaction type (S16); storing the target data in the target database (S17). The described method can avoid abnormal data reading caused by network abnormalities and other reasons, and thus improves the accuracy of data reading.

Description

Data processing method, device, terminal and storage medium based on distributed transaction

This application claims the priority of the Chinese patent application filed with the Chinese Patent Office on May 28, 2020, the application number is 202010467837.2, and the invention title is "Data processing method, device, terminal and storage medium based on distributed transaction", all of which The content is incorporated in this application by reference.

Technical field

This application relates to the field of blockchain technology, and in particular to a data processing method, device, terminal and storage medium based on distributed transactions.

Background technique

At present, blockchain technology is widely used due to its important features such as decentralization, openness, autonomy, immutability of information, and anonymity. Various blockchain technologies have emerged one after another. Interoperability (that is, cross-chain operation) has become a very important and urgent need. For example, enterprise users may need to migrate business between different chains; ordinary users may need to exchange assets between different chains; the digital legal currency of the central bank may need to circulate on various blockchains, etc.

Cross-chain operations inevitably involve the addition, deletion, modification and inspection of transaction data of different block nodes. In order to meet the ACID (atomicity, consistency, isolation, and durability) characteristics of transaction data of different nodes, it is necessary to introduce distributed in cross-chain technology. The operation of the transaction. However, the inventor realizes that due to network delays and other reasons, the amount of transaction data stored in the transaction's associated database will be inconsistent, resulting in the failure of the read transaction operation to read consistent data, resulting in abnormal data reading.

Therefore, it is necessary to provide a method that can verify whether the amount of data in the associated database is consistent, and process inconsistent data in a timely manner, thereby increasing the accuracy of data reading.

Summary of the invention

In view of the above, it is necessary to provide a data processing method, device, terminal, and storage medium based on distributed transactions, which can avoid the problem of abnormal data reading caused by network delays and other reasons, and increase the accuracy of data reading.

The first aspect of the present application provides a data processing method based on distributed transactions, which is applied to cross-chain operations of blockchains, and the data processing method based on distributed transactions includes:

When a block height verification request is received, obtain the database identifier carried in the block height verification request;

Determining a target database for performing block height verification operations according to the database identifier;

Monitor the height of the first block of the target database and the height of the second block of the original database;

Detecting whether the height of the first block is consistent with the height of the second block;

When the detection result is that the height of the first block is inconsistent with the height of the second block, calculate the block height difference between the target database and the original database, and retrieve the Transaction data corresponding to the block height difference;

Determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type;

Storing the target data in the target database.

A second aspect of the present application provides a terminal, the terminal includes a processor and a memory, and the processor is configured to execute computer-readable instructions stored in the memory to implement the following steps:

Storing the target data in the target database.

A third aspect of the present application provides a computer-readable storage medium having at least one computer-readable instruction stored thereon, and the at least one computer-readable instruction is executed by a processor to implement the following steps:

Storing the target data in the target database.

The fourth aspect of the present application provides a data processing device based on distributed transactions, which is applied to cross-chain operations of a blockchain, and the data processing device based on distributed transactions includes:

An identification acquisition module, which is used to acquire the database identification carried in the block height verification request when the block height verification request output by the transaction requester is received;

A database determining module, configured to determine a target database for performing block height verification operations according to the database identifier;

The height monitoring module is used to monitor the height of the first block of the target database and the height of the second block of the original database;

A height detection module for detecting whether the height of the first block is consistent with the height of the second block;

The data retrieval module is used to calculate the block height difference between the target database and the original database when the detection result is that the height of the first block is inconsistent with the height of the second block, and obtain from the Retrieve the transaction data corresponding to the block height difference from the original database;

The data matching module is used to determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type;

The data storage module is used to store the target data in the target database.

It can be seen from the above technical solutions that this application is applied to blockchain technology. Using this application, by verifying the block heights of different databases, it is possible to find databases with inconsistent block heights, and perform timely analysis on databases with inconsistent block heights. Data processing can avoid abnormal data reading caused by network abnormalities and other reasons, thereby improving the accuracy of data reading.

Description of the drawings

Fig. 1 is a flowchart of a data processing method based on distributed transactions provided by the first embodiment of the present application.

Fig. 2 is a schematic structural diagram of a terminal according to an embodiment of the present application.

Fig. 3 is an exemplary functional block diagram of the terminal shown in Fig. 2.

The following specific embodiments will further illustrate this application in conjunction with the above-mentioned drawings.

Detailed ways

In order to be able to understand the above objectives, features and advantages of the application more clearly, the application will be described in detail below with reference to the accompanying drawings and specific embodiments. It should be noted that the embodiments of the application and the features in the embodiments can be combined with each other if there is no conflict.

In the following description, many specific details are set forth in order to fully understand the present application, and the described embodiments are a part of the embodiments of the present application, rather than all the embodiments. Based on the embodiments in this application, all other embodiments obtained by those of ordinary skill in the art without creative work shall fall within the protection scope of this application.

Unless otherwise defined, all technical and scientific terms used herein have the same meaning as commonly understood by those skilled in the technical field of this application. The terms used in the specification of the application herein are only for the purpose of describing specific embodiments, and are not intended to limit the application.

The execution subject of the distributed transaction-based data processing method provided in the embodiment of the present application includes but is not limited to at least one of the electronic devices that can be configured to execute the method provided in the embodiment of the present application, such as a server and a terminal. In other words, the distributed transaction-based data processing method may be executed by software or hardware installed on a terminal device or a server device, and the software may be a blockchain platform. The server includes but is not limited to: a single server, a server cluster, a cloud server or a cloud server cluster, etc.

Blockchain is a new application mode of computer technology such as distributed data storage, point-to-point transmission, consensus mechanism, and encryption algorithm. Blockchain, essentially a decentralized database, is a series of data blocks associated with cryptographic methods. Each data block contains a batch of network transaction information for verification. The validity of the information (anti-counterfeiting) and the generation of the next block. The blockchain can include the underlying platform of the blockchain, the platform product service layer, and the application service layer.

The underlying platform of the blockchain can include processing modules such as user management, basic services, smart contracts, and operation monitoring. Among them, the user management module is responsible for the identity information management of all blockchain participants, including the maintenance of public and private key generation (account management), key management, and maintenance of the correspondence between the user’s real identity and the blockchain address (authority management), etc. In the case of authorization, supervise and audit certain real-identity transactions, and provide risk control rule configuration (risk control audit); basic service modules are deployed on all blockchain node devices to verify the validity of business requests, After completing the consensus on the valid request, it is recorded on the storage. For a new business request, the basic service first performs interface adaptation analysis and authentication processing (interface adaptation), and then encrypts the business information through the consensus algorithm (consensus management), After encryption, it is completely and consistently transmitted to the shared ledger (network communication), and recorded and stored; the smart contract module is responsible for contract registration and issuance, contract triggering and contract execution. Developers can define the contract logic through a certain programming language and publish it to On the blockchain (contract registration), according to the logic of the contract terms, call keys or other events to trigger execution, complete the contract logic, and also provide the function of contract upgrade and cancellation; the operation monitoring module is mainly responsible for the deployment of the product release process , Configuration modification, contract settings, cloud adaptation, and visual output of real-time status during product operation, such as: alarms, monitoring network conditions, monitoring node equipment health status, etc.

Fig. 1 is a flowchart of a data processing method based on distributed transactions provided by the first embodiment of the present application. The data processing method based on distributed transactions is applied to the cross-chain operation of blockchain technology. As shown in FIG. 1, the data processing method based on distributed transactions includes the following steps:

S11. When the block height verification request is received, obtain the database identifier carried in the block height verification request.

In at least one embodiment of the present application, when a new read transaction is initiated on the blockchain network, the transaction requester outputs a block height verification request, which is used to request verification of the block height in the associated database (that is, Whether the amount of transaction data is consistent. The block height refers to the number of blocks linked to the main chain, that is, the number of blocks linked to the block chain. The block height can be used to identify the position of the block on the blockchain, and the block height contains the basic attributes and transaction data related to the block, where the basic attributes include the magic number (between blocks). Separator), block size and version number; the transaction data includes transaction count (the number of transactions recorded in the current block) and transaction details (for example, transaction timestamp, etc.).

Preferably, when the blockchain network encounters some unexpected reasons that cause the server to crash, or the pressure carried by the server is too large, the block height of the associated database needs to be verified. Therefore, in order to reduce the number of block height checks and improve transaction processing efficiency, the method further includes: calling a monitoring process to obtain network data of the current blockchain network, where the network data includes network connection data and load data; Detect whether the network data is abnormal; when the detection result is that the network data is abnormal, perform a block height verification operation. Specifically, the step of detecting whether the network data is abnormal includes: detecting whether there is disconnection data in the network connection data; when the detection result is that the network connection data has disconnection data, determining that the network data exists abnormal. Wherein, the disconnection data is data in a preset data format, and it can be determined whether there is disconnection data by detecting whether there is data in the preset data format. Alternatively, the step of detecting whether the network data is abnormal further includes: detecting whether the load data exceeds a preset load data threshold; when the detection result is that the load data exceeds the preset load data threshold, determining the network data There is an exception. The preset load data threshold is a preset threshold that can ensure the normality of the blockchain network. The preset load data threshold can be obtained through neural network training, or can be given based on experience.

In at least one embodiment of the present application, the block height verification request carries a database identifier, the database identifier is used to identify a certain database, and the specific form of the database identifier can be configured according to actual needs, for example, The database identifier may specifically be a database name, a database ID, and the like. The number of database identifiers may be one or more. In an embodiment, the number of the database identifiers is 3, corresponding to the state database, the historical database, and the distributed transaction database, respectively.

S12: Determine a target database for performing a block height verification operation according to the database identifier.

In at least one embodiment of the present application, a target database for performing block height verification operations is determined according to the database identifier, and the target database may be one or more of a state database, a historical database, and a distributed transaction database. A. Wherein, the current status information of transactions of different transaction types is stored in the status database, the transaction types may include ordinary transactions and distributed transaction transactions, and the current status information is the latest status information of the transaction, including: executing ( running, preparing, committing, aborting, committed, and aborted. The historical database stores historical status information of transactions of different transaction types. The distributed transaction database stores transaction data whose transaction type is distributed transaction.

S13. Monitor the height of the first block of the target database and the height of the second block of the original database.

In at least one embodiment of the present application, the original transaction data is stored in the original database, and the transaction data stored in the original database is complete, and there will be no omissions. Therefore, the block height monitor can monitor the first block height of each target database and the second block height of the original database to determine whether the transaction data in the target database is complete. The block height monitor can be used to monitor transaction data in the database. The number of block height monitors can be one, or the number of target databases that need to perform block height verification.

S14. Detect whether the height of the first block is consistent with the height of the second block, and when the detection result is that the height of the first block is inconsistent with the height of the second block, perform step S15.

In at least one embodiment of the present application, it is detected whether the first block height is consistent with the second block height, and when the detection result is that the first block height is consistent with the second block height , To return the result of the block height consistency to the transaction requester. It is understandable that for the situation where the height of the first block of the target database is consistent with the height of the second block of the original database, if there is a new read transaction operation on the blockchain network at this time, no data read abnormality will occur Case.

S15. Calculate the block height difference between the target database and the original database, and retrieve transaction data corresponding to the block height difference from the original database.

In at least one embodiment of the present application, the block height difference between the target database and the original database is calculated, and the transaction data corresponding to the block height difference is retrieved from the original database. Specifically, the step of retrieving the transaction data corresponding to the block height difference from the original database includes: retrieving a block file in the original database; deserializing the block file in the block file Original transaction data; obtain the timestamp carried by the original transaction data; determine the transaction data corresponding to the block height difference in the original transaction data according to the timestamp. Wherein, the block file stores original transaction data, and the original transaction data is serialized and stored in the block file. The serialization rules may include one of the Protobuf protocol, the Thrift protocol, or the Java serialization protocol. There are no restrictions here. The deserialization rule corresponding to the serialization rule is called to perform deserialization processing on the original transaction data, so as to obtain the original transaction data that can be viewed and analyzed.

Preferably, when the number of the target database is multiple (for example, when the target database includes a state database, a historical database, and a distributed transaction database), in order to obtain the area between the target database and the original database The block height difference requires multiple reading of the block file, and the data processing efficiency is low. In order to reduce the number of times of reading the block file and improve the efficiency of data processing, the step of determining the transaction data corresponding to the block height difference includes: calculating the block height of the target database and the original database Difference value set; determine the maximum difference value in the block height difference value set; retrieve the transaction data corresponding to the maximum difference value; determine the original database and the transaction data according to the transaction data corresponding to the maximum difference value Transaction data corresponding to the block height difference of the state database, the historical database, and the distributed transaction database.

Exemplarily, when the second block height of the original database is 100, the corresponding first block height of the state database is 97, the first block height of the historical database is 95, and the distribution The height of the first block of the style transaction database is 93. It can be seen that the block height differences between the original database and the state database, historical database, and distributed transaction database are 3, 5, and 7, respectively. Since the maximum block height difference is 7, the transaction data corresponding to blocks with a block height of 94-100 are retrieved from the original database. It is understandable that by retrieving the transaction data corresponding to the maximum value at one time and sequentially storing the retrieved data in the corresponding target database, the block file can be read at one time, reducing the block file reverse sequence The optimized processing process improves the efficiency of data processing.

S16. Determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type.

The transaction type of the transaction data is determined, and the target data of the corresponding attribute is matched according to the transaction type. The transaction types include ordinary transactions and distributed transaction transactions. For distributed transaction transactions, the entire transaction process is based on the two-phase protocol. Therefore, the distributed transaction-based data processing method provided in this application is also based on the two-phase protocol.

In at least one embodiment of the present application, when the target database is a state database and/or a history database, the transaction type of the transaction data is determined, and the target data of the corresponding attribute is matched according to the transaction type. The steps include: when the transaction type is a normal transaction, obtaining the key value and value of the transaction data corresponding to the normal transaction; when the transaction type is a distributed transaction transaction, obtaining the phase nature of the distributed transaction transaction , And determine the target data according to the nature of the stage. The stage properties include the first stage and the second stage.

Specifically, the step of determining the target data according to the nature of the phase includes: judging whether the nature of the phase is in the first phase; when the judgment result is that the nature of the phase is in the first phase, determining the distributed transaction The transaction is at the target location in the block file, and the target location is written into the Index database (at this time, it is not necessary to write the key value and value value of the distributed transaction transaction into the target database); The result is that when the nature of the phase is in the second phase, the transaction status of the distributed transaction transaction is determined, and when the transaction status is committed, the target corresponding to the first phase in the Index database is obtained according to the distributed transaction ID And extract the data key value and value value of the write set of the distributed transaction transaction from the block file according to the target location. Wherein, the transaction status of the distributed transaction transaction in the second phase also includes aborted, and when the transaction status is the aborted state, there is no need to read data.

In at least one embodiment of the present application, when the target database is a distributed transaction database, the step of determining the transaction type of the transaction data and matching the target data of the corresponding attribute according to the transaction type includes: Determine whether the distributed transaction transaction is in the first stage; when the result of the determination is that the distributed transaction transaction is in the first stage, obtain the read set and write set of the distributed transaction transaction; when the result of the determination is the distribution When the transaction transaction is in the second stage, the read set and write set of the transaction corresponding to the first stage in the target database are determined and deleted according to the distributed transaction ID. By storing the read set and write set of the distributed transaction transaction in the first stage in the distributed transaction database, this part of the data can be locked, and other transactions can prevent other transactions from changing this data. When the distributed transaction transaction is in the second stage, delete the read set and write set of the transaction corresponding to the first stage in the target database, and unlock this part of the data.

It is understandable that when the transaction type is a normal transaction, there is no need to store transaction data of the normal transaction in the distributed transaction database.

S17. Store the target data in the target database.

In at least one embodiment of the present application, the target data is stored in the target database, so that the height of the first block of the target database is consistent with the height of the second block of the original database.

When the target database is a state database and/or a historical database, the step of storing the target data in the target database includes: storing key values and value values of transaction data of ordinary transactions in the state database And/or historical database; storing the data key value and value value of the write set of the distributed transaction transaction in the second stage and the transaction status as committed to the state database and/or historical database. When the target database is a distributed transaction database, the read set and write set of the distributed transaction transaction in the first stage are stored in the distributed transaction database.

In the method flow described in Figure 1, by checking the block heights of different databases, databases with inconsistent block heights can be found, and data processing on databases with inconsistent block heights can be performed in time to avoid network abnormalities and other reasons. Resulting in abnormal data reading, thereby improving the accuracy of data reading.

The above is a detailed description of the method provided by the embodiment of the present application. According to different requirements, the execution order of the blocks in the flowchart shown can be changed, and some blocks can be omitted. The terminal 1 provided in the embodiment of the present application will be described below.

FIG. 2 is a schematic structural diagram of a terminal according to an embodiment of the present application. As shown in FIG. 2, the terminal 1 includes a memory 10 in which the distributed transaction-based data processing device 100 is stored. The terminal 1 may be an electronic device with functions of data processing, analysis, program execution, and display, such as a computer, a tablet computer, or a personal digital assistant. When the distributed transaction-based data processing device 100 receives a block height verification request, it obtains the database identification carried in the block height verification request; and determines that it is used to perform the block height verification according to the database identification. Operation target database; monitor the height of the first block of the target database and the height of the second block of the original database; detect whether the height of the first block is consistent with the height of the second block; when the detection result is all When the height of the first block is inconsistent with the height of the second block, the block height difference between the target database and the original database is calculated, and the block height difference is retrieved from the original database Corresponding transaction data; determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type; store the target data in the target database. Using this application, by verifying the block heights of different databases, it is possible to find databases with inconsistent block heights, and to process data in time for databases with inconsistent block heights, which can avoid data reading abnormalities caused by network abnormalities and other reasons. In order to improve the accuracy of data reading.

In this embodiment, the terminal 1 may further include a display screen 20 and a processor 30. The memory 10 and the display screen 20 may be electrically connected to the processor 30 respectively.

The memory 10 may be different types of storage devices for storing various types of data. For example, it can be the memory or internal memory of the terminal 1, or a memory card that can be externally connected to the terminal 1, such as flash memory, SM card (Smart Media Card), SD card (Secure Digital Card, secure digital card) Wait. In addition, the memory 10 may include non-volatile memory, such as a hard disk, a memory, a plug-in hard disk, a smart memory card (Smart Media Card, SMC), a Secure Digital (SD) card, and a flash memory card (Flash Card). , At least one magnetic disk storage device, flash memory device, or other non-volatile solid state storage device. The memory 10 is used to store various types of data, for example, various types of applications (Applications) installed in the terminal 1, and data set and obtained by applying the above-mentioned distributed transaction-based data processing method.

The display screen 20 is installed in the terminal 1 for displaying information.

The processor 30 is configured to execute the distributed transaction-based data processing method and various software installed in the terminal 1, such as an operating system and application display software. The processor 30 includes, but is not limited to, a processor (Central Processing Unit, CPU), a Micro Controller Unit (MCU), and other devices for interpreting computer instructions and processing data in computer software.

The distributed transaction-based data processing apparatus 100 may include one or more modules, and the one or more modules are stored in the memory 10 of the terminal 1 and configured to be operated by one or more processors (this The implementation manner is executed by a processor 30) to complete the embodiment of the present application. When the distributed transaction-based data processing device 100 is applied to a cluster manager, for example, as shown in FIG. 3, the distributed transaction-based data processing device 100 may include an identification acquiring module 101, a database determining module 102, The height monitoring module 103, the height detection module 104, the data retrieval module 105, the data matching module 106, and the data storage module 107. The module referred to in the embodiment of the present application may be a program segment that completes a specific function, and is more suitable for describing the execution process of software in the processor 30 than a program.

It can be understood that, corresponding to the various implementations in the above-mentioned distributed transaction-based data processing method, the distributed transaction-based data processing apparatus 100 may include some or all of the functional modules shown in FIG. The functions will be described in detail below. It should be noted that the same nouns, related nouns, and specific explanations in the above implementations of the distributed transaction-based data processing method can also be applied to the following introduction to the functions of each module. To save space and avoid repetition, I won’t repeat them here.

The identification obtaining module 101 may be configured to obtain the database identification carried in the block height verification request when the block height verification request output by the transaction requester is received.

The database determining module 102 may be configured to determine a target database for performing the block height verification operation according to the database identifier.

The height monitoring module 103 may be used to monitor the height of the first block of the target database and the height of the second block of the original database.

The height detection module 104 may be used to detect whether the height of the first block is consistent with the height of the second block.

The data retrieval module 105 can be used to calculate the difference between the block height of the target database and the original database when the detection result is that the height of the first block is inconsistent with the height of the second block, and obtain information from all the blocks. The transaction data corresponding to the block height difference is retrieved from the original database.

The data matching module 106 may be used to determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type.

The data storage module 107 may be used to store the target data in the target database.

The embodiment of the present application also provides a computer-readable storage medium on which a computer program is stored, and when the computer program is executed by the processor 30, the steps of the distributed transaction-based data processing method in any of the foregoing embodiments are implemented.

If the distributed transaction-based data processing device 100 is implemented in the form of a software functional unit and sold or used as an independent product, it may be stored in a computer-readable storage medium, and the computer-readable storage medium may be non- Volatile storage media can also be volatile storage media. Based on this understanding, this application implements all or part of the processes in the above-mentioned implementation methods, and can also be completed by instructing relevant hardware through a computer program. The computer program can be stored in a computer-readable storage medium. When the program is executed by the processor 30, the steps of the foregoing method embodiments can be implemented. Wherein, the computer program includes computer program code, and the computer program code may be in the form of source code, object code, executable file, or some intermediate forms. The computer-readable storage medium may include: any entity or device capable of carrying the computer program code, recording medium, U disk, mobile hard disk, magnetic disk, optical disk, computer memory, read-only memory (ROM, Read-Only Memory) )Wait.

The so-called processor 30 may be a central processing unit (Central Processing Unit, CPU), other general processors, digital signal processors (Digital Signal Processor, DSP), application specific integrated circuits (Application Specific Integrated Circuit, ASIC), Field-Programmable Gate Array (FPGA) or other programmable logic devices, discrete gates or transistor logic devices, discrete hardware components, etc. The general-purpose processor can be a microprocessor or the processor can also be any conventional processor, etc. The processor 30 is the control center of the distributed transaction-based data processing device 100/terminal 1, using various interfaces Each part of the entire distributed transaction-based data processing device 100/terminal 1 is connected to the line.

The memory 10 is used to store the computer program and/or module, and the processor 30 runs or executes the computer program and/or module stored in the memory 10 and calls the data stored in the memory 10, The various functions of the distributed transaction-based data processing device 100/terminal 1 are realized. The memory 10 may mainly include a program storage area and a data storage area, where the program storage area may store an operating system, an application program required by at least one function (such as a sound playback function, an image playback function, etc.), etc.; the storage data area may Data and the like created in accordance with the use of the terminal 1 are stored.

In the several specific implementation manners provided in this application, it should be understood that the disclosed terminal and method may be implemented in other ways. For example, the system implementation described above is only illustrative. For example, the division of the modules is only a logical function division, and there may be other division methods in actual implementation.

For those skilled in the art, it is obvious that the embodiments of the present application are not limited to the details of the above exemplary embodiments, and can be implemented in other specific forms without departing from the spirit or basic characteristics of the embodiments of the present application. example. Therefore, no matter from which point of view, the embodiments should be regarded as exemplary and non-restrictive. The scope of the embodiments of the present application is defined by the appended claims rather than the above description, and therefore it is intended to fall on All changes within the meaning and scope of equivalent elements of the claims are included in the embodiments of the present application. Any reference signs in the claims should not be regarded as limiting the claims involved. Multiple units, modules or devices stated in the claims of a system, device or terminal can also be implemented by the same unit, module or device through software or hardware.

The above implementation manners are only used to illustrate the technical solutions of the embodiments of the present application, not to limit them. Although the embodiments of the present application are described in detail with reference to the above preferred implementation manners, those of ordinary skill in the art should understand that the technical solutions of the embodiments of the present application Modifications or equivalent replacements of the solutions should not depart from the spirit and scope of the technical solutions of the embodiments of the present application.

Claims

A data processing method based on distributed transactions is applied to cross-chain operations of blockchains, wherein the data processing method based on distributed transactions includes:

When a block height verification request is received, obtain the database identifier carried in the block height verification request;

Determining a target database for performing block height verification operations according to the database identifier;

Monitor the height of the first block of the target database and the height of the second block of the original database;

Detecting whether the height of the first block is consistent with the height of the second block;

When the detection result is that the height of the first block is inconsistent with the height of the second block, calculate the block height difference between the target database and the original database, and retrieve the Transaction data corresponding to the block height difference;

Determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type;

Storing the target data in the target database.
The data processing method based on distributed transactions according to claim 1, wherein the step of retrieving the transaction data corresponding to the block height difference from the original database comprises:

Retrieve the block file in the original database;

Deserialize the original transaction data in the block file;

Acquiring the timestamp carried in the original transaction data;

The transaction data corresponding to the block height difference in the original transaction data is determined according to the time stamp.
The data processing method based on distributed transactions according to claim 2, wherein when the target database includes a state database, a history database, and a distributed transaction database, the transaction data corresponding to the block height difference is determined The steps include:

Calculating a block height difference set between the target database and the original database;

Determine the maximum value of the difference in the block height difference concentration;

Retrieve the transaction data corresponding to the maximum value of the difference;

The transaction data corresponding to the block height difference of the original database, the state database, the history database, and the distributed transaction database are respectively determined according to the transaction data corresponding to the maximum value of the difference.
The data processing method based on distributed transactions according to claim 3, wherein when the target database is a state database and/or a historical database, the transaction type of the transaction data is determined, and the transaction type is determined according to the transaction type. The steps of matching out the target data of the corresponding attribute include:

When the transaction type is an ordinary transaction, obtain the key value and the value of the transaction data corresponding to the ordinary transaction;

When the transaction type is a distributed transaction transaction, the phase nature of the distributed transaction transaction is obtained, and the target data is determined according to the phase nature.
The data processing method based on distributed transactions according to claim 4, wherein the step of determining the target data according to the nature of the stage comprises:

Determine whether the nature of the stage is in the first stage;

When the judgment result is that the nature of the phase is in the first phase, determine the target position of the distributed transaction transaction in the block file, and write the target position into the Index database;

When the judgment result is that the nature of the phase is in the second phase, determine the transaction status of the distributed transaction transaction, and when the transaction status is committed, obtain the first phase corresponding to the Index database according to the distributed transaction ID And extract the data key value and value value of the write set of the distributed transaction transaction from the block file according to the target position.
The data processing method based on distributed transactions according to claim 3, wherein when the target database is a distributed transaction database, the transaction type of the transaction data is determined, and the corresponding transaction type is matched according to the transaction type. The steps for the target data of the attribute include:

Determine whether the distributed transaction transaction is in the first stage;

When the judgment result is that the distributed transaction transaction is in the first stage, acquiring the read set and the write set of the distributed transaction transaction;

When the judgment result is that the distributed transaction transaction is in the second stage, the read set and the write set of the transaction corresponding to the first stage in the target database are determined and deleted according to the distributed transaction ID.
The data processing method based on distributed transactions according to claim 1, wherein the method further comprises:

Invoke the monitoring process to obtain network data of the current blockchain network, where the network data includes network connection data and load data;

Detecting whether the network data is abnormal;

When the detection result is that the network data is abnormal, a block height verification request is received.
A terminal, wherein the terminal includes a processor and a memory, and the processor is configured to execute at least one computer-readable instruction stored in the memory to implement the following steps:

When a block height verification request is received, obtain the database identifier carried in the block height verification request;

Determining a target database for performing block height verification operations according to the database identifier;

Monitor the height of the first block of the target database and the height of the second block of the original database;

Detecting whether the height of the first block is consistent with the height of the second block;

When the detection result is that the height of the first block is inconsistent with the height of the second block, calculate the block height difference between the target database and the original database, and retrieve the Transaction data corresponding to the block height difference;

Determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type;

Storing the target data in the target database.
The terminal according to claim 8, wherein, in the step of retrieving the transaction data corresponding to the block height difference from the original database, the processor executes the at least one computer-readable instruction To achieve the following steps:

Retrieve the block file in the original database;

Deserialize the original transaction data in the block file;

Acquiring the timestamp carried in the original transaction data;

The transaction data corresponding to the block height difference in the original transaction data is determined according to the time stamp.
The terminal according to claim 9, wherein, when the target database includes a state database, a historical database, and a distributed transaction database, when the step of determining the transaction data corresponding to the block height difference, the The processor executes the at least one computer readable instruction to implement the following steps:

Calculating a block height difference set between the target database and the original database;

Determine the maximum value of the difference in the block height difference concentration;

Retrieve the transaction data corresponding to the maximum value of the difference;

The transaction data corresponding to the block height difference of the original database, the state database, the history database, and the distributed transaction database are respectively determined according to the transaction data corresponding to the maximum value of the difference.
The terminal according to claim 10, wherein, when the target database is a state database and/or a history database, the transaction type of the transaction data is determined, and the target data corresponding to the attribute is matched according to the transaction type When the processor executes the at least one computer-readable instruction, the processor is also used to implement the following steps:

When the transaction type is an ordinary transaction, obtain the key value and the value of the transaction data corresponding to the ordinary transaction;

When the transaction type is a distributed transaction transaction, the phase nature of the distributed transaction transaction is obtained, and the target data is determined according to the phase nature.
The terminal according to claim 11, wherein, in the step of determining the target data according to the nature of the stage, the processor executes the at least one computer-readable instruction to implement the following steps:

Determine whether the nature of the stage is in the first stage;

When the judgment result is that the nature of the phase is in the first phase, determine the target position of the distributed transaction transaction in the block file, and write the target position into the Index database;

When the judgment result is that the nature of the phase is in the second phase, determine the transaction status of the distributed transaction transaction, and when the transaction status is committed, obtain the first phase corresponding to the Index database according to the distributed transaction ID And extract the data key value and value value of the write set of the distributed transaction transaction from the block file according to the target position.
The terminal according to claim 10, wherein, when the target database is a distributed transaction database, the step of determining the transaction type of the transaction data, and matching the target data of the corresponding attribute according to the transaction type When the processor executes the at least one computer-readable instruction to implement the following steps:

Determine whether the distributed transaction transaction is in the first stage;

When the judgment result is that the distributed transaction transaction is in the first stage, acquiring the read set and the write set of the distributed transaction transaction;

When the judgment result is that the distributed transaction transaction is in the second stage, the read set and the write set of the transaction corresponding to the first stage in the target database are determined and deleted according to the distributed transaction ID.
A computer-readable storage medium, wherein the computer-readable storage medium stores at least one computer-readable instruction, and when the at least one computer-readable instruction is executed by a processor, the following steps are implemented:

When a block height verification request is received, obtain the database identifier carried in the block height verification request;

Determining a target database for performing block height verification operations according to the database identifier;

Monitor the height of the first block of the target database and the height of the second block of the original database;

Detecting whether the height of the first block is consistent with the height of the second block;

When the detection result is that the height of the first block is inconsistent with the height of the second block, calculate the block height difference between the target database and the original database, and retrieve the Transaction data corresponding to the block height difference;

Determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type;

Storing the target data in the target database.
The storage medium according to claim 14, wherein, in the step of retrieving the transaction data corresponding to the block height difference from the original database, the at least one computer readable instruction is executed by a processor To achieve the following steps:

Retrieve the block file in the original database;

Deserialize the original transaction data in the block file;

Acquiring the timestamp carried in the original transaction data;

The transaction data corresponding to the block height difference in the original transaction data is determined according to the time stamp.
The storage medium according to claim 15, wherein when the target database includes a state database, a historical database, and a distributed transaction database, when the step of determining the transaction data corresponding to the block height difference, the The at least one computer readable instruction is executed by the processor to implement the following steps:

Calculating a block height difference set between the target database and the original database;

Determine the maximum value of the difference in the block height difference concentration;

Retrieve the transaction data corresponding to the maximum value of the difference;

The transaction data corresponding to the block height difference of the original database, the state database, the history database, and the distributed transaction database are respectively determined according to the transaction data corresponding to the maximum value of the difference.
The storage medium according to claim 16, wherein when the target database is a state database and/or a historical database, the transaction type of the transaction data is determined, and the corresponding attribute is matched according to the transaction type In the step of target data, the at least one computer readable instruction is executed by the processor to implement the following steps:

When the transaction type is an ordinary transaction, obtain the key value and the value of the transaction data corresponding to the ordinary transaction;

When the transaction type is a distributed transaction transaction, the phase nature of the distributed transaction transaction is obtained, and the target data is determined according to the phase nature.
18. The storage medium according to claim 17, wherein in the step of determining the target data according to the nature of the stage, the at least one computer readable instruction is further used to implement the following steps when being executed by a processor:

Determine whether the nature of the stage is in the first stage;

When the judgment result is that the nature of the phase is in the first phase, determine the target position of the distributed transaction transaction in the block file, and write the target position into the Index database;

When the judgment result is that the nature of the phase is in the second phase, determine the transaction status of the distributed transaction transaction, and when the transaction status is committed, obtain the first phase corresponding to the Index database according to the distributed transaction ID And extract the data key value and value value of the write set of the distributed transaction transaction from the block file according to the target position.
The storage medium according to claim 16, wherein when the target database is a distributed transaction database, the transaction type of the transaction data is determined, and the target data of the corresponding attribute is matched according to the transaction type. During the steps, the at least one computer-readable instruction is executed by the processor to implement the following steps:

Determine whether the distributed transaction transaction is in the first stage;

When the judgment result is that the distributed transaction transaction is in the first stage, acquiring the read set and the write set of the distributed transaction transaction;

When the judgment result is that the distributed transaction transaction is in the second stage, the read set and the write set of the transaction corresponding to the first stage in the target database are determined and deleted according to the distributed transaction ID.
A data processing device based on distributed transactions is applied to cross-chain operations of blockchains, wherein the data processing device based on distributed transactions includes:

An identification acquisition module, which is used to acquire the database identification carried in the block height verification request when the block height verification request output by the transaction requester is received;

A database determining module, configured to determine a target database for performing block height verification operations according to the database identifier;

The height monitoring module is used to monitor the height of the first block of the target database and the height of the second block of the original database;

A height detection module for detecting whether the height of the first block is consistent with the height of the second block;

The data retrieval module is used to calculate the block height difference between the target database and the original database when the detection result is that the height of the first block is inconsistent with the height of the second block, and obtain from the Retrieve the transaction data corresponding to the block height difference from the original database;

The data matching module is used to determine the transaction type of the transaction data, and match the target data of the corresponding attribute according to the transaction type;

The data storage module is used to store the target data in the target database.