Asynchronous communication in an unstable network

• US 8,135,025 B2
• Filed: 06/03/2009
• Issued: 03/13/2012
• Est. Priority Date: 06/03/2009
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Saha, Sanjib, Dar, Affan Arshad, Chen, Xin, Puttaswamaiah, Manohar Bangalore
• Primary Examiner(s): Ton, Dang
• Assistant Examiner(s): KAMARA, MOHAMED A
• Application Number:
  US12/477,606
• Publication Number:
  US 20100309928A1
• Time in Patent Office: 1,014 Days
• Field of Search: 370/328, 370/412
• US Class Current: 370/412
• CPC Class Codes: H04L 12/1895 for short real-time information, e.g. alarms, notifications, alerts, updates
• CPC Class Codes: H04L 12/56 Packet switching systems
• CPC Class Codes: H04L 41/12 Discovery or management of network topologies
• CPC Class Codes: H04L 51/043 using or handling presence information
• CPC Class Codes: H04L 51/48 Message addressing, e.g. address format or anonymous messages, aliases
• CPC Class Codes: H04L 61/2503 Translation of Internet protocol [IP] addresses
• CPC Class Codes: H04L 61/5076 Update or notification mechanisms, e.g. DynDNS
• CPC Class Codes: H04L 61/58 Caching of addresses or names

Abstract

Embodiments are directed to promptly reestablishing communication between nodes in a dynamic computer network and dynamically maintaining an address list in an unstable network. A computer system sends a message to other message queuing nodes in a network, where each node in the message queuing network includes a corresponding persistent unique global identifier. The computer system maintains a list of unique global identifiers and the current network addresses of those network nodes from which the message queuing node has received a message or to which the message queuing node has sent a message. The computer system goes offline for a period of time and upon coming back online, sends an announcement message to each node maintained in the list indicating that the message queuing node is ready for communication in the message queuing network, where each message includes the destination node'"'"'s globally unique identifier and the node'"'"'s current network address.

Claims

1. A computer-implemented method for promptly reestablishing communication between nodes in a dynamic computer network, the method being performed at a computer system node having a processor and a memory and that is disposed within a computer networking environment having a plurality of computing systems, the method comprising:

an act of a message queuing node sending a message to one or more other message queuing nodes in a network, each node in the message queuing network including a corresponding persistent unique global identifier;

an act of maintaining a list of unique global identifiers of those network nodes from which the message queuing node has received a message or to which the message queuing node has sent a message;

an act of the message queuing node going offline for a period of time;

upon the message queuing node coming back online, an act of sending an announcement message to each node maintained in the list, the announcement message indicating that the message queuing node is ready for communication in the message queuing network, each message including the node'"'"'s globally unique identifier and the node'"'"'s current network address;

an act of determining that a connection has been established between the message queuing node and at least one node from the list of nodes; and

based on the determination, an act of automatically resuming message transfer between the message queuing node and the at least one list node, and such that communication between the message queuing node and the at least one list node is reinitiated automatically as soon as both are simultaneously online.

2. The method of claim 1, further comprising an act of broadcasting the announcement message containing the message queuing node'"'"'s identity and current network address to at least a plurality of the other nodes of the network.

3. The method of claim 1, wherein the unique global identifier is assigned to the node when the node is initially provisioned.

4. The method of claim 1, wherein each message queuing node'"'"'s unique global identifier is publicly available, such that applications can use the node'"'"'s unique global identifier to address messages to that node.

5. The method of claim 1, wherein when the message queuing node is offline, the message queuing node'"'"'s connection state is set to an offline state and the message queuing node'"'"'s network address value is set to null.

6. The method of claim 1, wherein the message queuing node comprises an address broadcast timer configured to initiate a broadcast of the node'"'"'s availability at predefined increments.

7. The method of claim 1, further comprising, upon the message queuing node coming back online, an act of the message queuing node sending any pending queued messages to nodes that have indicated they are available to receive messages.

8. The method of claim 1, wherein each node in the list includes the following information:

the unique global identifier of the destination node, the most recent network address of the destination node, session state indicating the current state of the network connection with the destination node, a collection of messages that are to be sent to the destination node, and timer that is started when the collection of messages has been successfully transmitted to the destination node.

9. The method of claim 8, wherein the timer is reset if an application adds new messages to be sent to the destination node.

10. The method of claim 9, further comprising:

an act of determining that the timer has expired; and

an act of removing the destination node from the list.

11. The method of claim 1, wherein the message queuing node listens for broadcast announcement messages on the network, such that when destination nodes come online with new network addresses, the message queuing node establishes a connection with the new network address of the destination node and begins transferring queued messages.

12. A computer storage device, comprising:

stored computer-executable instructions that, when executed by one or more processors of a computing system, cause the computing system to perform a method for dynamically maintaining an address list in an unstable network, the method comprising;

an act of determining that a message queuing node has one or more outstanding queued messages that are to be sent to one or more other nodes;

an act of the message queuing node dynamically maintaining the most recent network addresses of the nodes that are relevant to the message queuing node, wherein relevant nodes include those nodes for which the message queuing node has pending messages to be transmitted to the node, or those nodes that have substantially recently communicated with the message queuing node;

an act of the message queuing node establishing a communication handshake sequence with the relevant nodes, such that if a relevant node'"'"'s network address changes, the message queuing node is apprised thereof and the destination node is configured not to accept any message that was received erroneously due to network address changes;

an act of determining that at least one of the relevant nodes is no longer using its last known network address; and

an act of storing any pending messages until the message queuing node receives an indication from the destination node indicating the node'"'"'s new network address and that the relevant node is available for communication.

13. The computer storage device of claim 12, the method further comprising an act of sending the stored pending messages to the relevant node using the node'"'"'s new network address.

14. The computer storage device of claim 12, wherein the relevant node'"'"'s indication comprises a broadcasted announcement message.

15. The computer storage device of claim 12, wherein the relevant node'"'"'s indication comprises a targeted announcement message directed at the message queuing node because the message queuing node had previously communicated with the relevant node.

16. The computer storage device of claim 12, wherein each node in the message queuing network is configured to dynamically maintain the most recent network addresses of the nodes with which each node communicates.

17. A computer system comprising the following:

one or more processors;

system memory;

one or more computer-readable storage media having stored thereon computer-executable instructions that, when executed by the one or more processors, causes the computing system to perform a method for promptly reestablishing communication between nodes in a dynamic computer network, the method comprising the following;

an act of a message queuing node sending a message to one or more other message queuing nodes in a network, each node in the message queuing network including a corresponding persistent unique global identifier;

an act of maintaining a list of unique global identifiers of those network nodes from which the message queuing node has received a message or to which the message queuing node has sent the message;

an act of the message queuing node going offline for a period of time;

upon the message queuing node coming back online, an act of sending an announcement message to each node stored in the list, the announcement message indicating that the message queuing node is ready for communication in the message queuing network, each message including the node'"'"'s globally unique identifier and the node'"'"'s current network address;

an act of determining that a connection has been established between the message queuing node and at least one node from the list of nodes; and

based on the determination, an act of automatically resuming message transfer between the message queuing node and the at least one list node, and such that communication between the message queuing node and the at least one list node is reinitiated automatically as soon as both are simultaneously online.