CN111813791B - Distributed transaction compensation method and equipment - Google Patents

Abstract

The application aims to provide a distributed compensation transaction method and equipment, and the application sets a compensation transaction service corresponding to a business method in a business system; recording compensation transaction information when executing the business method, and storing the compensation transaction information into a database; and executing the local transaction, and processing the compensation transaction information and the compensation transaction service according to the execution result of the local transaction. Therefore, the consistency of data in a distributed environment can be ensured, the complexity of a transaction processing process is reduced, and other compensation transaction operations except for a business compensation processing part in a decoupling business system are performed.

Description

A method and device for distributed compensation transactions

Technical Field

The present application relates to the field of computers, and in particular to a method and device for distributed compensation transactions.

Background technique

In a distributed environment, in order to ensure data consistency between different data sources, distributed transactions are generally used. Currently, the implementation methods of distributed transactions mainly include the following: two-phase commit transactions; reliable message transactions; compensation transactions. However, these methods have the following disadvantages: the two-phase commit transaction method is complex to implement, sacrifices availability, has a greater impact on performance, and is not suitable for high-concurrency and high-performance scenarios; although the reliable message transaction method avoids distributed transactions and achieves eventual consistency, it has requirements for the reliability of the middleware; the compensation transaction method is simple to implement, but the transaction record table will be coupled to the business system. If there is no encapsulated solution, there are many steps to be processed.

Summary of the invention

One purpose of the present application is to provide a method and device to solve the problems of data consistency, complex transaction processing process and the need for other processing operations in the decoupling process in the prior art.

According to one aspect of the present application, a distributed compensation transaction method is provided, the method comprising:

Set up compensation transaction services corresponding to business methods in the business system;

When executing the business method, the compensation transaction information is recorded and stored in the database;

Execute the local transaction, and process the compensation transaction information and the compensation transaction service according to the execution result of the local transaction.

Furthermore, a compensation transaction service corresponding to the business method is set in the business system, including:

The compensating transaction annotation in the compensating transaction service is marked on the business method in the business system, and the maximum timeout of the compensating transaction and the number of retries of the compensation logic are set.

Further, processing the compensation transaction information and the compensation transaction service according to the execution result of the local transaction includes:

When the execution result of the local transaction is that the transaction is successful, the compensation transaction information is automatically deleted through the compensation transaction service.

Further, processing the compensation transaction information and the compensation transaction service according to the execution result of the local transaction includes:

When the execution result of the local transaction is a transaction failure, the compensation transaction information is notified to the business system in a message notification manner, and the business system executes the compensation logic in the compensation transaction service.

Further, when the execution result of the local transaction is a transaction failure, the compensating transaction information is notified to the business system in a message notification manner, including:

Starting a transaction scanning task corresponding to the compensation transaction service, and obtaining transaction compensation records of abnormal transactions in the database through the transaction scanning task;

The transaction compensation record of the abnormal transaction is notified to the business system in a message notification manner.

Further, the method comprises:

The business system monitors the message notification and executes or retries the compensation logic according to its own business information.

Furthermore, the business system executes the compensation logic in the compensation transaction service, including:

The compensation transaction service set in the business system determines the corresponding compensation logic method in the business system configured on the compensation transaction annotation according to the compensation transaction annotation;

The compensation logic method is called by reflection to be executed.

According to another aspect of the present application, a device for distributed compensation transactions is also provided, the device comprising:

A setting device, used for setting a compensation transaction service corresponding to a business method in a business system;

A recording device, used to record compensation transaction information when executing the business method, and store it in a database;

The execution device is used to execute the local transaction and process the compensation transaction information and the compensation transaction service according to the execution result of the local transaction.

According to another aspect of the present application, a device for distributed compensation transactions is also provided, the device comprising:

one or more processors; and

A memory storing computer readable instructions, which, when executed, cause the processor to perform the operations of the method as described above.

According to another aspect of the present application, a computer-readable medium is provided, on which computer-readable instructions are stored. The computer-readable instructions can be executed by a processor to implement the method described above.

