CN108616431B - Message processing method, device, equipment and machine readable storage medium - Google Patents
Message processing method, device, equipment and machine readable storage medium Download PDFInfo
- Publication number
- CN108616431B CN108616431B CN201810362692.2A CN201810362692A CN108616431B CN 108616431 B CN108616431 B CN 108616431B CN 201810362692 A CN201810362692 A CN 201810362692A CN 108616431 B CN108616431 B CN 108616431B
- Authority
- CN
- China
- Prior art keywords
- user information
- bras
- type
- message
- packet
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/28—Data switching networks characterised by path configuration, e.g. LAN [Local Area Networks] or WAN [Wide Area Networks]
- H04L12/2854—Wide area networks, e.g. public data networks
- H04L12/2856—Access arrangements, e.g. Internet access
- H04L12/2869—Operational details of access network equipments
- H04L12/287—Remote access server, e.g. BRAS
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/28—Data switching networks characterised by path configuration, e.g. LAN [Local Area Networks] or WAN [Wide Area Networks]
- H04L12/46—Interconnection of networks
- H04L12/4633—Interconnection of networks using encapsulation techniques, e.g. tunneling
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/28—Data switching networks characterised by path configuration, e.g. LAN [Local Area Networks] or WAN [Wide Area Networks]
- H04L12/46—Interconnection of networks
- H04L12/4641—Virtual LANs, VLANs, e.g. virtual private networks [VPN]
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/14—Session management
- H04L67/148—Migration or transfer of sessions
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/40—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass for recovering from a failure of a protocol instance or entity, e.g. service redundancy protocols, protocol state redundancy or protocol service redirection
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Telephonic Communication Services (AREA)
Abstract
The application provides a message processing method, a device, equipment and a machine readable storage medium, wherein the method comprises the following steps: after receiving a command for switching from a second BRAS-CP device to a first BRAS-CP device, sequentially acquiring each user information in a user information set from a database; before all user information in the user information set is acquired, if a first type of message sent by a BRAS-UP device is received, whether the user information corresponding to the first type of message exists in the user information already acquired by a first BRAS-CP device is judged; if not, preferentially acquiring the user information corresponding to the first type of message from the database, and processing according to the user information corresponding to the first type of message and the first type of message. By the technical scheme, the service can be provided for the user before the synchronization of the user information is completed, so that the time for user service interruption is reduced, and the user service experience is improved.
Description
Technical Field
The present application relates to the field of communications technologies, and in particular, to a method, an apparatus, a device, and a machine-readable storage medium for processing a packet.
Background
A BRAS (Broadband Remote Access Server) is used as an Access gateway and an IP network edge of a user, and since a control plane and a forwarding plane are tightly coupled together, performance processing is affected with each other, performance of the control plane and the forwarding plane cannot be fully exerted, and resource utilization rate is low.
In order to solve the above problems, a virtualized BRAS with a separate Control Plane and forwarding Plane is proposed at present, that is, a vbars architecture, where the Control Plane may be implemented by a BRAS-CP (BRAS Control Plane) device, and is located as a user Control management component, and may be used to implement functions of user Control management, user access Control, user authentication authorization charging, address management, configuration management, and the like. In addition, the forwarding Plane can be implemented by a BRAS-UP (broadband remote access server forwarding Plane) device, is positioned as a three-layer network edge and a user policy execution component, and can be used for implementing functions such as traffic forwarding, QoS (Quality of Service), traffic statistics, and the like.
At present, under a vBRAS architecture with separated transfer control, a plurality of BRAS-CP devices can be deployed, and when one BRAS-CP device (such as BRAS-CP device 1) fails, another BRAS-CP device (such as BRAS-CP device 2) can provide service for a user. However, before the BRAS-CP device 2 provides service for the user, the user information corresponding to the BRAS-CP device 1 needs to be synchronized first, and before the user information synchronization is completed, the BRAS-CP device 2 cannot provide service for the user, which causes service interruption and poor user experience.
Disclosure of Invention
The application provides a message processing method, which is applied to a first BRAS-CP device and comprises the following steps:
after receiving a command for switching from a second BRAS-CP device to a first BRAS-CP device, sequentially acquiring each user information in a user information set from a database; wherein each user information in the user information set is stored to the database by the second BRAS-CP device;
before all user information in the user information set is acquired, if a first type of message sent by a BRAS-UP device is received, whether the user information corresponding to the first type of message exists in the user information already acquired by a first BRAS-CP device is judged;
if not, preferentially acquiring the user information corresponding to the first type of message from the database, and processing according to the user information corresponding to the first type of message and the first type of message.
The application provides a message processing device, which is applied to a first BRAS-CP device and comprises:
the acquisition module is used for sequentially acquiring each user information in the user information set from the database after receiving a command of switching from the second BRAS-CP equipment to the first BRAS-CP equipment; wherein each user information in the user information set is stored to the database by the second BRAS-CP device;
a judging module, configured to, before acquiring all user information in the user information set, if a first type of packet sent by a BRAS-UP device is received, judge whether user information corresponding to the first type of packet exists in user information already acquired by a first BRAS-CP device;
and the processing module is used for preferentially acquiring the user information corresponding to the first type of message from the database and processing the first type of message according to the user information corresponding to the first type of message and the first type of message when the judgment result of the judgment module is negative.
A BRAS-CP device comprising a processor and a machine-readable storage medium storing machine-executable instructions executable by the processor; the processor is configured to execute machine-executable instructions to perform the method steps described above.
The present application provides a machine-readable storage medium having stored thereon machine-executable instructions that, when invoked and executed by a processor, cause the processor to perform the method steps described above.
Based on the above technical solution, in this embodiment of the application, when it is required to switch from the second BRAS-CP device to the first BRAS-CP device, the first BRAS-CP device sequentially obtains each user information in the user information set from the database, and before all the user information is obtained to the first BRAS-CP device, a message sent by the BRAS-UP device may be processed, instead of processing the message sent by the BRAS-UP device until all the user information is obtained to the first BRAS-CP device. Therefore, before the synchronization of the user information is completed, the service can be provided for the user, so that the service interruption time of the user is reduced, the service experience of the user is improved, the rapid switching between the BRAS-CP devices can be realized, and the reliability of the vBRAS architecture with separated transfer control is improved.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings needed to be used in the description of the embodiments of the present application or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments described in the present application, and other drawings can be obtained by those skilled in the art according to the drawings of the embodiments of the present application.
FIG. 1 is a schematic diagram of an application scenario in an embodiment of the present application;
fig. 2 is a flowchart of a message processing method according to an embodiment of the present application;
fig. 3 is a block diagram of a message processing apparatus according to an embodiment of the present application;
fig. 4 is a hardware structure diagram of a BRAS-CP device in an embodiment of the present application.
Detailed Description
The terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the application. As used in this application and the claims, the singular forms "a", "an", and "the" are intended to include the plural forms as well, unless the context clearly indicates otherwise. It should also be understood that the term "and/or" as used herein is meant to encompass any and all possible combinations of one or more of the associated listed items.
It is to be understood that although the terms first, second, third, etc. may be used herein to describe various information, such information should not be limited to these terms. These terms are only used to distinguish one type of information from another. For example, first information may also be referred to as second information, and similarly, second information may also be referred to as first information, without departing from the scope of the present application. Depending on the context, moreover, the word "if" is used may be interpreted as "at … …," or "when … …," or "in response to a determination.
The embodiment of the application provides a message processing method, which can be applied to a system comprising BRAS-CP equipment and BRAS-UP equipment, such as a vBRAS system with separated transfer control and the like. The BRAS-CP device is a device for implementing a control plane, and is used for implementing functions such as user control management, user access control, user authentication authorization charging, address management, configuration management and the like. The BRAS-UP device is a device for implementing a forwarding plane, and is used for implementing functions such as traffic forwarding, QoS, traffic statistics, ACL (Access control List) control, CAR (Committed Access Rate), route distribution, and the like.
Referring to fig. 1, which is a schematic view of an application scenario of the embodiment of the present application, in a vbrs system, a BRAS-UP device may be included, and at least two BRAS-CP devices may be included. In fig. 1, 1 BRAS-UP device and 2 BRAS-CP devices are taken as examples for explanation. Of course, in practical application, the number of BRAS-CP devices and the number of BRAS-UP devices may be more, and the number is not limited.
The host 111 may be a virtual machine, a PC (Personal Computer), a mobile terminal, a notebook Computer, or the like. The Authentication server 151 may be an AAA (Authentication Authorization Accounting) server, an RADIUS (Remote Authentication Dial In User Service) server, or the like. In addition, the management orchestrator 141 may be a mano (management and management), configured to implement management and control on the BRAS-CP device and the BRAS-UP device, and may call an API (application programming Interface) Interface through a Netconf (Network Configuration Protocol) Protocol to complete interaction with the BRAS-CP device and the BRAS-UP device. The Database 161 may be a Redis DBM (Database Manager), which is not limited to this type, for storing user information.
In one example, the BRAS-CP device may be a virtual BRAS-CP device in software, such as a virtual resource with BRAS service processing capability running on an X86 server, or a physical BRAS-CP device in hardware, such as a server with BRAS service processing capability. The BRAS-UP device may be a virtual BRAS-UP device in software, such as a virtual resource running on an X86 server, or a physical BRAS-UP device in hardware, such as a router or switch. Of course, the above only describes two expressions of BRAS-CP device and BRAS-UP device, which is not limited to this.
Moreover, when the BRAS-UP device is a virtual BRAS-UP device, different BRAS-UP devices may be deployed at the same server or at different servers. When the BRAS-CP device is a virtual BRAS-CP device and the BRAS-UP device is a virtual BRAS-UP device, the BRAS-CP device and the BRAS-UP device may be deployed in the same server or in different servers.
In one example, the BRAS-UP device may establish a tunnel (e.g., without limitation, an openflow tunnel, a VXLAN (Virtual Extensible Local Area Network) tunnel, etc.) with each BRAS-CP device. For example, a tunnel a may be established between the BRAS-UP device 121 and the BRAS-CP device 131, and a tunnel B may be established between the BRAS-UP device 121 and the BRAS-CP device 132. On the BRAS-UP device 121, the source address of the tunnel a is the address of the BRAS-UP device 121, and the destination address is the address of the BRAS-CP device 131; on the BRAS-CP device 131, the source address of the tunnel a is the address of the BRAS-CP device 131 and the destination address is the address of the BRAS-UP device 121. On the BRAS-UP device 121, the source address of the tunnel B is the address of the BRAS-UP device 121, and the destination address is the address of the BRAS-CP device 132; on the BRAS-CP device 132, the source address of the tunnel B is the address of the BRAS-CP device 132, and the destination address is the address of the BRAS-UP device 121.
In the above application scenario, the management orchestrator 141 may issue configuration information to the BRAS-UP device 121, which may include but is not limited to: VSI (Virtual Switch Instance) is vpnb, VXLAN identifies VXLAN100, AC (access Circuit) information, and AC information may include: the physical port is ten1/0/1, the service instance is 10, the VSI is vpnb, which means: the messages entering from the physical port ten1/0/1 can enter vpnb for forwarding, and because vpnb corresponds to vxlan100, the messages can be forwarded through the tunnel corresponding to vxlan 100. Assuming that the VXLAN identifier of the tunnel a is VXLAN100, the tunnel a may forward the packet.
In one example, the packets may be classified into three types, i.e., a first type of packet, a second type of packet, and a data packet. The first type of message is a Protocol message after the host passes authentication, for example, a charging message, a DHCP (Dynamic host configuration Protocol) continuation message, an offline message, and the like, and the type of the first type of message is not limited. The second type of message is a Protocol message before the host passes authentication, such as an ARP (address resolution Protocol) request message, an IPoE (Internet Protocol over ethernet, IP over ethernet) request message, a DHCP request message, and an authentication request message, and the type of the second type of message is not limited.
The following describes the processing of the first type of packet, the second type of packet, and the data packet with reference to specific situations.
In case one, after receiving the second type of packet sent by the host 111 from the physical port ten1/0/1, the BRAS-UP device 121 may forward the second type of packet through the tunnel a corresponding to the vxlan100, that is, send the second type of packet to the BRAS-CP device 131. After receiving the second type of packet, BRAS-CP device 131 may process the second type of packet to obtain user information corresponding to the second type of packet, that is, user information of host 111.
For example, assuming that the second type of message is an authentication request message, BRAS-CP device 131 may send the authentication request message to authentication server 151 after receiving the authentication request message, and authentication server 151 authenticates host 111 according to the authentication request message. If the authentication is passed, the BRAS-CP device 131 receives an authentication acceptance message returned by the authentication server 151, and if the authentication is not passed, the BRAS-CP device 131 receives an authentication rejection message returned by the authentication server 151, and the following description will take the authentication as an example.
In the authentication process, the BRAS-CP device 131 may obtain the user information of the host 111, such as the user information may include but is not limited to: IP address, Media Access Control (MAC) address, Virtual Local Area Network (VLAN) information, Virtual Private Network (VPN) information, VXLAN identifier, authorization information, user traffic, etc., where the authorization information includes, but is not limited to, one or any combination of the following: QoS strategy, speed limit strategy, statistical strategy, ACL strategy, charging strategy, etc. Of course, the user information is only an example, and is not limited thereto.
For the obtaining manner of the user information, the BRAS-CP device 131 may obtain the authorization information from the authentication server 151, for example, obtain the authorization information from the authentication server 151, the BRAS-CP device 131 may also collect the authorization information by itself, for example, obtain the IP address, the MAC address, the VLAN information, the VPN information, and the like of the host 111 from the authentication request packet, and the BRAS-CP device 131 may count the user traffic of the host 111, which is not limited to this.
Then, BRAS-CP device 131 may send the user information to BRAS-UP device 121, so that BRAS-UP device 121 performs transmission of data packet according to the user information. BRAS-CP device 131 may also send the subscriber information to database 161, with database 161 storing the subscriber information locally.
In case two, after receiving the data packet sent by the host 111, the BRAS-UP device 121 may forward the data packet according to the user information. For example, after receiving the user information, the BRAS-UP device 121 may obtain the contents such as the IP address, the MAC address, the VLAN information, the VPN information, and the VXLAN identifier from the user information, and generate a forwarding table entry based on the contents. Thus, after receiving the data packet sent by the host 111, the BRAS-UP device 121 may instruct forwarding of the data packet through the forwarding table entry.
Further, BRAS-UP device 121 may also obtain a QoS policy from the user information, and instruct BRAS-UP device 121 to perform QoS control through the QoS policy; acquiring a speed limit strategy from user information, and guiding BRAS-UP equipment 121 to realize CAR through the speed limit strategy; acquiring a statistical strategy from user information, and guiding the BRAS-UP device 121 to realize flow statistics through the statistical strategy; and obtaining the ACL strategy from the user information, and guiding the BRAS-UP equipment 121 to realize ACL control through the ACL strategy.
In case three, after receiving the first type of packet sent by the host 111 from the physical port ten1/0/1, the BRAS-UP device 121 may forward the first type of packet through the tunnel a corresponding to the vxlan100, that is, send the first type of packet to the BRAS-CP device 131. After receiving the first type of packet, BRAS-CP device 131 may obtain user information corresponding to the first type of packet, and process according to the user information and the first type of packet.
For example, assuming that the first type of packet is a charging packet, BRAS-CP device 131 may obtain the IP address of host 111 from the charging packet after receiving the charging packet, and query, from all locally stored user information, user information including the IP address, where the user information is user information corresponding to the charging packet. Then, BRAS-CP device 131 may perform charging processing on host 111 according to the charging packet and the user information, which is not limited herein. For example, the user traffic may be obtained from the charging packet, the charging policy may be obtained from the user information, and the host 111 may be charged according to the user traffic and the charging policy.
Then, BRAS-CP device 131 may also update the subscriber information to obtain updated subscriber information, and send the updated subscriber information to database 161, where database 161 locally stores the updated subscriber information. For example, BRAS-CP device 131 may update the user traffic in the user information by using the user traffic carried in the charging packet, for example, the user traffic is updated from user traffic 1 to user traffic 2, and the updating process is not limited. Then, the IP address of the host 111 and the updated user traffic 2 may be sent to the database 161, and the database 161 queries the user information including the IP address from all the locally stored user information and updates the user traffic 1 in the user information to the user traffic 2.
Based on the above process, the process of processing the packet by the BRAS-UP device 121 and the BRAS-CP device 131 is introduced, and in practical application, if the BRAS-CP device 132 is used to replace the BRAS-CP device 131, the method for processing the packet in the embodiment of the present application may refer to fig. 2, and may include the following steps:
When the second BRAS-CP device fails or a user needs to migrate from the second BRAS-CP device, the management orchestrator may send a command for switching from the second BRAS-CP device to the first BRAS-CP device, and the first BRAS-CP device may receive the command sent by the management orchestrator and learn, according to the command, that switching from the second BRAS-CP device to the first BRAS-CP device is needed.
If not, step 203 may be performed; if so, step 204 may be performed.
In the above embodiment, the first type of packet sent by the BRAS-UP device may be processed before all user information is acquired to the first BRAS-CP device, instead of processing the first type of packet sent by the BRAS-UP device after all user information is acquired to the first BRAS-CP device. Namely, before the user information synchronization is completed, the service can be provided for the user, the service interruption time of the user is reduced, the service experience of the user is improved, the BRAS-CP equipment can be quickly switched, and the reliability of the vBRAS architecture with separated transfer control is improved.
In an example, before the first BRAS-CP device obtains all the user information in the user information set, if the first BRAS-CP device receives a second type of message sent by the BRAS-UP device, the first BRAS-CP device may process according to the second type of message, obtain the user information corresponding to the second type of message, and send the user information corresponding to the second type of message to the BRAS-UP device, so that the BRAS-UP device forwards the data message according to the user information corresponding to the second type of message.
In the above embodiment, before all user information is acquired to the first BRAS-CP device, the second type of packet sent by the BRAS-UP device may be processed, instead of processing the second type of packet sent by the BRAS-UP device after all user information is acquired to the first BRAS-CP device. Namely, before the user information synchronization is completed, the service can be provided for the user, the service interruption time of the user is reduced, the service experience of the user is improved, the BRAS-CP equipment can be quickly switched, and the reliability of the vBRAS architecture with separated transfer control is improved.
In one example, after the first BRAS-CP device processes the first type of packet and the user information corresponding to the first type of packet, the first BRAS-CP device may further update the user information corresponding to the first type of packet to obtain updated user information, and store the updated user information in the first BRAS-CP device. However, after obtaining the updated subscriber information, the first BRAS-CP device may not send the updated subscriber information to the database, but after acquiring all the subscriber information in the subscriber information set, the first BRAS-CP device synchronizes the updated subscriber information to the database.
In an example, after the first BRAS-CP device obtains the subscriber information corresponding to the second type of packet, the subscriber information corresponding to the second type of packet may be further stored in the first BRAS-CP device. However, after obtaining the user information corresponding to the second type of packet, the first BRAS-CP device may not send the user information corresponding to the second type of packet to the database, but synchronize the user information corresponding to the second type of packet to the database after obtaining all the user information in the user information set.
In one example, after receiving the command for switching from the second BRAS-CP device to the first BRAS-CP device, the first BRAS-CP device may further set a timer for the second BRAS-CP device, and before the timer expires, the first BRAS-CP device determines that all the user information in the user information set is not acquired; when the timer is overtime, the first BRAS-CP equipment determines that all the user information in the user information set is acquired.
The aging time of the timer may be configured according to experience, for example, when the synchronization process of the user information is 1 to 2 minutes, it means that the first BRAS-CP device can acquire all the user information in the user information set to the local within 2 minutes, and therefore, the timeout time of the timer may be set to 2 minutes.
The above process is described in detail below with reference to the application scenario shown in fig. 1. In this application scenario, the first BRAS-CP device is the BRAS-CP device 132, and the second BRAS-CP device is the BRAS-CP device 131. Assuming that the BRAS-CP device 131 fails or that the BRAS-CP device 131 does not fail, but that a subscriber accessing the BRAS-CP device 131 needs to be migrated to the BRAS-CP device 132, the management orchestrator 141 may determine that the subscriber is served by the BRAS-CP device 132.
The management orchestrator 141 may issue configuration information to the BRAS-UP device 121, where the configuration information is used to switch a tunnel corresponding to the vxlan100 from a tunnel a to a tunnel B, and after receiving the first type of packet or the second type of packet, the BRAS-UP device 121 does not send the first type of packet or the second type of packet through the tunnel a any longer, but sends the first type of packet or the second type of packet through the tunnel B, so that the first type of packet or the second type of packet may be sent to the BRAS-CP device 132 instead of the BRAS-CP device 131.
The management orchestrator 141 may also send a command to the BRAS-CP device 132 to switch from the BRAS-CP device 131 to the BRAS-CP device 132, and the BRAS-CP device 132 may, upon receiving the command, sequentially retrieve each piece of subscriber information in the set of subscriber information from the database 161. For convenience of description, a set of all user information stored in the database 161 is referred to as a user information set, and the user information in the user information set is stored in the database 161 by the BRAS-CP device 131, as shown in table 1, for an example of the user information set, table 1 takes 5 pieces of user information as an example, and in an actual application, the number of the user information may be more.
TABLE 1
| Serial number | IP address | MAC address | VLAN information | VPN information | VXLAN identification | User traffic | … |
| 1 | IP address 1 | MAC Address 1 | VLAN information 1 | VPN information 1 | VXLAN sign 1 | User traffic 1 | … |
| 2 | IP address 2 | MAC Address 2 | VLAN information 2 | VPN information 2 | VXLAN sign 2 | User traffic 2 | … |
| 3 | IP address 3 | MAC Address 3 | VLAN information 3 | VPN information 3 | VXLAN sign 3 | User traffic 3 | … |
| 4 | IP address 4 | MAC Address 4 | VLAN information 4 | VPN information 4 | VXLAN sign 4 | User traffic 4 | … |
| 5 | IP address 5 | MAC Address 5 | VLAN information 5 | VPN information 5 | VXLAN sign 5 | User traffic 5 | … |
Assuming that the user information set stored in the database 161 is shown in table 1, the BRAS-CP device 132 first obtains the user information 1 in the user information set from the database 161, then obtains the user information 2 in the user information set from the database 161, and so on, until obtaining the user information 5 in the user information set from the database 161, so that all the user information in the user information set is successfully obtained locally.
Before all user information in the user information set is acquired to the BRAS-CP device 132, assuming that the BRAS-CP device 132 receives a second type of message sent by the BRAS-UP device 121, processing is performed according to the second type of message, and user information corresponding to the second type of message is acquired, and the user information corresponding to the second type of message is sent to the BRAS-UP device 121, so that the BRAS-UP device 121 forwards the data message according to the user information corresponding to the second type of message, and the processing process of the BRAS-UP device 121 is not described again.
After acquiring the user information corresponding to the second type of packet, the BRAS-CP device 132 may also locally store the user information corresponding to the second type of packet, but may not send the user information corresponding to the second type of packet to the database 161. Assuming that the BRAS-CP device 132 has already obtained the subscriber information 1 and the subscriber information 2 from the database 161, the subscriber information stored by the BRAS-CP device 132 may be as shown in table 2.
TABLE 2
| Serial number | IP address | MAC address | VLAN information | VPN information | VXLAN identification | User traffic | … | To be synchronized |
| 1 | IP address 1 | MAC Address 1 | VLAN information 1 | VPN information 1 | VXLAN sign 1 | User traffic 1 | … | |
| 2 | IP address 2 | MAC Address 2 | VLAN information 2 | VPN information 2 | VXLAN sign 2 | User traffic 2 | … | |
| 6 | IP address 6 | MAC Address 6 | VLAN information 6 | VPN information 6 | VXLAN sign 6 | User traffic 6 | … | Is that |
In table 2, the sequence numbers are used to distinguish different user information, and are only examples for convenience of description. "yes" to be synchronized means that the user information 6 is not currently synchronized to the database 161 and needs to be synchronized to the database 161 subsequently.
Before all user information in the user information set is acquired to the BRAS-CP device 132, assuming that the BRAS-CP device 132 receives a first type of message sent by the BRAS-UP device 121, the user information corresponding to the first type of message may be acquired, and processing may be performed according to the user information and the first type of message.
The acquiring, by the BRAS-CP device 132, the user information corresponding to the first type of packet may include: it is determined whether the user information corresponding to the first type of packet exists in the acquired user information (as shown in table 2). If yes, the user information corresponding to the first type of message can be obtained from the local user information. If not, the user information corresponding to the first type of message is preferentially acquired from the database 161.
For example, if the first type of packet carries an IP address 1, since the user information 1 including the IP address 1 exists in the user information shown in table 2, the BRAS-CP device 132 may obtain the user information 1 corresponding to the first type of packet from the local user information. For another example, if the first type of packet carries an IP address 5, since the user information shown in table 2 does not include the user information including the IP address 1, the BRAS-CP device 132 may preferentially acquire the user information corresponding to the first type of packet from the database 161. For example, prior to retrieving subscriber information 3 and subscriber information 4 from database 161, BRAS-CP device 132 may preferentially retrieve subscriber information 5 from database 161 and store subscriber information 5 locally, as shown in table 3.
TABLE 3
In one example, after BRAS-CP device 132 processes the user information and the first type of packet, the user information may be updated to obtain updated user information. For example, after processing according to the user information 5 and the first type of packet, the BRAS-CP device 132 may also update the user traffic 5 in the user information 5 to the user traffic 5 ', as shown in table 4, but after updating the user traffic 5 to the user traffic 5', the BRAS-CP device 132 may not send the user information 5 to the database 161.
TABLE 4
| Serial number | IP address | MAC address | VLAN information | VPN information | VXLAN identification | User traffic | … | To be synchronized |
| 1 | IP address 1 | MAC Address 1 | VLAN information 1 | VPN information 1 | VXLAN sign 1 | User traffic 1 | … | |
| 2 | IP address 2 | MAC Address 2 | VLAN information 2 | VPN information 2 | VXLAN sign 2 | User traffic 2 | … | |
| 6 | IP address 6 | MAC Address 6 | VLAN information 6 | VPN information 6 | VXLAN sign 6 | User traffic 6 | … | Is that |
| 5 | IP address 5 | MAC Address 5 | VLAN information 5 | VPN information 5 | VXLAN sign 5 | User traffic of 5' | … | Is that |
In an example, after all the user information in the user information set is acquired to the BRAS-CP device 132, the BRAS-CP device 132 may further acquire the user information 6 and the user information 5 to be synchronized to "yes", and synchronize the user information 6 and the user information 5 to the database 161, so that the database 161 updates the user information set shown in table 1 to the user information set shown in table 5, which is not limited to this process.
TABLE 5
| Serial number | IP address | MAC address | VLAN information | VPN information | VXLAN identification | User traffic | … |
| 1 | IP address 1 | MAC Address 1 | VLAN information 1 | VPN information 1 | VXLAN sign 1 | User traffic 1 | … |
| 2 | IP address 2 | MAC Address 2 | VLAN information 2 | VPN information 2 | VXLAN sign 2 | User traffic 2 | … |
| 3 | IP address 3 | MAC Address 3 | VLAN information 3 | VPN information 3 | VXLAN sign 3 | User traffic 3 | … |
| 4 | IP address 4 | MAC Address 4 | VLAN information 4 | VPN information 4 | VXLAN sign 4 | User traffic 4 | … |
| 5 | IP address 5 | MAC Address 5 | VLAN information 5 | VPN information 5 | VXLAN sign 5 | User traffic of 5' | … |
| 6 | IP address 6 | MAC Address 6 | VLAN information 6 | VPN information 6 | VXLAN sign 6 | User traffic 6 | … |
In an example, after all the user information in the user information set is acquired to the BRAS-CP device 132, the processing flow of the BRAS-CP device 132 may refer to the foregoing embodiment, and is not described herein again.
Based on the same application concept as the method, an embodiment of the present application further provides a message processing apparatus, which is applied to a first BRAS-CP device, and is shown in fig. 3, and is a structural diagram of the apparatus, where the apparatus includes:
an obtaining module 301, configured to obtain, in sequence, each piece of user information in a user information set from a database after receiving a command to switch from a second BRAS-CP device to a first BRAS-CP device; each user information in the user information set is stored to the database by the second BRAS-CP equipment;
a determining module 302, configured to determine, before acquiring all user information in the user information set, whether user information corresponding to a first type of packet exists in user information already acquired by a first BRAS-CP device if the first type of packet sent by a BRAS-UP device is received;
and the processing module 303 is configured to, if the determination result of the determining module is negative, preferentially obtain the user information corresponding to the first type of packet from the database, and process according to the user information corresponding to the first type of packet and the first type of packet.
The processing module 303 is further configured to, if the determination result of the determining module is yes, obtain user information corresponding to the first type of packet from the user information of the first BRAS-CP device, and process according to the user information corresponding to the first type of packet and the first type of packet.
The processing module 303 is further configured to, before acquiring all user information in the user information set, if a second type of packet sent by the BRAS-UP device is received, perform processing according to the second type of packet, and acquire user information corresponding to the second type of packet; and sending the user information corresponding to the second type of message to the BRAS-UP device.
The processing module 303 is further configured to update the user information corresponding to the first type of packet after processing is performed according to the user information corresponding to the first type of packet and the first type of packet, to obtain updated user information, and store the updated user information in the first BRAS-CP device; and after all the user information in the user information set is acquired, synchronizing the updated user information into the database.
In one example, the message processing apparatus further includes (not shown in the figure): the determining module is used for setting a timer for the second BRAS-CP equipment after receiving a command of switching from the second BRAS-CP equipment to the first BRAS-CP equipment, and determining that all user information in the user information set is acquired when the timer is over.
For a BRAS-CP device (e.g., a first BRAS-CP device) provided in the embodiment of the present application, from a hardware level, a schematic diagram of a hardware architecture of the BRAS-CP device may be as shown in fig. 4. The method comprises the following steps: a processor and a machine-readable storage medium storing machine-executable instructions executable by the processor; the processor is used for executing machine executable instructions to realize the message processing method. Further, the machine-readable storage medium stores machine-executable instructions that, when invoked and executed by a processor, cause the processor to implement the message processing method described above.
Here, a machine-readable storage medium may be any electronic, magnetic, optical, or other physical storage device that can contain or store information such as executable instructions, data, and so forth. For example, the machine-readable storage medium may be: a RAM (random access Memory), a volatile Memory, a non-volatile Memory, a flash Memory, a storage drive (e.g., a hard drive), a solid state drive, any type of storage disk (e.g., an optical disk, a dvd, etc.), or similar storage medium, or a combination thereof.
The systems, devices, modules or units illustrated in the above embodiments may be implemented by a computer chip or an entity, or by a product with certain functions. A typical implementation device is a computer, which may take the form of a personal computer, laptop computer, cellular telephone, camera phone, smart phone, personal digital assistant, media player, navigation device, email messaging device, game console, tablet computer, wearable device, or a combination of any of these devices.
For convenience of description, the above devices are described as being divided into various units by function, and are described separately. Of course, the functionality of the units may be implemented in one or more software and/or hardware when implementing the present application.
As will be appreciated by one skilled in the art, embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, embodiments of the present application 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 application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the application. 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.
Furthermore, 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.
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.
Claims (13)
1. A message processing method is applied to a first BRAS-CP device, and comprises the following steps:
after receiving a command for switching from a second BRAS-CP device to a first BRAS-CP device, sequentially acquiring each user information in a user information set from a database; wherein each user information in the user information set is stored to the database by the second BRAS-CP device;
before all user information in the user information set is acquired, if a first type of message sent by a BRAS-UP device is received, whether the user information corresponding to the first type of message exists in the user information already acquired by a first BRAS-CP device is judged;
if not, preferentially acquiring the user information corresponding to the first type of message from the database, and processing according to the user information corresponding to the first type of message and the first type of message.
2. The method of claim 1, wherein after determining whether the user information corresponding to the first type of packet exists in the user information that has been acquired by the first BRAS-CP device, the method further comprises:
if so, acquiring the user information corresponding to the first type of message from the user information of the equipment, and processing according to the user information corresponding to the first type of message and the first type of message.
3. The method of claim 1,
before acquiring all the user information in the user information set, the method further includes:
if a second type message sent by the BRAS-UP equipment is received, processing according to the second type message, and acquiring user information corresponding to the second type message;
and sending the user information corresponding to the second type of message to the BRAS-UP device.
4. The method of claim 1,
the receiving of the command for switching from the second BRAS-CP device to the first BRAS-CP device comprises:
receiving a command sent by a management orchestrator to switch from the second BRAS-CP device to the first BRAS-CP device; wherein the command is sent by the management orchestrator when the second BRAS-CP device fails or a user needs to migrate from the second BRAS-CP device.
5. The method according to claim 1 or 2,
after processing according to the user information corresponding to the first type of message and the first type of message, updating the user information corresponding to the first type of message to obtain updated user information, and storing the updated user information in the first BRAS-CP device;
and after all the user information in the user information set is acquired, synchronizing the updated user information into the database.
6. The method of claim 1, wherein after receiving a command to handoff from a second BRAS-CP device to a first BRAS-CP device, the method further comprises:
and setting a timer for the second BRAS-CP equipment, and determining that all user information in the user information set is acquired when the timer times out.
7. A message processing device is applied to a first BRAS-CP device, and comprises:
the acquisition module is used for sequentially acquiring each user information in the user information set from the database after receiving a command of switching from the second BRAS-CP equipment to the first BRAS-CP equipment; wherein each user information in the user information set is stored to the database by the second BRAS-CP device;
a judging module, configured to, before acquiring all user information in the user information set, if a first type of packet sent by a BRAS-UP device is received, judge whether user information corresponding to the first type of packet exists in user information already acquired by a first BRAS-CP device;
and the processing module is used for preferentially acquiring the user information corresponding to the first type of message from the database and processing the first type of message according to the user information corresponding to the first type of message and the first type of message when the judgment result of the judgment module is negative.
8. The apparatus of claim 7,
and the processing module is further configured to, when the determination result of the determining module is yes, obtain user information corresponding to the first type of packet from the user information of the first BRAS-CP device, and process according to the user information corresponding to the first type of packet and the first type of packet.
9. The apparatus of claim 7, wherein the processing module is further configured to, before acquiring all the user information in the user information set, if a second type of packet sent by the BRAS-UP device is received, process according to the second type of packet, and acquire user information corresponding to the second type of packet; and sending the user information corresponding to the second type of message to the BRAS-UP device.
10. The apparatus according to claim 7 or 8, wherein the processing module is further configured to update the user information corresponding to the first type of packet after processing according to the user information corresponding to the first type of packet and the first type of packet, to obtain updated user information, and store the updated user information in the first BRAS-CP device; and after all the user information in the user information set is acquired, synchronizing the updated user information into the database.
11. The apparatus of claim 7, further comprising:
the determining module is used for setting a timer for the second BRAS-CP equipment after receiving a command of switching from the second BRAS-CP equipment to the first BRAS-CP equipment, and determining that all user information in the user information set is acquired when the timer is over.
12. A BRAS-CP device comprising a processor and a machine-readable storage medium storing machine-executable instructions executable by the processor; the processor is configured to execute machine executable instructions to perform the method steps of any of claims 1-6.
13. A machine-readable storage medium having stored thereon machine-executable instructions which, when invoked and executed by a processor, cause the processor to perform the method steps of any of claims 1-6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810362692.2A CN108616431B (en) | 2018-04-20 | 2018-04-20 | Message processing method, device, equipment and machine readable storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810362692.2A CN108616431B (en) | 2018-04-20 | 2018-04-20 | Message processing method, device, equipment and machine readable storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN108616431A CN108616431A (en) | 2018-10-02 |
| CN108616431B true CN108616431B (en) | 2020-09-08 |
Family
ID=63660596
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810362692.2A Active CN108616431B (en) | 2018-04-20 | 2018-04-20 | Message processing method, device, equipment and machine readable storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108616431B (en) |
Families Citing this family (15)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111193644A (en) * | 2018-11-14 | 2020-05-22 | 中移（杭州）信息技术有限公司 | vBRAS service transmission method, device, terminal equipment and medium |
| CN111431787B (en) * | 2019-01-10 | 2022-02-11 | 中国移动通信有限公司研究院 | Tunnel establishment method and device and computer readable storage medium |
| CN110430115B (en) * | 2019-07-25 | 2021-08-06 | 新华三大数据技术有限公司 | Service recovery method, system, network device and computer readable storage medium |
| CN111654384A (en) * | 2019-09-27 | 2020-09-11 | 中兴通讯股份有限公司 | Main/standby switching method, BRAS (broadband remote Access Server) equipment and storage medium |
| CN113037599A (en) * | 2019-12-24 | 2021-06-25 | 中兴通讯股份有限公司 | Message processing method, device and storage medium |
| CN113067756A (en) * | 2020-01-02 | 2021-07-02 | 中国移动通信有限公司研究院 | Information transmission method, device, controller and access equipment |
| CN112511483B (en) * | 2020-03-02 | 2024-11-05 | 中兴通讯股份有限公司 | Data forwarding method, device and storage medium |
| CN112511326B (en) * | 2020-03-16 | 2024-02-02 | 中兴通讯股份有限公司 | Switching method, device, equipment and storage medium |
| CN112003731B (en) * | 2020-07-27 | 2022-07-12 | 新华三技术有限公司 | Configuration method and device |
| CN112104531B (en) * | 2020-08-25 | 2022-08-30 | 新华三技术有限公司 | Backup implementation method and device |
| CN112367252B (en) * | 2020-09-25 | 2022-05-27 | 新华三技术有限公司合肥分公司 | Method and device for realizing disaster recovery backup |
| CN112367197B (en) * | 2020-10-30 | 2022-08-30 | 新华三技术有限公司 | Network equipment migration method and device |
| CN112887137B (en) * | 2021-01-22 | 2022-05-24 | 新华三信息安全技术有限公司 | Method and device for realizing interface index consistency |
| CN113300878B (en) * | 2021-04-13 | 2022-10-21 | 北京华三通信技术有限公司 | Method and device for realizing data smoothing |
| CN115051970B (en) * | 2022-05-13 | 2024-09-13 | 中国电信股份有限公司 | Method and device for controlling user to be online, forwarding plane network element and medium |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101340374A (en) * | 2008-08-28 | 2009-01-07 | 杭州华三通信技术有限公司 | Method, system, apparatus for control transmission priority and network edge equipment |
| EP2073446A1 (en) * | 2007-12-21 | 2009-06-24 | British Telecmmunications public limited campany | Monitoring of network connections |
| CN101621409A (en) * | 2009-07-22 | 2010-01-06 | 中兴通讯股份有限公司 | Service control method, service control device and broadband access servers |
| CN102420818A (en) * | 2011-11-28 | 2012-04-18 | 中国联合网络通信集团有限公司 | Network access control method, device and system |
| CN103139139A (en) * | 2011-11-22 | 2013-06-05 | 华为技术有限公司 | Method and device of service migration between user equipment |
| CN106685818A (en) * | 2016-12-30 | 2017-05-17 | 北京华为数字技术有限公司 | Message feedback method and device |
| CN107733728A (en) * | 2017-11-30 | 2018-02-23 | 新华三技术有限公司 | Multi-computer back-up method and apparatus |
-
2018
- 2018-04-20 CN CN201810362692.2A patent/CN108616431B/en active Active
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| EP2073446A1 (en) * | 2007-12-21 | 2009-06-24 | British Telecmmunications public limited campany | Monitoring of network connections |
| CN101340374A (en) * | 2008-08-28 | 2009-01-07 | 杭州华三通信技术有限公司 | Method, system, apparatus for control transmission priority and network edge equipment |
| CN101621409A (en) * | 2009-07-22 | 2010-01-06 | 中兴通讯股份有限公司 | Service control method, service control device and broadband access servers |
| CN103139139A (en) * | 2011-11-22 | 2013-06-05 | 华为技术有限公司 | Method and device of service migration between user equipment |
| CN102420818A (en) * | 2011-11-28 | 2012-04-18 | 中国联合网络通信集团有限公司 | Network access control method, device and system |
| CN106685818A (en) * | 2016-12-30 | 2017-05-17 | 北京华为数字技术有限公司 | Message feedback method and device |
| CN107733728A (en) * | 2017-11-30 | 2018-02-23 | 新华三技术有限公司 | Multi-computer back-up method and apparatus |
Also Published As
| Publication number | Publication date |
|---|---|
| CN108616431A (en) | 2018-10-02 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108616431B (en) | Message processing method, device, equipment and machine readable storage medium | |
| CN108667695B (en) | Backup method and device for BRAS transfer control separation | |
| CN108512703B (en) | Backup method, device and equipment for BRAS transfer control separation and machine readable storage medium | |
| US8254249B2 (en) | Session resilience prioritization queuing mechanism to minimize and eliminate packet loss | |
| CN110430076B (en) | Route management method and device | |
| US10764742B1 (en) | Subscriber management with a stateless network architecture in a fifth generation (5G) network | |
| US10064096B2 (en) | Traffic distribution in heterogenous network environment | |
| US8804723B2 (en) | Efficient control packet replication in data plane | |
| CN109104364B (en) | Designated forwarder election method and device | |
| CN108737224B (en) | Message processing method and device based on micro-service architecture | |
| WO2020001514A1 (en) | Service processing | |
| CN108600109B (en) | Message forwarding method and device | |
| CN105871964B (en) | User Equipment (UE) processing method and device | |
| US9344386B2 (en) | Methods and apparatus for providing distributed load balancing of subscriber sessions in a multi-slot gateway | |
| CN109150808B (en) | Communication method, device and system | |
| CN108600069B (en) | Link switching method and device | |
| CN103631652A (en) | Method and system for achieving virtual machine migration | |
| US20190173790A1 (en) | Method and system for forwarding data, virtual load balancer, and readable storage medium | |
| CN109495526A (en) | A kind of file transmitting method, device, system, electronic equipment and storage medium | |
| CN106878052B (en) | User migration method and device | |
| CN108234358B (en) | Multicast message transmission method, device and machine readable storage medium | |
| CN112583947B (en) | DHCP processing method, device, equipment and machine readable storage medium | |
| WO2020046380A1 (en) | Systems and methods for integrating lte/5g access traffic into a dna fabric of a network | |
| CN108632125B (en) | Multicast table item management method, device, equipment and machine readable storage medium | |
| US20220360519A1 (en) | Method and device for packet forwarding |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |