Detailed Description
In order to make the objects, technical solutions and advantages of the present application more apparent, the technical solutions of the present application will be described in detail and completely with reference to the following specific embodiments of the present application and the accompanying drawings. It should be apparent that the described embodiments are only some of the embodiments of the present application, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present application.
In a mobile network, communication between a base station and the mobile network is typically performed through a specific protocol. In a scenario where servers in a mobile network are in a highly available deployment, each machine node (i.e., primary server node) may be provided with a standby machine node. When the main server node connected with the base station fails, the communication link between the base station and the main node can be switched to the communication link between the base station and the standby machine node.
In the prior art, when a communication link is switched between a main node and a standby machine node, a communication connection is generally required to be established between a base station and the standby machine node again based on a specific protocol. The switching mode causes communication interruption, and the user on the original communication link needs to re-attach the network.
In view of the above technical problems, in some embodiments of the present application, a solution is provided, and the technical solutions provided by the embodiments of the present application are described in detail below with reference to the accompanying drawings.
Fig. 1 is a schematic architecture diagram of a load balancing system of a cloud network according to an exemplary embodiment of the present application, and as shown in fig. 1, the load balancing system 100 of the cloud network includes: the main node 10 of the containerized application management platform, multiple machine nodes, and the multiple machine nodes are according to the main/standby mode. Any machine node 11 corresponds to a standby machine node 12.
The containerization application management platform can be realized based on a Kubernetes (container arrangement engine) platform. Kubernets is used to manage containerized applications on multiple hosts (or nodes) in a cloud platform, so that the containerized applications deployed on the hosts run in a desired state. Multiple hosts in a kubernets platform form a kubernets cluster.
The Kubernetes cluster includes a Master Node and a machine Node. The main node runs a main control component of Kubernetes and is used for controlling, scheduling, managing and the like the machine node. One machine node corresponds to one physical machine.
In this embodiment, in a high available deployment scenario, a standby machine node may be set for each machine node. The standby machine node is used for continuously executing interrupted services under the condition that the machine node has inevitable planned or unplanned abnormalities (such as downtime and faults) so as to realize dual-machine equipment. Each server can be implemented based on conventional server equipment, wherein the server equipment mainly comprises a processor, a hard disk, a memory, a system bus and the like, is similar to a general computer architecture, and is not described in detail again.
Wherein, machine node and 11 mainly are used for: and when no abnormity occurs, connecting with the base station and providing data service for the base station. Wherein, the connection between the machine node and the base station can be a long connection, that is: after the connection is established, the connection state can be continuously maintained; there is no need to re-establish a connection at each data transmission before the long connection is terminated.
In load balancing, the master node 10 is mainly configured to: and monitoring the running state of the machine node 11. The operation of monitoring the running state of the machine node 11 may be performed by a monitoring function component disposed on the master node 10. When the machine node 11 is monitored to be abnormal, the communication message of the base station is routed to the standby machine node 12 based on the load balancing strategy. The load balancing policy is a policy for directing an access request of a base station to a machine node or a standby machine node. In the load balancing policy, a trigger condition for forwarding a request between the primary and secondary machines may be customized, where the trigger condition may be a machine node downtime, a machine node failure, a machine node having a certain hardware resource abnormality (for example, the hardware resource occupancy rate reaches a set threshold), or a machine node having a certain software resource abnormality (for example, a software abnormal interruption operation), and the like, and this embodiment is not limited.
Wherein, the standby machine node 12 is mainly used for: acquiring session environment data of a machine node 11 and a base station; the session environment data refers to communication environment related data required for communication interaction between the machine node 11 and the base station, and may include, but is not limited to, a communication address, a serial number of a communication connection, authentication information, and other data. The standby machine node 12 may share the above-described session context data with the machine node 11.
When the standby machine node 12 receives the communication packet of the base station forwarded by the master node 10, the communication link to which the communication packet belongs may be accessed according to the session environment data between the machine node 11 and the base station. After access, the communication link between the base station and the machine node 11 is switched to the communication link between the base station and the machine node 12. In this switching process, the session environment of the correspondent node is not changed for the base station, the long connection can be maintained, and the base station side does not need to perform the operation of establishing a communication connection with the standby machine node 12. After accessing the communication link, the standby machine node 12 may communicate with the base station based on the shared session context data in response to the communication packet sent by the base station.
In some embodiments, for the standby machine node 12, before the machine node 11 does not generate an abnormality, the standby machine node 12 does not establish a communication connection with the base station, and therefore, after the standby machine node 12 receives the communication message of the base station routed by the master node 10, the communication link to which the communication message belongs cannot be identified. Typically, the standby machine node 12 may send a termination communication message to the base station. If the base station receives the termination communication message, the communication connection can be terminated, and the termination information is reported to an Upper Layer Protocol (ULP). When the upper layer protocol senses the interruption of the transmission layer network, the current application is terminated, so that the user senses the interruption of the network.
In this embodiment, in order to implement active/standby switching without sensing by the user, the standby machine node 12 may intercept the termination communication packet after sending the termination communication packet to the base station. Therefore, the base station side cannot sense the main/standby switching of the cloud network side.
When the communication protocols adopted by the cloud network and the base station are different, the termination zone bits in the termination communication message are also different. For example, when SCTP (Stream Control Transmission Protocol) is used for communication Transmission, the termination flag bit may be an ABORT flag bit or a SHUTDOWN flag bit. That is, when the standby machine node 12 does not establish a communication connection with the base station, if a communication packet of the base station is received, a packet including an ABORT flag or a SHUTDOWN flag is sent to the base station based on a communication mechanism set by a communication protocol, and the packet can be intercepted based on a firewall component before the packet is sent. When the base station does not receive the message containing the ABORT flag bit or the SHUTDOWN flag bit, the communication connection does not need to be terminated, and thus the user at the application side cannot sense the interruption caused by the network abnormality. After intercepting the terminating communication packet, the standby machine node 12 may access the communication link to which the communication packet belongs according to the session environment data between the machine node 11 and the base station. After accessing the communication link, the standby machine node 12 may establish a communication connection with the base station, so as to respond to the communication packet sent by the base station.
Based on the above embodiment, the standby machine node 12 can establish connection with the base station and perform communication interaction with the base station instead of the machine node 11, so that the communication requirement of the base station is met.
In this embodiment, when a machine node in the cloud network is abnormal, based on the load balancing capability provided by the master node of the containerized application management platform, a communication packet sent to the machine node by the base station may be routed to a standby machine node of the machine node. The standby machine node can share the conversation environment data between the machine node and the base station, and accesses a communication link between the machine node and the base station according to the conversation environment data between the machine node and the base station so as to communicate with the base station. On one hand, the main-standby switching can be realized under the condition that the base station side is not aware, on the other hand, the standby machine node can be quickly accessed into a communication link between the machine node and the base station according to the session environment data between the machine node and the base station, so that the communication transmission can be quickly recovered, and the influence on the application side is reduced.
In some alternative embodiments, the operation of the standby machine node 12 intercepting the packet containing the termination flag may be implemented based on a gateway or a router connected to the standby machine node 12, or may be implemented by a firewall component (iptables) on the standby machine node 12. The gateway, the router or the firewall component may be configured with a white list of interception addresses, and if the communication address of the correspondent node is in the white list, the terminating communication packet may not be sent to the correspondent node when receiving the communication packet sent by the communication address. If the communication address of the opposite communication terminal is not in the white list, when the communication message sent by the communication address is received, if the communication address cannot be identified, the communication terminal sends a communication termination message to the opposite communication terminal.
Based on this, after the standby machine node 12 accesses the communication link between the machine node 11 and the base station according to the session environment data, the standby machine node 12 establishes a communication connection with the base station, and can perform conventional communication interaction. The communication interaction may include: when a communication connection needs to be terminated (e.g., a link is abnormal), the standby machine node 12 actively sends a termination request to the base station. To avoid continuing to intercept the termination request of the standby machine node 12 during subsequent normal communication interactions, the white list of the intercepted addresses may be updated according to the communication address of the base station. For example, the communication address of the base station may be added to a white list of interception addresses. Therefore, in the subsequent communication process with the base station, when the machine node 11 needs to end the communication connection with the base station, a termination communication packet may be sent to the base station to end the communication session.
In some optional embodiments, the standby machine node 12 may also be used to interact with the operation and maintenance terminal to synchronize the working status to the operation and maintenance personnel in real time. The operation and maintenance terminal can be a mobile phone, a computer, a tablet computer and the like held by operation and maintenance personnel.
Optionally, when the communication link to which the communication packet forwarded by the main node 10 belongs cannot be identified, the standby machine node 12 may send an abnormality warning message to the operation and maintenance terminal to notify the operation and maintenance personnel of performing the abnormality maintenance.
Optionally, when accessing the communication link to which the communication packet forwarded by the master node 10 belongs according to the session environment data between the machine node 11 and the base station, the standby machine node 12 may send a master/standby switching message of the machine node to the operation and maintenance terminal. Therefore, the working state of the main machine and the standby machine can be automatically synchronized with the operation and maintenance personnel.
It should be noted that, in some exemplary embodiments, after the master node 10 routes the communication packet of the base station to the standby machine node when monitoring that the machine node 11 is abnormal, the master node may further analyze the abnormal reason of the machine node according to the monitored state change of the machine node, and record the abnormal reason of the machine node, so as to optimize the load balancing policy according to the abnormal reason.
For example, in some cases, when the master node 10 monitors that the machine node 11 is abnormally down, the master node may analyze the reason for the down according to the state change of the machine node. For example, if the state of the operating environment (e.g., disk state, memory state) changes before the machine node 11 goes down, it may be considered that the down reason of the machine node 11 is the change of the operating environment. For example, if the machine node 11 is subjected to a large number of malicious attacks before going down, it may be considered that the reason why the machine node 11 goes down is caused by the malicious attacks.
The master node 10 may record the above reasons and may optimize the load balancing policy. For example, before optimization, the load balancing policy is: and when the machine node is detected to be down, starting the standby machine node of the machine node to bear the access pressure of the machine node. The optimized load balancing strategy is as follows: when the change of the state of the running environment of the machine node is detected, the standby machine node of the machine node is started to bear the access pressure of the machine node, so that the load balancing can be performed in time before the machine node goes down. For another example, the optimized load balancing policy may be: when detecting that the machine node is attacked maliciously by a certain amount, starting the standby machine node of the machine node to bear the access pressure of the machine node, thereby balancing the load in time before the machine node goes down.
In the above and below embodiments of the present application, the standby machine node 12 mainly acquires data such as a communication address, a serial number of a communication connection, and authentication information between the machine node 11 and a base station when acquiring session environment data of the machine node 11 and the base station. When the communication protocols adopted by the cloud network and the base station are different, the description modes of the communication addresses are different. For example, when the communication Protocol is UDP (User Datagram Protocol), the communication address may be a UDP port number or a socket.
As shown in fig. 2, when the base station communicates with the machine node using the SCTP protocol, the communication address may include an address of an SCTP listening socket. Alternatively, the standby machine node 12 may obtain a data structure in the memory corresponding to the SCTP listening socket of the machine node 11. Accordingly, when accessing the communication link of the base station according to the session environment data, the standby machine node 12 may establish an SCTP association (association) with the base station according to the data structure in the memory corresponding to the SCTP listening socket.
In some exemplary embodiments, when the standby node 12 acquires a data structure in the memory corresponding to the SCTP listening socket in the machine node 11, it may request the acquisition of the data structure in the memory corresponding to the SCTP listening socket from the machine node 11. That is, the standby machine node 12 directly acquires the SCTP listening socket address to the machine node 11.
In other exemplary embodiments, when the standby node 12 acquires the data structure in the memory corresponding to the SCTP listening socket in the machine node 11, it may request to acquire the data structure in the memory corresponding to the SCTP listening socket of the machine node 11 from a database server in the cloud network. Wherein, the data structure in the memory corresponding to the SCTP listening socket is uploaded to the database server by the machine node 11.
Based on the above embodiment, in the cloud network, the socket information may be shared between the machine node 11 and the standby machine node 12, so that when the communication link is switched between the machine node 11 and the standby machine node 12, the standby machine node 12 may quickly access the communication link based on the shared socket information, thereby reducing the link switching delay.
In some exemplary embodiments, the machine nodes in the cloud network and the standby machine nodes are operated with core network components of the mobile network deployed in a containerization manner. The mobile network may be a 4G, 5G, 5.5G or 6G mobile network. Taking the example that the mobile Network is implemented as a 5G mobile Network, a 5G Core Network (5G Core Network, 5GC) may be deployed in a machine node and a standby machine node in a cloud Network in a containerized manner to provide a Core Network service to the base station. Taking the example that the mobile network is implemented as a 4G mobile network, an Evolved Packet Core (EPC) may be deployed in a containerized manner in a machine node and a standby machine node in the cloud network to provide a Core network service for the base station.
Alternatively, kubernets may implement load balancing between machine nodes and standby machine nodes based on MetalLB (a type of load balancer that may operate in a kubernets environment). The controller component (controller) of MetalB resides in the host node of Kubernets. Each machine node in Kubernetes runs the MetalB speaker (spaker) component. The speaker is a daemon of a node where the speaker is located, and is used for executing an announcement service according to an allocated IP (Internet Protocol) address.
As shown in fig. 2, the base station may communicate with a virtual address (vip) using SCTP protocol communications. Wherein, the virtual address is an IP address when the MetalLB exposes the service to the outside in a load balancing mode.
As shown in fig. 3, when a base station accesses a node in kubernets in an off-cluster load manner, the MetalLB may forward a packet of the base station to a machine node in kubernets based on a service of LoadBalancer (a service that forwards traffic to a network). When the message is forwarded, the controller component in the MetalLB can select a leader node (leader) from the plurality of nodes according to the destination IP of the communication message, and inform a speaker (spoke) of the node to be led to respond to the message of the base station. The speaker can send the message to the core network component for processing after the protocol conversion is carried out on the message.
As shown in FIG. 3, the machine node where EPC/5GC _2 is located is a standby machine node of the machine node where EPC/5GC _1 is located. When the machine node where the EPC/5GC _1 is located operates normally, and the controller component in the MetalLB receives the communication message of the base station, the loudspeaker of the machine node where the EPC/5GC _1 is located can be informed to respond to the communication message of the base station based on the destination IP of the communication message. Meanwhile, the controller component of MetalLB can monitor the working state of the machine node where EPC/5GC _1 is located in real time. When the machine node where the EPC/5GC _1 is located is monitored to be abnormal, a controller component in the MetalLB can inform a loudspeaker of the standby machine node (namely the machine node where the EPC/5GC _2 is located) to respond to a communication message of the base station. When the standby machine node can not identify the communication link to which the communication message belongs, the standby machine node can intercept a termination message aiming at the communication link and accesses the communication link according to the session environment data of the machine node so as to respond to the communication message.
In some embodiments, the core network service provided by the mobile network may be a live service, an automatic driving service, a video service, and the like. Taking the live broadcast service as an example, a core network component for providing the live broadcast traffic processing service can be operated on a machine node and a standby machine node in the cloud network.
In a live broadcast scenario, the machine node 11 is mainly used for connecting with a base station and processing a live broadcast traffic processing request of the base station. The live traffic processing request may be a push flow request or a pull flow request of the live traffic, which is not limited in this embodiment.
The master node 10 of the containerized application management platform is mainly used for: monitoring the running state of the machine node 11; when the machine node 11 is monitored to be abnormal, a live broadcast traffic processing request of the base station is routed to the standby machine node 12.
Wherein, the standby machine node 12 is mainly used for: session environment data of the machine node 11 and the base station is acquired. And receiving a live broadcast flow processing request forwarded by the main node based on a load balancing strategy. Intercepting a termination message aiming at a communication link when the communication link to which the live broadcast flow processing request belongs cannot be identified; and accessing the communication link according to the session environment data to process the live broadcast traffic processing request.
For example, when the master node 10 detects a machine node 11 failure, a live traffic pull request sent by a base station may be forwarded to the standby machine node 12. If the standby machine node 12 cannot identify the communication link corresponding to the live broadcast flow pull request, intercepting a termination message for the communication link, and accessing the communication link according to the session environment data of the machine node 11 to process the live broadcast flow pull request.
Based on the implementation mode, when the machine node is abnormal, based on the load balancing strategy and the session environment data of the machine and the shared machine node, the communication link is switched between the machine node and the standby machine node, so that the influence of the abnormal machine node on the live broadcast service can be reduced, and the live broadcast service capability can be improved.
In the automatic driving scenario, the machine node 11 is mainly used for connecting with a base station and processing an automatic driving data processing request of the base station. The automatic driving data processing request may be a downloading request or an uploading request of automatic driving data, and this embodiment is not limited.
The master node 10 of the containerized application management platform is mainly used for: monitoring the running state of the machine node 11; when the machine node 11 is monitored to be abnormal, an automatic driving data processing request of the base station is routed to the standby machine node 12.
Wherein, the standby machine node 12 is mainly used for: session environment data of the machine node 11 and the base station is acquired. And receiving an automatic driving data processing request forwarded by the main node based on a load balancing strategy. Intercepting a termination message for a communication link to which the automatic driving data processing request belongs when the communication link to which the automatic driving data processing request belongs cannot be identified; and accessing the communication link to process the autopilot data processing request based on the session context data.
For example, when the master node 10 monitors that the throughput of the data query of the machine node 11 exceeds a set upper limit, an autonomous driving data download request sent by the base station may be forwarded to the standby machine node 12. If the standby machine node 12 cannot identify the communication link corresponding to the automatic driving data downloading request, intercepting a termination message aiming at the communication link, and accessing the communication link according to the session environment data of the machine node 11 to process the automatic driving data downloading request.
Based on the implementation mode, when the machine node is abnormal, based on the load balancing strategy and the session environment data of the machine and the shared machine node, the communication link is switched between the machine node and the standby machine node, so that the influence of the abnormal machine node on the automatic driving service can be reduced, and the automatic driving service capability is improved.
Fig. 4 is a schematic flowchart of a load balancing method of a cloud network according to an embodiment of the present application. As shown in fig. 4, when executed on the standby machine node side in the cloud network, the method mainly includes the following steps:
step 401, a standby machine node in a cloud network acquires session environment data of the machine node and a base station.
And 402, receiving the communication message of the base station forwarded by the main node of the containerized application management platform based on the load balancing strategy when the machine node is abnormal.
Step 403, accessing the communication link to which the communication packet belongs according to the session environment data to respond to the communication packet.
In some exemplary embodiments, before accessing the communication link to which the communication packet belongs according to the session environment data, the method further includes: if the communication link to which the communication message belongs cannot be identified, sending a message containing a termination flag bit to the base station; and intercepting the message containing the termination zone bit so as to enable the base station side to maintain the connection of the communication link.
In some exemplary embodiments, after accessing the communication link to which the communication packet belongs according to the session environment data, the method further includes: and updating the white list of the interception address according to the communication address of the base station.
In some exemplary embodiments, the machine node and the standby machine node have core network components of a mobile network running thereon, the core network components being deployed in a containerized manner.
In some exemplary embodiments, the method further comprises: when the communication link to which the communication message belongs cannot be identified, sending an abnormal early warning message to an operation and maintenance terminal; and/or sending a master-slave switching message of the machine node to the operation and maintenance terminal when the communication link to which the communication message belongs is accessed according to the session environment data.
In some exemplary embodiments, one way for the standby machine node to obtain session context data of the machine node and a base station may include: acquiring a data structure in a memory corresponding to the SCTP monitoring socket of the machine node; one way to access the communication link to which the communication packet belongs according to the session environment data may include: and establishing SCTP association with the base station according to a data structure in a memory corresponding to the SCTP monitoring socket.
In some exemplary embodiments, one way to obtain the data structure in the memory corresponding to the SCTP listening socket in the machine node may include: requesting the machine node to acquire a data structure in a memory corresponding to the SCTP monitoring socket; or requesting a database server in the cloud network to acquire a data structure in a memory corresponding to the SCTP monitoring socket; and uploading a data structure in a memory corresponding to the SCTP monitoring socket to the database server by the machine node.
In this embodiment, when a machine node in the cloud network is abnormal, based on the load balancing capability provided by the master node of the containerized application management platform, the communication packet sent by the base station to the machine node may be routed to a standby machine node of the machine node. The standby machine node can share the conversation environment data between the machine node and the base station, and accesses a communication link between the machine node and the base station according to the conversation environment data between the machine node and the base station so as to communicate with the base station. On one hand, the main-standby switching can be realized under the condition that the base station side is not aware, on the other hand, the standby machine node can be quickly accessed into a communication link between the machine node and the base station according to the session environment data between the machine node and the base station, so that the communication transmission can be quickly recovered, and the influence on the application side is reduced.
Fig. 5 is a schematic flowchart of a load balancing method of a cloud network according to another embodiment of the present application. As shown in fig. 5, when executed on the master node side of a containerized application management platform deployed in a cloud network, the method mainly includes the following steps:
step 501, a main node of a containerized application management platform monitors the running state of a machine node, and the machine node is connected with a base station.
Step 501, when the machine node is monitored to be abnormal, routing a communication message of the base station to a standby machine node of the machine node based on a load balancing strategy so that the standby machine node receives the communication message of the base station forwarded by the main node, and accessing a communication link to which the communication message belongs according to the acquired session environment data of the machine node and the base station so as to respond to the communication message.
In some exemplary embodiments, when the machine node is monitored to be abnormal, after the communication packet of the base station is routed to a standby machine node of the machine node based on a load balancing policy, the method further includes: analyzing the abnormal reason of the machine node according to the monitored state change of the machine node; and recording the abnormal reason of the machine node so as to optimize the load balancing strategy according to the abnormal reason.
In this embodiment, when a machine node in the cloud network is abnormal, based on the load balancing capability provided by the master node of the containerized application management platform, the communication packet sent by the base station to the machine node may be routed to a standby machine node of the machine node. Thus, the standby machine node can access the communication link between the machine node and the base station according to the session environment data between the machine node and the base station to communicate with the base station. Based on the implementation mode, the main-standby switching can be realized under the condition that the base station side does not sense based on the load balancing strategy, and the communication requirement of the base station side is met.
It should be noted that the execution subjects of the steps of the methods provided in the above embodiments may be the same device, or different devices may be used as the execution subjects of the methods. For example, the execution subjects of steps 401 to 403 may be device a; for another example, the execution subject of steps 401 and 402 may be device a, and the execution subject of step 403 may be device B; and so on.
In addition, in some of the flows described in the above embodiments and the drawings, a plurality of operations are included in a specific order, but it should be clearly understood that the operations may be executed out of the order presented herein or in parallel, and the sequence numbers of the operations, such as 401, 402, etc., are merely used to distinguish various operations, and the sequence numbers themselves do not represent any execution order. Additionally, the flows may include more or fewer operations, and the operations may be performed sequentially or in parallel.
Fig. 6 illustrates a schematic structural diagram of a server according to an exemplary embodiment of the present application. As shown in fig. 6, the server includes: memory 601, processor 602, and communication component 603.
The memory 601 is used for storing computer programs and may be configured to store other various data to support operations on the server. Examples of such data include instructions for any application or method operating on the server, contact data, phonebook data, messages, pictures, videos, and so forth.
The memory 601 may be implemented by any type or combination of volatile or non-volatile memory devices such as Static Random Access Memory (SRAM), electrically erasable programmable read-only memory (EEPROM), erasable programmable read-only memory (EPROM), programmable read-only memory (PROM), read-only memory (ROM), magnetic memory, flash memory, magnetic or optical disks.
In some embodiments, the server illustrated in fig. 6 may be implemented as a master node deployed with a containerized application management platform in a cloud network. The cloud network is also provided with a plurality of machine nodes, and the machine nodes are arranged according to the main/standby mode. A processor 602, coupled to the memory 601, for executing the computer programs in the memory 601 to: monitoring the running state of the machine node in the cloud network, wherein the machine node is connected with a base station; when the machine node is monitored to be abnormal, the communication message of the base station is routed to a standby machine node of the machine node based on a load balancing strategy, so that the standby machine node receives the communication message of the base station forwarded by the main node, and a communication chain to which the communication message belongs is accessed according to the acquired session environment data of the machine node and the base station to respond to the communication message.
Further optionally, when monitoring that the machine node is abnormal, the processor 602, after routing the communication packet of the base station to a standby machine node of the machine node based on a load balancing policy, is further configured to: analyzing the abnormal reason of the machine node according to the monitored state change of the machine node; and recording the abnormal reason of the machine node so as to optimize the load balancing strategy according to the abnormal reason.
In other embodiments, the server illustrated in fig. 6 may be implemented as a standby machine node for any machine node in a cloud network. A processor 602, coupled to the memory 601, for executing the computer programs in the memory 601 to: acquiring session environment data of the machine node and a base station; when the machine node is abnormal, receiving a communication message of the base station forwarded by the main node based on a load balancing strategy; and accessing the communication link to which the communication message belongs according to the session environment data so as to respond to the communication message.
Further optionally, the core network component of the mobile network deployed in a containerization manner runs on the machine node and the standby machine node.
Further optionally, before accessing the communication link to which the communication packet belongs according to the session environment data, the processor 602 is further configured to: if the communication link to which the communication message belongs cannot be identified, sending a message containing a termination flag bit to the base station; and intercepting the message containing the termination zone bit so as to enable the base station side to maintain the connection of the communication link.
Further optionally, after accessing the communication link to which the communication packet belongs according to the session environment data, the processor 602 is further configured to: and updating the white list of the interception address according to the communication address of the base station.
Further optionally, the processor 602 is further configured to: when the communication link to which the communication message belongs cannot be identified, sending an abnormal early warning message to an operation and maintenance terminal; and/or sending a master-slave switching message of the machine node to the operation and maintenance terminal when the communication link to which the communication message belongs is accessed according to the session environment data.
Further optionally, when the standby machine node acquires the session environment data of the machine node and the base station, the processor 602 is specifically configured to: acquiring a data structure in a memory corresponding to the SCTP monitoring socket of the machine node; when accessing the communication link to which the communication packet belongs according to the session environment data, the processor 602 is specifically configured to: and establishing SCTP association with the base station according to a data structure in a memory corresponding to the SCTP monitoring socket.
Further optionally, when acquiring the data structure in the memory corresponding to the SCTP listening socket in the machine node, the processor 602 is specifically configured to: requesting the machine node to acquire a data structure in a memory corresponding to the SCTP monitoring socket; or requesting a database server in the cloud network to acquire a data structure in a memory corresponding to the SCTP monitoring socket; and uploading a data structure in a memory corresponding to the SCTP monitoring socket to the database server by the machine node.
Further, as shown in fig. 6, the server further includes: power supply components 604, and the like. Only some of the components are schematically shown in fig. 6, and it is not meant that the server includes only the components shown in fig. 6.
Wherein the communication component 603 is configured to facilitate communication between the device in which the communication component is located and other devices in a wired or wireless manner. The device in which the communication component is located may access a wireless network based on a communication standard, such as WiFi, 2G, 3G, 4G, or 5G, or a combination thereof. In an exemplary embodiment, the communication component receives a broadcast signal or broadcast related information from an external broadcast management system via a broadcast channel. In an exemplary embodiment, the communication component may be implemented based on Near Field Communication (NFC) technology, Radio Frequency Identification (RFID) technology, infrared data association (IrDA) technology, Ultra Wideband (UWB) technology, Bluetooth (BT) technology, and other technologies.
The power supply assembly 604 provides power to various components of the device in which the power supply assembly is located. The power components may include a power management system, one or more power supplies, and other components associated with generating, managing, and distributing power for the device in which the power component is located.
In this embodiment, when a machine node in the cloud network is abnormal, based on the load balancing capability provided by the master node of the containerized application management platform, a communication packet sent to the machine node by the base station may be routed to a standby machine node of the machine node. The standby machine node can share the conversation environment data between the machine node and the base station, and accesses a communication link between the machine node and the base station according to the conversation environment data between the machine node and the base station so as to communicate with the base station. On one hand, the main-standby switching can be realized under the condition that the base station side is not aware, on the other hand, the standby machine node can be quickly accessed into a communication link between the machine node and the base station according to the session environment data between the machine node and the base station, so that the communication transmission can be quickly recovered, and the influence on the application side is reduced.
Accordingly, the present application further provides a computer-readable storage medium storing a computer program, where the computer program can implement the steps that can be executed by the server in the foregoing embodiments when executed.
Accordingly, embodiments of the present application also provide a computer program product, which includes a computer program/instructions, wherein when the computer program is executed by a processor, the processor is caused to implement the steps that can be executed by the server in the above embodiments.
As will be appreciated by one skilled in the art, embodiments of the present invention may be provided as a method, system, or computer program product. Accordingly, the present invention may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present invention may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It will be understood that each flow and/or block of the flow diagrams and/or block diagrams, and combinations of flows and/or blocks in the flow diagrams and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
In a typical configuration, a computing device includes one or more processors (CPUs), input/output interfaces, network interfaces, and memory.
The memory may include forms of volatile memory in a computer readable medium, Random Access Memory (RAM) and/or non-volatile memory, such as Read Only Memory (ROM) or flash memory (flash RAM). Memory is an example of a computer-readable medium.
Computer-readable media, including both non-transitory and non-transitory, removable and non-removable media, may implement information storage by any method or technology. The information may be computer readable instructions, data structures, modules of a program, or other data. Examples of computer storage media include, but are not limited to, phase change memory (PRAM), Static Random Access Memory (SRAM), Dynamic Random Access Memory (DRAM), other types of Random Access Memory (RAM), Read Only Memory (ROM), Electrically Erasable Programmable Read Only Memory (EEPROM), flash memory or other memory technology, compact disc read only memory (CD-ROM), Digital Versatile Discs (DVD) or other optical storage, magnetic cassettes, magnetic disk storage or other magnetic storage devices, or any other non-transmission medium that can be used to store information that can be accessed by a computing device. As defined herein, a computer readable medium does not include a transitory computer readable medium such as a modulated data signal and a carrier wave.
It should also be noted that the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising an … …" does not exclude the presence of other like elements in a process, method, article, or apparatus that comprises the element.
The above description is only an example of the present application and is not intended to limit the present application. Various modifications and changes may occur to those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present application should be included in the scope of the claims of the present application.