CN114697265A - Message processing method and device - Google Patents

Abstract

The embodiment of the application discloses a message processing method and device. The method comprises the following steps: the method comprises the steps that a first server receives a first message from a terminal device, and the IP address of the terminal device is determined based on the first message; determining whether the first server processes the first message or not based on the IP address of the terminal equipment and first anchor point information, wherein the first anchor point information comprises a corresponding relation between the IP address of the terminal equipment and the IP address of a second server; and when the IP address of the first server is different from the IP address of the second server, forwarding the first message to the second server according to the IP address of the second server. By adopting the embodiment of the application, the message of the same terminal device is distributed to the DPI server for processing, so that the accuracy of message processing is improved.

Description

Message processing method and device

Technical Field

The present application relates to the field of network technologies, and in particular, to a method and an apparatus for processing a packet.

Background

A deep packet analysis (DPI) system is usually deployed at a network element side to collect an Internet Protocol (IP) message and generate a terminal internet protocol record (xDR) document, where the xDR document may be used to measure network quality and help a client optimize a network. For user plane DPI, a Long Term Evolution (LTE) network is usually deployed at a Serving Gateway (SGW) side to collect IP packets, and a fifth Generation mobile communication technology (5-Generation, 5G) is usually deployed at a User Plane Function (UPF) side to collect IP packets. For a large DPI system, because the number of collected IP packets is large, a server cluster, which may be composed of many servers, collects IP packets.

The DPI system is connected to the convergence switch after light splitting through a physical link, and the convergence switch converges and shunts the collected IP messages. When the DPI system includes a plurality of servers, the received IP packets need to be distributed to different DPI servers. However, due to the fact that the same terminal device moves between different network elements or uses an IPv4/IPv6 dual stack, etc., IP packets of the same service of one terminal device may be distributed to different DPI servers, which affects the accuracy of xDR documents generated based on the IP packets.

Disclosure of Invention

The embodiment of the application provides a message processing method and device. The message of the same terminal device is distributed to the same server for processing, so that the message forwarding number is reduced, the network flow is saved, and the accuracy of generating the xDR document is improved.

In a first aspect, an embodiment of the present application provides a message processing method, which may be applied to a first server or a component in the first server, for example, a chip, a processor, and the like, where the method includes: receiving a first message from the terminal equipment, and determining the IP address of the terminal equipment based on the first message; determining whether the first server processes the first message or not based on the IP address of the terminal equipment and first anchor point information, wherein the first anchor point information comprises the corresponding relation between the IP address of the terminal equipment and the IP address of the second server; and when the IP address of the first server is different from the IP address of the second server, the first server forwards the first message to the second server according to the IP address of the second server. Under the condition that the first server is a non-anchor point server, the first server forwards the first message of the terminal device to the anchor point server for processing through the first anchor point information, so that the message of the same terminal device is distributed to the same server for processing, the message forwarding number is reduced, the network flow is saved, and the accuracy of generating the xDR document is improved.

In one possible design, the first server processes the first message when the IP address of the first server is the same as the IP address of the second server. The message of the terminal equipment is guaranteed to be processed by the same server, so that the accuracy of generating the xDR document is improved.

In another possible design, the first server searches for the MAC address of the second server corresponding to the IP address of the second server from a preset correspondence between the IP address and the MAC address; and sending the first message to the second server according to the MAC address of the second server. The first message is forwarded to the second server for processing through the MAC address of the second server, so that the message of the terminal device is distributed to the same server for processing, and the accuracy of generating the xDR document is improved.

In one possible design, the method may also be applied to the second server, or a component in the second server, such as a chip, a processor, or the like, and the method includes: receiving a second message from the terminal equipment, and determining the IP address of the terminal equipment based on the second message; and sending the IP address of the terminal equipment and the IP address of the second server to the control server, wherein the IP address of the terminal equipment and the IP address of the second server are used for generating the first anchor point information. Under the condition that the second server is the anchor point server, the control server generates first anchor point information by collecting the IP address of the second server and the IP address of the terminal equipment, so that the messages of the same terminal equipment are distributed to the same server for processing through the first anchor point information, the number of message forwarding is reduced, the network flow is saved, and the accuracy of generating the xDR document is improved.

In another possible design, the second server may be the same server as the first server, or may be a different server.

In another possible design, the first anchor point information includes second anchor point information, and the second server determines whether the IP address of the terminal device is found from the second anchor point information; and when the IP address of the terminal equipment is not found from the second anchor point information, the IP address of the terminal equipment and the IP address of the second server are sent to the control server. By determining whether the IP address of the terminal equipment is found from the second anchor point information, the uniqueness of the anchor point server corresponding to the terminal equipment is guaranteed, and therefore the accuracy of message forwarding is improved.

In another possible design, the IP address of the terminal device is a first IP address or a second IP address, the second server sends control plane information to the control server, the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a corresponding relationship between the first IP address, the second IP address, and the IP address of the second server. Under the condition of double stacks, the corresponding relation between the double IP addresses of the terminal equipment and the second server is established, so that the IP address of the terminal equipment can be searched from the first anchor point information no matter which IP address is used by the terminal equipment to send the message, and the accuracy of message forwarding is guaranteed.

In another possible design, the second server receives the first anchor point information from the control server. The second server can process all messages sent by the terminal equipment according to the first anchor point information by receiving the first anchor point information, so that the messages of the terminal equipment are distributed to the same server for processing, and the accuracy of generating the xDR document is improved.

In a second aspect, an embodiment of the present application provides a message processing method, which may be applied to a control server or a component in the control server, for example, a chip, a processor, and the like, where the method includes: generating first anchor point information, wherein the first anchor point information comprises the corresponding relation between the IP address of the terminal equipment and the IP address of a second server, and the second server is used for processing the message of the terminal equipment; the first anchor point information is then broadcast. The control server broadcasts the first anchor point information, so that all servers in the server cluster can distribute the message of the terminal equipment to the same server for processing according to the first anchor point information, the message forwarding number is reduced, the network flow is saved, and the accuracy of generating the xDR document is improved.

In one possible design, the control server receives an IP address of the terminal device from the second server and an IP address of the second server; and generating first anchor point information according to the corresponding relation between the IP address of the terminal equipment and the IP address of the second server, and distributing the IP message of the terminal equipment to the second server for processing by generating the first anchor point information, so that the accuracy of generating the xDR document is improved.

In another possible design, the first anchor point information includes second anchor point information, and the control server determines whether the IP address of the terminal device is found from the second anchor point information; and when the IP address of the terminal equipment is not found from the second anchor point information, adding the corresponding relation between the IP address of the terminal equipment and the IP address of the second server into the second anchor point information to obtain the first anchor point information. By determining whether the IP address of the terminal equipment is found from the second anchor point information, the uniqueness of the anchor point server corresponding to the terminal equipment is guaranteed, and therefore the accuracy of message forwarding is improved.

In another possible embodiment, the IP address of the terminal is the first IP address or the second IP address. The control server receives control plane information from the second server, the control plane information comprises a first IP address and a second IP address of the terminal equipment, and the first anchor point information comprises a corresponding relation between the first IP address, the second IP address and the IP address of the second server. Under the condition of double stacks, the corresponding relation between the double IP addresses of the terminal equipment and the second server is established, so that the IP address of the terminal equipment can be searched from the first anchor point information no matter which IP address is used by the terminal equipment to send the message, and the accuracy of message forwarding is guaranteed.

In another possible design, the control server may record anchor point time corresponding to the IP address of the terminal device and the IP address of the second server, where the anchor point time may be a first time point when the IP address of the terminal device and the IP address of the second server are received, may also record a second time point when the correspondence between the IP address of the terminal device and the IP address of the second server in the second anchor point information, and may also be other time points. And by recording the anchor point time, the timeliness of the anchor point information is guaranteed.

In another possible design, after the control server receives the IP address of the second server and the IP address of the terminal device, the corresponding relationship between the IP address of the terminal device and the IP address of the second server in the first anchor point information may be updated. For example, the anchor point time corresponding to the IP address of the terminal device and the IP address of the second server may be modified. And the validity of the first anchor point information is ensured by updating the corresponding relation between the IP address of the terminal equipment and the IP address of the second server.

