SYSTEM AND METHOD FOR DYNAMIC CLUSTERED JMS IN AN APPLICATION SERVER ENVIRONMENT

• US 20160094625A1
• Filed: 09/25/2015
• Published: 03/31/2016
• Est. Priority Date: 01/21/2014
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: SENGODAN, KATHIRAVAN, SCHNEIDER, LINDA K., GAMBINO, SALVATORE ANTHONY, BARNES, THOMAS E., PATEL, RAJESH
• Granted Patent: US 10,187,454 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: H04L 51/00 User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
• CPC Class Codes: H04L 51/23 Reliability checks, e.g. acknowledgments or fault reporting
• 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/1008 based on parameters of servers, e.g. available memory or workload monitoring of computer activity G06F11/30

Abstract

In accordance with an embodiment, a system and method provides a dynamic clustered messaging service in an application server environment. A cluster includes one or more servers operating within the application server environment and is configured to vary a number of the servers based on a service load of applications running on the cluster. The number also varies based on failure and restart of the servers. A messaging service for communicating messages between components of the applications includes instances of messaging service artifacts running on the one or more servers. A placement engine operating on the cluster is configured to migrate the instances of messaging service artifacts between the one or more servers based on a set of rules as the number of the one or more servers in the cluster expands and contracts and as a number of the instances of messaging service artifacts expands and contracts.

Claims

1. A system for providing a dynamic clustered messaging service in an application server environment, comprising:

one or more computers, including the application server environment executing thereon;

a cluster including one or more servers operating within the application server environment,

wherein the cluster is configured to vary a number of the one or more servers based on a service load of applications running on the cluster, and

wherein the number of the one or more servers further varies based on failure and restart of the one or more servers;

a messaging service for communicating messages between components of the applications running on the cluster, the messaging service including instances of messaging service artifacts running on the one or more servers; and

a placement engine operating on the cluster, and

wherein the placement engine is configured to migrate the instances of messaging service artifacts between the one or more servers based on a set of rules as the number of the one or more servers in the cluster expands and contracts and as a number of the instances of messaging service artifacts expands and contracts.

2. The system of claim 1, wherein the messaging service is a Java Messaging Service (JMS).

3. The system of claim 1, wherein the placement engine is further configured to migrate the instances of messaging service artifacts between the one or more servers based on performance metrics for the one or more servers.

4. The system of claim 3, wherein the performance metrics for the one or more servers includes a load of the instances of messaging service artifacts on each of the one or more servers.

5. The system of claim 1, wherein a placement engine resides on each of the one or more servers, and

wherein the placement engine for one of the one or more servers is active at a time.

6. The system of claim 1, wherein the cluster is configured to expand and contract the number of the one or more servers based on a service load of applications running on the cluster, and

wherein the number of the one or more servers further expands and contracts based on failure and restart of the one or more servers.

7. The system of claim 1, wherein the placement engine migrates messaging service artifacts based further on settings of parameters for each of the messaging service artifacts.

8. The system of claim 7, wherein the parameters include distribution policy and migration policy.

9. The system of claim 1, wherein the messaging service artifacts include a file store, and wherein a configuration for the messaging service is provided within the file store.

10. A method for providing a dynamic clustered messaging service in an application server environment, comprising:

providing, at one or more computers, including the application server environment executing thereon,

a cluster including one or more servers operating within the application server environment,

wherein the cluster is configured to vary a number of the one or more servers based on a service load of applications running on the cluster, and

wherein the number of the one or more servers further varies based on failure and restart of the one or more servers,

a messaging service for communicating messages between components of the applications running on the cluster, the messaging service including instances of messaging service artifacts running on the one or more servers; and

migrating, via a placement engine operating on the cluster, the instances of messaging service artifacts between the one or more servers based on a set of rules as the number of the one or more servers in the cluster expands and contracts and as a number of the instances of messaging service artifacts expands and contracts.

11. The method of claim 10, wherein the messaging service is a Java Messaging Service (JMS).

12. The method of claim 10, further comprising migrating the instances of messaging service artifacts between the one or more servers based on performance metrics for the one or more servers.

13. The method of claim 12, wherein the performance metrics for the one or more servers includes a load of the instances of messaging service artifacts on each of the one or more servers.

14. The method of claim 10, wherein a placement engine resides on each of the one or more servers, and

wherein the placement engine for one of the one or more servers is active at a time.

15. The method of claim 10, wherein the cluster is configured to expand and contract the number of the one or more servers based on a service load of applications running on the cluster, and

wherein the number of the one or more servers further expands and contracts based on failure and restart of the one or more servers.

16. The method of claim 10, further comprising migrating messaging service artifacts based further on settings of parameters for each of the messaging service artifacts.

17. The method of claim 16, wherein the parameters include distribution policy and migration policy.

18. The method of claim 10, wherein the messaging service artifacts include a file store, and wherein a configuration for the messaging service is provided within the file store.

19. A non-transitory computer readable storage medium, including instructions stored thereon which when read and executed by one or more computers cause the one or more computers to perform the steps comprising:

providing, at one or more computers, including an application server environment executing thereon,

a cluster including one or more servers operating within the application server environment,

wherein the cluster is configured to vary a number of the one or more servers based on a service load of applications running on the cluster, and

wherein the number of the one or more servers further varies based on failure and restart of the one or more servers,

a messaging service for communicating messages between components of the applications running on the cluster, the messaging service including instances of messaging service artifacts running on the one or more servers; and

migrating, via a placement engine operating on the cluster, the instances of messaging service artifacts between the one or more servers based on a set of rules as the number of the one or more servers in the cluster expands and contracts and as a number of the instances of messaging service artifacts expands and contracts.