Method, apparatus, and system for executing distributed transaction resources

• US 10,326,828 B2
• Filed: 05/12/2017
• Issued: 06/18/2019
• Est. Priority Date: 11/12/2014
• Status: Active Grant

• Current Assignee: Huawei Cloud Computing Technologies Company Limited (Huawei Investment & Holding Co., Ltd.)
• Original Assignee: Huawei Technologies Co., Ltd. (Huawei Investment & Holding Co., Ltd.)
• Inventors: Yin, Jiaxin, Gao, Ying, Zhang, Yongjing
• Primary Examiner(s): Lim, Krisna
• Application Number:
  US15/594,302
• Publication Number:
  US 20170251051A1
• Time in Patent Office: 767 Days
• Field of Search: 709219
• CPC Class Codes: H04L 65/40 Support for services or applications
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 69/329 in the application layer [OSI layer 7]
• CPC Class Codes: H04W 4/70 Services for machine-to-machine communication [M2M] or machine type communication [MTC]

Abstract

The method includes: receiving, by a first managed object device, a first transaction resource creation request that is sent by an application server and includes an identifier of a first to-be-operated resource, a first execution time, and a first to-be-executed operation; receiving, by a second managed object device, a second transaction resource creation request that is sent by the application server and includes an identifier of a second to-be-operated resource, a second execution time, and a second to-be-executed operation, where the first execution time and the second execution time are the same; successfully creating, by the first managed object device, a first transaction resource according to the first transaction resource creation request, and successfully creating, by the second managed device, a second transaction resource according to the second transaction resource creation request.

Claims

1. A method for executing distributed transaction resources for a machine to machine communications (M2M) system, the method comprising:

receiving, by a first managed object device of the M2M system, a first transaction resource creation request sent by an application server of the M2M system for a first transaction, wherein the first transaction resource creation request comprises an identifier of a first to-be-operated resource, a first execution time, and a first to-be-executed operation;

receiving, by a second managed object device of the M2M system different from the first managed object device, a second transaction resource creation request sent by the application server for the first transaction, wherein the second transaction resource creation request comprises an identifier of a second to-be-operated resource, a second execution time, and a second to-be-executed operation, and the first execution time and the second execution time are the same;

successfully creating, by the first managed object device, a first transaction resource of the first transaction according to the first transaction resource creation request, and successfully creating, by the second managed object device, a second transaction resource of the first transaction according to the second transaction resource creation request, wherein the first transaction resource comprises the first execution time and the first to-be-executed operation, and the second transaction resource comprises the second execution time and the second to-be-executed operation; and

sending, by the first managed object device, a response indicative of successful creation of the first transaction resource of the first transaction to the application server, and sending, by the second managed object device, a response indicative of successful creation of the second transaction resource of the first transaction to the application server.

2. The method according to claim 1, wherein the method further comprises:

receiving, by the first managed object device, a third transaction resource creation request sent by the application server for a second transaction, wherein the third transaction resource creation request comprises the identifier of the first to-be-operated resource, a third execution time, and a third to-be-executed operation;

receiving, by the second managed object device, a fourth transaction resource creation request sent by the application server for the second transaction, wherein the fourth transaction resource creation request comprises the identifier of the second to-be-operated resource, a fourth execution time, and a fourth to-be-executed operation, and the third execution time and the fourth execution time are the same;

determining, by the first managed object device, that a third transaction resource of the second transaction fails to be created according to the third transaction resource creation request, and sending a response indicative of unsuccessful creation of the third transaction resource of the second transaction to the application server; and

successfully creating, by the second managed device, a fourth transaction resource of the second transaction according to the fourth transaction resource creation request, and sending a response indicative of successful creation of the fourth transaction resource of the second transaction to the application server, wherein the response indicative of successful creation of the fourth transaction resource carries an identifier of the fourth transaction resource;

receiving, by the second managed object device, a processing request sent by the application server for the fourth transaction resource of the second transaction, wherein the processing request for the fourth transaction resource of the second transaction carries the identifier of the fourth transaction resource; and

processing, by the second managed object device, the created fourth transaction resource according to the identifier of the fourth transaction resource.

3. The method according to claim 2, wherein the determining comprises:

determining, by the first managed object device, that a first transaction resource queue exists on the first managed object device, wherein the first transaction resource queue comprises at least one transaction resource;

determining, by the first managed object device according to the third execution time and a state of the first to-be-operated resource of the first managed object device, that the third transaction resource does not meet a preset resource creation condition; and

determining, by the first managed object device according to the preset resource creation condition, to update the third execution time to a time later than an execution time of a transaction resource in the first transaction resource queue; and

sending, by the first managed object device, a second failure response carrying the updated third execution time to the application server.

4. The method according to claim 2, wherein successfully creating the fourth transaction resource comprises:

determining, by the second managed object device, that a second transaction resource queue exists on the second managed object device, wherein the second transaction resource queue comprises at least one transaction resource; and

determining, by the second managed object device according to the fourth execution time and a state of the second to-be-operated resource of the second managed object device, that the fourth transaction resource meets the preset resource creation condition, and creating the fourth transaction resource.

5. The method according to claim 2,

wherein the processing request for the fourth transaction resource of the second transaction is an update request that carries the identifier of the fourth transaction resource and the updated third execution time;

and

wherein the processing the created fourth transaction resource, by the second managed object device comprises;

successfully updating, by the second managed object device, the fourth transaction resource according to the updated third execution time, and returning an update success response message to the application server;

or

failing to update the fourth transaction resource according to the updated third execution time, and returning an update failure response message to the application server.

6. The method according to claim 5, wherein successfully updating the fourth transaction resource comprises:

deleting, by the second managed object device, the fourth transaction resource on the second managed object device according to the identifier of the fourth transaction resource;

using, by the second managed object device, the updated third execution time as an execution time of a new fourth transaction resource;

determining, by the second managed object device according to the execution time of the new fourth transaction resource and the state of the second to-be-operated resource of the second managed object device, that the new fourth transaction resource meets the preset resource creation condition; and

creating, by the second managed object device, the new fourth transaction resource according to the updated third execution time.

7. The method according to claim 2,

wherein the processing request for the fourth transaction resource of the second transaction is a deletion request that carries the identifier of the fourth transaction resource;

and

wherein the processing the created fourth transaction resource comprises;

deleting, by the second managed object device, the fourth transaction resource on the second managed object device according to the identifier of the fourth transaction resource.

8. The method according to claim 7, wherein one transaction resource in the second transaction resource queue is in a reserved state, and after the deleting the fourth transaction resource on the second managed object device, the method further comprises:

determining, by the second managed object device, according to the state of the second to-be-operated resource after a transaction resource at a first position in the second transaction resource queue is executed, whether a transaction resource at a second position can be executed successfully, wherein the first position is a position previous to the fourth transaction resource in the second transaction resource queue, and the second position is a position next to the fourth transaction resource in the second transaction resource queue; and

if the transaction resource at the second position is executed successfully, sending, by the second managed object device, a first deletion response to the application server, and after the transaction resource at the first position is executed, updating a state of the transaction resource at the second position to the reserved state;

or

if the transaction resource at the second position fails to be executed, deleting, by the second managed object device, the transaction resource at the second position.

9. The method according to claim 7, wherein at least two transaction resources in the second transaction resource queue are in a reserved state, and after the deleting the fourth transaction resource on the second managed object device, the method further comprises:

determining, by the second managed object device, whether a transaction resource in a semi-reserved state in the second transaction resource queue meets a preset deletion condition; and

if the transaction resource in the semi-reserved state in the second transaction resource queue meets the preset deletion condition, deleting, by the second managed object device, the transaction resource in the semi-reserved state, and sending a second deletion response to the application server;

or

if the transaction resource in the semi-reserved state in the second transaction resource queue does not meet the preset deletion condition, determining, by the second managed object device, according to the state of the second to-be-operated resource after any transaction resource previous to the transaction resource in the semi-reserved state is executed, that the transaction resource in the semi-reserved state can be executed successfully, and updating, by the second managed object device, the transaction resource in the semi-reserved state to the reserved state.

10. A method for executing distributed transaction resources for a machine to machine communications (M2M) system, the method comprising:

sending, by an application server of the M2M system, a first transaction resource creation request for a first transaction to a first managed object device of the M2M system, wherein the first transaction resource creation request comprises an identifier of a first to-be-operated resource, a first execution time, and a first to-be-executed operation;