In another possible design, when a time interval from the anchor point time to the current time point exceeds a preset threshold, that is, when the time length of the correspondence between the IP address of the terminal device and the IP address of the second server is not updated exceeds the preset threshold, it is indicated that the second server does not process the IP packet sent by the terminal device in the time interval, and the control server may delete the correspondence between the IP address of the terminal device and the IP address of the second server in the first anchor point information. By deleting the anchor point information of the terminal equipment which does not upload the message within a certain time, the timeliness of the first anchor point information is guaranteed, the information redundancy is reduced, and the message processing efficiency is improved.

In another possible design, in the process of processing the IP packet of the terminal device by the DPI system, the control server may monitor the session state of the terminal device, and when it is detected that the session state of the terminal device is a disconnected state, the control server deletes the correspondence between the IP address of the terminal device and the IP address of the second server in the first anchor point information. When the session of the terminal equipment is disconnected, the corresponding relation between the IP address of the terminal equipment and the IP address of the second server is deleted, so that redundant information in the first anchor point information is reduced, and the message processing efficiency is improved.

In another possible embodiment, the control server receives the IP address of the terminal device from the first server and the IP address of the first server; and when the IP address of the terminal equipment is found from the first anchor point information, discarding the received IP address of the terminal equipment and the IP address of the first server. The uniqueness of the anchor point server corresponding to the terminal equipment in the first anchor point information is guaranteed, and therefore the accuracy of message forwarding is improved.

In a third aspect, an embodiment of the present application provides a message processing apparatus, where the message processing apparatus is configured to implement the method and the function performed by the first server or the second server in the first aspect, and the message processing apparatus is implemented by hardware/software, where the hardware/software includes a module corresponding to the function.

In a fourth aspect, an embodiment of the present application provides a message processing apparatus, where the message processing apparatus is configured to implement the method and the function performed by the control server in the second aspect, and the method and the function are implemented by hardware/software, and the hardware/software includes modules corresponding to the functions.

In a fifth aspect, the present application provides a message processing apparatus, where the message processing apparatus may be a first server or a second server, or an apparatus in the first server or the second server, or an apparatus capable of being used in cooperation with the first server or the second server. The message processing device can also be a chip system. The message processing apparatus may perform the method of the first aspect. The functions of the message processing device can be realized by hardware, and can also be realized by executing corresponding software by hardware. The hardware or software includes one or more modules corresponding to the functions described above. The module may be software and/or hardware. The operations and advantageous effects executed by the message processing apparatus may refer to the method and advantageous effects described in the first aspect, and repeated details are not repeated.

In a sixth aspect, the present application provides a message processing apparatus, which may be a control server, an apparatus in the control server, or an apparatus capable of being used in cooperation with the control server. The message processing device can also be a chip system. The message processing apparatus may perform the method of the second aspect. The functions of the message processing device can be realized by hardware, and can also be realized by executing corresponding software by hardware. The hardware or software includes one or more modules corresponding to the functions described above. The module may be software and/or hardware. The operations and advantageous effects executed by the message processing apparatus may refer to the method and advantageous effects described in the second aspect, and repeated details are not repeated.

In a seventh aspect, the present application provides a message processing apparatus comprising a processor, wherein the method according to any one of the first and second aspects is performed when the processor calls a computer program in a memory.

In an eighth aspect, the present application provides a message processing apparatus, including a processor and a memory, where the memory is used to store computer execution instructions; the processor is configured to execute computer-executable instructions stored by the memory to cause the message processing apparatus to perform the method of any one of the first and second aspects.

In a ninth aspect, the present application provides a message processing apparatus, where the message processing apparatus includes a processor, a memory, and a transceiver, where the transceiver is configured to receive first anchor point information or first anchor point information; the memory for storing program code; the processor is configured to call the program code from the memory to perform the method according to any one of the first and second aspects.

In a tenth aspect, the present application provides a message processing apparatus, where the message processing apparatus includes a processor and an interface circuit, and the interface circuit is configured to receive a code instruction and transmit the code instruction to the processor; the processor executes the code instructions to perform a method as described in any one of the first and second aspects.

In an eleventh aspect, the present application provides a computer-readable storage medium for storing instructions that, when executed, cause a method as in any one of the first and second aspects to be implemented.

In a twelfth aspect, the present application provides a computer program product comprising instructions that, when executed, cause a method as in any one of the first and second aspects to be implemented.

In a thirteenth aspect, an embodiment of the present application provides a communication system, where the communication system includes at least one DPI server and at least one control server, the DPI server is configured to perform the steps in the first aspect, and the control server is configured to perform the steps in the second aspect.

Drawings

In order to more clearly illustrate the technical solutions in the embodiments or the background art of the present application, the drawings required to be used in the embodiments or the background art of the present application will be described below.

FIG. 1 is a schematic diagram of a message collection system;

figure 2 is a schematic diagram of a DPI system;

FIG. 3 is a schematic diagram of an IPv4/IPv6 dual stack;

fig. 4 is a schematic structural diagram of a message processing system according to an embodiment of the present application;

fig. 5 is a schematic flowchart of a message processing method according to an embodiment of the present application;

FIG. 6 is a schematic diagram of a GTP tunnel description;

fig. 7 is a schematic flowchart of a message processing method according to an embodiment of the present application;

fig. 8 is a schematic structural diagram of a message processing apparatus according to an embodiment of the present application;

fig. 9 is a schematic structural diagram of another message processing apparatus according to an embodiment of the present application;

fig. 10 is a schematic structural diagram of another message processing apparatus according to an embodiment of the present application;

fig. 11 is a schematic structural diagram of a first server according to an embodiment of the present disclosure;

fig. 12 is a schematic structural diagram of a second server according to an embodiment of the present application;

fig. 13 is a schematic structural diagram of a control server according to an embodiment of the present application.

Detailed Description

The embodiments of the present application will be described below with reference to the drawings.

As shown in fig. 1, fig. 1 is a schematic diagram of a message collection system. The system may include abase station 101, aDPI system 102, and agateway 103. Where thegateway 103 may be a Serving Gateway (SGW) or a UPF entity, theDPI system 102 is disposed between thebase station 101 and thegateway 103. The system can be applied to the collection of IP messages of 4G networks and can also be applied to the collection of IP messages of 5G networks. When the system is applied to the collection of IP packets of a 4G network, thebase station 101 in fig. 1 may be an evolved network base station (E-UTRAN NodeB, eNodeB), and thegateway 103 may be an SGW. When the system is applied to the collection of IP packets of a 5G network, thebase station 101 in fig. 1 may be a 5G base station (NR NodeB, gdnodeb), and thegateway 103 may be a UPF entity. The scheme is not only suitable for the S1-U interface of the 4G network, but also suitable for the S5/S8 interface of the 4G network and the N3 or N9 interface of the 5G network. The DPI system can collect the IP messages collected by the SGW or UPF entity to generate the xDR document.

Figure 2 is a schematic diagram of a DPI system, as shown in figure 2. The DPI system may include an aggregation switch and a plurality of DPI servers. The DPI system is connected to the convergence switch after light splitting through a physical link, and then the convergence switch converges and shunts the received IP message. When the DPI system includes a plurality of DPI servers, the accessed IP packets need to be distributed to different DPI servers, and each DPI server generates an xDR document based on the received IP packets. The DPI server sends the xDR document to a service analysis system, and the service analysis system generates Key Quality Indicators (KQI) of the network based on the xDR document so as to monitor the network quality.

An xDR document of the DPI system is defined based on the terminal device, that is, an xDR document is generated by a complete behavior of a terminal device, and an IP packet may be switched to different network elements during a moving process of the terminal device. Since the aggregation switch only has the network element-based distribution capability, but not the terminal device-based distribution capability, one terminal device cannot be distributed to the same DPI server.

As shown in FIG. 3, many end devices already support IPv4/IPv6 dual stacks. When the same terminal device performs data service, the IP addresses IPv4 and IPv6 are used simultaneously. The IPv4/IPv6 dual stack refers to a node which uses both IPv4 and IPv6 protocol stacks, and in this scenario, the node refers to a terminal device or an application server. Compared with IPv4, IPv6 has the advantage that protocols such as a Transmission Control Protocol (TCP), a User Datagram Protocol (UDP), and a Stream Control Transmission Protocol (SCTP) in a transport layer are completely consistent, and a dual-stack node can communicate with a node supporting an IPv4 protocol and a node supporting an IPv6 protocol.

