Message broadcasting in a clustered computing environment

摘要

Embodiments of the present invention provide message broadcasting within a clustered computing environment such as a Cloud computing environment. Specifically, under the present invention, a message is received in a message queue (e.g., on a message queue server). From the message queue, the message is sent to a single node of a plurality of heterogeneous nodes within the clustered computing environment. The single node can be selected based on any factor such as a best available node within the plurality of nodes. This single node will process the message and identify a set of message listeners to whom the message should be broadcast. Typically, the set of message listeners is identified based on a topic of the message and an association of the topic to the set of message listeners (e.g., as set forth in a table or the like). In any event, the single node will then publish the message to the set of message listeners. Delivery confirmations, responses, etc. associated with the message will then be tracked, processed, and/or routed by the single node. Thus, embodiments of the present invention obviate the need for a given message from having to be delivered to and/or processed by multiple nodes.

主权项

1. A method for message broadcasting in a clustered computing environment, comprising:
receiving a message in a message queue; selecting a single node from a plurality of substantially similar nodes in a cluster having substantially identical software in the clustered computing environment to process the message, wherein the single node is selected based on an availability of resources to the single node; sending, in response to the selecting, the message from the queue to the single node without sending the message to any other nodes of the plurality of nodes; processing the message on the single node; identifying, by the single node, a subset of a set of message listeners to receive the message based on a topic of the message using the single node; broadcasting the message to the subset of message listeners from the single node, without sending the message to any other nodes of the plurality of nodes; publishing, by the single node, the message to the subset of message listeners; tracking, by the single node, at least one of: a message delivery and a response, from at least one message listener of the subset of message listeners; and routing, by the single node, the at least one of: a message delivery and a response, from the at least one message listener of the subset of message listeners.