System and method for dynamic clustered JMS in an application server environment

• US 10,187,454 B2
• Filed: 09/25/2015
• Issued: 01/22/2019
• 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
• Primary Examiner(s): Dailey, Thomas J
• Application Number:
  US14/865,748
• Publication Number:
  US 20160094625A1
• Time in Patent Office: 1,215 Days
• Field of Search: None
• 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 having memory and at least one processor, the application server environment executing thereon and associated with a domain for execution of software applications and a plurality of deployable resources,

wherein the domain and a plurality of partitions are provided at a cluster including a plurality of servers operating within the application server environment;

wherein each partition of the plurality of partitions provides a subdivision of the domain, and includes a resource group that enables partition-specific information for the deployable resources; and

wherein the cluster is configured to vary a number of the plurality of servers based on a service load of applications running on the cluster, and failure and restart of the plurality of 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 plurality of servers; and

a placement engine residing on each of the plurality of servers, whereupon a determination that a server on which an active placement engine fails, an inactive placement engine on one of the others of the plurality of servers is made active, and

wherein an active placement engine is configured to migrate one or more of the instances of messaging service artifacts between servers as the number of servers in the cluster and a number of the instances of messaging service artifacts is varied,

wherein the active placement engine selects a server to which a particular messaging service artifact is migrated based on a distribution policy and a number of messaging service artifacts presently provided on each of the available servers.

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

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

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

5. The system of claim 1, wherein the cluster is configured to vary the number of servers based on a service load of applications running on the cluster, and

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

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

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

8. 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.

18. The system of claim 1, wherein the distribution policy includes a set of criteria including at least one of:

whether a preferred server from the available servers is identified for the messaging service artifact, a weight of the messaging service artifact, and a success rate of placing other messaging service artifacts on each of the available servers for a period of time preceding migration.

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

providing, at one or more computers having memory and at least one processor, the application server environment executing thereon and associated with a domain for execution of software applications and a plurality of deployable resources,

wherein the domain and a plurality of partitions are provided at a cluster including a plurality of servers operating within the application server environment;

wherein each partition of the plurality of partitions provides a subdivision of the domain, and includes a resource group that enables partition-specific information for the deployable resources; and

wherein the cluster is configured to vary a number of the plurality of servers based on a service load of applications running on the cluster, and failure and restart of the plurality of servers;

providing 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 plurality of servers;

providing a placement engine residing on each of the plurality of servers, whereupon a determination that a server on which an active placement engine fails, an inactive placement engine on one of the others of the plurality of servers is made active, and

migrating, via an active placement engine, one or more of the instances of messaging service artifacts between servers as the number of servers in the cluster and a number of the instances of messaging service artifacts is varied,

wherein the active placement engine selects a server to which a particular messaging service artifact is migrated based on a distribution policy and a number of messaging service artifacts presently provided on each of the available servers.

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

11. The method of claim 9, further comprising migrating the instances of messaging service artifacts between the plurality of servers based on performance metrics for the plurality of servers.

12. The method of claim 11, wherein the performance metrics for the plurality of servers includes a load of the instances of messaging service artifacts on each of the plurality of servers.

13. The method of claim 9, wherein the cluster is configured to vary the number of servers based on a service load of applications running on the cluster, and

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

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

15. The method of claim 14, wherein the parameters include distribution policy and migration policy.

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

19. The method of claim 9, wherein the distribution policy includes a set of criteria including at least one of:

whether a preferred server from the available servers is identified for the messaging service artifact, a weight of the messaging service artifact, and a success rate of placing other messaging service artifacts on each of the available servers for a period of time preceding migration.

17. 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 having memory and at least one processor, the application server environment executing thereon and associated with a domain for execution of software applications and a plurality of deployable resources,

wherein the domain and a plurality of partitions are provided at a cluster including a plurality of servers operating within the application server environment;

wherein each partition of the plurality of partitions provides a subdivision of the domain, and includes a resource group that enables partition-specific information for the deployable resources; and

wherein the cluster is configured to vary a number of the plurality of servers based on a service load of applications running on the cluster, and failure and restart of the plurality of servers;

providing 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 plurality of servers;

providing a placement engine residing on each of the plurality of servers, whereupon a determination that a server on which an active placement engine fails, an inactive placement engine on one of the others of the plurality of servers is made active, and

migrating, via an active placement engine, one or more of the instances of messaging service artifacts between servers as the number of servers in the cluster and a number of the instances of messaging service artifacts is varied,

wherein the active placement engine selects a server to which a particular messaging service artifact is migrated based on a distribution policy and a number of messaging service artifacts presently provided on each of the available servers.