Therefore, in a mobile scenario of the terminal device or a scenario of using a dual stack, in order to ensure accuracy of the xDR document, it is necessary to ensure that an IP packet of one terminal device is completely distributed to the same DPI server in the server cluster. The current DPI system generally performs distribution based on a network element through a convergence switch, and the convergence switch only has the capability of performing convergence and distribution based on an outer IP address, and cannot perform convergence and distribution based on an IP address of a terminal device in a tunnel. Due to the fact that the same terminal device moves among different network elements or the IPv4/IPv6 dual stack is used, and the like, IP messages of the same service of one terminal device can be distributed to different DPI servers, and accuracy of an xDR document generated based on the IP messages is affected.

As shown in fig. 4, fig. 4 is a schematic structural diagram of a message processing system according to an embodiment of the present application. The message processing system comprises a convergence switch, a server cluster, a control server and a forwarding switch. The aggregation switch can receive messages on a plurality of links and distribute the messages to DPI servers in the server cluster. The server cluster comprises a plurality of DPI servers (DPI server 1, DPI server 2, … …, DPI server N). Each DPI server may include a status monitoring module, an identification resolution module, and a distribution execution module. The state monitoring module is used for acquiring the IP address of the terminal equipment and the IP address of the DPI server and reporting the IP address of the terminal equipment and the IP address of the DPI server to the control server. The distribution execution module may be configured to receive an IP packet sent by the aggregation switch, or receive anchor point information sent by the control server, and execute forwarding or processing the IP packet according to the anchor point information. The identification analysis module can be used for identifying and analyzing the protocol according to the received IP message.

The control server may also be referred to as a policy control server, and the control server may include a policy control module, where the policy control module is configured to receive an IP address of the terminal device and an IP address of the DPI server reported by the DPI server, store the IP address of the DPI server that receives a packet of the terminal device for the first time, establish a correspondence between the address of the DPI server and the IP address of the terminal device, generate anchor point information, and broadcast the anchor point information to the server cluster, so that each DPI server in the server cluster forwards an IP packet or processes an IP packet according to the anchor point information. The forwarding switch is a logical concept, and the physical entity may be a separate switch or a multiplexing aggregation switch, and is used to perform packet-two packet forwarding of packets between DPI servers in a server cluster.

Optionally, the message processing system may further include a terminal device, which may be a User Equipment (UE), a cellular phone, a smart phone, a portable computer, a handheld communication device, a handheld computing device, a satellite radio, a global positioning system, a Personal Digital Assistant (PDA), and/or any other suitable device for communication, and so forth. The terminal device sends IP packets to the DPI server through a plurality of links (e.g.,link 1, link 2, link 3, and link 4 in fig. 4) via the aggregation switch.

The functions of each functional entity or functional module are described in detail below by embodiments, and are not described herein again.

As shown in fig. 5, fig. 5 is a schematic flow chart of a message processing method provided in the embodiment of the present application, where the steps in the embodiment of the present application at least include:

s501, the control server generates first anchor point information.

The first anchor point information may include a correspondence between an IP address of the terminal device and an IP address of the second server. The second server may be a server that receives the IP packet sent by the terminal device for the first time, that is, an anchor point server. The message sent by the terminal device for the first time may be a first message for the same service, a first message for multiple services, a first message in one or multiple sending periods, a first message in a preset time period, and so on. The first anchor information may be an anchor information table or an anchor information mapping function, etc.

Optionally, the first anchor point information includes second anchor point information, that is, the second anchor point information includes part or all of the information in the first anchor point information. The control server may pre-store the second anchor point information, after the control server receives the IP address of the terminal device and the IP address of the second server from the second server, if the IP address of the terminal device is not found from the second anchor point information, it indicates that the IP packet of the terminal device is collected by the second server for the first time, and no other server in the server cluster collects the IP packet of the terminal device, so that the second server is the anchor point server corresponding to the terminal device, and the control server generates the first anchor point information according to a correspondence between the IP address of the terminal device and the IP address of the second server. For example, the control server may add a correspondence relationship between the IP address of the terminal device and the IP address of the second server to the second anchor information to obtain the first anchor information.

Optionally, the control server may record anchor point time corresponding to the received IP address of the terminal device and the IP address of the second server. The anchor point time may be a first time point at which the IP address of the terminal device and the IP address of the second server are received, a second time point at which the correspondence between the IP address of the terminal device and the IP address of the second server in the second anchor point information is recorded, or other time points.

It should be noted that the control server may also add the correspondence between the IP addresses of the other terminal devices and the IP addresses of the other servers to the second anchor information by using the same method. With the increase of the number of the terminal devices which need to upload the message, the IP addresses of more terminal devices and the IP addresses of the corresponding anchor point servers can be recorded, so as to generate the first anchor point information.

S502, the control server broadcasts the first anchor point information.

Optionally, the control server may broadcast the first anchor point information to all servers in the DPI system, and the first anchor point information is saved after the first anchor point information is received by the first server and the second server in the DPI system.

S503, the first server receives a first message from the terminal device, and determines the IP address of the terminal device based on the first message.

The first packet may be an IP packet, and the IP packet may be a data plane packet.

Optionally, the first server may receive the first message from the terminal device through the aggregation switch. The aggregation switch is responsible for accessing an IP message of an S1-U or N3 interface, and configures a distribution rule based on a network element IP address pair. The S1-U interface is an interface between a 4G network base station (eNodeB) and an SGW, and the N3 interface is an interface between a 5G network base station (gNodeB) and a UPF entity. Firstly, a terminal device sends a first message to a convergence switch, and after the convergence switch receives the first message sent by the terminal device, the convergence switch distributes the received first message to a first server of a server cluster based on a configured distribution rule of a network element IP address pair.

Optionally, after receiving the first message, the first server may determine the IP address of the terminal device according to the first message. The first message includes network element information at two ends of a GPRS Tunneling Protocol (GTP) tunnel. For example, as shown in fig. 6, fig. 6 is a schematic diagram of a GTP tunnel description. The IP address of the tunnel outer layer is the IP address of the network element, and the IP address of the tunnel inner layer is the IP address of the terminal device or the IP address of the server. The first server may determine the IP address of the terminal device according to the sending direction of the first packet. For example, if the first packet is sent from the eNodeB to the SGW or from the gsnodeb to the UPF entity, the source IP address of the GTP tunnel inner layer is the IP address of the terminal device. If the first message is sent to the eNodeB by the SGW or sent to the gsnodeb by the UPF entity, the destination IP address of the inner layer of the GTP tunnel is the IP address of the terminal device.

S504, the first server determines whether the first server processes the first message or not based on the IP address of the terminal device and the first anchor point information. The first anchor point information comprises the corresponding relation between the IP address of the terminal device and the IP address of the second server.

Optionally, the first server may search the IP address of the terminal device from the first anchor point information, and when the IP address of the terminal device is found from the first anchor point information, it is indicated that an IP packet sent by the terminal device for the first time is already acquired, it is determined whether an IP address of the second server corresponding to the IP address of the terminal device is the same as the IP address of the first server, and if the IP address of the second server is the same as the IP address of the first server, that is, the first server and the second server are the same server, it is determined that the first server processes the first packet. And if the IP address of the second server is not the same as the IP address of the first server, determining that the second server processes the first message.

And S505, when the IP address of the first server is different from the IP address of the second server, the first server forwards the first message to the second server according to the IP address of the second server.

Optionally, when the IP address of the first server is different from the IP address of the second server, it indicates that the first server and the second server are not the same server, and because the second server is an anchor point server corresponding to the terminal device, the first server needs to forward the first packet to the second server. Specifically, the first server may search for the MAC address of the second server corresponding to the IP address of the second server from a preset correspondence between IP addresses and MAC addresses; modifying the destination address of the second IP message into the MAC address of the second server; and sending the first IP message to the second server according to the MAC address of the second server.

Optionally, the first packet forwarded by the first server to the second server may carry indication information, where the indication information is used to indicate that the first packet is processed by the second server. And after the second server receives the first message, determining that the first message is processed by the second server according to the indication information.

Optionally, after receiving the first packet forwarded by the first server, the second server first determines the IP address of the terminal device based on the first packet. And then determining whether the second server processes the first message or not according to the IP address of the terminal equipment and the pre-stored first anchor point information, and when the corresponding relation between the IP of the terminal equipment and the IP address of the second server is found from the first anchor point information, determining that the first message is processed by the second server.

