Hashing based messaging approach to a cluster

• US 7,400,624 B2
• Filed: 05/27/2003
• Issued: 07/15/2008
• Est. Priority Date: 05/27/2003
• Status: Active Grant

• Current Assignee: Oracle America, Inc. (Oracle Corporation)
• Original Assignee: Sun Microsystems Incorporated (Oracle Corporation)
• Inventors: T V, Venkateshwara, Kumar, Ajay
• Primary Examiner(s): Jung; Min
• Application Number:
  US10/445,746
• Publication Number:
  US 20040240462A1
• Time in Patent Office: 1,876 Days
• Field of Search: 370/432, 370/392, 370/390, 709/229, 709/206, 709/230, 713/201, 719/313, 380/278
• US Class Current: 370/390
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 67/1001 for accessing one among a plurality of replicated servers

Abstract

In a system and method for distributing and processing messages, a message may be sent to a message middleware component by a message producer. The message middleware component may provide the message to a cluster of nodes (such as a cluster of application servers or a cluster of application components). The node may implement a message verifier to determine if it is the node responsible for processing the message. The node that is responsible for processing the message may process the message and communicate the result to the other nodes. The other nodes not responsible for processing the message may ignore the message.

Claims

1. A system, comprising:

a message middleware component configured to receive a plurality of messages from one or more message producers;

a cluster of message consumer nodes comprising at least two nodes, wherein the cluster is configured so that each of the at least two nodes receives each message of a plurality of messages from the message middleware component;

wherein each node of the cluster determines for each one of the plurality of messages received whether it is the node in the cluster of nodes assigned to process the message; and

wherein only the node assigned to process the message processes the message so that each one of the plurality of messages is processed by only one node of the cluster.

2. The system as recited in claim 1, wherein the at least two nodes receive the message as a subscriber to a topic.

3. The system as recited in claim 1, wherein the message s received by at least one node in the at least two nodes through a point-to-point transfer.

4. The system as recited in claim 1, wherein the cluster of message consumer nodes comprises a message middleware neutral interface to the message middleware component such that the cluster of message consumer nodes may participate in messaging with a plurality of different types of message middleware components.

5. The system as recited in claim 1, wherein at least one node in the cluster of message consumer nodes receives the message from a message-oriented middleware as a subscriber to a topic.

6. The system as recited in claim 1, wherein determining for each message received whether the node is the node assigned to processing the message includes calculating a relative value and comparing the calculated relative value to a range of calculated relative values each message consumer node is assigned to.

7. The system as recited in claim 1, wherein a message verifier determines a node to process the message using information in the message.

8. The system as recited in claim 7, wherein the information in the message utilized to determine a node to process the message includes a destination of the message, a delivery mode of the message, an identification of the message, a time the message was sent, a type of the message, an expiration of the message, or a priority of the message.

9. The system as recited in claim 7, further comprising the node in the cluster of nodes that processes the message according to the message verifier, acknowledges receipt of the message to a message source.

10. The system as recited in claim 1, wherein if a node is not assigned to process the message, the node ignores the message.

11. The system as recited in claim 1, wherein the message is a Java Message Service (JMS) message and the node assigned to process the message implements a message driven bean.

12. The system as recited in claim 1, wherein each node in the at least two nodes subscribes to a topic.

13. The system as recited in claim 1, wherein each message consumer node is implemented within an application server container.

14. The system as recited in claim 1, wherein the message is processed neutral to the message-oriented middleware.

15. A method, comprising:

receiving a plurality of messages at a clustered message consumer comprising a plurality of message consumer nodes, wherein a subset of the nodes receives the message, wherein the subset comprises at least two of the plurality of message consumer nodes;

for each of the plurality of messages;

determining which node in the subset of nodes is assigned to a unique message range that the message falls within; and

processing the message, wherein the node in the subset of nodes assigned to the unique message range the message falls within processes the message so that only one node processes the message for the subset.

16. The method as claimed in claim 15, wherein the message is received through a message-oriented middleware, wherein each node in the subset of nodes that received the message subscribed to a topic associated with the message.

17. The method as recited in claim 15, wherein the subset of nodes receives the message as a subscriber to a topic.

18. The method as recited in claim 15, wherein at least one node in the subset of nodes receives the message through a point-to-point transfer.

19. The method as recited in claim 15, wherein the message is a Java Message Service (JMS) message and the node assigned to process the message implements a message driven bean.

20. The method as recited in claim 15, wherein a message verifier determines a node in the subset of nodes to process the message using information in the message, wherein the information in the message utilized to determine a node to process the message includes a destination of the message, a delivery mode of the message, an identification of the message, a time the message was sent, a type of the message, an expiration of the message, or a priority of the message.

21. The method as recited in claim 15, wherein the clustered message consumer interacts with message producers or with a message oriented middleware component as a single message consumer.

22. The method as recited in claim 15, wherein each message consumer node is implemented within an application server container.

23. The method as recited in claim 15, further comprising the node in the subset of nodes that processes the message acknowledges receipt of the message to a message producer.

24. A computer readable storage medium, comprising program instructions, wherein the program instructions are computer-executable to implement:

receiving a plurality of messages at a clustered message consumer comprising a plurality of message consumer nodes, wherein a subset of the nodes receives the message, wherein the subset comprises at least two of the plurality of message consumer nodes;

for each of the plurality of messages;

determining which node in the subset of nodes is assigned to a unique message range that the message falls within; and

processing the message, wherein the node in the subset of nodes assigned to the unique message range the message falls within processes the message so that only one node processes the message for the subset.

25. The computer readable storage medium as claimed in claim 24, wherein the message is received through a message-oriented middleware, wherein each node in the subset of nodes that received the message subscribed to a topic associated with the message.

26. The computer readable storage medium as recited in claim 24, wherein the subset of nodes receives the message as a subscriber to a topic.

27. The computer readable storage medium as recited in claim 24, wherein at least one node in the subset of nodes receives the message through a point-to-point transfer.

28. The computer readable storage medium as recited in claim 24, wherein the message is a Java Message Service (JMS) message and the node assigned to process the message implements a message driven bean.

29. The computer readable storage medium as recited in claim 24, wherein a message verifier determines a node in the subset of nodes to process the message using information in the message, wherein the information in the message utilized to determine a node to process the message includes a destination of the message, a delivery mode of the message, an identification of the message, a time the message was sent, a type of the message, an expiration of the message, or a priority of the message.

30. The computer readable storage medium as recited in claim 24, wherein the clustered message consumer interacts with message producers or with a message oriented middleware component as a single message consumer.

31. The computer readable storage medium as recited in claim 24, wherein each message consumer node is implemented within an application server container.

32. The computer readable storage medium as recited in claim 24, wherein the node in the subset of nodes that processes the message acknowledges receipt of the message to a message producer.