sending, by the application server, a second transaction resource creation request for the first transaction to a second managed object device of the M2M system, wherein the second transaction resource creation request comprises an identifier of a second to-be-operated resource, a second execution time, and a second to-be-executed operation, and the first execution time and the second execution time are the same; and

receiving, by the application server, within a preset time, a response that is sent by the second managed object device and that is indicative of successful creation of a second transaction resource of the first transaction, and receiving, within the preset time, a response that is sent by the first managed object device and that is indicative of successful creation of a first transaction resource of the first transaction.

11. The method according to claim 10, wherein the method further comprises:

sending, by the application server, a third transaction resource creation request for a second transaction to the first managed object device, wherein the third transaction resource creation request comprises the identifier of the first to-be-operated resource, a third execution time, and a third to-be-executed operation;

sending, by the application server, a fourth transaction resource creation request for the second transaction to the second managed object device, wherein the fourth transaction resource creation request comprises the identifier of the second to-be-operated resource, a fourth execution time, and a fourth to-be-executed operation, and the third execution time and the fourth execution time are the same;

receiving, by the application server, within a preset time, a response that is sent by the first managed object device and that is indicative of unsuccessful creation of a third transaction resource of the second transaction, and receiving, within the preset time, a response that is sent by the second managed object device and that is indicative of successful creation of a fourth transaction resource of the second transaction, wherein the response indicative of successful creation of the fourth transaction resource carries an identifier of the fourth transaction resource; and

sending, by the application server, according to the response indicative of unsuccessful creation of the third transaction resource of the second transaction and the response indicative of successful creation of the fourth transaction resource of the second transaction, a processing request for the fourth transaction resource of the second transaction to the second managed object device that sends the response indicative of successful creation of the fourth transaction resource, wherein the processing request for the fourth transaction resource of the second transaction carries the identifier of the fourth transaction resource.

12. The method according to claim 11, wherein sending the processing request for the fourth transaction resource comprises:

determining, by the application server, that the response indicative of unsuccessful creation of the third transaction resource of the second transaction is a first failure response that does not carry an updated third execution time, and sending a deletion request carrying the identifier of the fourth transaction resource to the second managed object device that sends the response indicative of successful creation of the fourth transaction resource;

or

determining, by the application server, that the response indicative of unsuccessful creation of the third transaction resource of the second transaction is a second failure response carrying an updated third execution time, and sending an update request carrying the updated third execution time and the identifier of the fourth transaction resource to the second managed object device that sends the response indicative of successful creation of the fourth transaction resource; and

wherein the method further comprises;

sending, by the application server, a third transaction resource creation request carrying the updated third execution time to the first managed object device.

13. An application server for a machine to machine communications (M2M) system comprising:

a processor;

a memory storing a program to be executed in the processor, the program comprising instructions for;

sending a first transaction resource creation request for a first transaction to a first managed object device of the M2M system, wherein the first transaction resource creation request comprises an identifier of a first to-be-operated resource, a first execution time, and a first to-be-executed operation;

sending a second transaction resource creation request for the first transaction to a second managed object device of the M2M system, wherein the second transaction resource creation request comprises the identifier of the first to-be-operated resource, a second execution time, and a second to-be-executed operation, and the first execution time and the second execution time are the same; and

receiving, within a preset time, a response that is sent by the second managed object device and that is indicative of successful creation of a second transaction resource of the first transaction;

receiving a response that is sent by the first managed object device and that is indicative of successful creation of a first transaction resource of the first transaction.

14. The application server according to claim 13, wherein the instructions for sending comprise further instructions for:

sending a third transaction resource creation request for a second transaction to the first managed object device, wherein the third transaction resource creation request comprises the identifier of the first to-be-operated resource, a third execution time, and a third to-be-executed operation; and

sending a fourth transaction resource creation request for the second transaction to the second managed object device, wherein the fourth transaction resource creation request comprises the identifier of the second to-be-operated resource, a fourth execution time, and a fourth to-be-executed operation, and the third execution time and the fourth execution time are the same;

receiving, within a preset time, a response that is sent by the first managed object device and that is indicative of unsuccessful creation of a third transaction resource of the second transaction;