Optionally, the first server may send the IP address of the terminal device and the IP address of the first server to the control server. After receiving the IP address of the terminal device and the IP address of the first server, the control server may find the IP address of the terminal device from the first anchor point information, and the IP address of the terminal device corresponds to the second server, which indicates that the second server is the anchor point server corresponding to the terminal device. In the case where the first server and the second server are not the same server, the control server may discard the received IP address of the terminal device and the IP address of the first server.

After receiving the first message forwarded by the first server, the second server analyzes the first message, generates an xDR document based on the first message and other IP messages sent by the terminal device, then sends the xDR document to the business analysis system, and after receiving the xDR document, the business analysis system generates a key quality index KQI of the network based on the xDR document so as to monitor the network quality.

S506, when the IP address of the first server is the same as the IP address of the second server, the first server processes the first message.

Optionally, when the IP address of the first server is the same as the IP address of the second server, it indicates that the first server and the second server are the same server, and the first server is also an anchor point server corresponding to the terminal device, and the first packet sent by the terminal device may be processed by the first server. The first server can analyze the first message, generate an xDR document based on the first message sent by the terminal device and other IP messages, and then send the xDR document to the service analysis system, and after receiving the xDR document, the service analysis system generates a key quality index KQI of the network based on the xDR document so as to monitor the network quality.

Optionally, after determining that the first packet is processed by the first server, the first server may send the IP address of the first server and the IP address of the terminal device to the control server. After the control server receives the IP address of the first server and the IP address of the terminal device, the IP address of the terminal device may be found from the first anchor point information, and the IP address of the terminal device corresponds to the second server, which indicates that the second server is the anchor point server corresponding to the terminal device. In the case where the first server and the second server are the same server, the correspondence between the IP address of the terminal device and the IP address of the second server in the first anchor point information may be updated. For example, the anchor point time corresponding to the IP address of the terminal device and the IP address of the second server may be modified.

Further, the control server may determine whether a time interval from the anchor point time to the current time point exceeds a preset threshold, and when the time interval from the anchor point time to the current time point exceeds the preset threshold, that is, when the time duration during which the correspondence between the IP address of the terminal device and the IP address of the second server is not updated exceeds the preset threshold, it is indicated that the second server does not process the IP packet sent by the terminal device in the time interval, and the control server may delete the correspondence between the IP address of the terminal device and the IP address of the second server in the first anchor point information.

Optionally, after the control server updates the corresponding relationship between the IP address of the terminal device in the first anchor point information and the IP address of the second server, the control server may broadcast the updated corresponding relationship between the IP address of the terminal device and the IP address of the second server to the first server or the second server, so that the first server or the second server updates the corresponding relationship between the IP address of the terminal device in the first anchor point information and the IP address of the second server stored by the first server or the second server. Or, the control server may also broadcast the updated first anchor point information to the first server or the second server, so that the first server or the second server updates all information in the first anchor point information.

Optionally, in the process that the DPI system processes the IP packet of the terminal device, the control server may monitor the session state of the terminal device, and when the control server detects that the session state of the terminal device is a disconnected state, the control server may delete the correspondence between the IP address of the terminal device and the IP address of the first server in the first anchor point information. When detecting that the session state of the terminal device is the connection state, the corresponding relationship between the IP address of the terminal device and the IP address of the first server in the first anchor point information may be maintained.

In the embodiment of the application, the first server determines whether the first message is processed by the first server or forwarded to the second server through the first anchor point information, so that the message of the terminal device is distributed to the same server for processing, the message forwarding number is reduced, the network flow is saved, and the accuracy of generating the xDR document is improved.

The above embodiments mainly describe how the first server and the second server forward or process the packet according to the first anchor point information, and the following mainly describes how the control server generates the first anchor point information. The first anchor point information generated by the following embodiments may be applied to the embodiment shown in fig. 5.

As shown in fig. 7, fig. 7 is a schematic flow chart of a message processing method provided in the embodiment of the present application, where the steps in the embodiment of the present application at least include:

s701, a second server receives a second message from a terminal device, and determines the IP address of the terminal device based on the second message.

The second packet may be an IP packet, and the IP packet may be a data plane packet.

The specific implementation manner of the second server receiving the second packet from the terminal device in this step is similar to the method in which the first server receives the first packet from the terminal device in the previous embodiment, and the specific implementation manner of the second server determining the IP address of the terminal device based on the second packet in this step is also similar to the method in which the first server determines the IP address of the terminal device based on the first packet in the previous embodiment, which is specifically referred to step S503 and is not described herein again.

S702, the second server sends the IP address of the terminal device and the IP address of the second server to the control server.

Optionally, the control server stores the second anchor point information in advance, and the second anchor point information may be broadcast by the control server to the second server in advance. The second anchor point information may be an empty set, or may include partial information of the first anchor point information. The second server may determine whether the IP address of the terminal device is found from the second anchor point information after determining the IP address of the terminal device, and when the IP address of the terminal device is not found from the second anchor point information, the second server acquires the IP packet of the terminal device for the first time, and no other server in the server cluster acquires the IP packet of the terminal device. The second packet may be a first packet sent by the terminal device for the same service, or a first packet sent by the terminal device for multiple services, or a first packet sent by the terminal device in one or multiple sending cycles, or a first packet sent by the terminal device in a preset time period, or the like. And the second server receiving the second message is the anchor point server corresponding to the terminal equipment. The second server can send the IP address of the terminal device and the IP address of the second server to the control server through the judgment.

S703, the control server generates first anchor point information.

Optionally, after the control server receives the IP address of the terminal device from the second server and the IP address of the second server; and generating first anchor point information according to the IP address of the terminal equipment and the IP address of the second server.

Further, the control server stores second anchor point information in advance, after receiving the IP address of the terminal device and the IP address of the second server from the second server, the control server determines whether the IP address of the terminal device is found from the second anchor point information, and if the IP address of the terminal device is not found from the second anchor point information, the control server may add the correspondence between the IP address of the terminal device and the IP address of the second server to the second anchor point information to obtain the first anchor point information.

Optionally, the control server may record anchor point time corresponding to the IP address of the terminal device and the IP address of the second server, where the anchor point time may be a first time point when the IP address of the terminal device and the IP address of the second server are received, may also record a second time point in the second anchor point information where the correspondence between the IP address of the terminal device and the IP address of the second server is recorded, and may also be other time points.

It should be noted that the control server may also add the correspondence between the IP addresses of the other terminal devices and the IP addresses of the other servers to the second anchor information by using the same method. With the increase of the number of the terminal devices which need to upload the message, the IP addresses of more terminal devices and the IP addresses of the anchor point servers corresponding to the terminal devices can be recorded, so that the first anchor point information is obtained.

The first anchor point information may include a correspondence between an IP address of the terminal device, an IP address of the second server, and a time point. For example, the first anchor information may be an anchor information table or an anchor information mapping function. As shown in table 1, the anchor information table may include a correspondence of the IP1 address of theDPI server 1, the IP2 address of theterminal apparatus 1, andtime 1, and a correspondence of the IP3 address of the DPI server 2, the IP4 address of the terminal apparatus 2, and time 2.

IP address of DPI server	IP address of terminal equipment	Whether or not it has been reported	Anchor point time
				IP1	IP2	Is that	Time 1
IP3	IP4	Is that	Time 2

TABLE 1

Optionally, in a user dual-stack internet scenario, one terminal device includes two IP addresses (e.g., IPv4 and IPv 6). The IP address of the terminal device is a first IP address or a second IP address, the control server may receive control plane information from the second server, where the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a correspondence between the first IP address, the second IP address, and the IP address of the second server. Therefore, no matter the terminal equipment uses the first IP address or the second IP address to send the message, the IP address of the terminal equipment can be searched from the first anchor point information.

For example, as shown in table 2, the first anchor information may include correspondence between the IP1 address of theDPI server 1, the IP2 address of theterminal device 1, the IP5 address of theterminal device 1, andtime 1, and correspondence between the IP3 address of the DPI server 2, the IP4 address of the terminal device 2, and the IP6 address of the terminal device 2, and time 2.

TABLE 2

Optionally, in a process that the DPI system processes an IP packet of the terminal device, the control server may monitor a session state of the terminal device, and when it is detected that the session state of the terminal device is a disconnected state, the control server deletes a correspondence between the IP address of the terminal device and the IP address of the second server in the first anchor point information. And when the session state of the terminal equipment is detected to be a connection state, maintaining the corresponding relation between the IP address of the terminal equipment and the IP address of the second server in the first anchor point information.

