Transaction processing method, apparatus, and device and computer storage medium

Patent metadata

Field	Value
Publication number	US-11544245-B2
Application number	US-202117170207-A
Country	US
Kind code	B2
Filing date	Feb 8, 2021
Priority date	Dec 3, 2019
Publication date	Jan 3, 2023
Grant date	Jan 3, 2023

Abstract

A transaction processing method includes: dividing a to-be-processed transaction obtained from a database into at least two subtransactions; dividing each subtransaction into N parts with an association relationship; processing the N parts of each subtransaction based on the association relationship, to obtain a processing result of a lastly executed part of the N parts; determining, upon detecting an abnormal subtransaction based on the processing result, a processing policy matching an abnormality reason of the abnormal subtransaction; and processing the abnormal subtransaction by using the processing policy, to obtain a final processing result of the to-be-processed transaction.

First claim

What is claimed is:

1. A transaction processing method, applied to a computing device, the method comprising:
dividing a to-be-processed transaction obtained from a database into at least two subtransactions including a first subtransaction, a second subtransaction, and a third subtransaction, wherein:
in a forward operation, two forward execution paths proceed from the first subtransaction respectively to the second subtransaction and the third subtransaction; and
in a reverse operation, a reverse execution path returns from the third subtransaction back to second subtraction, while leaving the third subtransaction present in relation to the first subtransaction;

dividing the first or the second or the third subtransaction into N parts with an association relationship, N being an integer greater than 1;
processing the N parts of the first or the second or the third subtransaction based on the association relationship, to obtain a processing result;
determining, upon detecting an abnormal subtransaction based on the processing result, a processing policy; and
processing the abnormal subtransaction by using the processing policy, to obtain a final processing result of the to-be-processed transaction.

2. The method according to claim 1 , wherein the dividing the first or the second or the third subtransaction into N parts comprises:
determining a category set of a network interface to which the first or the second or the third subtransaction belongs; and
dividing the the first or the second or the third subtransaction into the N parts based on the category set of the network interface.

3. The method according to claim 1 , wherein
the first, the second, and third subtransactions are independent of each other.

4. The method according to claim 1 , wherein the processing the N parts of the first or the second or the third subtransaction comprises:
determining a processing path of the at least two subtransactions; and
processing the N parts of the first or the second or the third subtransaction based on the processing path and the association relationship, to obtain the processing result of the subtransaction.

5. The method according to claim 2 , wherein when the category set of the network interface includes M categories, the first or the second or the third subtransaction is divided into at least M parts, M being an integer greater than 1, and the processing the N parts of first or the second or the third subtransaction comprises:
determining a serial execution sequence between the at least M parts based on the association relationship; and
executing an M th part of the at least M parts in the serial execution sequence based on the serial execution sequence and a processing result of an (M−1) th part of the at least M parts in the serial execution sequence, to obtain the processing result.

6. The method according to claim 1 , further comprising:
determining a new processing result of processing the abnormal subtransaction by using the processing policy;
determining a processing result set of a currently processed subtransaction when the abnormal subtransaction is still in an abnormal status in the new processing result;
storing the processing result set through a message middleware; and
reading the processing result set from the message middleware when an inputted read instruction is received.

7. The method according to claim 1 , wherein the determining the processing policy comprises:
using a processing result of a previous subtransaction of the abnormal subtransaction as a processing result of the abnormal subtransaction when abnormality occurs at a client side during processing of the abnormal subtransaction; and
processing N parts of the abnormal subtransaction based on the association relationship when the abnormality occurs at a server side during processing of the abnormal subtransaction.

8. The method according to claim 1 , wherein the dividing the to-be-processed transaction into the at least two subtransactions comprises:
determining a resource interface set to implement the to-be-processed transaction;
dividing the to-be-processed transaction into the at least two subtransactions according to the resource interface set.

9. A transaction processing device, comprising: a memory, configured to store an executable instruction; and a processor, configured to execute the executable instruction to perform:
dividing a to-be-processed transaction obtained from a database into at least two subtransactions including a first subtransaction, a second subtransaction, and a third subtransaction, wherein:
in a forward operation, two forward execution paths proceed from the first subtransaction respectively to the second subtransaction and the third subtransaction; and
in a reverse operation, a reverse execution path returns from the third subtransaction back to second subtraction, while leaving the third subtransaction present in relation to the first subtransaction;

dividing the first or the second or the third subtransaction into N parts with an association relationship, N being an integer greater than 1;
processing the N parts of the first or the second or the third subtransaction based on the association relationship, to obtain a processing result;
determining, upon detecting an abnormal subtransaction based on the processing result, a processing policy; and
processing the abnormal subtransaction by using the processing policy, to obtain a final processing result of the to-be-processed transaction.

10. The device according to claim 9 , wherein the dividing the first or the second or the third subtransaction into N parts comprises:
determining a category set of a network interface to which the first or the second or the third subtransaction belongs; and
dividing the the first or the second or the third subtransaction into the N parts based on the category set of the network interface.

11. The device according to claim 9 , wherein the first, the second, and third subtransactions are independent of each other.

12. The device according to claim 9 , wherein the processing the N parts of the first or the second or the third subtransaction comprises:
determining a processing path of the at least two subtransactions; and

processing the N parts of the first or the second or the third subtransaction based on the processing path and the association relationship, to obtain the processing result of the subtransaction.

13. The device according to claim 10 ,
wherein when the category set of the network interface includes M categories, the first or the second or the third subtransaction is divided into at least M parts, M being an integer greater than 1, and the processing the N parts of first or the second or the third subtransaction comprises:
determining a serial execution sequence between the at least M parts based on the association relationship; and
executing an M th part of the at least M parts in the serial execution sequence based on the serial execution sequence and a processing result of an (M−1) th part of the at least M parts in the serial execution sequence, to obtain the processing result.

14. The device according to claim 9 , further comprising:
determining a new processing result of processing the abnormal subtransaction by using the processing policy;
determining a processing result set of a currently processed subtransaction when the abnormal subtransaction is still in an abnormal status in the new processing result;
storing the processing result set through a message middleware; and
reading the processing result set from the message middleware when an inputted read ins

Assignees

• Tencent Tech Shenzhen Co Ltd

Inventors

• Yang Jia
• Fei Qiang
• Chen Ningguo
• Liu Dezhi

Classifications

• G06F2201/87

  Monitoring of transactions · CPC title

• G06F16/2315 Primary

  Optimistic concurrency control · CPC title

• G06F16/2379

  Updates performed during online database operations; commit processing · CPC title

• G06F11/1474 Primary

  in transactions (updating of structured data in databases G06F16/23) · CPC title

• G06F11/1471

  involving logging of persistent data for recovery · CPC title