MULTI-OPERATIONAL TRANSACTIONAL ACCESS OF IN-MEMORY DATA GRIDS IN A CLIENT-SERVER ENVIRONMENT

• US 20130019000A1
• Filed: 07/14/2011
• Published: 01/17/2013
• Est. Priority Date: 07/14/2011
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Surtani, Manik, Markus, Mircea
• Granted Patent: US 8,805,984 B2
• Time in Patent Office: Days
• US Class Current: 709/223
• CPC Class Codes: G06F 9/466 Transaction processing

Abstract

A client computing system identifies a start of a multi-operational transaction pertaining to access of data stored in caches being managed by nodes residing in Java Virtual Machines in an in-memory data grid. The client computing system stores transaction context data indicating the start of the multi-operational transaction and identifies an application request to perform an operation pertaining to the multi-operational transaction. The application request is from an application that resides outside of the Java Virtual Machines of the nodes. The client computing system determines the transaction context of the operation based on the transaction context data and sends an operation request over a network to a managing node in the in-memory data grid to manage the multi-operational transaction. The operation request includes header data based on the transaction context data.

Claims

1. A method, implemented by a client computing system programmed to perform the following, comprising:

identifying, by the client computing system, a start of a multi-operational transaction pertaining to access of data stored in caches being managed by a plurality of nodes residing in Java Virtual Machines in an in-memory data grid;

storing transaction context data indicating the start of the multi-operational transaction;

identifying an application request to perform an operation pertaining to the multi-operational transaction, the application request from an application residing outside of the Java Virtual Machines of the nodes;

determining the transaction context of the operation based on the transaction context data; and

sending an operation request over a network to a managing node in the in-memory data grid to manage the multi-operational transaction of accessing the caches being managed by the nodes in the in-memory data grid, the operation request including header data based on the transaction context data.

2. The method of claim 1, further comprising:

storing resource management node tracking data to associate the multi-operational transaction with a node in the in-memory data grid to manage the multi-operational transaction, the resource management tracking data comprising a transaction identifier for the multi-operational transaction and a identifier for the managing node.

3. The method of claim 2, further comprising:

identifying a next application request to perform an operation, the next application request comprising a transaction identifier;

determining that the next application request is associated with a multi-operational transaction;

determining the managing node that is associated with the multi-operational transaction by comparing the transaction identifier in the next application request to the resource management node tracking data; and

sending a next operation request over the network to the managing node in the in-memory data grid that is associated with the multi-operational transaction, the next operation request including header data based on the transaction context data.

4. The method of claim 1, wherein the transaction context data comprises at least one of a transaction type and a transaction identifier.

5. The method of claim 1, wherein the multi-operational transaction is an X/Open XA (XA) transaction comprising a plurality of operations to access the caches being managed by the nodes in the in-memory data grid.

6. The method of claim 1, wherein sending an operation request over a network to a managing node in the in-memory data grid comprises sending the operation request over the network using a Hot Rod protocol.

7. A method, implemented by a server computing system programmed to perform the following, comprising:

receiving, by a node in an in-memory data grid, a request to perform an operation pertaining to multi-operational transactional access of data stored in caches being managed by a plurality of nodes residing in Java Virtual Machines in the in-memory data grid, the request being a translation of an original request from an application residing outside of the Java Virtual Machines of the nodes;

identifying a node having cache data relating to the operation in the in-memory data grid;

storing node tracking data to associate the identified node with a transaction identifier for the multi-operational transaction in the request; and

sending the request to the identified node, wherein the identified node performs the requested operation on the cache and stores operation tracking data to associate the operation with the transaction identifier.

8. The method of claim 7, further comprising:

receiving a next request to perform an operation pertaining to multi-operational transactional access of the data stored in the in-memory data grid, the next request being a translation of an original next request from the application residing outside of the Java Virtual Machines of the nodes;

identifying a node having cache data relating to the operation in the in-memory data grid;

updating the node tracking data to associate the identified node with a transaction identifier for the multi-operational transaction in the next request based on a determination that the identified node is not being tracked in the node tracking data; and

sending the next request to the identified node, wherein the identified node performs the requested operation on the cache and stores operation tracking data to associate the operation with the transaction identifier.

9. The method of claim 7, further comprising:

receiving at least one of a prepare request to prepare the operations pertaining to transaction identifier for commitment and a rollback request to rollback the operations pertaining to transaction identifier;

identifying one or more nodes in the plurality of nodes that are associated with the transaction identifier based on the node tracking data; and

