Hierarchical publish and subscribe system

• US 9,047,589 B2
• Filed: 10/30/2009
• Issued: 06/02/2015
• Est. Priority Date: 10/30/2009
• Status: Active Grant

• Current Assignee: VeriSign, Inc.
• Original Assignee: VeriSign, Inc.
• Inventors: Gallant, John Kenneth, Verd, Brad, Henderson, Karl M.
• Primary Examiner(s): Winder, Patrice
• Assistant Examiner(s): TRAN, NAM T
• Application Number:
  US12/610,066
• Publication Number:
  US 20110106891A1
• Time in Patent Office: 2,041 Days
• US Class Current: 1/1
• CPC Class Codes: G06Q 10/107 Computer-aided management of electronic mailing [e-mailing]
• CPC Class Codes: H04L 12/1854 with non-centralised forwarding system, e.g. chaincast
• CPC Class Codes: H04L 51/04 Real-time or near real-time messaging, e.g. instant messaging [IM]
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

A method of publishing a publication message includes receiving, at one of a plurality of first relays, a subscription request from a first client and transmitting the subscription request from the one of the plurality of first relays to only one of a plurality of central relays. The method also includes receiving, at another of the plurality of first relays, a publication request from a second client. The publication request includes the publication message. The method further includes transmitting the publication message from the another of the plurality of first relays to all of the plurality of central relays, transmitting the publication message from at least one of the plurality of central relays to the one of the plurality of first relays, and transmitting the publication message from the one of the plurality of first relays to the first client.

Claims

1. A computer-implemented method of subscribing and publishing a publication message, the method comprising

receiving a first subscription request at a remote relay from a first client, wherein the first subscription request includes a target;

transmitting a subscription message from the remote relay to a single one of a plurality of central relays based on the first subscription request, wherein the transmitting includes the remote relay subscribing to the single one of a plurality of central relays on behalf of the first client and wherein the subscription message includes the target;

entering a subscription, at the single one of a plurality of central relays, based on the received subscription message and not forwarding the received subscription message;

receiving a publication message at the remote relay from a second client, wherein the publication message includes a pattern;

transmitting the publication message to each of the central relays of the plurality of central relays,

determining, by the remote relay, that the target from the subscription request matches at least a portion of the pattern in the publication message; and

transmitting at least a portion of the publication message from the remote relay to the first client.

2. The method of claim 1 wherein the pattern is a string of a first length and the target is a string of a second length less than the first length.

3. The method of claim 1 wherein the first client is a remote client.

4. The method of claim 1, further comprising receiving a second subscription request at a remote relay from a third client, wherein the second subscription request includes the target, wherein the third client is a remote client.

5. The method of claim 4 wherein the first client and the third client are co-located with the remote relay.

6. A computer-implemented method of publishing a publication message, the method comprising:

receiving a subscription request at a non-central relay from a client, wherein the subscription request includes a target;

transmitting a subscription message from the non-central relay to a single one of a plurality of central relays based on the subscription request, wherein the transmitting includes the non-central relay subscribing to the single one of a plurality of central relays on behalf of the client and wherein the subscription message includes the target;

entering a subscription, at the single one of a plurality of central relays, based on the received subscription message and not forwarding the received subscription message;

receiving, at the non-central relay, the publication message from another client, wherein the publication message includes a pattern;

determining that a target of the subscription request received from the client matches at least a portion of the pattern;

providing at least a portion of the publication message from the non-central relay to all of a plurality of central relays; and

providing at least a portion of the publication message from the non-central relay to the the client.

7. The method of claim 6 wherein the non-central relay comprises a remote relay.

8. The method of claim 6 wherein the publication message is included in a publication request received by the non-central relay.

9. A computer-implemented method for publishing a publication message, the method comprising:

receiving, at a first one of a plurality of central relays, a subscription request from a first client, wherein the subscription request includes a target;

entering a subscription, at the first one of a plurality of central relays, based on the received subscription request and not forwarding the received subscription request;

receiving, at a second one of the plurality of central relays, a publication request from a second client, the publication request including the publication message, wherein the publication message includes a pattern;

determining that the target is correlated to the pattern;

transmitting the publication message from the second one of the plurality of central relays to the first one of the plurality of central relays and to other central relays of the plurality of central relays;

determining that a connection between the first one of the plurality of central relays and the second one of the plurality of central relays is available; and

transmitting the publication message from the first one of the plurality of central relays to the first client.

10. The method of claim 9 wherein the first client comprises a client collocated with the first one of the plurality of central relays.

11. The method of claim 9 wherein the first client comprises a remote relay.

12. The method of claim 9 wherein the second one of the plurality central relays comprises the first one of the plurality of central relays.

13. The method of claim 9 wherein transmitting the publication message comprises transmitting a portion of the publication request.

14. The method of claim 9, further comprising:

determining that a connection between the first one of the plurality of central relays and the second one of the plurality of central relays is not available; and

transmitting the publication message from the second one of the central relays to the first client.

15. A method for routing messages in a publish/subscribe network, the method comprising:

receiving a subscription request at a second remote relay from a client, wherein the subscription request includes a target;

transmitting a subscription message from the second remote relay to a first central relay of a plurality of central relays based on the subscription request, wherein the transmitting includes the second remote relay subscribing to the first central relay on behalf of the first client and wherein the subscription message includes the target;

entering a subscription, at the first central relay, based on the received subscription message and not forwarding the received subscription message;

receiving, at the first central relay of a plurality of central relays, a publication message from a first remote relay;

determining, by the first central relay, that a second central relay of the plurality of central relays, did not receive the publication message;

forwarding, by the first central relay, the publication message that was received from the first remote relay to the second central relay on behalf of the first remote relay;

determining, by the first central relay, that the publication message received from the first remote relay matches at least a portion of the subscription message received from the second remote relay; and

providing the publication message from the second remote relay to the client.

16. The method of claim 15, further comprising storing the publication message in a storage device in the first central relay.

17. The method of claim 15, further comprising receiving, at the first central relay, another publication message from the second central relay that was forward on from the second remote relay.