Dynamic subscription and message routing on a topic between publishing nodes and subscribing nodes
First Claim
1. A system for dynamically routing a message over a network having a first node and a plurality of other nodes, the system comprising:
- a publisher for generating and sending the message on a topic, the publisher having an output;
a plurality of subscribers each having an input for receiving the message, at least one of the plurality of subscribers subscribing to the topic; and
a broker having an input, an output and a topic/node table, the broker associated with the first node, in response to receipt of the message, the broker identifying the topic associated with the message and determining using the topic/node table and the identified topic which of the plurality of other nodes to which to send the message for delivery to the one of the plurality of subscribers subscribing to the topic, the input of the broker coupled to the output of the publisher, and the output of the broker coupled to the inputs of the plurality of subscribers.
8 Assignments
0 Petitions
Accused Products
Abstract
A system for dynamic message routing on a topic between publishing nodes and subscribing nodes includes a plurality of message queues, at least one topic/node table, a subscribing module, a publishing module, and other modules to send messages between one or more publisher and one or more subscribers. These modules are coupled together by a bus in a plurality of nodes and provide for the dynamic message routing on a topic between publishing nodes and subscribing nodes. The message queues store messages at each node for delivery to subscribers local to that node. The topic/node table lists which clients subscribe to which topics, and is used by the other modules to ensure proper distribution of messages. The subscribing module is use to establish a subscription to a topic for that node. The publishing module is used to identify subscribers to a topic and transmit messages to subscribers dynamically. The other modules include various devices to optimize message communication in a publish/subscribe architecture operating on a distributed computing system. The present invention also includes a number of novel methods including: a method for publishing a message on a topic, a method for forwarding a message on a topic, a method for subscribing to messages on a topic, a method for automatically removing subscribers, a method for direct publishing of messages, and methods for optimizing message transmission between nodes.
99 Citations
16 Claims
-
1. A system for dynamically routing a message over a network having a first node and a plurality of other nodes, the system comprising:
-
a publisher for generating and sending the message on a topic, the publisher having an output; a plurality of subscribers each having an input for receiving the message, at least one of the plurality of subscribers subscribing to the topic; and a broker having an input, an output and a topic/node table, the broker associated with the first node, in response to receipt of the message, the broker identifying the topic associated with the message and determining using the topic/node table and the identified topic which of the plurality of other nodes to which to send the message for delivery to the one of the plurality of subscribers subscribing to the topic, the input of the broker coupled to the output of the publisher, and the output of the broker coupled to the inputs of the plurality of subscribers. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16)
-
Specification