CN111679892A - Distributed transaction processing method, device, equipment and medium - Google Patents
Distributed transaction processing method, device, equipment and medium Download PDFInfo
- Publication number
- CN111679892A CN111679892A CN202010501312.6A CN202010501312A CN111679892A CN 111679892 A CN111679892 A CN 111679892A CN 202010501312 A CN202010501312 A CN 202010501312A CN 111679892 A CN111679892 A CN 111679892A
- Authority
- CN
- China
- Prior art keywords
- information
- processed
- distributed transaction
- transaction processing
- processing party
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/466—Transaction processing
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/23—Updating
- G06F16/2365—Ensuring data consistency and integrity
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/465—Distributed object oriented systems
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/548—Queue
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Software Systems (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computer Security & Cryptography (AREA)
- Data Mining & Analysis (AREA)
- Databases & Information Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The embodiment of the invention discloses a method, a device, equipment and a medium for processing distributed transactions, wherein the method is applied to a local distributed transaction system and comprises the following steps: receiving to-be-processed information sent by a distributed transaction establishing cube, and storing the to-be-processed information into a pre-established message list of a local distributed transaction; when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes operation corresponding to the information to be processed. According to the technical scheme of the embodiment of the invention, the distributed transaction is divided into the local transactions to process each piece of information to be processed, so that the technical effects of processing consistency and high efficiency of the information to be processed are improved.
Description
Technical Field
The embodiment of the invention relates to the technical field of computers, in particular to a distributed transaction processing method, a distributed transaction processing device, distributed transaction processing equipment and a distributed transaction processing medium.
Background
Distributed transactions in the prior art are mainly bound with specific scenes, and the coupling is strong, so that information cannot be shared. That is, the message data and the service data are in the same database, so that the data cannot be applied to other scenes, and the message service performance is limited by the concurrency performance of the relational database in the using process.
Disclosure of Invention
The invention provides a distributed transaction processing method, a device, equipment and a medium, which are used for realizing the technical effects of improving the message processing efficiency and message synchronization.
In a first aspect, an embodiment of the present invention provides a method for processing a distributed transaction, where the method is applied in a local distributed transaction system, and includes:
receiving to-be-processed information sent by a distributed transaction establishing cube, and storing the to-be-processed information into a pre-established message list of a local distributed transaction;
when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes operation corresponding to the information to be processed.
In a second aspect, an embodiment of the present invention further provides a device for processing a distributed transaction, where the device is configured in a local distributed transaction system, and includes:
the information storage module is used for receiving to-be-processed information sent by the distributed transaction establishing cube and storing the to-be-processed information into a pre-established message list of the local distributed transaction;
and the information sending module is used for determining the information to be processed and sending the information to be processed to the distributed transaction processing party when request information of the distributed transaction processing party for acquiring the information to be processed is received, so that the distributed transaction processing party executes the operation corresponding to the information to be processed.
In a third aspect, an embodiment of the present invention further provides an apparatus, where the apparatus includes:
one or more processors;
a storage device for storing one or more programs,
when the one or more programs are executed by the one or more processors, the one or more processors implement the method for processing the distributed transaction according to any of the embodiments of the present invention.
In a fourth aspect, embodiments of the present invention further provide a storage medium containing computer-executable instructions, which when executed by a computer processor, are configured to perform a method for processing a distributed transaction according to any one of the embodiments of the present invention.
According to the technical scheme of the embodiment of the invention, the information to be processed sent by the distributed transaction establishing cube is received and stored in a pre-established message list of the local distributed transaction; when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes an operation corresponding to the information to be processed, that is, the distributed transaction is split into local distributed transactions, and each information to be processed is processed based on the local distributed transactions, thereby solving the technical problems that the information cannot be shared and the data consistency is poor due to the fact that the distributed transactions are bound with a specific scene in the prior art, and realizing the technical effects of improving the consistency and the processing efficiency of the information to be processed.
Drawings
In order to more clearly illustrate the technical solutions of the exemplary embodiments of the present invention, a brief description is given below of the drawings used in describing the embodiments. It should be clear that the described figures are only views of some of the embodiments of the invention to be described, not all, and that for a person skilled in the art, other figures can be derived from these figures without inventive effort.
Fig. 1 is a schematic processing flow diagram of a distributed transaction according to an embodiment of the present invention;
FIG. 2 is a flowchart illustrating a corresponding process of the distributed task cube according to a second embodiment of the present invention;
fig. 3 is a flowchart illustrating a distributed task executing party according to a second embodiment of the present invention;
fig. 4 is a schematic structural diagram of a distributed task processing apparatus according to a third embodiment of the present invention;
fig. 5 is a schematic structural diagram of an apparatus according to a fourth embodiment of the present invention.
Detailed Description
The present invention will be described in further detail with reference to the accompanying drawings and examples. It is to be understood that the specific embodiments described herein are merely illustrative of the invention and are not limiting of the invention. It should be further noted that, for the convenience of description, only some of the structures related to the present invention are shown in the drawings, not all of the structures.
Example one
Fig. 1 is a schematic flow chart of a distributed transaction processing method according to an embodiment of the present invention, which is applicable to a case where corresponding service information is processed for multiple distributed transactions, that is, each piece of information to be processed is processed, and the method may be executed by a distributed transaction processing apparatus, and the apparatus may be implemented in a form of software and/or hardware.
As shown in fig. 1, the method of the present embodiment includes:
s110, receiving to-be-processed information sent by the distributed transaction establishing cube, and storing the to-be-processed information into a pre-established message list of the local distributed transaction.
The distributed transaction refers to a server which is located on a server supporting the transaction, a resource server and a transaction manager which are respectively located on different nodes of the distributed system. The distributed transaction that generates the information to be processed can be used as a distributed transaction cube, i.e., the party that generates the business information can be used as a distributed transaction cube. Correspondingly, the distributed transaction for acquiring the service message, i.e. the information to be processed, can be used as a distributed transaction processing party or a distributed transaction processing party. A local distributed transaction refers to a server that is established locally. Message queues may be created in local distributed transactions to store pending information sent by each distributed transaction. The information to be processed refers to information that needs to be sent to the distributed transaction processing party.
In this embodiment, after storing the information to be processed in the message list of the pre-established local distributed transaction, the method further includes: updating the state of the information to be processed into a state to be processed, and adding the information to be processed in the state to be processed into a message queue; correspondingly, acquiring information to be processed and sending the information to the distributed transaction processing party comprises the following steps: and acquiring the information to be processed from the message queue and sending the information to be processed to the distributed transaction processing party.
If the information to be processed is not sent to the message queue, that is, the information to be processed is in an unprocessed state, the state of the information to be processed can be marked as the state to be processed. To successfully send the pending information to the distributed transaction handler, the pending information may be stored in an asynchronous message queue. That is to say, the technical solution of this embodiment may send the information to be processed to each distributed transaction processing party based on the asynchronous message queue.
S120, when request information of the distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes operation corresponding to the information to be processed.
If a certain distributed transaction processing party needs to execute an operation corresponding to the information to be processed, the information to be processed needs to be received first, and then the corresponding operation is executed. The distributed transaction processing party executing the information to be processed may send request information for acquiring the information to be processed to the local distributed transaction. When the local distributed transaction receives the request information, the information to be processed corresponding to the request information can be obtained based on the request information.
Specifically, when the local distributed transaction receives request information sent by the distributed transaction processing party, the to-be-processed information corresponding to the request information may be determined based on the request information, and the to-be-processed information is sent to the executing party of the distributed transaction, so that the distributed transaction processing party executes an operation corresponding to the to-be-processed information.
According to the technical scheme of the embodiment of the invention, the information to be processed sent by the distributed transaction establishing cube is received and stored in a pre-established message list of the local distributed transaction; when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes an operation corresponding to the information to be processed, namely a local distributed transaction is established, and each information to be processed is processed based on the local distributed transaction.
On the basis of the technical scheme, adding the message in the state to be processed into a message queue comprises the following steps: and adding the information to be processed in the state to be processed into the asynchronous message queue so as to send the information to be processed to the distributed transaction processing party based on the asynchronous message queue.
In order to ensure that each piece of to-be-processed information is sent to the corresponding distributed transaction processing party, the to-be-processed information corresponding to each distributed transaction processing party may be added to the asynchronous message queue, so that when the local distributed transaction processing party receives the request information, the to-be-processed information is sent to the distributed transaction processing parties based on the asynchronous message queue.
In this embodiment, in order to ensure that the pending information is successfully transmitted to the distributed transaction processing method, when the pending information is transmitted based on the asynchronous message queue, whether the pending information is successfully transmitted or not and a processing manner corresponding to the transmission result may be determined based on the response information of the distributed transaction processing side. Optionally, if response information that transmission of the to-be-processed information fails is received, the to-be-processed information is acquired from the message list, added to the asynchronous message queue, and then transmitted to the distributed transaction processing party until response information that transmission of the to-be-processed information succeeds is received. The advantage of this arrangement is that it can be ensured that the pending information is sent to the corresponding distributed transaction handler, thereby enabling the distributed transaction handler to perform the operation corresponding to the pending information.
In order to avoid the situation of information redundancy in the local distributed transaction, when the distributed transaction processing party completes the execution of the task corresponding to the information to be processed, a feedback result is sent to the local distributed transaction, and the information to be processed stored in the local distributed transaction is deleted from the message list based on the feedback result.
Optionally, feedback information fed back by the distributed transaction processing party is received, where the feedback information includes an execution result of the distributed transaction processing party executing a task corresponding to the information to be processed; and processing the information to be processed based on the feedback information.
The execution result includes success and failure, and correspondingly, the feedback information includes results of success and failure of task execution.
Specifically, when the received feedback information includes an identifier indicating that the task is successfully executed, the information to be processed may be deleted from the message list of the local distributed transaction; when the received feedback information includes the identifier of the task execution failure, it indicates that the distributed transaction processing party needs to execute the operation again, the to-be-processed information may be added to the asynchronous message queue again, and the to-be-processed information is sent to the distributed transaction processing party based on the asynchronous message queue until the feedback result includes the identifier of the distributed transaction processing party that the execution is successful.
The implementation flow of the embodiment of the invention can be as follows: after completing the operation of writing the service data, the distributed transaction builder may send the information to be processed to the local distributed transaction. And the local distributed transaction receives the information to be processed, adds the information to be processed into a local message list. And forwarding the information to be processed to an asynchronous message queue, and sending the information to be processed in the asynchronous message queue to the distributed transaction processing party when receiving request information sent by the distributed transaction processing party, so as to execute operation corresponding to the information to be processed when the distributed transaction processing party receives the information to be processed.
Example two
For clear understanding of the present solution, the technical solutions of the embodiments of the present invention can be explained from two perspectives, namely, a distributed transaction establishing party and a distributed transaction processing party. Fig. 2 is a flowchart illustrating a process of building a distributed task according to a second embodiment of the present invention. As shown in fig. 2, the method includes:
TssService (inventory system) first starts the transaction and then adds data to the Order and reduces the inventory of Tss. After receiving the feedback information of successful service execution, the service execution information can be recorded and the service execution information required to be sent to the distributed transaction processing party is stored in an EventPublish (service to be sent table) table in the local distributed transaction. That is, the information to be processed is stored into the created information storage table. The state stored in the information storage table to the processing information may be marked as new information. And searching data with the state of NEW in the EventPublish table based on the timer, and adding the data with the state of NEW into the asynchronous message queue, namely adding the data with the state of NEW into kafka so as to send the information to be processed to the distributed transaction processing party based on the asynchronous message queue kafka to execute the operation corresponding to the information to be processed. Note that, after data whose state is NEW is added to kafka, the state of such data may be updated to publish (processed completion).
Fig. 3 is a flowchart corresponding to a distributed transaction processing party according to a second embodiment of the present invention. The technical solution of the present embodiment can be understood by referring to fig. 3.
SaasService starts a transaction, receives to-be-processed information sent by an asynchronous message queue kafka in a local distributed transaction, stores the received to-be-processed information into an EventProcess table in a distributed transaction processing party, and can mark the state of the received to-be-processed information at the moment as NEW. After the pending information sent by the successful kafka is saved, the successful response information can be received to the local distributed transaction feedback message. Based on the timer, regularly inquiring data with a state of NEW in the EventProcess table, and executing a service with the state of NEW and corresponding to the information to be processed; and updating the data of the NEW state in the EventProcesseTable to be the PROCESSED state after the service is successfully executed.
The technical scheme of the embodiment of the invention mainly splits the distributed transaction into local transactions for processing. The method comprises the steps that a transaction message table is additionally built in a consumer, the consumer processes service and records transaction messages in local transactions, data in the transaction message table are polled to send the transaction messages, and a provider consumes the transactions in the transaction message table based on a message queue.
According to the technical scheme of the embodiment of the invention, each piece of information is processed based on the local distributed transaction, so that the reliability of information data is ensured, the distributed transaction cube and the distributed transaction processing party respectively use the primary transaction in the database, the consistency of the data is reported to the greatest extent, and the processing efficiency of the data is further improved.
According to the technical scheme of the embodiment of the invention, the information to be processed sent by the distributed transaction establishing cube is received and stored in a pre-established message list of the local distributed transaction; when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes an operation corresponding to the information to be processed, namely a local distributed transaction is established, and each information to be processed is processed based on the local distributed transaction.
EXAMPLE III
Fig. 4 is a schematic structural diagram of a distributed task processing apparatus according to a third embodiment of the present invention. As shown in fig. 4, the apparatus includes: an information storage module 410 and an information transmission module 420.
The information storage module 410 is configured to receive to-be-processed information sent by the distributed transaction establishing unit, and store the to-be-processed information in a pre-established local distributed transaction message list; an information sending module 420, configured to, when receiving request information for a distributed transaction processing party to obtain the to-be-processed information, determine the to-be-processed information and send the to-be-processed information to the distributed transaction processing party, so that the distributed transaction processing party executes an operation corresponding to the to-be-processed information.
On the basis of the above technical solution, after the information storage module is configured to store the to-be-processed information in a message list of a pre-established local distributed transaction, the information storage module is further configured to:
after the state of the information to be processed is updated to be a state to be processed, adding the information to be processed in the state to be processed into a message queue; correspondingly, the information sending module is further configured to: and acquiring the information to be processed from the message queue and sending the information to the distributed transaction processing party.
On the basis of the technical scheme, the information storage module is further configured to add the to-be-processed information in the to-be-processed state to an asynchronous message queue, so as to send the to-be-processed information to the distributed task executor based on the asynchronous message queue.
On the basis of the above technical solution, the apparatus further includes: a feedback information receiving module, configured to receive feedback information fed back by the distributed transaction processing party, where the feedback information includes an execution result of the distributed transaction processing party executing a task corresponding to the information to be processed; and the feedback information processing module is used for processing the information to be processed based on the feedback information.
On the basis of the above technical solutions, the feedback information processing module is further configured to: when the received feedback information comprises an identifier of successful task execution, deleting the information to be processed from the message list; and when the received feedback information comprises the identification of the task execution failure, adding the information to be processed into the asynchronous message queue again, and retransmitting the information to be processed until the received feedback information comprises the identification of the task execution success.
On the basis of the above technical solutions, the information sending module is further configured to, when request information for acquiring the to-be-processed information by the distributed transaction processing party is received, acquire the to-be-processed information matched with the identification information from the message list based on the identification information in the request information.
According to the technical scheme of the embodiment of the invention, the information to be processed sent by the distributed transaction establishing cube is received and stored in a pre-established message list of the local distributed transaction; when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes an operation corresponding to the information to be processed, namely a local distributed transaction is established, and each information to be processed is processed based on the local distributed transaction. The distributed information processing device provided by the embodiment of the invention can execute the distributed information processing method provided by any embodiment of the invention, and has corresponding functional modules and beneficial effects of the execution method.
It should be noted that, the units and modules included in the apparatus are merely divided according to functional logic, but are not limited to the above division as long as the corresponding functions can be implemented; in addition, specific names of the functional units are only for convenience of distinguishing from each other, and are not used for limiting the protection scope of the embodiment of the invention.
Example four
Fig. 5 is a schematic structural diagram of an apparatus according to a fourth embodiment of the present invention. FIG. 5 illustrates a block diagram of an exemplary device 50 suitable for use in implementing embodiments of the present invention. The device 50 shown in fig. 5 is only an example and should not bring any limitation to the function and scope of use of the embodiments of the present invention.
As shown in FIG. 5, device 50 is embodied in a general purpose computing device. The components of the device 50 may include, but are not limited to: one or more processors or processing units 501, a system memory 502, and a bus 503 that couples the various system components (including the system memory 502 and the processing unit 501).
The system memory 502 may include computer system readable media in the form of volatile memory, such as Random Access Memory (RAM)504 and/or cache memory 505. The device 50 may further include other removable/non-removable, volatile/nonvolatile computer system storage media. By way of example only, storage system 506 may be used to read from and write to non-removable, nonvolatile magnetic media (not shown in FIG. 5, commonly referred to as a "hard drive"). Although not shown in FIG. 5, a magnetic disk drive for reading from and writing to a removable, nonvolatile magnetic disk (e.g., a "floppy disk") and an optical disk drive for reading from or writing to a removable, nonvolatile optical disk (e.g., a CD-ROM, DVD-ROM, or other optical media) may be provided. In these cases, each drive may be connected to the bus 503 by one or more data media interfaces. Memory 502 may include at least one program product having a set (e.g., at least one) of program modules that are configured to carry out the functions of embodiments of the invention.
A program/utility 508 having a set (at least one) of program modules 507 may be stored, for instance, in memory 502, such program modules 507 including, but not limited to, an operating system, one or more application programs, other program modules, and program data, each of which examples or some combination thereof may comprise an implementation of a network environment. Program modules 507 generally perform the functions and/or methodologies of embodiments of the invention as described herein.
The processing unit 501 executes various functional applications and data processing by executing programs stored in the system memory 502, for example, to implement the processing method of distributed transaction provided by the embodiment of the present invention.
EXAMPLE five
An embodiment of the present invention also provides a storage medium containing computer-executable instructions, which when executed by a computer processor, perform a processing method for distributed transactions.
The method comprises the following steps:
receiving to-be-processed information sent by a distributed transaction establishing cube, and storing the to-be-processed information into a pre-established message list of a local distributed transaction;
when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes operation corresponding to the information to be processed.
Computer storage media for embodiments of the invention may employ any combination of one or more computer-readable media. The computer readable medium may be a computer readable signal medium or a computer readable storage medium. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination of the foregoing. More specific examples (a non-exhaustive list) of the computer readable storage medium would include the following: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.
A computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device.
Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
Computer program code for carrying out operations for embodiments of the present invention may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, Smalltalk, C + + or the like and conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any type of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or the connection may be made to an external computer (for example, through the Internet using an Internet service provider).
It is to be noted that the foregoing is only illustrative of the preferred embodiments of the present invention and the technical principles employed. It will be understood by those skilled in the art that the present invention is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the invention. Therefore, although the present invention has been described in greater detail by the above embodiments, the present invention is not limited to the above embodiments, and may include other equivalent embodiments without departing from the spirit of the present invention, and the scope of the present invention is determined by the scope of the appended claims.
Claims (10)
1. A method for processing a distributed transaction, comprising:
receiving to-be-processed information sent by a distributed transaction establishing cube, and storing the to-be-processed information into a pre-established message list of a local distributed transaction;
when request information of a distributed transaction processing party for acquiring the information to be processed is received, the information to be processed is determined and sent to the distributed transaction processing party, so that the distributed transaction processing party executes operation corresponding to the information to be processed.
2. The method of claim 1, further comprising, after storing the pending information in a message list of a pre-established local distributed transaction:
after the state of the information to be processed is updated to be a state to be processed, adding the information to be processed in the state to be processed into a message queue;
correspondingly, the obtaining the information to be processed and sending the information to the distributed transaction processing party includes:
and acquiring the information to be processed from the message queue and sending the information to the distributed transaction processing party.
3. The method of claim 2, wherein adding the pending information of the pending state to a message queue comprises:
and adding the information to be processed in the state to be processed into an asynchronous message queue so as to send the information to be processed to the distributed transaction processing party based on the asynchronous message queue.
4. The method of claim 3, further comprising:
receiving feedback information fed back by the distributed transaction processing party, wherein the feedback information comprises an execution result of the distributed transaction processing party executing a task corresponding to the information to be processed;
and processing the information to be processed based on the feedback information.
5. The method of claim 4, wherein the processing the information to be processed based on the feedback information comprises:
when the received feedback information comprises an identifier of successful task execution, deleting the information to be processed from the message list;
and when the received feedback information comprises the identification of the task execution failure, adding the information to be processed into the asynchronous message queue again, and retransmitting the information to be processed until the received feedback information comprises the identification of the task execution success.
6. The method of claim 1, wherein when receiving request information for obtaining the to-be-processed information from a distributed transaction processing party, determining the to-be-processed information and sending the to-be-processed information to the distributed transaction processing party comprises:
and when request information of the distributed transaction party for acquiring the information to be processed is received, acquiring the information to be processed matched with the identification information from the message list based on the identification information in the request information.
7. An apparatus for processing a distributed transaction, comprising:
the information storage module is used for receiving to-be-processed information sent by the distributed transaction establishing cube and storing the to-be-processed information into a pre-established message list of the local distributed transaction;
and the information sending module is used for determining the information to be processed and sending the information to be processed to the distributed transaction processing party when request information of the distributed transaction processing party for acquiring the information to be processed is received, so that the distributed transaction processing party executes the operation corresponding to the information to be processed.
8. The apparatus of claim 7, wherein the information storage module, after being configured to store the to-be-processed information in a message list of a pre-established local distributed transaction, is further configured to:
after the state of the information to be processed is updated to be a state to be processed, adding the information to be processed in the state to be processed into a message queue;
correspondingly, the information sending module is further configured to:
and acquiring the information to be processed from the message queue and sending the information to the distributed transaction processing party.
9. An apparatus, characterized in that the apparatus comprises:
one or more processors;
a storage device for storing one or more programs,
when executed by the one or more processors, cause the one or more processors to implement a method of processing a distributed transaction as claimed in any of claims 1 to 6.
10. A storage medium containing computer-executable instructions for performing a method of processing a distributed transaction as claimed in any one of claims 1 to 6 when executed by a computer processor.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010501312.6A CN111679892A (en) | 2020-06-04 | 2020-06-04 | Distributed transaction processing method, device, equipment and medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010501312.6A CN111679892A (en) | 2020-06-04 | 2020-06-04 | Distributed transaction processing method, device, equipment and medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111679892A true CN111679892A (en) | 2020-09-18 |
Family
ID=72434892
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010501312.6A Pending CN111679892A (en) | 2020-06-04 | 2020-06-04 | Distributed transaction processing method, device, equipment and medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111679892A (en) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112463810A (en) * | 2020-12-08 | 2021-03-09 | 佳讯飞鸿（北京）智能科技研究院有限公司 | Data processing method, device, equipment and storage medium based on distributed transaction |
| CN112632093A (en) * | 2020-12-30 | 2021-04-09 | 北京嘀嘀无限科技发展有限公司 | Work order processing method, device, system, storage medium and program product |
| CN113518384A (en) * | 2021-07-29 | 2021-10-19 | 中移（杭州）信息技术有限公司 | Distributed transaction processing method, device, equipment and computer readable storage medium |
| CN114661429A (en) * | 2022-03-25 | 2022-06-24 | 阿里云计算有限公司 | Transaction processing method and device |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106302647A (en) * | 2016-07-29 | 2017-01-04 | 深圳前海微众银行股份有限公司 | Message distribution method and server |
| CN106874076A (en) * | 2017-01-21 | 2017-06-20 | 浙江沛宏网络科技有限公司 | Distributed transaction processing method |
| WO2018103318A1 (en) * | 2016-12-06 | 2018-06-14 | 上海壹账通金融科技有限公司 | Distributed transaction handling method and system |
| CN108965457A (en) * | 2018-08-02 | 2018-12-07 | 郑州云海信息技术有限公司 | A kind of message delivery method of distributed cluster system, device, equipment and medium |
| CN110968586A (en) * | 2018-09-30 | 2020-04-07 | 北京国双科技有限公司 | Distributed transaction processing method and device |
-
2020
- 2020-06-04 CN CN202010501312.6A patent/CN111679892A/en active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106302647A (en) * | 2016-07-29 | 2017-01-04 | 深圳前海微众银行股份有限公司 | Message distribution method and server |
| WO2018103318A1 (en) * | 2016-12-06 | 2018-06-14 | 上海壹账通金融科技有限公司 | Distributed transaction handling method and system |
| CN106874076A (en) * | 2017-01-21 | 2017-06-20 | 浙江沛宏网络科技有限公司 | Distributed transaction processing method |
| CN108965457A (en) * | 2018-08-02 | 2018-12-07 | 郑州云海信息技术有限公司 | A kind of message delivery method of distributed cluster system, device, equipment and medium |
| CN110968586A (en) * | 2018-09-30 | 2020-04-07 | 北京国双科技有限公司 | Distributed transaction processing method and device |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112463810A (en) * | 2020-12-08 | 2021-03-09 | 佳讯飞鸿（北京）智能科技研究院有限公司 | Data processing method, device, equipment and storage medium based on distributed transaction |
| CN112632093A (en) * | 2020-12-30 | 2021-04-09 | 北京嘀嘀无限科技发展有限公司 | Work order processing method, device, system, storage medium and program product |
| CN112632093B (en) * | 2020-12-30 | 2025-05-27 | 北京嘀嘀无限科技发展有限公司 | Work order processing method, device, system, storage medium and program product |
| CN113518384A (en) * | 2021-07-29 | 2021-10-19 | 中移（杭州）信息技术有限公司 | Distributed transaction processing method, device, equipment and computer readable storage medium |
| CN113518384B (en) * | 2021-07-29 | 2023-12-01 | 中移（杭州）信息技术有限公司 | Distributed transaction processing method, device, equipment and computer readable storage medium |
| CN114661429A (en) * | 2022-03-25 | 2022-06-24 | 阿里云计算有限公司 | Transaction processing method and device |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111339186B (en) | Workflow engine data synchronization method, device, medium and electronic equipment | |
| CN111679892A (en) | Distributed transaction processing method, device, equipment and medium | |
| US8799906B2 (en) | Processing a batched unit of work | |
| CN110633320A (en) | Processing method, system, equipment and storage medium of distributed data service | |
| CN111225012A (en) | Transaction processing method, device and equipment | |
| CN112346794A (en) | Interface calling method, device, equipment and medium | |
| CN114285807A (en) | Message information management method, device, server and storage medium | |
| CN110555150B (en) | Data monitoring method, device, equipment and storage medium | |
| CN112711487A (en) | Data source management and control method and device, management and control server and storage medium | |
| CN113760862B (en) | A method, device, equipment and storage medium for incremental data breakpoint resume transmission | |
| CN113645260A (en) | Service retry method, device, storage medium and electronic equipment | |
| CN111639936A (en) | Transaction information acquisition method and device, electronic equipment and readable storage medium | |
| CN115036044B (en) | A message processing method, device, electronic device and storage medium | |
| CN113783666B (en) | Method and device for processing business | |
| CN114490104B (en) | Information forwarding method, device, equipment and medium in Android system module | |
| CN111262727B (en) | Service capacity expansion method, device, equipment and storage medium | |
| CN109740027B (en) | Data exchange method, device, server and storage medium | |
| CN114201564A (en) | Map production task processing method and device, electronic equipment and storage medium | |
| CN109918231B (en) | Data reforming abnormity repairing method, device, equipment and storage medium | |
| CN113986995A (en) | Request distribution method, device, storage medium and electronic device | |
| CN113220237A (en) | Distributed storage method, device, equipment and storage medium | |
| CN113077241A (en) | Approval processing method, device, equipment and storage medium | |
| CN113781154A (en) | Information rollback method, system, electronic equipment and storage medium | |
| CN114529263B (en) | Data processing method, device, electronic device and storage medium | |
| CN115767448B (en) | Message sending method, device, equipment and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| TA01 | Transfer of patent application right | ||
| TA01 | Transfer of patent application right |
Effective date of registration: 20220920 Address after: 25 Financial Street, Xicheng District, Beijing 100033 Applicant after: CHINA CONSTRUCTION BANK Corp. Address before: 25 Financial Street, Xicheng District, Beijing 100033 Applicant before: CHINA CONSTRUCTION BANK Corp. Applicant before: Jianxin Financial Science and Technology Co.,Ltd. |