Compared with the prior art, this application sets the compensation transaction service corresponding to the business method in the business system; records the compensation transaction information when executing the business method and stores it in the database; executes the local transaction, and processes the compensation transaction information and the compensation transaction service according to the execution result of the local transaction. It can ensure the consistency of data in a distributed environment, reduce the complexity of the transaction processing process, and decouple other compensation transaction operations in the business system except the business compensation processing part.

BRIEF DESCRIPTION OF THE DRAWINGS

Other features, objects and advantages of the present application will become more apparent by reading the detailed description of non-limiting embodiments made with reference to the following drawings:

FIG1 is a schematic diagram showing a method flow of a distributed compensation transaction provided according to one aspect of the present application;

FIG2 is a flow chart showing a method for implementing distributed compensation transactions through a business system and a compensation transaction service in a specific embodiment of the present application;

FIG3 shows a schematic structural diagram of a device for distributed compensation transactions according to another aspect of the present application.

The same or similar reference numerals in the drawings represent the same or similar components.

Detailed ways

The present application is described in further detail below in conjunction with the accompanying drawings.

In a typical configuration of the present application, the terminal, the device of the service network and the trusted party all include one or more processors (eg, a central processing unit (CPU)), an input/output interface, a network interface and a memory.

Memory may include non-permanent memory in a computer-readable medium, random access memory (RAM) and/or non-volatile memory in the form of read-only memory (ROM) or flash RAM. Memory is an example of a computer-readable medium.

