Method and system for application level load balancing in a publish/subscribe message architecture

摘要

A method of publishing a message includes receiving a subscription request at a first remote relay from a first client and transmitting a subscription message from the remote relay to each of a first set of central relays. The method also includes receiving a publication request at a second remote relay from a second client and transmitting a publication message from the second remote relay to a first central relay of the first set of central relays and a second central relay of a second set of central relays. The method further includes determining, at the first central relay, that a target matches at least a portion of a pattern, transmitting the message string from the first central relay to the first remote relay, determining, at the first remote relay, that the target matches at least a portion of the pattern, and transmitting the message string to the first client.

主权项

1. A computer-implemented method for processing a request at a first remote relay, the method comprising:
receiving the request at the first remote relay from a first client, wherein the request comprises a subscription request or a publication request; determining, by the first remote relay, if the request is either the subscription request or the publication request; upon determining that the request is the subscription request, providing a subscription message from the first remote relay to each of a first set of central relays from among more than one set of central relays, wherein the subscription message comprises information related to the subscription request; upon determining that the request is the publication request, providing a publication message from the first remote relay to one central relay in each of the first set of central relays and a second set of central relays, wherein the publication message comprises information related to the publication request; determining, by the first remote relay, if a publication received from one of the central relays in either the first set of central relays or the second set of central relays is intended for the first client based on correspondence information from the publication with the information from the subscription request; and providing the publication to the first client if information from the publication corresponds to the information from the subscription request.