receiving, within the preset time, a response that is sent by the second managed object device and that is indicative of successful creation of a fourth transaction resource of the second transaction, wherein the response indicative of successful creation of the fourth transaction resource carries an identifier of the fourth transaction resource; and

sending, based on the response indicative of unsuccessful creation of the third transaction resource of the second transaction and the response indicative of successful creation of the fourth transaction resource of the second transaction, a processing request for the fourth transaction resource of the second transaction to the second managed object device that sends the response indicative of successful creation of the fourth transaction resource, wherein the processing request for the fourth transaction resource of the second transaction carries the identifier of the fourth transaction resource.

15. The application server according to claim 14, wherein the instructions for sending comprise further instructions for:

determining that the response indicative of unsuccessful creation of the third transaction resource of the second transaction is a first failure response that does not carry an updated third execution time, and send a deletion request carrying the identifier of the fourth transaction resource to the second managed object device that sends the response indicative of successful creation of the fourth transaction resource;

or

determining that the response indicative of unsuccessful creation of the third transaction resource of the second transaction is a second failure response carrying the updated third execution time, and sending an update request carrying the updated third execution time and the identifier of the fourth transaction resource to the second managed object device that sends the response indicative of successful creation of the fourth transaction resource; and

sending a third transaction resource creation request carrying the updated third execution time to the first managed device.

16. A managed object device in a machine to machine communications (M2M) system, the managed object device comprising:

a processor;

a memory storing a program to be executed in the processor, the program comprising instructions for;

receiving a first transaction resource creation request sent by an application server of the M2M system for a first transaction, wherein the first transaction resource creation request comprises an identifier of a first to-be-operated resource, a first execution time, and a first to-be-executed operation, the first execution time is the same as a second execution time in a second transaction resource creation request for the first transaction, and the second transaction resource creation request is received by a second managed object device of the M2M system other than the managed object device in the M2M system;

successfully creating a first transaction resource according to the first transaction resource creation request, wherein the first transaction resource comprises the first execution time and the first to-be-executed operation;

determining, when the first execution time arrives, that a processing request sent by the application server for the first transaction resource of the first transaction is not received, wherein the processing request for the first transaction resource of the first transaction is sent after the application server receives a response that is sent by the second managed object device and that is indicative of unsuccessful creation of a second transaction resource of the first transaction; and

executing the first to-be-executed operation.

17. The managed object device according to claim 16, wherein the program comprises further instructions for:

receiving a third transaction resource creation request sent by the application server for a second transaction, wherein the third transaction resource creation request comprises the identifier of the first to-be-operated resource, a third execution time, and a third to-be-executed operation, and the third execution time is the same as a fourth execution time in a fourth transaction resource creation request received by the second managed object device for the second transaction;

determining that a third transaction resource was not created according to the third transaction resource creation request; and

sending a response indicative of unsuccessful creation of the third transaction resource of the second transaction to the application server.

18. The managed object device according to claim 16, wherein the instructions for successfully creating comprise further instructions for:

determining that a first transaction resource queue exists on the managed object device;

determining, according to the third execution time and a state of the first to-be-operated resource of the managed object device, that the third transaction resource does not meet a preset resource creation condition;

determining, according to the preset resource creation condition, to update the third execution time to a time later than an execution time of a transaction resource in the first transaction resource queue, wherein the first transaction resource queue comprises at least one transaction resource; and

the instructions for sending further comprising instructions for sending a second failure response carrying the updated third execution time to the application server.

19. The managed object device according to claim 16, wherein the program comprises further instructions for:

receiving a third transaction resource creation request sent by the application server for a second transaction, wherein the third transaction resource creation request comprises the identifier of the first to-be-operated resource, a third execution time, and a third to-be-executed operation, and the third execution time is the same as a fourth execution time in a fourth transaction resource creation request received by the second managed object device for the second transaction;

successfully creating a third transaction resource according to the third transaction resource creation request;

sending a response indicative of successful creation of the third transaction resource of the second transaction to the application server, wherein the response indicative of successful creation of the third transaction resource carries an identifier of the third transaction resource;

determining, before the third execution time arrives, that a processing request sent by the application server for the third transaction resource of the second transaction is received, wherein the processing request for the third transaction resource of the second transaction carries the identifier of the third transaction resource; and

processing the created third transaction resource according to the identifier of the third transaction resource.