S704, the control server broadcasts the first anchor point information.

Optionally, the control server may broadcast the first anchor point information to all servers in the DPI system, and the first anchor point information is saved after the first anchor point information is received by the first server and the second server in the DPI system.

S705, the second server processes the second message according to the first anchor point information.

Specifically, after receiving the first anchor point information broadcast by the control server, the second server may determine whether the second packet is processed by the second server according to the first anchor point information and the IP address of the terminal device corresponding to the second packet. Since the first anchor point information already has the corresponding relationship between the IP address of the terminal device and the IP address of the second server, it can be determined that the second packet is processed by the second server. And through the first anchor point information, it can be determined that all IP packets (including the first packet in the above embodiment) sent by the terminal device later can be processed by the second server.

The method for processing the second packet by the second server is the same as the method for processing the first packet in the previous embodiment, and is not described herein again.

In the embodiment of the application, the control server generates the first anchor point information by collecting the IP address of the second server and the IP address of the terminal device, so that all servers in the server cluster can forward the IP message of the terminal device to the same server for processing according to the first anchor point information, the message forwarding number is reduced, the network flow is saved, and the accuracy of generating the xDR document is improved.

The various embodiments described herein may be implemented as stand-alone solutions or combined in accordance with inherent logic and are intended to fall within the scope of the present application.

It is to be understood that, in the above embodiments of the method, the method and the operation implemented by the first server may also be implemented by a component (e.g., a chip or a circuit) applicable to the first server, and the method and the operation implemented by the second server may also be implemented by a component (e.g., a chip or a circuit) applicable to the second server. The methods and operations implemented by the control server may also be implemented by components (e.g., chips or circuits) that may be used to control the server.

The above description mainly introduces the scheme provided by the embodiments of the present application from various interaction perspectives. It will be appreciated that each network element, such as the DPI server or the control server, for example, includes corresponding hardware structures and/or software modules for performing each function in order to implement the above functions. Those of skill in the art would appreciate that the various illustrative components and algorithm steps described in connection with the embodiments disclosed herein may be implemented as hardware or combinations of hardware and computer software. Whether a function is performed as hardware or computer software drives hardware depends upon the particular application and design constraints imposed on the solution. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present application.

In the embodiment of the present application, the DPI server or the control server may be divided into the functional modules according to the above method example, for example, each functional module may be divided corresponding to each function, or two or more functions may be integrated into one processing module. The integrated module can be realized in a form of hardware or a form of a software functional module. It should be noted that, in the embodiment of the present application, the division of the module is schematic, and is only one logic function division, and another division manner may be available in actual implementation. The following description will be given by taking an example in which each function module is divided for each function.

The method provided by the embodiment of the present application is described in detail above with reference to fig. 5 and 7. Hereinafter, a message processing method and apparatus provided in the embodiments of the present application are described in detail with reference to fig. 8 to 10. It should be understood that the description of the apparatus embodiments corresponds to the description of the method embodiments, and therefore, for brevity, details are not repeated here, since the details that are not described in detail may be referred to the above method embodiments.

Referring to fig. 8, fig. 8 is a schematic structural diagram of a message processing apparatus according to an embodiment of the present disclosure. The message processing apparatus may include afirst receiving module 801 and afirst sending module 803. Optionally, afirst processing module 802 may also be included. Thefirst receiving module 801 and thefirst sending module 803 may communicate with the outside, and thefirst processing module 802 is configured to perform processing, such as processing an IP packet. Thefirst receiving module 801 and thefirst transmitting module 803 may also be referred to as a communication interface, a transceiving unit, or a transceiving module. Thefirst receiving module 801 and thefirst sending module 803 may be used to perform the actions performed by the first server in the above method embodiments.

For example: thefirst receiving module 801 and thefirst sending module 803 may also be referred to as a transceiver module or a transceiver unit (including a receiving unit and/or a sending unit), which are respectively configured to perform the steps of sending and receiving by the first server in the above method embodiments.

In one possible design, the message processing apparatus may implement the steps or processes corresponding to the first server in the above method embodiment, for example, the first server, or a chip or circuit configured in the first server. Thefirst receiving module 801 and thefirst sending module 803 are configured to perform transceiving related operations on the first server side in the foregoing method embodiment, and thefirst processing module 802 is configured to perform processing related operations on the first server in the foregoing method embodiment.

In an alternative design:

afirst receiving module 801, configured to receive a first packet from a terminal device, and determine an IP address of the terminal device based on the first packet;

afirst processing module 802, configured to determine whether the first server processes the first packet based on the IP address of the terminal device and first anchor point information, where the first anchor point information includes a correspondence between the IP address of the terminal device and an IP address of a second server;

afirst sending module 803, configured to forward the first packet to the second server according to the IP address of the second server when the IP address of the first server is different from the IP address of the second server.

Optionally, thefirst processing module 802 is further configured to process the first packet when the IP address of the first server is the same as the IP address of the second server.

Optionally, thefirst processing module 802 is further configured to search, from a preset correspondence between an IP address and an MAC address, the MAC address of the second server corresponding to the IP address of the second server; thefirst sending module 803 is further configured to send the first packet to the second server according to the MAC address of the second server.

It should be noted that, the implementation of each module may also correspond to the corresponding description of the method embodiments shown in fig. 5 and fig. 7, and execute the method and the function executed by the first server in the foregoing embodiments.

Referring to fig. 9, fig. 9 is a schematic structural diagram of a message processing apparatus according to an embodiment of the present disclosure. The message processing apparatus may include asecond receiving module 901 and asecond sending module 903, and optionally, may further include asecond processing module 902. Thesecond receiving module 901 and thesecond sending module 903 may communicate with the outside, and thesecond processing module 902 is configured to perform processing, such as processing an IP packet. Thesecond receiving module 901 and thesecond sending module 903 may also be referred to as a communication interface, a transceiving unit, or a transceiving module. Thesecond receiving module 901 and thesecond sending module 903 may be configured to perform the actions performed by the second server in the foregoing method embodiments.

For example: thesecond receiving module 901 and thesecond sending module 903 may also be referred to as a transceiver module or a transceiver unit (including a receiving unit and/or a sending unit), which are respectively configured to perform the steps of sending and receiving by the second server in the above method embodiments.

In one possible design, the message processing apparatus may implement the steps or processes corresponding to the second server in the above method embodiment, for example, the second server, or a chip or circuit configured in the second server. Thesecond receiving module 901 and thesecond sending module 903 are configured to perform transceiving related operations on the second server side in the foregoing method embodiment, and thesecond processing module 902 is configured to perform processing related operations on the second server in the foregoing method embodiment.

In one possible design:

asecond receiving module 901, configured to receive a second message from the terminal device;

asecond processing module 902, configured to determine an IP address of the terminal device based on the second packet;

asecond sending module 903, configured to send the IP address of the terminal device and the IP address of the second server to a control server, where the IP address of the terminal device and the IP address of the second server are used to generate the first anchor point information.

Optionally, the first anchor point information includes second anchor point information, and thesecond processing module 902 is further configured to determine whether the IP address of the terminal device is found from the second anchor point information; thesecond sending module 903 is further configured to send the IP address of the terminal device and the IP address of the second server to the control server when the IP address of the terminal device is not found in the second anchor point information.

Optionally, the IP address of the terminal device is a first IP address or a second IP address, and thesecond sending module 903 is further configured to send control plane information to the control server, where the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a correspondence between the first IP address, the second IP address, and the IP address of the second server.

Optionally, thesecond receiving module 901 is further configured to receive the first anchor point information from the control server.

It should be noted that the implementation of each module may also correspond to the corresponding description of the method embodiments shown in fig. 5 and fig. 7, and execute the method and the function executed by the second server in the foregoing embodiments.

Referring to fig. 10, fig. 10 is a schematic structural diagram of another message processing apparatus according to an embodiment of the present application. The message processing apparatus may include areceiving module 1001 and asending module 1003, and optionally, may further include aprocessing module 1002. Thereceiving module 1001 and the sendingmodule 1003 may communicate with the outside, and theprocessing module 1002 is configured to perform processing, such as processing an IP packet. Thereceiving module 1001 and thetransmitting module 1003 may also be referred to as a communication interface, a transceiving unit, or a transceiving module. Thereceiving module 1001 and the sendingmodule 1003 may be configured to perform the actions performed by the control server in the above method embodiments.