Computer readable media include permanent and non-permanent, removable and non-removable media that can be used to store information by any method or technology. Information can be computer-readable instructions, data structures, program modules or other data. Examples of computer storage media include, but are not limited to, Phase-Change RAM (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 Disk (DVD) or other optical storage, magnetic cassettes, tape disk storage or other magnetic storage devices or any other non-transmission media that can be used to store information that can be accessed by a computing device. As defined herein, computer readable media does not include non-transitory media such as modulated data signals and carrier waves.

FIG1 shows a schematic flow chart of a method for distributed compensation transactions according to one aspect of the present application. The method comprises: steps S11 to S13.

In step S11, a compensation transaction service corresponding to the business method is set in the business system; here, a general compensation transaction RPC service is introduced in the business system, and the compensation transaction service is set for the specific methods in the business class that need to support compensation transactions; for example, in the business of lottery and coupon issuance, the lottery operation and coupon issuance belong to two operations of two business systems. The two operations must be atomic and the data must be eventually consistent, and both must succeed or fail. In a distributed environment, there may be a situation where the prize is won but the prize issuance fails. In order to ensure the eventual consistency of the data, it is necessary to add a transaction, that is, in the business system of lottery and coupon issuance, corresponding compensation transaction services are set for the lottery operation method and the coupon issuance method.

In step S12, when the business method is executed, the compensation transaction information is recorded and stored in the database; here, when the business system executes the business method corresponding to the compensation transaction, the compensation transaction information is recorded through the compensation transaction RPC service, and the recorded compensation transaction information is stored in the database, so that the compensation transaction information is no longer saved after the transaction is executed.

In step S13, the local transaction is executed, and the compensation transaction information and the compensation transaction service are processed according to the execution result of the local transaction. Here, the local transaction is executed to obtain an execution result, which is a transaction success or a transaction failure. When a timeout or an exception occurs, it can be considered as a transaction failure. The compensation transaction information is processed and the compensation transaction service is executed according to the execution result.

In one embodiment of the present application, in step S11, the compensation transaction annotation in the compensation transaction service is marked on the business method in the business system, and the maximum timeout of the compensation transaction and the number of retries of the compensation logic are set. Here, the compensation transaction annotation is marked on the specific method in the business class that needs to support compensation transactions, and the specific method of compensation implementation, the maximum timeout of the transaction and the number of retries of the compensation logic are set. Among them, the mechanism adopted by the transaction can first try the forward logic, and directly submit if successful, but if it fails, the rollback logic needs to be executed to ensure the final consistency of the data. The compensation method is the rollback logic when the attempt fails due to network timeout or other unknown reasons, and is automatically called and executed by the compensating transaction component. Using annotations can be more convenient to use. The logic of encapsulating annotations is to add Spring AOP aspects to the annotations and process the methods with the annotations added; the processing content is: before the business method is executed, the transaction record is first inserted into the database, and then the business method is executed. If successful, the transaction record is deleted, and if it fails, the transaction status is updated to failure. When the business system executes the business method of the compensation transaction, the compensation transaction information will be recorded through the compensation transaction service. The compensation logic execution adopts the best effort notification solution. The business party can set the maximum timeout time and the number of retries of the compensation logic to avoid resource waste caused by infinite retries.

In one embodiment of the present application, in step S13, when the execution result of the local transaction is a successful transaction, the compensation transaction information is automatically deleted through the compensation transaction service. Here, after the business system successfully executes the business method, the compensation transaction information is automatically deleted through the compensation transaction RPC service. The transaction record is stored in the database, and there is no need to save it after the transaction is executed. After the transaction is processed, the compensation service automatically deletes the record to avoid the performance being affected by the excessive amount of data in the transaction record table.

In one embodiment of the present application, in step S13, when the execution result of the local transaction is a transaction failure, the compensation transaction information is notified to the business system in a message notification manner, and the business system executes the compensation logic in the compensation transaction service. Here, when executing a local transaction, if the transaction times out or is abnormal, the transaction fails, then the compensation transaction service schedules scanning abnormal transactions to notify the business system for compensation. Specifically, the compensation transaction service sends transaction compensation information MQ to notify the business system to execute the compensation logic, and the business system executes the compensation transaction.

In a specific embodiment of the present application, as shown in Figure 2, the compensation transaction service provides a compensation transaction mechanism guarantee to the business system in the form of an RPC service, records compensation transaction information, deletes compensation transaction record operations, and directly deletes the compensation transaction record if the transaction is successfully executed. If the transaction fails, an MQ message is sent through the scheduled scanning schedule of the compensation transaction to notify the business system to execute the transaction compensation logic. The specific process is as follows: the business system records the compensation transaction information of the compensation transaction service, wherein the compensation transaction information includes compensation dependency data, transaction timeout information, and compensation retry information; the compensation transaction service returns the operation result to the business system, and the business system executes the local transaction. If the transaction is successful, the compensation transaction information is deleted. If the transaction fails, the compensation transaction service sends transaction compensation information MQ to notify the business system to execute the compensation logic, and the business system executes the compensation transaction.

In one embodiment of the present application, the transaction scanning task corresponding to the compensation transaction service can be started, and the transaction compensation record of the abnormal transaction in the database can be obtained through the transaction scanning task; the transaction compensation record of the abnormal transaction is notified to the business system in the form of a message notification. Here, the corresponding transaction scanning task is started in the compensation transaction service, and the failed transactions that need to be retried are scanned regularly, and MQ is sent to notify the business system to execute its corresponding transaction compensation logic.

In one embodiment of the present application, the method includes: monitoring the message notification through the business system, and executing or retrying the compensation logic according to its own business information. Specifically, the compensation transaction service set in the business system can determine the corresponding compensation logic method in the business system configured on the compensation transaction annotation according to the compensation transaction annotation; and call the compensation logic method by reflection to execute. Here, the business system monitors the compensation transaction notification MQ, and according to its own business situation or retrying the compensation logic, the compensation logic needs to support idempotence. The execution of the compensation logic is ultimately realized by consuming MQ messages. Under extreme conditions such as network anomalies, in order to ensure the reliable reach of the message, the MQ message may be repeatedly sent. In order to avoid data inconsistency caused by repeated consumption, the business party needs to perform idempotence processing of the compensation logic by itself. When the transaction is retried, an MQ message will be sent to notify the business system. The compensation transaction service will call the corresponding compensation logic method in the system configured on the transaction annotation by reflection, and the compensation implementation is provided by the business user; compensation implementation, for example, if the lottery is successful, but the coupon issuance is abnormally interrupted, then check whether the coupon issuance is successful. If successful, the lottery record status is updated to valid, otherwise no processing is performed, and the lottery record status defaults to invalid.

Through the method described above in this application, the consistency of data in a distributed environment can be guaranteed, the complexity of the transaction processing process can be reduced, and other compensation transaction operations in the business system except the business compensation processing part can be decoupled.

In addition, an embodiment of the present application further provides a computer-readable medium on which computer-readable instructions are stored. The computer-readable instructions can be executed by a processor to implement the aforementioned distributed compensation transaction method.

Corresponding to the method described above, the present application also provides a terminal, which includes a module or unit capable of executing the method steps described in Figure 1 or Figure 2 or each embodiment. These modules or units can be implemented by hardware, software, or a combination of hardware and software, which is not limited by the present application. For example, in one embodiment of the present application, a device for distributed compensation transactions is also provided, and the device includes:

one or more processors; and

A memory storing computer readable instructions, which, when executed, cause the processor to perform the operations of the method as described above.

For example, the computer readable instructions, when executed, cause the one or more processors to:

Set up compensation transaction services corresponding to business methods in the business system;

When executing the business method, the compensation transaction information is recorded and stored in the database;

Execute the local transaction, and process the compensation transaction information and the compensation transaction service according to the execution result of the local transaction.

Figure 3 shows a structural schematic diagram of a device for distributed compensation transactions provided in accordance with another aspect of the present application, the device comprising: a setting device 11, a recording device 12 and an execution device 13, wherein the setting device 11 is used to set a compensation transaction service corresponding to a business method in a business system; the recording device 12 is used to record compensation transaction information when executing the business method and store it in a database; the execution device 13 is used to execute local transactions and process the compensation transaction information and the compensation transaction service according to the execution result of the local transaction.

It should be noted that the contents executed by the setting device 11, the recording device 12 and the execution device 13 are respectively the same or correspondingly the same as the contents in the above steps S11, S12 and S13, and for the sake of simplicity, they are not repeated here.

Obviously, those skilled in the art can make various changes and modifications to the present application without departing from the spirit and scope of the present application. Thus, if these modifications and variations of the present application fall within the scope of the claims of the present application and their equivalents, the present application is also intended to include these modifications and variations.

It should be noted that the present application can be implemented in software and/or a combination of software and hardware, for example, can be implemented using an application specific integrated circuit (ASIC), a general purpose computer or any other similar hardware device. In one embodiment, the software program of the present application can be executed by a processor to implement the steps or functions described above. Similarly, the software program of the present application (including relevant data structures) can be stored in a computer-readable recording medium, for example, a RAM memory, a magnetic or optical drive or a floppy disk and similar devices. In addition, some steps or functions of the present application can be implemented using hardware, for example, as a circuit that cooperates with a processor to perform each step or function.

In addition, a part of the present application may be applied as a computer program product, such as a computer program instruction, which, when executed by a computer, can call or provide the method and/or technical solution according to the present application through the operation of the computer. The program instruction for calling the method of the present application may be stored in a fixed or removable recording medium, and/or transmitted through a data stream in a broadcast or other signal-bearing medium, and/or stored in a working memory of a computer device that runs according to the program instruction. Here, according to an embodiment of the present application, a device is included, the device including a memory for storing computer program instructions and a processor for executing program instructions, wherein, when the computer program instruction is executed by the processor, the device is triggered to run the method and/or technical solution based on the aforementioned multiple embodiments according to the present application.

It is obvious to those skilled in the art that the present application is not limited to the details of the above exemplary embodiments, and that the present application can be implemented in other specific forms without departing from the spirit or basic features of the present application. Therefore, from any point of view, the embodiments should be regarded as exemplary and non-restrictive, and the scope of the present application is limited by the attached claims rather than the above description, so it is intended to include all changes that fall within the meaning and scope of the equivalent elements of the claims in the present application. Any figure mark in the claims should not be regarded as limiting the claims involved. In addition, it is obvious that the word "comprising" does not exclude other units or steps, and the singular does not exclude the plural. Multiple units or devices stated in the device claim can also be implemented by one unit or device through software or hardware. The words first, second, etc. are used to indicate names, and do not indicate any particular order.

Claims (8)

1. A method of distributed compensation transactions, the method comprising:

setting compensation business service corresponding to a business method in a business system;

Recording compensation transaction information when executing the business method, and storing the compensation transaction information into a database;

Executing local transaction, processing the compensation transaction information and the compensation transaction service according to the execution result of the local transaction, and notifying the business system of the compensation transaction information in a message notification mode when the execution result of the local transaction is that the transaction fails, and executing compensation logic in the compensation transaction service by the business system;

the method for setting the compensation business service corresponding to the business method in the business system comprises the following steps:

Marking a compensation transaction annotation in compensation transaction service on a business method in a business system, packaging the annotation, setting the maximum timeout time of the compensation transaction and the retry times of compensation logic, wherein the logic for packaging the annotation is a method for adding a Spring AOP section to the annotation and processing the annotation, the processing content is that a transaction record is firstly inserted into a database before the business method is executed, then the business method is executed, if the transaction record is successfully executed, the transaction record is deleted, and if the transaction record is failed, the updating of the transaction state is failed.

2. The method of claim 1, wherein processing the compensation transaction information and the compensation transaction service according to the execution result of the local transaction comprises:

and when the execution result of the local transaction is that the transaction is successful, automatically deleting the compensation transaction information through the compensation transaction service.

3. The method according to claim 1, wherein when the execution result of the local transaction is that the transaction fails, notifying the business system of the compensating transaction information in a message notification manner includes:

Starting a transaction scanning task corresponding to the compensation transaction service, and acquiring a transaction compensation record of an abnormal transaction in the database through the transaction scanning task;

And notifying the business system of the transaction compensation record of the abnormal transaction in a message notification mode.

4. The method according to claim 1, characterized in that the method comprises:

and monitoring the message notification through the service system, and executing or retrying compensation logic according to the service information of the service system.

5. The method of claim 1, wherein executing, by the business system, compensation logic in the compensation transaction service comprises:

The compensation transaction service set in the business system determines a corresponding compensation logic method in the business system configured on the compensation transaction annotation according to the compensation transaction annotation;

And calling the compensation logic method in a reflection mode to execute.

6. An apparatus for distributed compensation transactions, the apparatus comprising:

the setting device is used for setting the compensation business service corresponding to the business method in the business system;

recording means for recording the compensation transaction information when the business method is executed, and storing the compensation transaction information in a database;

The execution device is used for executing the local transaction, processing the compensation transaction information and the compensation transaction service according to the execution result of the local transaction, notifying the business system of the compensation transaction information in a message notification mode when the execution result of the local transaction is that the transaction fails, and executing the compensation logic in the compensation transaction service by the business system;

Wherein, the setting device is used for:

Marking a compensation transaction annotation in compensation transaction service on a business method in a business system, packaging the annotation, setting the maximum timeout time of the compensation transaction and the retry times of compensation logic, wherein the logic for packaging the annotation is a method for adding a Spring AOP section to the annotation and processing the annotation, the processing content is that a transaction record is firstly inserted into a database before the business method is executed, then the business method is executed, if the transaction record is successfully executed, the transaction record is deleted, and if the transaction record is failed, the updating of the transaction state is failed.

7. An apparatus for distributed compensation transactions, the apparatus comprising:

One or more processors; and

A memory storing computer readable instructions that, when executed, cause the processor to perform the operations of the method of any one of claims 1 to 5.

8. A computer readable medium having stored thereon computer readable instructions executable by a processor to implement the method of any of claims 1 to 5.