Providing distributed dynamic routing using a logical broker

• US 9,137,189 B2
• Filed: 03/24/2011
• Issued: 09/15/2015
• Est. Priority Date: 03/24/2011
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Ross, Theodore L.
• Primary Examiner(s): Park, Jeong S
• Application Number:
  US13/071,243
• Publication Number:
  US 20120246241A1
• Time in Patent Office: 1,636 Days
• Field of Search: 709/206, 709/238
• US Class Current: 1/1
• CPC Class Codes: H04L 45/308 Route determination based on user's profile, e.g. premium users
• CPC Class Codes: H04L 45/42 Centralised routing
• CPC Class Codes: H04L 45/44 Distributed routing
• CPC Class Codes: H04L 51/214 using selective forwarding
• CPC Class Codes: H04L 51/234 for tracking messages
• CPC Class Codes: H04L 67/55 Push-based network services
• CPC Class Codes: H04L 67/63 Routing a service request depending on the request content or context

Abstract

Systems and methods are disclosed that provide a single logical broker from the point of view of a message consumer connected to a messaging network. The messaging network implements dynamic routing that adapts to changes in the message preferences of the message consumer and the message consumer'"'"'s availability throughout the messaging network. In various embodiments, the connection/disconnection of a message consumer and/or changes to message routing criteria at any broker in the network are propagated to all other brokers in the network until the entire network is adapted, such that a message consumer may connect to any broker node and receive the same network service and functionality regardless of connection point.

Claims

1. A method comprising:

receiving, by an upstream broker of a plurality of brokers from a first downstream broker of the plurality of brokers over a first communications link, first message-identifying information of a message consumer, wherein the first downstream broker is closer than the upstream broker to a point where the message consumer is connected to the plurality of brokers;

configuring, using a processing unit and in response to receiving the first message-identifying information over the first communications link, routing information stored by the upstream broker to route received messages corresponding to the first message-identifying information to the first downstream broker over the first communication link;

receiving a message from a message producer;

determining that the message is identified by the first message-identifying information;

routing, in response to determining that the message is identified by the first message-identifying information, the message to the first downstream broker according to the stored routing information;

receiving, by the upstream broker from a second downstream broker of the plurality of brokers over a second communications link, second message-identifying information of the message consumer, wherein the second communications link differs from the first communications link, and wherein the second message-identifying information differs from the first message-identifying information; and

reconfiguring, using the processing unit and in response to receiving the second message-identifying information over the second communications link, the routing information stored by the upstream broker to route received messages corresponding to the second message-identifying information to the second downstream broker over the second communications link.

2. The method of claim 1, further comprising:

receiving an indication that the message consumer has disconnected from the plurality of brokers;

reconfiguring, using the processing unit, the routing information stored by the upstream broker to cease to route messages identified by the first message-identifying information to the first downstream broker over the first communications link; and

reconfiguring, using the processing unit, the routing information stored by the upstream broker to cease to route messages identified by the second message-identifying information to the second downstream broker over the second communications link.

3. The method of claim 1, wherein the first downstream broker is directly connected to the message consumer.

4. The method of claim 1, wherein the message is in AMQP format.

5. A system comprising:

a memory to store routing information; and

a processing unit operatively coupled to the memory, the processing unit to;

receive, by an upstream broker of a plurality of brokers from a first downstream broker of the plurality of brokers over a first communications link, first message-identifying information of a message consumer, wherein the first downstream broker is closer than the upstream broker to a point where the message consumer is connected to the plurality of brokers;

configure, in response to receiving the first message-identifying information over the first communications link, the routing information to route received messages corresponding to the first message-identifying information to the downstream broker over the first communication link;

receive a message from a message producer;

determine that the message is identified by the first message-identifying information;

route, in response to determining that the message is identified by the first message-identifying information, the message to the first downstream broker according to the routing information;

receive, by the upstream broker from a second downstream broker of the plurality of brokers over a second communications link, second message-identifying information of the message consumer, wherein the second communications link differs from the first communications link, and wherein the second message-identifying information differs from the first message-identifying information; and

reconfigure, in response to receiving the second message-identifying information over the second communications link, the routing information stored by the upstream broker to route received messages corresponding to the second message-identifying information to the second downstream broker over the second communications link.

6. The system of claim 5, wherein the processing unit is further to:

receive an indication that the message consumer has disconnected from the plurality of brokers;

reconfigure the routing information to cease to route messages identified by the first message-identifying information to the first downstream broker over the first communications link; and

reconfigure the routing information to cease to route messages identified by the second message-identifying information to the second downstream broker over the second communications link.

7. The system of claim 5, wherein the first downstream broker is directly connected to the message consumer.

8. The system of claim 5, wherein the message is in AMQP format.

9. A non-transitory computer-readable medium having instructions encoded thereon that, when executed by a processing unit, cause the processing unit to:

receive, by an upstream broker of a plurality of brokers from a first downstream broker of the plurality of brokers over a first communications link, first message-identifying information of a message consumer, wherein the downstream broker is closer than the upstream broker to a point where the message consumer is connected to the plurality of brokers;

configure, using the processing unit in response to receiving the first message-identifying information over the first communications link, routing information stored by the upstream broker to route received messages corresponding to the first message-identifying information to the first downstream broker over the first communications link;

receive a message from a message producer;

determine that the message is identified by the first message-identifying information;

route, in response to determining that the message is identified by the first message-identifying information, the message to the downstream broker according to the stored routing information;

receive, by the upstream broker from a second downstream broker of the plurality of brokers over a second communications link, second message-identifying information of the message consumer, wherein the second communications link differs from the first communications link, and wherein the second message-identifying information differs from the first message-identifying information; and

reconfigure, using the processing unit and in response to receiving the second message-identifying information over the second communications link, the routing information stored by the upstream broker to route received messages corresponding to the second message-identifying information to the second downstream broker over the second communications link.

10. The non-transitory computer-readable medium of claim 9, the instructions further causing the processing unit to:

receive an indication that the message consumer has disconnected from the plurality of brokers;

reconfigure, using the processing unit, the routing information stored by the upstream broker to cease to route messages identified by the first message-identifying information to the first downstream broker over the first communications; and

reconfigure, using the processing unit, the routing information stored by the upstream broker to cease to route messages identified by the second message-identifying information to the second downstream broker over the second communications link.

11. The non-transitory computer-readable medium of claim 9, wherein the first downstream broker is directly connected to the message consumer.

12. The non-transitory computer-readable medium of claim 9, wherein the message is in AMQP format.