sending the at least one of the prepare request and the rollback request to the identified nodes, wherein the identified nodes at least one of prepare the operations and rollback the operations pertaining to the transaction identifier based on the operation tracking data.

10. A system comprising:

a first memory to store transaction context data indicating a start of the multi-operational transaction; and

a first processing device coupled to the first memory to

identify the start of the multi-operational transaction pertaining to access of data stored in caches being managed by a plurality of nodes residing in Java Virtual Machines in an in-memory data grid;

identify an application request to perform an operation pertaining to the multi-operational transaction, the application request from an application residing outside of the Java Virtual Machines of the nodes;

determine the transaction context of the operation based on the transaction context data; and

send an operation request over a network to a managing node in the in-memory data grid to manage the multi-operational transaction of accessing the caches being managed by the nodes in the in-memory data grid, the operation request including header data based on the transaction context data.

11. The system of claim 10, further comprising:

a data store to store resource management node tracking data to associate the multi-operational transaction with a node in the in-memory data grid to manage the multi-operational transaction, the resource management tracking data comprising a transaction identifier for the multi-operational transaction and a identifier for the managing node.

12. The system of claim 11, wherein the processing device is further to:

identify a next application request to perform an operation, the next application request comprising a transaction identifier;

determine that the next application request is associated with a multi-operational transaction;

determine the managing node that is associated with the multi-operational transaction by comparing the transaction identifier in the next application request to the resource management node tracking data; and

send a next operation request over the network to the managing node in the in-memory data grid that is associated with the multi-operational transaction, the next operation request including header data based on the transaction context data.

13. The system of claim 10, wherein the multi-operational transaction is an X/Open XA (XA) transaction comprising a plurality of operations to access the caches being managed by the nodes in the in-memory data grid.

14. The system of claim 10, further comprising:

a plurality of caches;

a plurality of nodes residing in Java Virtual Machines in a in-memory data grid to manage the plurality of caches;

wherein at least one node comprises;

a second memory to store node tracking data to associate an identified node with a transaction identifier for a multi-operational transaction in a request; and

a second processing device coupled to the second memory to

receive the request to perform the operation pertaining to multi-operational transactional access of data stored in the caches, the request being a translation of an original request from an application residing outside of the Java Virtual Machines of the nodes;

identify a node having cache data relating to the multi-operational transaction; and

send the request to the identified node, wherein the identified node performs the requested operation on the cache and stores operation tracking data to associate the operation with the transaction identifier.

15. A non-transitory computer-readable storage medium including instructions that, when executed by a computer system, cause the computer system to perform a set of operations comprising:

identifying a start of a multi-operational transaction pertaining to access of data stored in caches being managed by a plurality of nodes residing in Java Virtual Machines in an in-memory data grid;

storing transaction context data indicating the start of the multi-operational transaction;

identifying an application request to perform an operation pertaining to the multi-operational transaction, the application request from an application residing outside of the Java Virtual Machines of the nodes;

determining the transaction context of the operation based on the transaction context data; and

sending an operation request over a network to a managing node in the in-memory data grid to manage the multi-operational transaction of accessing the caches being managed by the nodes in the in-memory data grid, the operation request including header data based on the transaction context data.

16. The non-transitory computer-readable storage medium of claim 15, further comprising:

storing resource management node tracking data to associate the multi-operational transaction with a node in the in-memory data grid to manage the transaction, the tracking data comprising a transaction identifier for the multi-operational transaction and a identifier for the managing node.

17. The non-transitory computer-readable storage medium of claim 16, further comprising:

identifying a next application request to perform an operation, the next application request comprising a transaction identifier;

determining that the next application request is associated with a multi-operational transaction;

determining the managing node that is associated with the multi-operational transaction by comparing the transaction identifier in the next application request to the resource management node tracking data; and

sending a next operation request over the network to the managing node in the in-memory data grid that is associated with the multi-operational transaction, the next operation request including header data based on the transaction context data.

18. The non-transitory computer-readable storage medium of claim 15 wherein the transaction context data comprises at least one of a transaction type and a transaction identifier.

19. The non-transitory computer-readable storage medium of claim 15, wherein the multi-operational transaction is an X/Open XA (XA) transaction comprising a plurality of operations to access the caches being managed by the nodes in the in-memory data grid.

20. The non-transitory computer-readable storage medium of claim 15, wherein sending an operation request over a network to a managing node in the in-memory data grid comprises sending the operation request over the network using a Hot Rod protocol.