For example: the receivingmodule 1001 and the sendingmodule 1003 may also be referred to as a transceiver module or a transceiver unit (including a receiving unit and/or a sending unit), respectively, for performing the steps of controlling the server to send and receive in the above method embodiments.

In one possible design, the message processing apparatus may implement the steps or processes executed by the control server corresponding to the above method embodiment, for example, the steps or processes may be executed by the control server, or a chip or a circuit configured in the control server. Thereceiving module 1001 and the sendingmodule 1003 are configured to perform transceiving related operations on the control server side in the foregoing method embodiments, and theprocessing module 1002 is configured to perform processing related operations on the control server in the foregoing method embodiments.

In one possible design:

aprocessing module 1002, configured to generate first anchor point information, where the first anchor point information includes a correspondence between an IP address of a terminal device and an IP address of a second server, and the second server is configured to process a packet of the terminal device;

asending module 1003, configured to broadcast the first anchor point information.

Optionally, thereceiving module 1001 is configured to receive an IP address of the terminal device from the second server and an IP address of the second server; theprocessing module 1002 is further configured to generate the first anchor point information according to a corresponding relationship between the IP address of the terminal device and the IP address of the second server.

Optionally, the first anchor point information includes second anchor point information, and theprocessing module 1002 is further configured to determine whether the IP address of the terminal device is found from the second anchor point information; and when the IP address of the terminal equipment is not found from the second anchor point information, adding the corresponding relation between the IP address of the terminal equipment and the IP address of the second server into the second anchor point information to obtain the first anchor point information.

Optionally, the IP address of the terminal device is a first IP address or a second IP address, and thereceiving module 1001 is further configured to receive control plane information from the second server, where the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a correspondence between the first IP address, the second IP address, and the IP address of the second server.

Optionally, theprocessing module 1002 is further configured to delete the corresponding relationship between the IP address of the terminal device and the IP address of the second server in the first anchor point information when it is detected that the session state of the terminal device is a disconnected state.

Optionally, thereceiving module 1001 is further configured to receive an IP address of the terminal device from a first server and an IP address of the first server; aprocessing module 1002, configured to discard the received IP address of the terminal device and the received IP address of the first server when the IP address of the terminal device is found from the first anchor point information.

It should be noted that, the implementation of each module may also correspond to the corresponding description of the method embodiments shown in fig. 5 and fig. 7, and execute the method and the function executed by the control server in the foregoing embodiments.

Fig. 11 is a schematic structural diagram of a first server according to an embodiment of the present disclosure. The first server may be applied in the system shown in fig. 4, and perform the functions of the first server in the above method embodiment, or implement the steps or processes performed by the first server in the above method embodiment.

As shown in fig. 11, the first server includes aprocessor 1101 and atransceiver 1102. Optionally, the first server further comprises amemory 1103. Theprocessor 1101, thetransceiver 1102 and thememory 1103 can communicate with each other via the internal connection path to transmit control and/or data signals, thememory 1103 is used for storing a computer program, and theprocessor 1101 is used for calling and running the computer program from thememory 1103 to control thetransceiver 1102 to transmit and receive signals. Optionally, the first server may further include an antenna, configured to send out the uplink data or the uplink control signaling output by thetransceiver 1102 through a wireless signal.

Theprocessor 1101 and thememory 1103 may be combined into a single processing device, and theprocessor 1101 is configured to execute the program codes stored in thememory 1103 to implement the above-mentioned functions. In particular implementations, thememory 1103 may be integrated with theprocessor 1101 or may be separate from theprocessor 1101. Theprocessor 1101 may correspond to the processing module in fig. 8.

Thetransceiver 1102 may correspond to the receiving module and the transmitting module in fig. 8, and may also be referred to as a transceiver unit or a transceiver module. Thetransceiver 1102 may include a receiver (or receiver, receiving circuit) and a transmitter (or transmitter, transmitting circuit). Wherein the receiver is used for receiving signals, and the transmitter is used for transmitting signals.

It should be understood that the first server shown in fig. 11 is capable of implementing the processes involving the first server in the method embodiments shown in fig. 5 or fig. 7. The operations and/or functions of the modules in the first server are respectively for implementing the corresponding flows in the above method embodiments. Specifically, reference may be made to the description of the above method embodiments, and the detailed description is appropriately omitted herein to avoid redundancy.

Theprocessor 1101 described above may be used to perform the actions described in the previous method embodiment that are implemented internally by the first server, and thetransceiver 1102 may be used to perform the actions described in the previous method embodiment that the first server sends to or receives from the control server. Please refer to the description of the previous embodiment of the method, which is not repeated herein.

Theprocessor 1101 may be, among other things, a central processing unit, a general purpose processor, a digital signal processor, an application specific integrated circuit, a field programmable gate array or other programmable logic device, transistor logic, a hardware component, or any combination thereof. Which may implement or perform the various illustrative logical blocks, modules, and circuits described in connection with the disclosure. Theprocessor 1101 may also be a combination of computing functions, e.g., a combination comprising one or more microprocessors, a digital signal processor and a microprocessor, or the like. Thecommunication bus 1104 may be a peripheral component interconnect standard PCI bus or an extended industry standard architecture EISA bus or the like. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of illustration, only one thick line is shown in FIG. 11, but this is not intended to represent only one bus or type of bus. Acommunication bus 1104 is used to enable connective communication between these components. In this embodiment, thetransceiver 1102 is used for performing signaling or data communication with other node devices. Thememory 1103 may include a volatile memory, such as a nonvolatile dynamic random access memory (NVRAM), a phase change random access memory (PRAM), a Magnetoresistive Random Access Memory (MRAM), and the like, and a nonvolatile memory, such as at least one magnetic disk memory device, an electrically erasable programmable read-only memory (EEPROM), a flash memory device, such as a NOR flash memory (NOR flash memory) or a NAND flash memory (EEPROM), and a semiconductor device, such as a Solid State Disk (SSD). Thememory 1103 may optionally be at least one storage device located remotely from theprocessor 1101. Optionally, thememory 1103 may also store a set of computer program codes or configuration information. Optionally, theprocessor 1101 may also execute programs stored in thememory 1103. The processor may cooperate with the memory and the transceiver to perform any of the methods and functions of the first server of the embodiments of the above-mentioned application.

Fig. 12 is a schematic structural diagram of a second server according to an embodiment of the present application. The second server may be applied to a system as shown in fig. 4, and perform the functions of the second server in the above method embodiment, or implement the steps or processes performed by the second server in the above method embodiment.

As shown in fig. 12, the second server includes aprocessor 1201 and atransceiver 1202. Optionally, the second server further comprises amemory 1203. Theprocessor 1201, thetransceiver 1202 and thememory 1203 may communicate with each other through an internal connection path to transmit control and/or data signals, thememory 1203 is used for storing a computer program, and theprocessor 1201 is used for calling and running the computer program from thememory 1203 to control thetransceiver 1202 to transmit and receive signals. Optionally, the second server may further include an antenna, configured to send out the uplink data or the uplink control signaling output by thetransceiver 1202 through a wireless signal.

Theprocessor 1201 and thememory 1203 may be combined into a processing device, and theprocessor 1201 is configured to execute the program code stored in thememory 1203 to implement the above-described functions. In particular implementations, thememory 1203 may also be integrated with theprocessor 1201 or may be separate from theprocessor 1201. Theprocessor 1201 may correspond to the processing module in fig. 9.

Thetransceiver 1202 may correspond to the receiving module and the transmitting module in fig. 9, and may also be referred to as a transceiver unit or a transceiver module. Thetransceiver 1202 may include a receiver (or receiver, receiving circuit) and a transmitter (or transmitter, transmitting circuit). Wherein the receiver is used for receiving signals, and the transmitter is used for transmitting signals.

It should be understood that the second server shown in fig. 12 is capable of implementing the various processes involving the second server in the method embodiments shown in fig. 5 or fig. 7. The operations and/or functions of the modules in the second server are respectively for implementing the corresponding flows in the above method embodiments. Specifically, reference may be made to the description of the above method embodiments, and the detailed description is appropriately omitted herein to avoid redundancy.

