Fast content-based routing
Systems and methods for fast, efficient content-based routing that allow a router to perform true content-based routing without having to de-serialize the data and apply a full content-based filter by determining the exact set of consumers to forward the data onto based on packet headers. A system for fast content-based routing may receive a subscription from a receiver machine and may assign a unique ID associated with the subscription in a router table. The system may then place a ID associated with a particular subscription in a message header if the message corresponds to the subscription. The system may then analyze the router table to determine one or more receiver machines associated with the ID in the header of the message. The system may then send, from a sender machine to one or more receiver machines, one or more messages containing the ID in the header of the message.
1. A method for efficient content-based routing, the method comprising:
receiving, at a sender machine, a subscription of requested content requested by a receiver machine;
assigning a unique subscription identification (ID) identifying the requested content and associated with the subscription in a router table;
prior to sending a message, placing, by the sender machine, the subscription ID in a header of the message if the message corresponds to the requested content;
analyzing the router table to determine one or more receiver machines associated with the requested content identified by the subscription ID in the header of the message; and
sending, from the sender machine, one or more messages to the one or more receiver machines associated with the requested content identified by the subscription ID in the header of the message.
2. The method of claim 1 , wherein the one or more messages are sent over a network of one or more routers operable to analyze the subscription ID in the header of the one or more messages.
3. The method of claim 1 , wherein the router table comprises one or more entries comprising:
the subscription;
the subscription ID associated with the subscription; and
a receiver machine ID associated with the receiver machine subscribing to the subscription.
4. The method of claim 1 , further comprising:
not sending, from the sender machine, the one or more messages to the one or more receiver machines not associated with the subscription ID in the header of the message.
5. The method of claim 1 , wherein the subscription ID is an integer.
6. The method of claim 1 , wherein the subscription comprises one or more fields and one or more values, wherein the one or more fields are associated with a category of content, and wherein the one or more values are associated with a particular type of content.
7. The method of claim 1 , wherein the subscription is for a particular sports magazine and the subscription ID associated with the subscription is 77.
8. The method of claim 1 , wherein the router table is located at one of the one or more middleware servers.
9. The method of claim 1 , wherein the sender machine communicates with the receiver machine through a peer to peer (P2P) network.
10. The method of claim 1 , wherein the router table is located at the sender machine.
11. The method of claim 1 , wherein the sender machine is a middleware server.
12. The method of claim 1 , wherein the receiver machine is a middleware server.
13. A system for efficient content-based routing, the system comprising:
a sender machine configured to:
receive a subscription of requested content requested by a receiver machine;
assign a unique subscription identification (ID) identifying the requested content and associated with the subscription in a router table;
prior to sending a message, place the subscription ID in a header of the message if the message corresponds to the requested content;
analyze the router table to determine one or more receiver machines associated with the requested content identified by the subscription ID in the header of the message; and
send one or more messages to the one or more receiver machines associated with the requested content identified by the subscription ID in the header of the message.
14. The system of claim 13 , wherein the one or more messages are sent over a network of one or more routers operable to analyze the subscription ID in the header of the one or more messages.
15. The system of claim 13 , wherein the router table comprises one or more entries comprising:
the subscription;
the subscription ID associated with the subscription; and
a receiver machine ID associated with the receiver machine subscribing to the subscription.
16. The system of claim 13 , further comprising:
not sending, from the sender machine, the one or more messages to the one or more receiver machines not associated with the subscription ID in the header of the message.
17. The system of claim 13 , wherein the subscription ID is an integer.
18. The system of claim 13 , wherein the subscription comprises one or more fields and one or more values, wherein the one or more fields are associated with a category of content, and wherein the one or more values are associated with a particular type of content.
19. The system of claim 13 , wherein the subscription is for a particular sports magazine and the subscription ID associated with the subscription is 77.
20. The system of claim 13 , wherein the router table is located at one of the one or more middleware servers.
21. The system of claim 13 , wherein the sender machine communicates with the receiver machine through a peer to peer (P2P) network.
22. The system of claim 13 , wherein the router table is located at the sender machine.
23. The system of claim 13 , wherein the sender machine is a middleware server.
24. The system of claim 13 , wherein the receiver machine is a middleware server.
25. Logic for deploying an application, the logic being embodied in a non-transistory computer readable medium and when executed operable to:
receive a subscription of requested content requested by a receiver machine;
assign a unique subscription identification (ID) identifying the requested content and associated with the subscription in a router table;
prior to sending a message, place the subscription ID associated with a particular subscription in a header of the message if the message corresponds to the requested content;
analyze the router table to determine one or more receiver machines associated with the requested content identified by the subscription ID in the header of the message; and
send one or more messages to the one or more receiver machines associated with the requested content identified by the subscription ID in the header of the message.