Hashing based messaging approach to a cluster

• US 20040240462A1
• Filed: 05/27/2003
• Published: 12/02/2004
• Est. Priority Date: 05/27/2003
• Status: Active Grant

• Current Assignee: Oracle America, Inc. (Oracle Corporation)
• Original Assignee: Sun Microsystems Incorporated (Oracle Corporation)
• Inventors: Kumar, Ajay, T, Venkateshwara V
• Granted Patent: US 7,400,624 B2
• Time in Patent Office: Days
• US Class Current: 370/432
• 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 producer;

a message middleware component configured to receive a message from the message producer;

a cluster of message consumer nodes comprising at least two nodes wherein each node is configured to receive the message;

wherein each node receiving the message determines for each message received whether it is the node in the cluster of nodes assigned to processing the message; and

wherein only the node assigned to process the message processes the message.

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 is received by a 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 plurality of 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 1, wherein if a node is not assigned to process the message, the node ignores the message.

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

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

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

13. The system as recited in claim 1, 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.

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 message at a clustered message consumer comprising a plurality of message consumer nodes, wherein a subset of the nodes receives the message;

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.

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 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 carrier medium comprising program instructions, wherein the program instructions are computer-executable to:

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

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.

25. The carrier 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 carrier medium as recited in claim 24, wherein the subset of nodes receives the message as a subscriber to a topic.

27. The carrier 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 carrier medium as recited in claim 24, wherein the message is a Java Message Service (JMS) message and the node implements a message driven bean.

29. The carrier 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 carrier 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 carrier medium as recited in claim 24, wherein each message consumer node is implemented within an application server container.

32. The carrier medium as recited in claim 24, further comprising the node in the subset of nodes that processes the message acknowledges receipt of the message to a message producer.