Theprocessor 1201 described above may be used to perform the actions described in the previous method embodiment that are implemented internally by the second server, and thetransceiver 1202 may be used to perform the actions described in the previous method embodiment that the second server transmits to or receives from the terminal device. Please refer to the description in the previous embodiment of the method, which is not repeated herein.

Theprocessor 1201 may be, among other things, a variety of types of processors as previously mentioned. Thecommunication bus 1204 may be a peripheral component interconnect standard PCI bus or an extended industry standard architecture EISA bus, or the like. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of illustration, only one thick line is shown in FIG. 12, but this is not intended to represent only one bus or type of bus. Acommunication bus 1204 is used to enable connective communication between these components. Thetransceiver 1202 of the device in the embodiment of the present application is used for communicating signaling or data with other devices. Thememory 1203 may be various types of memories as mentioned earlier. Thememory 1203 may optionally also be at least one storage device located remotely from theaforementioned processor 1201. A set of computer program codes or configuration information is stored in thememory 1203, and theprocessor 1201 executes the programs in thememory 1203. The processor may cooperate with the memory and the transceiver to perform any of the methods and functions of the second server in the embodiments of the above-mentioned application.

Fig. 13 is a schematic structural diagram of a control server according to an embodiment of the present application. The control server can be applied to a system as shown in fig. 4, and performs the functions of the control server in the above method embodiment, or implements the steps or flows performed by the control server in the above method embodiment.

As shown in fig. 13, the control server includes aprocessor 1301 and atransceiver 1302. Optionally, the control server further comprises amemory 1303. Theprocessor 1301, thetransceiver 1302 and thememory 1303 can communicate with each other via the internal connection path to transmit control and/or data signals, thememory 1303 is used for storing a computer program, and theprocessor 1301 is used for calling and running the computer program from thememory 1303 to control thetransceiver 1302 to transmit and receive signals. Optionally, the control server may further include an antenna for transmitting the uplink data or the uplink control signaling output by thetransceiver 1302 through a wireless signal.

Theprocessor 1301 and thememory 1303 may be combined into a processing device, and theprocessor 1301 is configured to execute the program code stored in thememory 1303 to implement the above functions. In particular implementations, thememory 1303 may also be integrated into theprocessor 1301 or separate from theprocessor 1301. Theprocessor 1301 may correspond to the processing module in fig. 10.

Thetransceiver 1302 may correspond to the receiving module and the transmitting module in fig. 10, and may also be referred to as a transceiver unit or a transceiver module. Thetransceiver 1302 may include a receiver (or receiver, receiving circuit) and a transmitter (or transmitter, transmitting circuit). Wherein the receiver is used for receiving signals, and the transmitter is used for transmitting signals.

It should be understood that the control server shown in fig. 13 is capable of implementing the various processes involving the control server in the method embodiments shown in fig. 5 or fig. 7. The operation and/or function of each module in the control server are respectively for implementing the corresponding flow in the above method embodiment. Specifically, reference may be made to the description of the above method embodiments, and the detailed description is appropriately omitted herein to avoid redundancy.

Theprocessor 1301 described above may be used to perform the actions described in the previous method embodiments that are implemented internally by the control server, while thetransceiver 1302 may be used to perform the actions described in the previous method embodiments that the control server transmits to or receives from the terminal device. Please refer to the description of the previous embodiment of the method, which is not repeated herein.

Theprocessor 1301 may be any of the various types of processors mentioned above. Thecommunication bus 1304 may be a peripheral component interconnect standard PCI bus or an extended industry standard architecture EISA bus, or the like. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of illustration, only one thick line is shown in FIG. 13, but this is not intended to represent only one bus or type of bus. Acommunication bus 1304 is used to enable connective communication between these components. Thetransceiver 1302 of the device in this embodiment of the present application is used for communicating signaling or data with other devices. Thememory 1303 may be various types of memories mentioned earlier. Thememory 1303 may optionally be at least one memory device located remotely from theprocessor 1301. A set of computer program codes or configuration information is stored in thememory 1303, and theprocessor 1301 executes the programs in thememory 1303. The processor may cooperate with the memory and transceiver to perform any of the methods and functions of the control server of the embodiments of the above-mentioned application.

The present application further provides a chip system, where the chip system includes a processor, configured to support a DPI server or a control server to implement the functions involved in any of the foregoing embodiments, such as generating or processing the first anchor point information involved in the foregoing method. In one possible design, the system-on-chip may further include a memory for program instructions and data necessary for the DPI server or the control server. The chip system may be constituted by a chip, or may include a chip and other discrete devices.

Embodiments of the present application further provide a processor, coupled to the memory, for performing any of the methods and functions related to the DPI server or the control server in any of the embodiments.

Embodiments of the present application further provide a computer-readable storage medium having stored therein instructions, which when executed on a computer, cause the computer to perform any of the methods and functions related to the DPI server or the control server in any of the embodiments described above.

Embodiments of the present application also provide a computer program product containing instructions, which when executed on a computer, cause the computer to perform any of the methods and functions related to the DPI server or the control server in any of the embodiments described above.

Embodiments of the present application further provide an apparatus for performing any method and function related to a DPI server or a control server in any of the above embodiments.

An embodiment of the present application further provides a wireless communication system, where the system includes at least one DPI server and at least one control server involved in any of the above embodiments.

In the above embodiments, the implementation may be wholly or partially realized by software, hardware, firmware, or any combination thereof. When implemented in software, may be implemented in whole or in part in the form of a computer program product. The computer program product includes one or more computer instructions. When loaded and executed on a computer, cause the processes or functions described in accordance with the embodiments of the application to occur, in whole or in part. The computer may be a general purpose computer, a special purpose computer, a network of computers, or other programmable device. The computer instructions may be stored on a computer readable storage medium or transmitted from one computer readable storage medium to another, for example, from one website, computer, server, or data center to another website, computer, server, or data center via wire (e.g., coaxial cable, fiber optic, Digital Subscriber Line (DSL)) or wireless (e.g., infrared, wireless, microwave, etc.). The computer-readable storage medium can be any available medium that can be accessed by a computer or a data storage device, such as a server, a data center, etc., that incorporates one or more of the available media. The usable medium may be a magnetic medium (e.g., a floppy disk, a hard disk, a magnetic tape), an optical medium (e.g., a Digital Video Disk (DVD)), or a semiconductor medium (e.g., a Solid State Disk (SSD)), among others.

The DPI server or the control server in each of the above-mentioned apparatus embodiments corresponds to the DPI server or the control server in the method embodiments, and the corresponding module or unit executes the corresponding steps, for example, the receiving module and the sending module (transceiver) execute the steps of receiving or sending in the method embodiments, and other steps besides sending and receiving may be executed by the processing module (processor). The functionality of the specific modules may be referred to in the respective method embodiments. The number of the processors can be one or more.

As used in this specification, the terms "component," "module," "system," and the like are intended to refer to a computer-related entity, either hardware, firmware, a combination of hardware and software, or software in execution. For example, a component may be, but is not limited to being, a process running on a processor, an object, an executable, a thread of execution, a program, and/or a computer. By way of illustration, both an application running on a computing device and the computing device can be a component. One or more components can reside within a process and/or thread of execution and a component may be localized on one computer and/or distributed between two or more computers. In addition, these components can execute from various computer readable media having various data structures stored thereon. The components may communicate by way of local and/or remote processes such as in accordance with a signal having one or more data packets (e.g., data from two components interacting with another component in a local system, distributed system, and/or across a network such as the internet with other systems by way of the signal).

Those of ordinary skill in the art will appreciate that the various illustrative logical blocks and steps (step) described in connection with the embodiments disclosed herein may be implemented as electronic hardware or combinations of computer software and electronic hardware. Whether such functionality is implemented as hardware or software depends upon the particular application and design constraints imposed on the implementation. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present application.

The functions, if implemented in the form of software functional units and sold or used as a stand-alone product, may be stored in a computer readable storage medium. Based on such understanding, the technical solutions of the present application or portions thereof that substantially contribute to the prior art may be embodied in the form of a software product, which is stored in a storage medium and includes several instructions for causing a computer device (which may be a personal computer, a server, or a network device) to execute all or part of the steps of the methods described in the embodiments of the present application. And the aforementioned storage medium includes: various media capable of storing program codes, such as a usb disk, a removable hard disk, a read-only memory (ROM), a Random Access Memory (RAM), a magnetic disk, or an optical disk.

