Message oriented middleware cluster synchronization

Patent metadata

Field	Value
Publication number	US-12223369-B2
Application number	US-202117370384-A
Country	US
Kind code	B2
Filing date	Jul 8, 2021
Priority date	Jul 8, 2021
Publication date	Feb 11, 2025
Grant date	Feb 11, 2025

Abstract

A method comprises collecting message-oriented-middleware system parameters from a plurality of message-oriented-middleware clusters, analyzing the parameters using one or more machine learning algorithms, and predicting, based at least in part on the analyzing, at least one anomaly in a message-oriented-middleware cluster of the plurality of message-oriented-middleware clusters. In the method, message metadata is collected from the message-oriented-middleware cluster, and at least part of the message metadata is transmitted to one or more remaining ones of the plurality of message-oriented-middleware clusters. At least the part of the message metadata corresponds to messaging operations to be transferred from the message-oriented-middleware cluster to the one or more remaining ones of the plurality of message-oriented-middleware clusters.

First claim

What is claimed is:

1. A method, comprising:
collecting message-oriented-middleware system parameters from a plurality of message-oriented-middleware clusters;
analyzing the message-oriented-middleware system parameters using one or more machine learning algorithms;
predicting, based at least in part on the analyzing, at least one anomaly in a message-oriented-middleware cluster of the plurality of message-oriented-middleware clusters;
collecting message metadata from the message-oriented-middleware cluster based, at least in part, on the predicting;
transmitting at least part of the message metadata to one or more remaining ones of the plurality of message-oriented-middleware clusters;
wherein the part of the message metadata corresponds to messaging operations to be transferred from the message-oriented-middleware cluster to the one or more remaining ones of the plurality of message-oriented-middleware clusters, and wherein the part of the message metadata comprises one or more details about progress of message transmission in the message-oriented-middleware cluster, the one or more details including at least one of message offset information and one or more timestamps for messages committed to transmission by the message-oriented-middleware cluster; and
synchronizing, based at least in part on the one or more details about the progress of the message transmission, the messaging operations between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters to prevent message duplication between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters;
wherein the synchronizing comprises translating the message metadata from a format of a first message-oriented-middleware system to a format of a second message-oriented-middleware system to permit the second message-oriented-middleware system to process the one or more details about the progress of the message transmission and prevent re-transmission of the messages committed to transmission by the message-oriented-middleware cluster; and
wherein the steps of the method are executed by a processing device operatively coupled to a memory.

2. The method of claim 1 , wherein the plurality of message-oriented-middleware clusters respectively comprise a plurality of nodes.

3. The method of claim 1 , wherein the message-oriented-middleware system parameters comprise at least one of one or more central processing unit utilization parameters, one or more storage utilization parameters, one or more input/output parameters, message queue depth, one or more channel agent values and one or more channel connection agent values.

4. The method of claim 1 , wherein the part of the message metadata further comprises at least one of last message read information, last message committed information, one or more topic attributes and one or more transaction identifiers.

5. The method of claim 1 , wherein the one or more machine learning algorithms utilize an unsupervised learning technique to detect one or more outlier parameters of the message-oriented-middleware system parameters.

6. The method of claim 5 , wherein the one or more machine learning algorithms comprise an isolation forest algorithm.

7. The method of claim 6 , further comprising training the one or more machine learning algorithms with training data comprising historical parameter data.

8. The method of claim 1 , wherein the collecting of the message metadata and the transmitting of at least the part of the message metadata is performed in response to the predicting of the at least one anomaly in the message-oriented-middleware cluster.

9. The method of claim 1 , further comprising comparing the message metadata from the message-oriented-middleware cluster with message metadata from the one or more remaining ones of the plurality of message-oriented-middleware clusters to determine differences between the message metadata from the message-oriented-middleware cluster and the message metadata from the one or more remaining ones of the plurality of message-oriented-middleware clusters.

10. The method of claim 9 , further comprising determining, based at least in part on the differences, at least a portion of the message metadata from the one or more remaining ones of the plurality of message-oriented-middleware clusters requiring an update.

11. The method of claim 10 , wherein the part of the message metadata transmitted to the one or more remaining ones of the plurality of message-oriented-middleware clusters corresponds to the message metadata from the one or more remaining ones of the plurality of message-oriented-middleware clusters requiring the update.

12. The method of claim 1 , further comprising providing one or more application programming interfaces to one or more message-oriented-middleware clients, wherein the one or more application programming interfaces are used by the one or more message-oriented-middleware clients to retrieve at least the part of the message metadata.

13. An apparatus comprising:
a processing device operatively coupled to a memory and configured to:
collect message-oriented-middleware system parameters from a plurality of message-oriented-middleware clusters;
analyze the message-oriented-middleware system parameters using one or more machine learning algorithms;
predict, based at least in part on the analyzing, at least one anomaly in a message-oriented-middleware cluster of the plurality of message-oriented-middleware clusters;
collect message metadata from the message-oriented-middleware cluster based, at least in part, on the predicting;
transmit at least part of the message metadata to one or more remaining ones of the plurality of message-oriented-middleware clusters;
wherein the part of the message metadata corresponds to messaging operations to be transferred from the message-oriented-middleware cluster to the one or more remaining ones of the plurality of message-oriented-middleware clusters, and wherein the part of the message metadata comprises one or more details about progress of message transmission in the message-oriented-middleware cluster, the one or more details including at least one of message offset information and one or more timestamps for messages committed to transmission by the message-oriented-middleware cluster; and
synchronize, based at least in part on the one or more details about the progress of the message transmission, the messaging operations between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters to prevent message duplication between the message-oriented-middleware cluster and the one or more remaining ones of the plurality of message-oriented-middleware clusters;
wherein, in synchronizing, the processing device is configured to translate the message metadata from a format of a first message-oriented-middleware system to a format of a second message-oriented-middleware system to permit the second message-oriented-middleware system to process the one or more details about the progress of the message transmission and prevent re-transmission of the messages committed to transmission by the message-oriented-middleware cluster.

14. The apparatus of claim 13 , wherein the plurality of message-oriented-middleware clusters respectively comprise a plurality of nodes.

15. The apparatus of claim 13 , wherein the processing device is further configured to compare the message metadata from the message-oriented-middleware cluster with

Assignees

• Dell Products Lp

Inventors

• Mishra Abhijit
• Akkinapalli Krishna Mohan
• Das Satish Ranjan
• Mohanty Bijan Kumar
• Dinh Hung
• Kannan Saravanan
• Nimmakayala Sivamohan

Classifications

• G06N20/00

  Machine learning · CPC title

• G06N5/01

  Dynamic search techniques; Heuristics; Dynamic trees; Branch-and-bound · CPC title

• G06N20/20

  Ensemble learning · CPC title

• G06F9/546 Primary

  Message passing systems or structures, e.g. queues · CPC title

• G06F15/17325 Primary

  Synchronisation; Hardware support therefor (intertask synchronisation G06F9/52) · CPC title