Techniques to distribute messages using communication pipelines

• US 9,203,780 B2
• Filed: 01/27/2012
• Issued: 12/01/2015
• Est. Priority Date: 01/27/2012
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Inventors: Parthasarathy, Vijay Kishen Hampapur, Noureddine, Moustafa, Narayanan, Ranjith
• Primary Examiner(s): Tran, Jimmy H
• Application Number:
  US13/360,511
• Publication Number:
  US 20130198293A1
• Time in Patent Office: 1,404 Days
• Field of Search: 709/206, 709/230, 709/232, 709/235, 709/236, 709/238, 709/240, 709/244
• US Class Current: 1/1
• CPC Class Codes: H04L 49/1546 using pipelined operation
• CPC Class Codes: H04L 49/3063 Pipelined operation
• CPC Class Codes: H04L 51/043 using or handling presence information

Abstract

Techniques to distribute messages using communication pipelines are described. An apparatus may comprise a message receiving component operative to receive a message at a first server for forwarding to a virtual receiver, a routing component operative to identify a second server maintaining the virtual receiver and determine a communication pipeline between the first server and the second server, and a message sending component operative to send the message from the first server to the second server over the communication pipeline. Other embodiments are described and claimed.

Claims

1. An apparatus, comprising:

a processor circuit coupled to a memory unit comprising components configured to execute on the processor, the components comprising;

a message receiving component to receive a message at a first server for forwarding to a virtual receiver, the virtual receiver being maintained on a single second server;

a routing component to identify the second server maintaining the virtual receiver and determine a communication pipeline between the first server and the second server, wherein the second server is in one of;

a same cluster of servers as the first server or a different cluster of servers from the first server, and wherein each pair of servers in a cluster of servers has a unique communication pipeline, and wherein each pair of clusters of servers has a unique communication pipeline; and

a message sending component to send the message from the first server to the second server over the communication pipeline.

2. The apparatus of claim 1, wherein the virtual receiver represents a group of receivers associated with the second server.

3. The apparatus of claim 2, wherein the received message is associated with a virtual publisher maintained by the first server, wherein each receiver of the group of receivers is subscribed to the virtual publisher.

4. The apparatus of claim 1, wherein the received message comprises a presence notification message containing presence state information representing a change in presence state of a virtual publisher maintained by the first server.

5. The apparatus of claim 1, wherein the received message is received from a publisher associated with the first server.

6. The apparatus of claim 1, wherein the first server is a member of a first cluster and the message is received from a third server in a second cluster, wherein a plurality of virtual receivers maintained by a plurality of servers within the first cluster are identified to receive the message, wherein a plurality of communication pipelines between the first server and the plurality of servers are identified, and wherein the message is sent from the first server to the plurality of servers over the identified plurality of communication pipelines.

7. The apparatus of claim 1, wherein the message sending component is configured to send the message from the first server to the second server over the communication pipeline as part of a batch message comprising a plurality of messages for the virtual receiver, wherein each message in the plurality of messages comprises message information, and wherein the message information in each message is the same message information as the message information in every other message in the plurality.

8. The apparatus of claim 1 wherein each communication pipeline is a half-duplex buffered stream configured to carry multiple messages intended for different recipients within a single message.

9. A computer-implemented method, comprising:

receiving a message at a first server for forwarding to a virtual receiver, the virtual receiver being maintained on a single second server;

identifying the second server maintaining the virtual receiver;

determining a communication pipeline between the first server and the second server, wherein the second server is in one of;

a same cluster of servers as the first server or a different cluster of servers from the first server, and wherein each pair of servers in a cluster of servers has a unique communication pipeline, and wherein each pair of clusters of servers has a unique communication pipeline; and

sending the message from the first server to the second server over the communication pipeline as part of a batch message comprising a plurality of messages for the virtual receiver.

10. The computer-implemented method of claim 9, wherein the virtual receiver represents a group of receivers associated with the second server.

11. The computer implemented method of claim 10, wherein the received message is associated with a virtual publisher maintained by the first server, wherein each receiver of the group of receivers is subscribed to the virtual publisher.

12. The computer-implemented method of claim 9, wherein the received message comprises a presence notification message containing presence state information representing a change in presence state of a virtual publisher maintained by the first server.

13. The computer-implemented method of claim 9, wherein the received message is received from a publisher associated with the first server.

14. The computer-implemented method of claim 9, wherein the first server is a member of a first cluster and the message is received from a third server in a second cluster, wherein a plurality of virtual receivers maintained by a plurality of servers within the first cluster are identified to receive the message, wherein a plurality of communication pipelines between the first server and the plurality of servers are identified, and wherein the message is sent from the first server to the plurality of servers over the identified plurality of notification pipelines.

15. An article of manufacture comprising at least one computer-readable storage device comprising instructions that, when executed, cause a system to:

receive a message at a first server for forwarding to a virtual receiver, the virtual receiver being maintained on a single second server, wherein the virtual receiver represents a group of receivers associated with the second server;

identify a second server maintaining the virtual receiver;

determine a communication pipeline between the first server and the second server, wherein the second server is in one of;

a same cluster of servers as the first server or a different cluster of servers from the first server, and wherein each pair of servers in a cluster of servers has a unique communication pipeline, and wherein each pair of clusters of servers has a unique communication pipeline; and

send the message from the first server to the second server over the communication pipeline as part of a batch message comprising a plurality of messages for the virtual receiver.

16. The article of manufacture of claim 15, wherein the received message is associated with a virtual publisher maintained by the first server, wherein each receiver of the group of receivers is subscribed to the virtual publisher.

17. The article of manufacture of claim 15, wherein the received message comprises a presence notification message containing presence state information representing a change in presence state of a virtual publisher maintained by the first server.

18. The article of manufacture of claim 15, wherein the received message is received from a publisher associated with the first server.

19. The article of manufacture of claim 15, wherein the first server is a member of a first cluster and the message is received from a third server in a second cluster, wherein a plurality of virtual receivers maintained by a plurality of servers within the first cluster are identified to receive the message, wherein a plurality of communication pipelines between the first server and the plurality of servers are identified, and wherein the message is sent from the first server to the plurality of servers over the identified plurality of notification pipelines.