SYSTEM AND METHOD FOR PARALLEL MULTIPLEXING BETWEEN SERVERS IN A CLUSTER

• US 20140280988A1
• Filed: 05/28/2014
• Published: 09/18/2014
• Est. Priority Date: 09/15/2010
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Reynolds, Nathan, Otenko, Oleksandr, Dorr, Joshua
• Granted Patent: US 9,495,392 B2
• Time in Patent Office: Days
• US Class Current: 709/227
• CPC Class Codes: G06F 15/17318 Parallel communications techniques, e.g. gather, scatter, reduce, roadcast, multicast, all to all
• CPC Class Codes: G06F 16/20 of structured data, e.g. relational data
• CPC Class Codes: G06F 16/2358 Change logging, detection, and notification replication G06F16/27
• CPC Class Codes: G06F 16/252 between a Database Management System and a front-end application
• CPC Class Codes: G06F 16/278 Data partitioning, e.g. horizontal or vertical partitioning
• CPC Class Codes: G06F 9/45504 Abstract machines for programme code execution, e.g. Java virtual machine [JVM], interpreters, emulators
• CPC Class Codes: H04L 41/042 comprising distributed management centres cooperatively managing the network
• CPC Class Codes: H04L 41/0686 Additional information in the notification, e.g. enhancement of specific meta-data
• CPC Class Codes: H04L 49/358 Infiniband Switches
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• 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 67/1001 for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/1004 Server selection for load balancing
• CPC Class Codes: H04L 67/1027 Persistence of sessions during load balancing
• CPC Class Codes: H04L 67/1034 Reaction to server failures by a load balancer
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/14 Session management for real-time applications in data packet communications networks H04L65/1066
• CPC Class Codes: H04L 67/142 Managing session states for stateless protocols; Signalling session states; State transitions; Keeping-state mechanisms
• CPC Class Codes: H04L 67/146 Markers for unambiguous identification of a particular session, e.g. session cookie or URL-encoding
• CPC Class Codes: H04L 69/14 Multichannel or multilink protocols
• CPC Class Codes: Y10T 409/308904 : Multiple row dividing head
• CPC Class Codes: Y10T 409/309072 : including cutter limited to rotary motion
• CPC Class Codes: Y10T 409/309128 : with means to adjust work support vertically
• CPC Class Codes: Y10T 409/309352 : Cutter spindle or spindle support
• CPC Class Codes: Y10T 409/309408 : with cutter holder

Abstract

Systems and methods are provided for providing parallel muxing between servers in a cluster. One such system can include a cluster of one or more high performance computing systems, each including one or more processors and a high performance memory. The cluster communicates over an InfiniBand network. The system can also include a middleware environment, executing on the cluster, that includes one or more application server instances. The system can further include a plurality of muxers, wherein each application server instance includes at least one muxer. Each muxer can receive information from a plurality of threads to transmit to a different muxer on a different application server instance over the Infiniband network using a plurality of parallel channels.

Claims

1. A system for providing parallel multiplexing between servers in a cluster, comprising:

a cluster of one or more computing systems, each including one or more processors and a memory, and wherein the cluster communicates over a network;

a middleware environment, executing on the cluster, that includes a plurality of application server instances;

a plurality of multiplexers, wherein each of the plurality of multiplexers resides on a said application server instance; and

a plurality of parallel channels used to transmit data from a said application server instance to a different said application server instance;

wherein when a request is received by the said multiplexer on the said application server instance to transmit data to the different said application sever instance, the system operates to

determine a number of parallel channels in the plurality of parallel channels, and

hash a session identifier associated with the request to balance the request among the plurality of parallel channels.

2. The system of claim 1, wherein the system monitors configurations of the plurality of parallel channels, and determines the number of parallel channels once or at a regular interval in response to changes in the configurations.

3. The system of claim 2, wherein the system makes the determination automatically or at the direction of a user.

4. The system of claim 2, wherein the number of parallel channels is based on an attribute of a software object used to manage the cluster of computing systems.

5. The system of claim 1, where the system uses a round-robin algorithm to balance the request among the plurality of parallel channels.

6. The system of claim 1, wherein each of the plurality of parallel channels is associated with an exclusive remote method invocation (RMI) stub.

7. The system of claim 1, wherein the data to be transmitted is session data to be replicated.

8. A method for providing parallel multiplexing between servers in a cluster, comprising:

providing a cluster of one or more computing systems, each including one or more processors and a memory, and wherein the cluster communicates over a network;

providing a middleware environment, executing on the cluster, that includes a plurality of application server instances;

providing a plurality of multiplexers, wherein each of the plurality of multiplexers resides on a said application server instance; and

providing a plurality of parallel channels used to transmit data from a said application server instance to a different said application server instance;

wherein when a request is received by the said multiplexer on the said application server instance to transmit data to the different said application sever instance, the system operates to

determine a number of parallel channels in the plurality of parallel channels, and

hash a session identifier associated with the request to balance the request among the plurality of parallel channels.

9. The method of claim 8, wherein the system monitors configurations of the plurality of parallel channels, and determines the number of parallel channels once or at a regular interval in response to changes in the configurations.

10. The method of claim 9, wherein the system makes the determination automatically or at the direction of a user.

11. The method of claim 9, wherein the number of parallel channels is based on an attribute of a software object used to manage the cluster of computing systems.

12. The method of claim 8, where the system uses a round-robin algorithm to balance the request among the plurality of parallel channels.

13. The method of claim 8, wherein each of the plurality of parallel channels is associated with an exclusive remote method invocation (RMI) stub.

14. The method of claim 8, wherein the data to be transmitted is session data to be replicated.

15. A non-transitory computer readable storage medium, including instructions stored there on which, when executed by a computer, cause the computer to perform the steps comprising:

providing a cluster of one or more computing systems, each including one or more processors and a memory, and wherein the cluster communicates over a network;

providing a middleware environment, executing on the cluster, that includes a plurality of application server instances;

providing a plurality of multiplexers, wherein each of the plurality of multiplexers resides on a said application server instance; and

providing a plurality of parallel channels used to transmit data from a said application server instance to a different said application server instance;

wherein when a request is received by the said multiplexer on the said application server instance to transmit data to the different said application sever instance, the system operates to

determine a number of parallel channels in the plurality of parallel channels, and

hash a session identifier associated with the request to balance the request among the plurality of parallel channels.

16. The non-transitory computer readable storage medium of claim 15, wherein the system monitors configurations of the plurality of parallel channels, and determines the number of parallel channels once or at a regular interval in response to changes in the configurations.

17. The non-transitory computer readable storage medium of claim 16, wherein the system makes the determination automatically or at the direction of a user.

18. The non-transitory computer readable storage medium of claim 16, wherein the number of parallel channels is based on an attribute of a software object used to manage the cluster of computing systems.

19. The non-transitory computer readable storage medium of claim 15, where the system uses a round-robin algorithm to balance the request among the plurality of parallel channels.

20. The non-transitory computer readable storage medium of claim 15, wherein each of the plurality of parallel channels is associated with an exclusive remote method invocation (RMI) stub.