The above description is only for the specific embodiments of the present application, but the scope of the present application is not limited thereto, and any person skilled in the art can easily conceive of the changes or substitutions within the technical scope of the present application, and shall be covered by the scope of the present application. Therefore, the protection scope of the present application shall be subject to the protection scope of the claims.

Claims (30)

1. A message processing method is characterized by comprising the following steps:

the method comprises the steps that a first server receives a first message from a terminal device, and the IP address of the terminal device is determined based on the first message;

the first server determines whether the first server processes the first message or not based on the IP address of the terminal equipment and first anchor point information, wherein the first anchor point information comprises a corresponding relation between the IP address of the terminal equipment and the IP address of a second server;

and when the IP address of the first server is different from the IP address of the second server, the first server forwards the first message to the second server according to the IP address of the second server.

2. The method of claim 1, wherein the method further comprises:

and when the IP address of the first server is the same as that of the second server, the first server processes the first message.

3. The method of claim 1, wherein the first server forwarding the first packet to the second server based on the IP address of the second server comprises:

the first server searches the MAC address of the second server corresponding to the IP address of the second server from the corresponding relation between the preset IP address and the MAC address;

and the first server sends the first message to the second server according to the MAC address of the second server.

4. The method according to any of claims 1-3, wherein before the first server receives the first message from the terminal device, further comprising:

the second server receives a second message from the terminal equipment, and determines the IP address of the terminal equipment based on the second message;

and the second server sends the IP address of the terminal equipment and the IP address of the second server to a control server, wherein the IP address of the terminal equipment and the IP address of the second server are used for generating the first anchor point information.

5. The method of claim 4, wherein the first anchor information comprises second anchor information, the second server sending the IP address of the terminal device and the IP address of the second server to a control server comprising:

the second server determines whether the IP address of the terminal equipment is found from the second anchor point information;

and when the IP address of the terminal equipment is not found from the second anchor point information, the second server sends the IP address of the terminal equipment and the IP address of the second server to the control server.

6. The method of claim 4 or 5, wherein the IP address of the terminal device is a first IP address or a second IP address, the method further comprising:

the second server sends control plane information to the control server, the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a corresponding relationship between the first IP address, the second IP address and the IP address of the second server.

7. The method of any of claims 4-6, wherein after the second server sends the IP address of the terminal device and the IP address of the first server to a control server, further comprising:

the second server receives the first anchor point information from the control server.

8. A method for processing a packet, comprising:

the control server generates first anchor point information, wherein the first anchor point information comprises a corresponding relation between an IP address of the terminal equipment and an IP address of a second server, and the second server is used for processing a message of the terminal equipment;

and the control server broadcasts the first anchor point information.

9. The method of claim 8, wherein the control server generating first anchor point information comprises:

the control server receives the IP address of the terminal equipment from the second server and the IP address of the second server;

and the control server generates the first anchor point information according to the corresponding relation between the IP address of the terminal equipment and the IP address of the second server.

10. The method of claim 9, wherein the first anchor information comprises second anchor information, and wherein the generating, by the control server, the first anchor information according to the correspondence between the IP address of the terminal device and the IP address of the second server comprises:

the control server determines whether the IP address of the terminal equipment is searched from the second anchor point information;

and when the IP address of the terminal equipment is not found from the second anchor point information, the control server adds the corresponding relation between the IP address of the terminal equipment and the IP address of the second server to the second anchor point information to obtain the first anchor point information.

11. The method of claim 9 or 10, wherein the IP address of the terminal device is a first IP address or a second IP address, the method further comprising:

the control server receives control plane information from the second server, the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a corresponding relationship between the first IP address, the second IP address and the IP address of the second server.

12. The method of any one of claims 8-11, further comprising:

and when the session state of the terminal equipment is detected to be a disconnected state, the control server deletes the corresponding relation between the IP address of the terminal equipment and the IP address of the second server in the first anchor point information.

13. The method of any one of claims 8-12, further comprising:

the control server receives an IP address of the terminal equipment and an IP address of a first server from the first server;

and when the IP address of the terminal equipment is found from the first anchor point information, the control server discards the received IP address of the terminal equipment and the IP address of the first server.

14. A message processing system comprising a first server, the first server comprising:

the first receiving module is used for receiving a first message from the terminal equipment and determining the IP address of the terminal equipment based on the first message;

a first processing module, configured to determine whether the first server processes the first packet based on an IP address of the terminal device and first anchor point information, where the first anchor point information includes a correspondence between the IP address of the terminal device and an IP address of a second server;

and the first sending module is used for forwarding the first message to the second server according to the IP address of the second server when the IP address of the first server is different from the IP address of the second server.

15. The system of claim 14,

the first processing module is further configured to process the first packet when the IP address of the first server is the same as the IP address of the second server.

16. The system of claim 14,

the first processing module is further configured to search for the MAC address of the second server corresponding to the IP address of the second server from a preset correspondence between IP addresses and MAC addresses;

the first sending module is further configured to send the first packet to the second server according to the MAC address of the second server.

17. The system of any of claims 14-16, wherein the message processing system includes a second server, the second server comprising:

a second receiving module, configured to receive a second message from the terminal device;

the second processing module is used for determining the IP address of the terminal equipment based on the second message;

and a second sending module, configured to send the IP address of the terminal device and the IP address of the second server to a control server, where the IP address of the terminal device and the IP address of the second server are used to generate the first anchor point information.

18. The system of claim 17, wherein the first anchor point information comprises second anchor point information,

the second processing module is further configured to determine whether the IP address of the terminal device is found from the second anchor point information;

the second sending module is further configured to send the IP address of the terminal device and the IP address of the second server to the control server when the IP address of the terminal device is not found in the second anchor point information.

19. The system according to claim 17 or 18, wherein the IP address of the terminal device is a first IP address or a second IP address,

the second sending module is further configured to send control plane information to the control server, where the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a correspondence between the first IP address, the second IP address, and an IP address of the second server.

20. The system of any one of claims 17-19,

the second receiving module is further configured to receive the first anchor point information from the control server.

21. A message processing apparatus, comprising:

the processing module is used for generating first anchor point information, the first anchor point information comprises a corresponding relation between an IP address of the terminal equipment and an IP address of a second server, and the second server is used for processing a message of the terminal equipment;

and the sending module is used for broadcasting the first anchor point information.

22. The apparatus of claim 21, wherein the apparatus further comprises:

a receiving module, configured to receive an IP address of the terminal device from the second server and an IP address of the second server;

the processing module is further configured to generate the first anchor point information according to a corresponding relationship between the IP address of the terminal device and the IP address of the second server.

23. The apparatus of claim 22, wherein the first anchor information comprises second anchor information,

the processing module is further configured to determine whether the IP address of the terminal device is found from the second anchor point information; and when the IP address of the terminal equipment is not found from the second anchor point information, adding the corresponding relation between the IP address of the terminal equipment and the IP address of the second server into the second anchor point information to obtain the first anchor point information.

24. The apparatus of claim 22 or 23, wherein the IP address of the terminal device is a first IP address or a second IP address,

the receiving module is further configured to receive control plane information from the second server, where the control plane information includes the first IP address and the second IP address of the terminal device, and the first anchor point information includes a correspondence between the first IP address, the second IP address, and an IP address of the second server.

25. The apparatus of any one of claims 21-24,

the processing module is further configured to delete the correspondence between the IP address of the terminal device and the IP address of the second server in the first anchor point information when it is detected that the session state of the terminal device is a disconnected state.

26. The apparatus of any one of claims 21-25,

the receiving module is used for receiving the IP address of the terminal equipment from a first server and the IP address of the first server;

the processing module is configured to discard the received IP address of the terminal device and the received IP address of the first server when the IP address of the terminal device is found from the first anchor point information.

27. An apparatus comprising a processor and a memory, the memory to store instructions, the processor to execute the instructions to cause the apparatus to perform the method of any of claims 1 to 13.

28. A computer-readable storage medium storing instructions that, when executed on a computer, cause the computer to perform the method of any one of claims 1 to 13.

29. A computer program product comprising one or more computer instructions which, when run on a computer, cause the computer to perform the method of any one of claims 1 to 13.

30. A message handling system, the system comprising a first server for performing the method of any of claims 1 to 3, a second server for performing the method of any of claims 4 to 7, and a control server for performing the method of any of claims 8 to 13.

Images