Method, device, and system for message distribution

Abstract

The disclosure relates to a message distribution method, device, and system. A message distribution method includes: creating a session based on a received first type of session message and allocating a corresponding cluster node to the session; and upon receiving a second type of session message associated with the session, distributing the second type of session message to the cluster node corresponding to the session. With the technical solution according to the embodiments of the invention, both the first type of session message and the second type of session message may be processed on the same cluster node, smooth and dynamic capacity expansion may be achieved for the cluster, the system performance may be enhanced, and system maintenance may be facilitated.

1 . A method for message distribution, comprising:
 extracting, by a load balance (LB) device, a first ID from a received session control message;   creating a session by using the first ID as a key word, and holding the session;   allocating a cluster node corresponding to the session; distributing the session control message to a first means which is in the cluster node corresponding to the session and is used to store session control information for the session;   upon receiving a session traffic message associated with the session, extracting, by the LB device, a second ID from the session traffic message;   determining, according to the second ID, whether session traffic message is associated with the session created by using the first ID; and   distributing the session traffic message to a second means which is in the cluster node corresponding to the session and searches for the session control information of the session from the first means.   
     
     
         2 . The method according to  claim 1 , wherein determining, according to the second ID, whether session traffic message is associated with the session created by using the first ID comprising:
 determining whether the second ID is same as the key word for creating the session; and   if the second ID is same as the key word, the session traffic message being associated with the session.   
     
     
         3 . The method according to  claim 2 , wherein the first ID is the Internet Protocol (IP) address of a terminal transmitting or receiving the session control message and the second ID is the IP address of a terminal transmitting or receiving the session traffic message. 
     
     
         4 . The method according to  claim 1 , wherein the first ID is the number of a terminal transmitting or receiving the session control message, the method further comprising:
 extracting a third ID from the session control message, the third ID being the IP address of a terminal transmitting or receiving the session control message, and creating a correspondence relationship between the IP address and the terminal number;   upon receiving the session traffic message, extracting the second ID from the session traffic message, the second ID being the IP address of a terminal transmitting or receiving the session traffic message;   based on the correspondence relationship between the IP address and the terminal number, searching for a terminal number corresponding to the second ID;   determining whether the found terminal number is same as the key word for creating the session; and   if the found terminal number is same as the key word, the second type of session message being associated with the session.   
     
     
         5 . The method according to  claim 1 , further comprising:
 detecting whether the cluster node has a fault; and   if the cluster node has a fault, creating another session based on the second type of session message and allocating another corresponding non-fault cluster node to the session.   
     
     
         6 . The method according to  claim 1 , further comprising:
 transmitting the session control message or the session traffic message to a backup node so as to back up the session information in the session control message or the session traffic message.   
     
     
         7 . A load balance device including a processor, the processor, comprising:
 a preprocessing unit, configured to create a session based on a received session control message and allocate a corresponding cluster node to the session and distribute the session control message to a first means which is in the cluster node corresponding to the session and is used to store session control information for the session; and   a distribution unit, configured to: upon receiving a session traffic message associated with the session, distribute the session traffic message to a second means which is in the cluster node corresponding to the session and searches for the session control information of the session from the first means.   
     
     
         8 . The device according to  claim 7 , wherein the preprocessing unit comprises:
 a first extraction module, configured to extract a first ID from the session control message;   a creation module, configured to create the session by using the first ID as a key word, and hold the session; and   an allocation module, configured to allocate a corresponding cluster node to the session and distribute the session control message to the first means which is in the cluster node corresponding to the session and is used to store session control information for the session.   
     
     
         9 . The device according to  claim 8 , wherein the distribution unit comprises:
 a receiving module, configured to receive the session traffic message;   a second extraction module, configured to extract a second ID from the session traffic message;   a determination module, configured to determine whether the second ID is same as the key word for creating the session, the session traffic message being associated with the session if the second ID is same as the key word; and   a transmission module, configured to distribute the session traffic message associated with the session to the second means, which is in the cluster node corresponding to the session and searches for the session control information of the session from the first means, when the determination module determines that the session traffic message is associated with the session.   
     
     
         10 . The device according to  claim 9 , wherein the first ID is the IP address of a terminal transmitting or receiving the session control message and the second ID is the IP address of a terminal transmitting or receiving the session traffic message. 
     
     
         11 . The device according to  claim 10 , wherein the first ID is the number of a terminal transmitting or receiving the session control message, the preprocessing unit further comprising:
 a third extraction module, configured to extract a third ID from the session control message, the third ID being the IP address of a terminal transmitting or receiving the session control message; and   a relationship module, configured to create a correspondence relationship between the IP address of the terminal transmitting or receiving the first type of message and the terminal number;   the distribution unit comprising:   a receiving module, configured to receive the session traffic message;   a second extraction module, configured to extract the second ID from the session traffic message, the second ID being the IP address of a terminal transmitting or receiving the session traffic message;   a searching module, configured to: based on the correspondence relationship in the relationship module, search for a terminal number corresponding to the second ID;   a determination module, configured to determine whether the terminal number is same as the key word for creating the session, the session traffic message being associated with the session if the terminal number is same as the key word; and   a transmission module, configured to distribute the session traffic message associated with the session to the second means, which is in the cluster node corresponding to the session and searches for the session control information of the session from the first means, when the determination module determines that the session traffic message is associated with the session.   
     
     
         12 . The device according to  claim 9 , further comprising:
 a fault detection unit, configured to detect whether the cluster node has a fault, and if the cluster node has a fault, trigger the preprocessing unit to create another session based on the session traffic message and allocate another corresponding non-fault cluster node to the session.   
     
     
         13 . The device according to  claim 9 , further comprising:
 a backup unit, configured to transmit the session control message or the session traffic message to a backup node so as to back up the session information in the session control message or the session traffic message.   
     
     
         14 . A cluster node device, comprising a processor including a first means and a second means, wherein:
 the first means is configured to receive a control session message and store the control session information in the control session message; and   the second means is configured to receive a traffic session message, search for the control session information in the UIDB based on the traffic session message, and process the traffic session message based on the session control information.   
     
     
         15 . The device according to  claim 14 , where the second means comprises:
 a receiving unit, configured to receive a traffic session message;   a local searching unit, configured to transmit a search request for the control session information to the first means and receive control session information in a response from the UIDB;   an external searching unit, configured to: when the local searching unit fails to find the control session information, search for the control session information backed up on a backup node device outside the cluster node device; and   a processing unit, configured to process the traffic session message based on the found control session information.