CN114826979B - Network link quality acquisition method, device, system, equipment and storage medium - Google Patents

Abstract

The application provides a network link quality acquisition method, a device, a system, equipment and a storage medium. The method comprises the following steps: based on the MQTT transmission protocol, a first MQTT release message comprising a target acquisition task is sent to a probe proxy server through a probe analysis server, a corresponding probe receives the first MQTT release message in a subscription mode, a target network link is tested according to the first MQTT release message, target network link data obtained through testing is sent back to the corresponding probe analysis server through a second MQTT release message in a similar subscription mode, and therefore the probe analysis server can select to acquire the target network link data, and is connected with the probe analysis server and a plurality of probes through the probe proxy server, so that the operation pressure of the probe analysis server is reduced.

Description

Network link quality acquisition method, device, system, equipment and storage medium

technical field

The present application relates to communication technologies, and in particular to a method, device, system, equipment and storage medium for acquiring network link quality.

Background technique

Communication operators' probes use hardware probes, such as rack-mounted hardware probes, home gateway embedded probes, set-top boxes, and other hardware devices used to obtain network traffic-related parameters. Communication operators install probes in the network that needs to capture traffic to obtain data on the target network link, such as delay, throughput, packet loss rate, error rate, etc.

At present, communication operators need to adopt a distributed solution to monitor the network links of the entire network, deploy multiple probes in different locations, and after each probe collects data, send it to a remote probe analysis server to collect all probes The data. The probe analysis server performs network link analysis and long-term reports on the entire network based on the data collected by the received probes, and judges whether the network quality is good or bad. When the number of probes increases in this way of network link quality acquisition, the operating pressure of the probe analysis server will be increased.

Contents of the invention

The present application provides a network link quality acquisition method, device, system, equipment and storage medium, which are used to solve the problem of high operating pressure of the probe analysis server.

In a first aspect, the present application provides a method for acquiring network link quality, which is applied to a probe proxy server, and the probe proxy server is respectively connected to a probe analysis server and at least one probe, and the method includes:

The probe proxy server receives the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe analysis server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server , the target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link;

The probe proxy server sends the first MQTT publishing message to the first probe; the first probe is the probe of the at least one probe that is on the target network link and subscribes to the target collection task Needle;

The probe proxy server receives the second MQTT publishing message sent by the first probe, and the second MQTT publishing message is used to instruct the first probe to send the target network based on the target collection task. The link test obtains the link data of the target network;

Optionally, the variable header of the first MQTT publishing message carries the subject of the target collection task, and the payload of the first MQTT publishing message carries detailed information of the target collection task; The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries the target network link data.

Optionally, the probe proxy server sends the first MQTT publishing message to the first probe, including: the probe proxy server subscribes to the probe according to the topic of the collection task, and the target collection task determining the first probe from the at least one probe; the probe proxy server sends the first MQTT publishing message to the first probe.

Optionally, the probe proxy server receives a first MQTT subscription message sent by each of the probes, and the first MQTT subscription message is used to request to subscribe to the topic of the collection task corresponding to each of the probes; The probe proxy server constructs a subscription relationship between the subject of the collection task and the probe according to the first MQTT subscription message of each probe.

Optionally, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the method further includes:

The probe proxy server receives the second MQTT subscription message sent by the first probe; the second MQTT subscription message is used to subscribe to the third MQTT publishing message in batches; the third MQTT publishing message The payload is a preset size, and is used for the first probe to obtain the bandwidth of the target network link based on the reception of the third MQTT message; the probe proxy server sends the first probe Send the third MQTT publishing message in batches.

Optionally, the probe proxy server receives the third MQTT publishing messages sent in batches by the probe analysis server.

Optionally, the probe proxy server receives a third MQTT subscription message sent by the probe analysis server, and the third MQTT subscription message is used to request to subscribe to the subject of the target collection data; the probe The proxy server constructs a subscription relationship between the probe analysis server and the subject of target data collection according to the third MQTT subscription message of the probe analysis server;

The probe proxy server sends the second MQTT publishing message to the probe analysis server, including: the probe proxy server sends a message to the probe analysis server according to the subscription relationship between the probe analysis server and the subject of the target data collection The probe analysis server sends the second MQTT publishing message.

Optionally, both the first MQTT release message and the second MQTT release message are sent in a QoS2 manner.

Optionally, the first probe is a software probe deployed on the client of the target network link, the first probe is connected to the probe proxy server using websockets, and the first probe An MQTT message is transmitted between the needle and the probe proxy server through an HTTP upgrade process.

In a second aspect, the present application provides a method for acquiring network link quality, which is applied to a probe analysis server, and the probe proxy server is respectively connected to the probe analysis server and at least one probe, and the method includes:

The probe analysis server sends a first MQTT publishing message based on the message queue telemetry transport protocol to the probe proxy server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link;

The probe analysis server receives the second MQTT publishing message sent by the probe proxy server, and the second MQTT publishing message is used to instruct the first probe to analyze the target network link based on the target collection task. The target network link data is obtained through the test, and the first probe is a probe that is in the target network link and subscribes to the target collection task among the at least one probe;

The probe analysis server obtains the quality result of the target network link according to the second MQTT publishing message.

Optionally, the variable header of the first MQTT publishing message carries the subject of the target collection task, and the payload of the first MQTT publishing message carries detailed information of the target collection task; The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries the target network link data.

Optionally, before the probe analysis server receives the second MQTT publishing message sent by the probe proxy server, it also includes:

The probe analysis server sends a third MQTT subscription message to the probe proxy server, and the third MQTT subscription message is used to request to subscribe to the subject of the target collection data.

Optionally, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the method further includes:

The probe analysis server sends the third MQTT publishing message in batches to the probe proxy server, and the payload of the third MQTT publishing message is a preset size, which is used for the first probe based on the first 3. Acquiring the bandwidth of the target network link according to the reception status of the MQTT publishing message.

Optionally, both the first MQTT release message and the second MQTT release message are sent in a QoS2 manner.

Optionally, the target network link between the first probe and the target node has a first routing path and a second routing path, and the first probe to the target test node currently adopts the first route path, the target collection task is used to collect target network link data when a second routing path is used between the first probe and the target test node;

Before the probe analysis server sends the first MQTT publishing message to the probe proxy server, the method also includes:

The probe analysis server sends a first route switching request of the target network link to the network management system, where the first route switching request is used to request switching from the first routing path to the second routing path;

After the probe analysis server receives the second MQTT publishing message sent by the probe proxy server, it also includes:

The probe analysis server sends a second route switching request of the target network link to the network management system, where the second route switching request is used to request switching from the second routing path to the first routing path.

Optionally, when the quality result of the target network link indicates that there is a problem with the target network link, the probe analysis server acquires the monitoring data of the target node from the network management system; the probe analysis server obtains the monitoring data of the target node according to The monitoring data generates a quality analysis report of the target network link; the probe analysis server outputs the quality analysis report.

In a third aspect, the present application provides a method for acquiring network link quality, which is applied to probes, and the probe proxy server is respectively connected to the probe analysis server and at least one of the probes. The method includes:

The first probe of the at least one probe receives the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe proxy server, and the first MQTT publishing message is used to instruct the probe to analyze A target collection task subscribed by the server, the target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link;

The first probe tests the target network link based on the target acquisition task to obtain target network link data;

The second MQTT publishing message sent by the first probe to the probe proxy server, so that the probe proxy server forwards the second MQTT publishing message to the probe analysis server, and the first Two MQTT publishing messages are used to indicate the target network link data.

Optionally, the variable header of the first MQTT publishing message carries the subject of the target collection task, and the payload of the first MQTT publishing message carries detailed information of the target collection task; The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries the target network link data.

Optionally, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the first probe collects the target network based on the target network The link test obtains the link data of the target network, including:

The first probe receives the third MQTT publishing message sent in batches by the probe proxy server; the payload of the third MQTT publishing message is a preset size; the first probe is based on the third The receiving status of the MQTT publishing message acquires the bandwidth of the target network link.

Optionally, the target network link data includes the bandwidth of the target network link, and the target node is not the probe proxy server; the first probe detects the target network based on the target collection task The link test obtains the link data of the target network, including:

The first probe uses preset speed measurement software to measure the speed of the target network link to obtain the bandwidth of the target network link.

Optionally, both the first MQTT release message and the second MQTT release message are sent in a QoS2 manner.

Optionally, the first probe is a software probe deployed on the client of the target network link, the first probe is connected to the probe proxy server using websockets, and the first probe An MQTT message is transmitted between the needle and the probe proxy server through an HTTP upgrade process.

In a fourth aspect, the present application provides a network link quality acquisition device, the probe proxy server is respectively connected to the probe analysis server and at least one probe; the device is applied to the probe proxy server, including:

The receiving module is configured to receive the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe analysis server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link;

A sending module, configured to send a first MQTT publishing message to a first probe; the first probe is a probe in at least one probe that is on a target network link and subscribes to the above-mentioned target collection task;

The receiving module is further configured to receive a second MQTT publishing message sent by the first probe, and the second MQTT publishing message is used to instruct the first probe to send information to the target network based on the target collection task. The link test obtains the link data of the target network;

The sending module is further configured to send the second MQTT publishing message to the probe analysis server.

In the fifth aspect, the present application provides a network link quality acquisition device, the probe proxy server is respectively connected to the probe analysis server and at least one probe; the device is applied to the probe analysis server, including:

A sending module, configured to send a first MQTT publishing message based on the message queue telemetry transport protocol to the probe proxy server, the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, the The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link;

A receiving module, configured to receive a second MQTT publishing message sent by the probe proxy server, where the second MQTT publishing message is used to instruct the first probe to test the target network link based on the target collection task Obtaining target network link data, the first probe is a probe in the at least one probe that is in the target network link and subscribes to the target collection task;

An acquiring module, configured to acquire the quality result of the target network link according to the second MQTT publishing message.

In a sixth aspect, the present application provides a network link quality acquisition device, the probe proxy server is respectively connected to the probe analysis server and at least one probe; the device is applied to the probe, including:

The receiving module is configured to receive the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe proxy server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link;

A collection module, configured to test the target network link based on the target collection task to obtain target network link data;

The sending module is configured to send the second MQTT publishing message to the probe proxy server, so that the probe proxy server forwards the second MQTT publishing message to the probe analysis server, and the second The MQTT publish message is used to indicate the target network link data.

In a seventh aspect, the present application provides a probe proxy server, including: a processor, a communication interface, and a memory; the processor is respectively connected to the communication interface and the memory; the memory stores computer-executed instructions; The communication interface communicates with external devices; the processor executes computer-executable instructions stored in the memory, so as to implement the method as described in the first aspect.

In an eighth aspect, the present application provides a probe analysis server, including: a processor, a communication interface, and a memory; the processor is respectively connected in communication with the communication interface and the memory; the memory stores computer-executable instructions; The communication interface communicates with the external device; the processor executes the computer-executed instructions stored in the memory, so as to implement the method as described in the second aspect.

In a ninth aspect, the present application provides one, including: a processor, a communication interface, and a memory; the processor is respectively connected to the communication interface and the memory in communication; the memory stores computer-executable instructions; the communication interface Communicating and interacting with external devices; the processor executes computer-executed instructions stored in the memory, so as to implement the method as described in the third aspect.

In the tenth aspect, the present application provides a network link quality acquisition system, including: the probe proxy server as described in the seventh aspect, the probe analysis server as described in the eighth aspect, and at least one of the probes; wherein, the probe proxy server is respectively connected to the probe analysis server and the at least one probe.

In an eleventh aspect, the present application provides a computer-readable storage medium, where computer-executable instructions are stored in the computer-readable storage medium, and when the computer-executable instructions are executed by a processor, they are used to implement the first aspect to the third aspect. The network link quality acquisition method described in any one of the aspects.

The network link quality acquisition method, device, system, equipment and storage medium provided by this application distribute the first MQTT release report to the probe and the probe analysis server respectively through the MQTT transmission protocol based on the QoS2 level protocol. The method of publishing the message with the second MQTT enables the probe analysis server to choose to obtain specific target network link data and connects to multiple probe analysis servers and multiple probes through the probe proxy server, reducing the number of connections per probe. A probe analyzes the operating pressure and storage pressure of the server, and ensures that MQTT messages can reach the receiving end stably, avoiding the risk of test packet loss and improving the stability of network link testing. In addition, by using the Websockets connection method, the data transmission between the software probe and the probe proxy server can bypass the firewall of the user terminal device that prohibits Ping, thereby completing the network link quality acquisition method provided by this application, thereby avoiding The user terminal device needs to release the Ping function due to the need to perform collection tasks, and thus suffers from malicious attacks from the external network. The method for obtaining network link quality provided by the application also sends a route switching request to the network management system through the probe analysis server, tests the redundant network links in the metropolitan area network, and obtains the quality of all network links in the metropolitan area network , so as to obtain more comprehensive target network link data in the target network link, making the operator's data analysis results more comprehensive.

Description of drawings

The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the application and together with the description serve to explain the principles of the application.

FIG. 1 is a schematic structural diagram of a network link quality acquisition system provided by the prior art;

FIG. 2 is a schematic structural diagram of a network link quality acquisition system provided by the present application;

FIG. 3 is a schematic flowchart of a method for acquiring network link quality provided by the present application;

FIG. 4 is a schematic flow diagram of a transmission method for a target acquisition task provided by the present application;

FIG. 5A is a schematic diagram of a message format of a first MQTT publishing message provided by the present application;

FIG. 5B is a schematic diagram of a message format of a first MQTT subscription message provided by the present application;

FIG. 6 is a schematic structural diagram of a device for acquiring network link quality provided by the present application;

FIG. 7 is a schematic structural diagram of another network link quality acquisition device provided by the present application;

FIG. 8 is a schematic structural diagram of another network link quality acquisition device provided by the present application;

FIG. 9 is a schematic diagram of a probe proxy server provided by the present application;

FIG. 10 is a schematic diagram of a probe analysis server provided by the present application;

Fig. 11 is a schematic diagram of a probe provided in the present application.

By means of the above drawings, specific embodiments of the present application have been shown, which will be described in more detail hereinafter. These drawings and text descriptions are not intended to limit the scope of the concept of the application in any way, but to illustrate the concept of the application for those skilled in the art by referring to specific embodiments.

Detailed ways

Reference will now be made in detail to the exemplary embodiments, examples of which are illustrated in the accompanying drawings. When the following description refers to the accompanying drawings, the same numerals in different drawings refer to the same or similar elements unless otherwise indicated. The implementations described in the following exemplary embodiments do not represent all implementations consistent with this application. Rather, they are merely examples of apparatuses and methods consistent with aspects of the present application as recited in the appended claims.

For ease of understanding, firstly, the architecture of the network link quality acquisition system used in the prior art will be described.

Figure 1 is a schematic diagram of the architecture of a network link quality acquisition system provided by the prior art. As shown in Figure 1, the network link quality acquisition system provided by the communication operator includes: a probe analysis server, and multiple probes .

The multiple probes mentioned here can be deployed on multiple target network links, the target network links can be links of communication networks, and the connections between multiple network links can be wireless or wired. To establish a network connection between multiple terminal devices for communication.

The plurality of probes may be rack-mounted hardware probes, home gateway embedded probes, set-top boxes, and other hardware devices used to obtain parameters related to network traffic. The probe is deployed on the aforementioned network link, and is used to obtain data of the network link corresponding to the deployment location. The data is used to reflect information such as network connectivity and network speed of the network link, such as network delay, data throughput, packet loss rate, error rate, and the like. The probe can also communicate with the probe analysis server to transmit the acquired data to the probe analysis server for the probe analysis server to analyze the data of the network link and determine the fault node of the network link according to the analysis result , to facilitate the maintenance of network links and ensure the normal communication of the network.

The probe analysis server may be, for example, a communication operator deployment server, communicates with the above-mentioned multiple probes through the above-mentioned multiple network links, receives the data obtained by the above-mentioned multiple probes, and analyzes the data of the multiple network links. Analyze and output the analysis results.

However, under the current network link quality acquisition system architecture, the data test of the network link and the data collection process of the probe are all initiated by the probe analysis server. When the number of network links is large, more probes need to be deployed correspondingly, resulting in an increase in the number of probes communicating with the probe analysis server and increasing the operating pressure of the probe analysis server.

Message Queuing Telemetry Transport (MQTT) is a "lightweight" communication protocol based on the publish/subscribe (publish/subscribe) model, which is built on the TCP/IP protocol. Using the MQTT protocol for data transmission, it can provide real-time and reliable message services for connected remote devices with very little code and limited bandwidth, and can use the publish/subscribe message mode to provide one-to-many message publishing and decoupling applications . As an instant messaging protocol with low overhead and low bandwidth occupation, the MQTT protocol has a wide range of applications in the Internet of Things, small devices, and mobile applications.

In view of this, this application proposes a method for applying the MQTT protocol to network link quality acquisition. The system architecture adopted in this application will be described below.

As shown in FIG. 2 , the network link quality acquisition system proposed in this application includes: at least one probe analysis server, a probe proxy server, and at least one probe.

The network link quality acquisition system proposed in this application transmits data based on Message Queuing Telemetry Transport (MQTT). Wherein, the probe proxy server is a broker (Broker) identity in the MQTT protocol, and the probe and the probe analysis server can respectively be a publisher (Publish) or a subscriber (Subscribe) identity in the MQTT protocol in different scenarios. For example, when the probe analysis server or the probe sends a publishing message to the probe proxy server, it is the identity of the publisher in the MQTT protocol. When the probe analysis server or the probe receives the corresponding publishing message subscribed by itself forwarded by the probe proxy server, it is the subscriber identity in the MQTT protocol.

Probes can be hardware probes or software probes. A software probe is an application program installed on the client side of the target network link to obtain network traffic-related parameters in the form of software. There is a communication connection between the above-mentioned probe and the probe proxy server, and the subscription message sent by the probe proxy server is received through the MQTT protocol, or the publish message is sent to the probe proxy server through the MQTT protocol.

The probe proxy server communicates with multiple probes and multiple probe analysis servers respectively, and transmits publishing messages and subscription messages through the MQTT protocol. For example, the probe proxy server can receive the release message sent by the probe analysis server, and send the release message to the probes that have subscribed to the release message, or receive the release message sent by the probe, and send the release message to the The publishing message is sent to the probe analysis server that has subscribed to the publishing message.

The probe analysis server may be the probe analysis server in the above-mentioned prior art, which is used to initiate a network condition collection request for a specified network link and receive and analyze network condition information, so as to provide the operator with network condition data of the specified network link Analyze the results.

FIG. 2 is a schematic diagram of a probe analysis server, a probe proxy server, a hardware probe and a software probe as examples. In this scenario, the probe analysis server can send an MQTT publishing message carrying the topic of the collection task to the probe proxy server, and the probe proxy server distributes the message to the probes that have subscribed to the topic according to the subscription relationship of multiple probes. MQTT publishes messages, thereby reducing the number of probes that each probe proxy server receives feedback data, and reducing the operating pressure of each probe proxy server.

It should be understood that in the network link quality acquisition system proposed in the present application, there may also be multiple probe analysis servers, and there may also be multiple probe proxy servers, wherein the probe analysis server may communicate with each probe proxy server Different probe proxy servers are connected to different probes. Through the above method, the number of probes connected to the probe proxy server can be reduced, so as to further reduce the operating pressure of each probe proxy server and further reduce the number of probes connected to the proxy server. The operating pressure of the proxy server.

The following embodiments illustrate the proposed network link quality acquisition method by taking a probe proxy server connected to a probe analysis server and a system structure of multiple probes as an example.

The following describes in detail the technical solution of the present application and how the technical solution of the present application solves the above technical problems according to the network link quality acquisition system architecture shown in FIG. 2 and specific embodiments. The following specific embodiments may be combined with each other, and the same or similar concepts or processes may not be repeated in some embodiments. Embodiments of the present application will be described below in conjunction with the accompanying drawings.

FIG. 3 is a schematic flow diagram of a method for acquiring network link quality provided by an embodiment of the present application. As shown in FIG. 3 , the method of this embodiment includes the following steps:

S301. The probe analysis server sends a first MQTT publishing message to the probe proxy server, the first MQTT publishing message is used to instruct the probe analysis server to subscribe to a target collection task, and the target collection task is used to collect the probe To target network link data between target nodes, the target network link data is used to characterize the quality of the target network link.

Correspondingly, the probe proxy server receives the first MQTT publishing message.

The first MQTT publishing message may include: a fixed header, a variable header and a payload.

In a possible manner, the variable header of the first MQTT publishing message may include a subject carrying a target collection task, and the target collection task may indicate a corresponding collection task that needs to be executed on the target network link. The subject of the target collection task may include the path of the network link where the probe is located, or may include preset identification information, and the identification information may be used to represent the subscription relationship of the probes that subscribe to the first MQTT publishing message.

The payload of the first MQTT release message carries the detailed information of the above-mentioned target acquisition task, and the detailed information may include at least one test item for characterizing the quality of the target network link, such as bandwidth test, Ping test, and Trace test.

Wherein, the bandwidth test can be used to test the network bandwidth of the target network link, and determine the data transmission speed of the target network link. The Ping test can be used to test whether data packets can reach a specific host or server through a specified data transmission protocol, and determine the packet loss rate and network delay of the target network link. The Trace test can be used to test the forwarding path from the source node (that is, the node that sends data) to the destination node (that is, the node that receives the data), and record information such as the delay from the source node to each intermediate destination node along the path.

Through the detailed information carried in the payload, the probe corresponding to the target network link can be instructed to test the target network link according to the above transmission parameters, and obtain the target network link data corresponding to each test item to determine the bandwidth of the target network link Value, packet loss rate, error rate and other link quality indicators. It should be understood that this embodiment only uses the above test items as an example for description, and does not limit the test items for testing the link quality of the target network.

It should be understood that the above is only an example of a possible implementation of the first MQTT publishing message, and this application does not limit how to publish the target collection task through the first MQTT publishing message.

S302. The probe proxy server sends a first MQTT publishing message to the first probe; the first probe is a probe in at least one probe that is on a target network link and subscribes to a target collection task.

Correspondingly, the first probe receives the first MQTT publishing message.

Wherein, the probe proxy server can confirm the subscription relationship of the probe according to the topic of the target collection task included in the first MQTT release message, and confirm the corresponding probe in the network link to be collected through the subscription relationship. When the probe proxy server determines the first probe that has subscribed to the target collection task from all the connected probes, it sends the above-mentioned first MQTT publishing message to the first probe.

In a possible implementation manner, the subject of the target collection task may include the path of the network link where the probe is located, and the subscription relationship may be based on the location of the network link where the probe corresponds to the path of the target network link, And, the theme of the target acquisition task is determined. The subscription relationship may be preset when the probe is deployed, or may be determined by an MQTT subscription message sent by the probe to the probe proxy server during the working process. The probe can generate an MQTT subscription message including topic information that needs to be subscribed according to the network link node or path information where the probe is located, and the probe proxy server can use the subscription topic information in the MQTT subscription message, and, MQTT subscription message, and the subscription relationship built with the topic of the target collection task.

In another possible implementation manner, the above-mentioned subscription relationship may be determined according to a mapping relationship of identification information preset in the subject of the target collection task. The mapping relationship may be preset when the probe is deployed, or the mapping relationship of identification information may be manually input during the working process of the probe. The probe proxy server builds a subscription relationship with the topic of the target collection task according to the identification information included in the MQTT subscription message generated by the probe and including the topic information to be subscribed to.

S303. The first probe tests the target network link based on the target acquisition task to obtain transmission parameters.

According to the received first MQTT release message, the first probe determines the detailed information of the target acquisition task carried in the payload in the first MQTT release message, and determines the test items that need to be tested on the quality of the target network link, according to The test item tests the target network link, so as to obtain the target network link data corresponding to the test item. It should be understood that the test method for testing the target network link may be any corresponding test method in the prior art, which is not limited in this application.

In a possible implementation manner, when the target network link is a trunk network link between the first probe and the probe proxy server, and the test target IP address of the probe is the probe proxy server IP address, the target The method for performing a bandwidth test on a network link may be that the first probe sends a second MQTT subscription message to the probe proxy server, and the second MQTT subscription message may be based on a subscription relationship similar to the foregoing for batch subscription of the third MQTT Publishing a message, the third MQTT publishing message can be preset on the probe proxy server, or can be obtained by the probe proxy server from the probe analysis server. The received second MQTT subscription message is requested from the probe analysis server. The probe proxy server sends the third MQTT publishing message in batches to the first probe, and the payload of the third MQTT publishing message is a preset size, for example, it may be a fully loaded MQTT message. The aforementioned fully loaded MQTT message means that in addition to the fixed header, the storage space of the message is fully occupied by arbitrary data in the variable header and payload of the MQTT message. The probe proxy server obtains the network bandwidth transmission parameter of the target network link by obtaining the receiving time when the first probe receives the third MQTT release message and the third MQTT release message of the preset size, and the calculation formula can be : Network bandwidth transmission parameter=preset size of the third MQTT release message/receiving time of the third MQTT release message.

In another possible implementation manner, when the target network link is a branch network link between the first probe and other network devices, and the test target IP address of the probe is not the IP address of the probe proxy server, the probe Preset speed measurement software can be run, the speed measurement software can be existing speed measurement software in the prior art, and the network bandwidth transmission parameters of the target network link can be read according to the speed measurement results of the speed measurement software.

S304. The first probe sends a second MQTT publishing message to the probe proxy server.

Correspondingly, the probe proxy server receives the second MQTT publishing message. The second MQTT publishing message is used to instruct the first probe to test the target network link based on the target collection task to obtain target network link data.

The first probe sends the second MQTT publishing message to the probe proxy server through the MQTT protocol, so that the probe proxy server forwards the second MQTT publishing message to the probe analysis server.

In a possible manner, the second MQTT publishing message is composed of a fixed header, a variable header, and a payload. The variable header of the second MQTT publishing message carries the topic of the target collection data, and the target collection data can instruct the first probe to test the target network link where it is located to obtain the target network link data. The subject of the target collection data may include the path of the network link where the first probe is located, which is used to indicate the data source of the target collection data. The payload of the second MQTT release message carries the target network link test target network link data corresponding to the aforementioned target acquisition task, which data, for example, may include bandwidth test results, Ping test results, Trace test results, etc. for characterizing the target network The test result of link quality is specifically related to the detailed information of the target acquisition task in the first MQTT release message.

It should be understood that the above is only an example of a possible implementation of the second MQTT publishing message, and this application does not limit how to publish the target collection data through the second MQTT publishing message.

S305. The probe proxy server sends the second MQTT publishing message to the probe analysis server.

Correspondingly, the probe analysis server receives the second MQTT publishing message.

The probe proxy server sends the second MQTT publishing message to the probe analysis server corresponding to the subject of the target data collection according to the subject of the target collection data in the received second MQTT publishing message.

According to the subscription behavior of the probe analysis server, the probe proxy server sends the second MQTT publishing message to the probe analysis server that has subscribed to the subject of the target collected data. The subscription behavior of the probe analysis server can be confirmed according to the topic of the target collection task contained in the first MQTT publishing message it sends to the probe proxy server, that is, the probe analysis server can send a message to the probe according to the topic of the target collection task. A subscription message is sent to the proxy server, so as to subscribe to the second MQTT publishing message forwarded by the subsequent probe proxy server and including the subject of the target collection data. The time node when the probe analysis server generates the subscription message and sends the subscription message to the probe proxy server can be before the probe analysis server sends the first MQTT release message to the probe proxy server, or it can be in the probe analysis After the server sends the first MQTT publishing message to the probe proxy server.

The probe analysis server obtains the quality result of the target network link according to the target network link data included in the received second MQTT release message, and the quality result can indicate whether there is a problem with the target network link, for example, network connection status, Packet loss rate, error rate, etc. If there is a problem in the target network, the probe proxy server can obtain the monitoring data of the target node with the problem from the network management system. The network management system can be, for example, a network management system used by an operator to manage network links. Taking the integrated network management system as an example, the monitoring data can represent the network configuration information and data of the target node. The probe analysis server performs data analysis on the network quality of the target network link according to the acquired monitoring data of the target node and generates corresponding analysis results.

As shown in Figure 3, the method provided by the embodiment of the present application is based on the MQTT transmission protocol. The probe analysis server sends the first MQTT release message including the target collection task to the probe proxy server, and the corresponding probes are subscribed. Receive the first MQTT release message, and test the target network link according to the first MQTT release message, and send the target network link data through the second MQTT release message through the second MQTT release message, and send it back to the corresponding Probe analysis server, so that the probe analysis server can choose to obtain the target network link data, and through the connection between the probe proxy server and the probe analysis server and multiple probes, the operating pressure of the probe analysis server is reduced .

Continue to refer to the existing network link quality acquisition system shown in FIG. 1 . At present, the probe is connected to the probe analysis server through Hyper Text Transfer Protocol (Hyper Text Transfer Protocol, HTTP), File Transfer Protocol (File Transfer Protocol, FTP), Trivial File Transfer Protocol (Trivial File Transfer Protocol, TFTP), etc. Yes, the probe can collect the data of its network link according to the collection command of the probe analysis server, and feed back the collection result data to the probe analysis server after the collection is completed. In this transmission mode, when there is a problem with the network link, there is a risk of packet loss in the test result data packet sent by the probe to the probe analysis server, and the probe analysis server cannot analyze the problem node of the network link.

Therefore, the present application provides a method for transmitting a target collection task to solve the above problems. Fig. 4 is a schematic flow chart of a transmission method for a target collection task provided by an embodiment of the present application. In this embodiment, the subject of the target collection task of the first MQTT release message includes the path of the network link where the probe is located as an example. , as shown in Figure 4, the method of the present embodiment includes the following steps:

S401. The probe analysis server sends a first MQTT publishing message to the probe proxy server.

The detailed content of the first MQTT publishing message sent by the probe analysis server to the probe proxy server is as described in step S301. Exemplarily, the format of the first MQTT publishing message is shown in FIG. 5A.

Wherein, the "MQTT control message type (3)" in the fixed header of the first MQTT publishing message means that the message type is an MQTT publishing message. DUP refers to the retransmission flag, which indicates whether the message is requested to be sent for the first time, or is a retransmission of an earlier message request. If the DUP flag is set to 0, it indicates that this is the first request to send this publication message. If the DUP flag is set to 1, it indicates that this may be a retransmission of an earlier message request. QoS is the above-mentioned QoS level protocol, and this application uses QoS2 level as an example for illustration.

Among them, the QoS levels of the MQTT protocol can be divided into QoS0, QoS1, and QoS2. Among them, if the MQTT message is transmitted at the QoS0 level, no matter whether the receiving end receives the MQTT message, the source end of the message will only send the MQTT message once; if the MQTT message is transmitted at the QoS1 level, the source end of the message needs to Send the MQTT message continuously according to the preset time interval until it is determined that the receiving end has received the MQTT message at least once; when transmitting the MQTT message at the QoS2 level, the source of the message needs to continuously send the MQTT message according to the preset time interval until it is determined that the receiving end has received the MQTT message only once. This application can use QoS1 level or QoS2 level, or other methods that can ensure that the receiving end receives the MQTT message to carry out the message transmission process. Based on the QoS2 level, this application can ensure that the MQTT message can be accurately sent to the receiving end, and the receiving end only receives the MQTT message once, so as to avoid the packet loss problem caused by the network link failure, and can also avoid receiving the MQTT message at the receiving end. Receive multiple redundant MQTT messages to reduce the operating pressure on the receiving end.

The variable header of the first MQTT publishing message includes the subject of the target collection task, and the subject of the target collecting task can be used by the subscriber to subscribe to the first MQTT publish message, that is, to establish a subscription relationship with the subscriber.

The payload of the first MQTT publishing message includes detailed information of the target collection task, so as to indicate items that need to be collected or tested by the target collection task.

S402. The probe proxy server receives the first MQTT publish message, and receives the first MQTT subscribe message sent by the first probe.

The time when the probe proxy server receives the first MQTT subscription message sent by the first probe can be at the time node when the probe is deployed, or when the probe analysis server sends the first MQTT publish message to the probe proxy server any time before. The above-mentioned first MQTT subscription message refers to a message conforming to the subscription message format in the MQTT control message specification. Exemplarily, the format of the first MQTT subscription message is as shown in FIG. 5B.

Among them, the "MQTT control message type (3)" in the fixed header of the first MQTT subscription message refers to the message type as an MQTT subscription message, and the content interpretation of other parts in the fixed header is consistent with the first MQTT release message. I won't repeat them here. The message identifier contained in the variable header of the first MQTT subscription message is a non-zero 16-bit message identifier, which is used to identify different messages.

The payload of the first MQTT subscription message includes a topic filter list, and the topic filter list includes all topic names that need to be subscribed to in the first MQTT subscription message, and the QoS level that each topic name needs to correspond to. The above topic name may include any wildcard conforming to the MQTT protocol, so as to confirm the subscription relationship through the wildcard and the topic of the target collection task included in the first MQTT publishing message.

S403. The probe proxy server sends the first MQTT release message to the first probe that has subscribed to the first MQTT release message according to the first MQTT release message and the first MQTT subscription message.

The first probe may subscribe to the corresponding MQTT publish message from the probe proxy server through the topic filter list in the first MQTT subscription message sent to the probe proxy server as in step S402. Wherein, the probe proxy server can match the topic in the variable header of the MQTT publishing message according to the topic filter list in an MQTT subscription message, and determine the successfully matched topic as the MQTT publishing message subscribed by the first probe. message. In this embodiment, the first probe subscribes to the first MQTT publish message from the probe proxy server through the first MQTT subscribe message. After completing the subscription, the probe proxy server sends the first MQTT publishing message to the first probe that has subscribed to the first MQTT publishing message.

Optionally, the probe can also modify the subject of the corresponding collection task that the probe needs to subscribe to by resending the changed first MQTT subscription message.

According to a transmission method of a target collection task shown in FIG. 4 , the one-to-many data transmission between the probe proxy server and the probe and the probe analysis server respectively can be completed. In addition, the transmission method of the target collection data from the probe to the probe proxy server and then to the probe analysis server can adopt the same subscription process as that in Figure 4, thus enabling the many-to-many communication between the probe and the probe analysis server . In addition, this method adopts the QoS2 level for data transmission of MQTT publishing messages and MQTT subscription messages, ensuring that MQTT messages can be accurately sent to the probe analysis server, and the probe analysis server only receives the MQTT message once , so as to avoid the packet loss problem caused by network link failure, and also prevent the receiving end from receiving multiple redundant MQTT messages, which reduces the operating pressure of the probe analysis server and ensures the transmission of the target collection task stability.

Continue to refer to the existing network link quality acquisition system shown in FIG. 1 . At present, there are multiple routing paths uplinking between the network link nodes of the MAN, that is, there are multiple backup routing paths between the same starting routing node and the same ending routing node, so as to ensure In the case of a routing path failure, the network can still be connected through other backup routing paths. The network link quality acquisition method in the prior art can only obtain data on the currently used routing path, and cannot obtain data on other redundant backup routing paths. The data.

In view of this, the present application proposes a network link quality acquisition method for redundant backup routing paths based on the network link quality acquisition system shown in FIG. 2 .

In a possible scenario, the target network link between the first probe and the target node has a first routing path and a second routing path, and the first probe to the target test node currently adopts the first routing path, The target collection task is used to collect target network link data when the second routing path is used between the first probe and the target test node.

Probe analysis server Before the probe proxy server sends the first MQTT release message, the probe analysis server can extract the content of the target collection task, which can include the routing path to be collected for the target collection task, and the routing path to be collected includes A plurality of routing nodes to be collected, for example, the routing path to be collected, that is, the second routing path is "routing node 1.1—routing node 2.2—routing node 3.2—routing node 4.1".

The probe analysis server sends a first route switching request of the target network link to the network management system according to the content of the extracted target acquisition task, the first route switching request is used to request switching from the first routing path to the second routing path, the above-mentioned The first route switch request may include the above-mentioned second route path information. After receiving the first route switching request, the network management system may send a static route to the routing node on the routing path to indicate that the routing path adopted by the target test node is the second routing path. If the IPs on the test path are all on the same network segment, the static route is a 32-bit static route; if the IPs on the test path are on different network segments, the static route can be a static route with other bits. Taking the IP on the test path as an example, the format of the above 32-bit static route is "IP address of ip route-static routing node 4.1\subnet mask\IP address of next-hop routing node".

Exemplarily, the currently used first routing path is "routing node 1.1-routing node 2.1-routing node 3.1-routing node 4.1", taking the switching of one-hop routing node in the routing path as an example, if the current routing node is routing node 1.1 , the network management system sends a 32-bit static route to routing node 1.1, indicating that the routing path that the next hop of routing node 1.1 needs to take is routing node 2.2. The format of the 32-bit static routing can be, for example, "ip route-static routing node 4.1's IP address\subnet mask\routing node 2.2's IP address".

After the probe analysis server receives the first MQTT subscription message sent by the probe proxy server, the probe analysis server sends the second route switching request of the target network link to the network management system to instruct the network management system to delete the sent 32-bit static route , so that the currently used routing path is switched from the second routing path back to the first routing path, so that after the target collection task of the network link is completed for the backup routing path, the network link in this area can resume testing during data transmission The previous routing path will not affect the normal use of the network links in this area.

In this embodiment, the content of the target acquisition task is extracted by the probe analysis server, and a route switching request is made to the network management system. According to the 32-bit static route issued by the network management system, the routing path is guided to perform data transmission according to the required routing path, thereby obtaining the target Collect the target network link data required by the task, so that all redundant routing paths in the metropolitan area network can be tested, and all target network link data can be obtained, so that the quality of the network link can be comprehensively evaluated.

In addition, at present, the client port of some user terminal equipment does not allow the equipment or server to use the Internet packet explorer (Packet Internet Groper, Ping) function, that is, the Ping prohibition function is enabled, such as some Internet dedicated line access services (Dedicated Internet Access, DIA) In order to prevent network attacks, users set their firewalls to ban ping. When the firewall disables ping, the firewall does not allow the hardware probe to send the acquired data of the target network link to the probe proxy server in the form of MQTT packets. Therefore, the probe analysis server cannot obtain the target collection data of the hardware probe, and can only generally evaluate the quality of the target network link as "poor quality". However, if the client does not enable the Ping function because it needs to perform collection tasks, there is a risk of being attacked by an external network.

However, since the WebSocket transmission protocol uses the 80 (HTTP) or 443 (HTTPS) ports allowed by the client firewall to communicate, the client firewall will think that the WebSocket data frame is an HTTP message for the client internal network to access the external network, thus Allow WebSocket data frames to pass through the firewall. Therefore, when the client disables ping, the MQTT message can be passed through the firewall by encapsulating the MQTT message into a WebSocket data frame.

Therefore, the present application proposes a method for obtaining network link quality when the client is prohibited from pinging by using a software probe. The detailed content of the method may be as follows, for example:

First of all, in order to support the transmission method of MQTT over WebSockets, it is necessary to artificially deploy the environment of MQTT over WebSockets on the probe proxy server and the client whose Ping is disabled. Among them, a JavaScript library supporting MQTT over WebSockets needs to be installed on the probe proxy server, so that the probe proxy server supports the transmission form of MQTT over WebSockets. It is also necessary to deploy a software probe to a Ping-forbidden client, use the software probe installation program to install a browser that supports WebSockets on the Ping-forbidden client, and install a JavaScript library that supports MQTT over WebSockets at the same time. Make the browser an MQTT client. In addition, the software probe installation program can also install network testing tools on the client at the same time, such as Ping, Trace, MTR and other tools, so that the software probe can test the target network link.

Secondly, after completing the deployment of the MQTT over WebSockets operating environment, the software probe can use the above-mentioned installed network testing tools to perform target collection tasks on the target network link. After completing the target collection task, the software probe can use the WebSockets browser to encapsulate the MQTT publishing message including the target collection data in one or more WebSocket data frames, and send the MQTT publishing message in the form of WebSocket data frames to the probe proxy server.

The above method of encapsulating the MQTT message in the WebSocket data frame through the software probe, and using the WebSocket transmission protocol to pass through the firewall of the client that prohibits Ping can realize the transmission of the MQTT message when the client prohibits Ping, thus completing While improving the quality of the network link, it also avoids the problem that the client needs to release the Ping function due to the collection task, thus suffering from malicious attacks from the external network.

The network link quality acquisition method provided by the above-mentioned embodiments of the present application is based on the MQTT transmission protocol of the QoS2 level protocol, and the probe proxy server distributes the first MQTT release message and the second MQTT release message to the probe and the probe analysis server respectively. The way of the packet enables the probe analysis server to choose to obtain specific target network link data and connect to multiple probe analysis servers and multiple probes through the probe proxy server, reducing the cost of each probe analysis server. Operating pressure and storage pressure, and ensure that MQTT messages can reach the receiving end stably, avoiding the risk of test packet loss, and improving the stability of network link testing. In addition, by using the Websockets connection method, the data transmission between the software probe and the probe proxy server can bypass the firewall of the user terminal device that prohibits Ping, thereby completing the network link quality acquisition method provided by this application, thereby avoiding The user terminal device needs to release the Ping function due to the need to perform collection tasks, and thus suffers from malicious attacks from the external network. The method for obtaining network link quality provided by the application also sends a route switching request to the network management system through the probe analysis server, tests the redundant network links in the metropolitan area network, and obtains the quality of all network links in the metropolitan area network , so as to obtain more comprehensive target network link data in the target network link, making the operator's data analysis results more comprehensive.

FIG. 6 is a schematic structural diagram of an apparatus for acquiring network link quality provided by an embodiment of the present application. The probe proxy server is connected to the probe analysis server and at least one probe; the network link quality acquiring device is applied to the probe proxy server.

As shown in FIG. 6 , the device for acquiring network link quality includes: a receiving module 11 and a sending module 12 . Optionally, the apparatus for acquiring network link quality may include, for example, at least one of the following modules: a processing module 13 .

The receiving module 11 is configured to receive the first MQTT publishing message sent by the probe analysis server, the first MQTT publishing message is used to indicate the target collection task subscribed by the probe analysis server, and the target collection task is used to collect the probe A transmission parameter of the target network link between the target nodes, where the transmission parameter of the target network link is used to characterize the quality of the above target network link.

The sending module 12 is configured to send the first MQTT publishing message to the first probe. The first probe is a probe in at least one probe that is on the target network link and subscribes to the above-mentioned target collection task. Exemplarily, the first MQTT release message is sent in QoS2 mode; the first probe is a software probe deployed on the client of the target network link, and the first probe and the probe proxy server are connected by websockets, An MQTT message is transmitted between the first probe and the probe proxy server through an HTTP upgrade process.

The receiving module 11 is also configured to receive the second MQTT publishing message sent by the above-mentioned first probe, and the second MQTT publishing message is used to instruct the first probe to test the above-mentioned target network link based on the above-mentioned target collection task. The transmission parameters. Exemplarily, the second MQTT publish message is sent in a QoS2 manner.

The sending module 12 is further configured to send the second MQTT publishing message to the probe analysis server.

Optionally, the variable header of the first MQTT publishing message carries the subject of the target collection task, and the payload of the first MQTT publishing message carries detailed information of the target collection task. The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries transmission parameters. The processing module 13 is configured to determine the above-mentioned first probe from at least one probe according to the mapping relationship between the subject of the collection task and the probe, and the subject of the target collection task. The sending module 12 is specifically configured to send the above-mentioned first MQTT publishing message to the first probe.

Optionally, the receiving module 11 is also configured to receive the first MQTT subscription message sent by each probe, and the first MQTT subscription message is used to request to subscribe to the topic of the collection task corresponding to each of the above-mentioned probes; the processing module 13, It is also used to construct a subscription relationship between the subject of the collection task and the probe according to the first MQTT subscription message of each of the above probes.

Optionally, the receiving module 11 is also configured to receive the second MQTT subscription message sent by the first probe, the second MQTT subscription message is used to subscribe to the third MQTT publishing message in batches; the third MQTT publishing message The payload is a preset size, and is used for the first probe to obtain the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message. The sending module 12 is further configured to send the third MQTT publishing message to the first probe in batches.

Optionally, the receiving module 11 is also configured to receive the third MQTT publishing messages sent in batches by the probe analysis server.

Optionally, the receiving module 11 is also used to receive the third MQTT subscription message sent by the probe analysis server, the third MQTT subscription message is used to request to subscribe to the subject of the target data collection; the processing module 13 is also used to According to the third MQTT subscription message of the analysis server, the subscription relationship between the probe analysis server and the subject of the target data collection is constructed; Send the second MQTT publishing message to the analysis server.

Optionally, the transmission parameters of the target network link include the bandwidth of the target network link, the target node is a probe proxy server, and the sending module 12 is also used to send the third MQTT publishing message in batches to the above-mentioned first probe . The processing module 13 is further used for the first probe to acquire the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message. The payload of the third MQTT publishing message is a preset size.

The device for obtaining network link quality provided by the embodiment of the present application can perform the actions of the probe proxy server in the above method embodiment, and its implementation principle and technical effect are similar, and will not be repeated here. The acquisition of network link quality may be, for example, a probe proxy server, or a chip of the probe proxy server, for example, a processor.

FIG. 7 is a schematic structural diagram of an apparatus for acquiring network link quality provided by an embodiment of the present application. The network link quality acquisition device includes a probe proxy server and a probe analysis server, and multiple probes are connected; the device is applied to the probe analysis server.

As shown in FIG. 7 , the device for acquiring network link quality includes: a sending module 21 , a receiving module 22 , and an acquiring module 23 . Optionally, the apparatus for acquiring network link quality may include, for example, at least one of the following modules: a generation module 24 and an output module 25 .

The sending module 21 is configured to send the first MQTT publishing message to the probe proxy server, the first MQTT publishing message is used to indicate the target collection task subscribed by the probe analysis server, and the target collection task is used to collect the link between the probe and the target node. The target network link data between target network link data is used to characterize the quality of the target network link. Exemplarily, the variable header of the first MQTT publishing message carries the subject of the target collection task, and the payload of the first MQTT publishing message carries the detailed information of the target collection task; the first MQTT publishing message is sent in QoS2 mode .

The receiving module 22 is configured to receive the second MQTT publishing message sent by the probe proxy server, and the second MQTT publishing message is used to instruct the first probe to test the target network link based on the target collection task to obtain the target network link data, The first probe is a probe in at least one probe that is on the target network link and subscribes to the target collection task. Exemplarily, the variable header of the second MQTT publishing message carries the subject of the target data collection, and the payload of the second MQTT publishing message carries the target network link data; the second MQTT publishing message is sent in QoS2 mode.

The acquiring module 23 is configured to acquire the quality result of the target network link according to the second MQTT publishing message.

Optionally, the sending module 21 is also used to send the third MQTT subscription message to the probe proxy server before the receiving module 22 receives the second MQTT publishing message sent by the probe proxy server, the third MQTT subscription message It is used to request to subscribe to the subject of the target data collection; the probe proxy server constructs a subscription relationship between the probe analysis server and the subject of target data collection according to the third MQTT subscription message of each probe analysis server.

Optionally, the target network link data includes the bandwidth of the target network link, the target node is a probe proxy server, and the sending module 21 is also used to send the third MQTT publishing message in batches to the probe proxy server, and the third MQTT publishes The payload of the message is a preset size, and is used for the first probe to obtain the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message.

Optionally, the target network link between the first probe and the target node has a first routing path and a second routing path, the first probe to the target test node currently adopts the first routing path, and the target collection task is used to collect When the second routing path is used between the first probe and the target test node, the target network link data; the sending module 21 is also used to send the target network to the network management system before sending the first MQTT release message to the probe proxy server A first route switching request for the link, where the first route switching request is used to request switching from the first routing path to the second routing path. After the probe analysis server receives the second MQTT publishing message sent by the probe proxy server, the sending module 21 is also used to send the second route switching request of the target network link to the network management system, and the second route switching request is used to request from The second routing path is switched to the first routing path.

Optionally, the obtaining module 23 is configured to obtain the monitoring data of the target node from the network management system when the quality result of the target network link indicates that there is a problem with the target network link. The generating module 24 is configured to generate a quality analysis report of the target network link according to the monitoring data. The output module 25 is used to output the quality analysis report.

The device for obtaining network link quality provided by the embodiment of the present application can execute the actions of the probe analysis server in the above method embodiment, and its implementation principle and technical effect are similar, and will not be repeated here. The acquisition of network link quality may be, for example, a probe analysis server, or a chip of the probe analysis server, for example, a processor.

FIG. 8 is a schematic structural diagram of an apparatus for acquiring network link quality provided by an embodiment of the present application. The network link quality acquisition device includes a probe proxy server and a probe analysis server, and a plurality of probes are connected; the device is applied to the probes.

As shown in FIG. 8 , the network link quality acquiring device includes: a receiving module 31 , a collecting module 32 , and a sending module 33 . Optionally, the device for acquiring network link quality may include at least one of the following modules, for example:

The receiving module 31 is configured to receive the first MQTT publishing message sent by the probe proxy server, the first MQTT publishing message is used to indicate the target collection task subscribed by the probe analysis server, and the target collection task is used to collect the probe to the target node The target network link data between the target network link data is used to characterize the quality of the target network link. Exemplarily, the variable header of the first MQTT publishing message carries the subject of the target collection task, the payload of the first MQTT publishing message carries the detailed information of the target collection task, and the first MQTT publishing message is sent in QoS2 mode .

The collection module 32 is configured to test the target network link based on the target collection task to obtain target network link data.

The sending module 33 is configured to send a second MQTT publishing message to the probe proxy server, so that the probe proxy server forwards the second MQTT publishing message to the probe analysis server, and the second MQTT publishing message is used to indicate the target network chain road data. Exemplarily, the variable header of the second MQTT publishing message carries the subject of the target data collection, the payload of the second MQTT publishing message carries the target network link data, and the second MQTT publishing message is sent in QoS2 mode.

Optionally, the first probe is a software probe deployed on the client of the target network link, websockets connection is adopted between the first probe and the probe proxy server, and the connection between the first probe and the probe proxy server is MQTT packets are transmitted through the HTTP upgrade process.

Optionally, the target network link data includes the bandwidth of the target network link, and the target node is a probe proxy server; the first probe tests the target network link based on the target collection task to obtain the target network link data, and the receiving module 31, It is also used to receive the third MQTT publishing message sent in batches by the probe proxy server; the payload of the third MQTT publishing message is a preset size. The acquisition module 32 is further configured to acquire the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message.

Optionally, the target network link data includes the bandwidth of the target network link, and the target node is a non-probe proxy server; the first probe tests the target network link based on the target collection task to obtain the target network link data, and the acquisition module 32, It is also used to measure the speed of the target network link through the preset speed measurement software, and obtain the bandwidth of the target network link.

The device for acquiring network link quality provided by the embodiments of the present application can perform the actions of the probes in the above method embodiments. The implementation principles and technical effects are similar, and will not be repeated here. The acquisition of the network link quality may be, for example, a probe, or a chip of the probe, for example, a processor.

FIG. 9 is a schematic diagram of a probe proxy server provided by the present application. As shown in FIG. 9 , the probe proxy server 900 may include: at least one processor 901 , a memory 902 and a communication interface 903 .

The memory 902 is used to store programs. Specifically, the program may include program code, and the program code includes computer operation instructions.

The memory 902 may include a high-speed RAM memory, and may also include a non-volatile memory (non-volatile memory), such as at least one disk memory.

The processor 901 is configured to execute the computer-executed instructions stored in the memory 902, so as to implement the method for acquiring network link quality described in the foregoing method embodiments. Wherein, the processor 901 may be a central processing unit (Central Processing Unit, referred to as CPU), or a specific integrated circuit (Application Specific Integrated Circuit, referred to as ASIC), or configured to implement one or more of the embodiments of the present application integrated circuit.

The processor 901 can communicate and interact with external devices through the communication interface 903. The external device can be, for example, a probe analysis server or at least one probe. In specific implementation, if the communication interface 903, the memory 902 and the processor 901 are implemented independently, then The communication interface 903, the memory 902, and the processor 901 may be connected to each other through a bus to complete mutual communication. The bus may be an Industry Standard Architecture (Industry Standard Architecture, ISA for short) bus, a Peripheral Component Interconnect (PCI for short) bus, or an Extended Industry Standard Architecture (EISA for short) bus. The bus can be divided into address bus, data bus, control bus, etc., but it does not mean that there is only one bus or one type of bus.

Optionally, in terms of specific implementation, if the communication interface 903, the memory 902, and the processor 901 are integrated and implemented on one chip, the communication interface 903, the memory 902, and the processor 901 may complete communication through an internal interface.

FIG. 10 is a schematic diagram of a probe analysis server provided by the present application. As shown in FIG. 10 , the probe analysis server 1000 may include: at least one processor 1001 , a memory 1002 and a communication interface 1003 .

The memory 1002 is used to store programs. Specifically, the program may include program code, and the program code includes computer operation instructions.

The memory 1002 may include a high-speed RAM memory, and may also include a non-volatile memory (non-volatile memory), such as at least one magnetic disk memory.

The processor 1001 is configured to execute the computer-executed instructions stored in the memory 1002, so as to implement the method for acquiring network link quality described in the foregoing method embodiments. Wherein, the processor 1001 may be a central processing unit (Central Processing Unit, referred to as CPU), or a specific integrated circuit (Application Specific Integrated Circuit, referred to as ASIC), or configured to implement one or more of the embodiments of the present application integrated circuit.

The processor 1001 can communicate and interact with external devices through the communication interface 1003. The external device can be, for example, a probe proxy server or a network management system. In terms of specific implementation, if the communication interface 1003, the memory 1002, and the processor 1001 are implemented independently, then the communication interface 1003, the memory 1002, and the processor 1001 may be connected to each other through a bus to complete mutual communication. The bus may be an Industry Standard Architecture (Industry Standard Architecture, ISA for short) bus, a Peripheral Component Interconnect (PCI for short) bus, or an Extended Industry Standard Architecture (EISA for short) bus. The bus can be divided into address bus, data bus, control bus, etc., but it does not mean that there is only one bus or one type of bus.

Optionally, in specific implementation, if the communication interface 1003, the memory 1002 and the processor 1001 are integrated and implemented on one chip, then the communication interface 1003, the memory 1002 and the processor 1001 may communicate through internal interfaces.

Fig. 11 is a schematic diagram of a probe provided in this application. As shown in FIG. 11 , the probe 1100 may include: at least one processor 1101 , a memory 1102 and a communication interface 1103 .

The memory 1102 is used to store programs. Specifically, the program may include program code, and the program code includes computer operation instructions.

The memory 1102 may include a high-speed RAM memory, and may also include a non-volatile memory (non-volatile memory), such as at least one magnetic disk memory.

The processor 1101 is configured to execute the computer-executed instructions stored in the memory 1102, so as to implement the method for acquiring network link quality described in the foregoing method embodiments. Wherein, the processor 1101 may be a central processing unit (Central Processing Unit, referred to as CPU), or a specific integrated circuit (Application Specific Integrated Circuit, referred to as ASIC), or configured to implement one or more of the embodiments of the present application integrated circuit.

The processor 1101 can communicate and interact with external devices through the communication interface 1103. The external device can be, for example, a probe proxy server. The processor 1102 and the processor 1101 may be connected to each other through a bus and communicate with each other. The bus may be an Industry Standard Architecture (Industry Standard Architecture, ISA for short) bus, a Peripheral Component Interconnect (PCI for short) bus, or an Extended Industry Standard Architecture (EISA for short) bus. The bus can be divided into address bus, data bus, control bus, etc., but it does not mean that there is only one bus or one type of bus.

Optionally, in terms of specific implementation, if the communication interface 1103, the memory 1102, and the processor 1101 are integrated and implemented on one chip, then the communication interface 1103, the memory 1102, and the processor 1101 may communicate through an internal interface.

The present application also provides a network link quality acquisition system as shown in FIG. 2 , the system includes: a probe proxy server, a probe analysis server, and at least one probe. The probe proxy server is respectively connected to the probe analysis server and at least one probe.

Wherein, the probe proxy server is used to perform the actions of the probe proxy server described in the above method embodiments, the probe analysis server is used to perform the actions of the probe analysis server described in the above method embodiments, and the probe is used to perform the above-mentioned The actions of the probes described in the method embodiments enable the network link quality acquisition system to use the MQTT protocol to acquire the network link quality. The implementation principle and technical effect are similar to those of the above method embodiments, and will not be repeated here.

The present application also provides a computer-readable storage medium, which may include: U disk, mobile hard disk, read-only memory (ROM, Read-Only Memory), random-access memory (RAM, Random AccessMemory) Various media that can store program codes, such as a magnetic disk or an optical disk, specifically, the computer-readable storage medium stores program instructions, and the program instructions are used in the methods in the above-mentioned embodiments.

Finally, it should be noted that the above embodiments are only used to illustrate the technical solution of the present application, rather than to limit it. Although the present application has been described in detail with reference to the foregoing embodiments, those skilled in the art should understand that: they can still modify the technical solutions described in the foregoing embodiments, or perform equivalent replacements for some or all of the technical features . However, these modifications or replacements do not make the essence of the corresponding technical solutions depart from the scope of the technical solutions of the embodiments of the present application.

Claims (27)

1. A method for acquiring network link quality, characterized in that it is applied to a probe proxy server, and the probe proxy server is respectively connected to a probe analysis server and at least one probe, and the method comprises: The probe proxy server receives the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe analysis server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server , the target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link; The probe proxy server sends the first MQTT publishing message to the first probe; the first probe is the probe of the at least one probe that is on the target network link and subscribes to the target collection task Needle; The probe proxy server receives the second MQTT publishing message sent by the first probe, and the second MQTT publishing message is used to instruct the first probe to send the target network based on the target collection task. The link test obtains the link data of the target network; The probe proxy server sends the second MQTT publishing message to the probe analysis server; Wherein, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the method also includes: The probe proxy server receives the second MQTT subscription message sent by the first probe; the second MQTT subscription message is used to subscribe to the third MQTT publishing message in batches; the third MQTT publishing message The payload is a preset size, and is used for the first probe to obtain the bandwidth of the target network link based on the reception of the third MQTT release message; The probe proxy server sends third MQTT publishing messages to the first probe in batches. 2. The method according to claim 1, wherein the variable header of the first MQTT release message carries the subject of the target collection task, and the payload of the first MQTT release message carries a Detailed information of the target acquisition task; The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries the target network link data. 3. The method according to claim 2, wherein the probe proxy server sends the first MQTT publishing message to the first probe, comprising: The probe proxy server determines the first probe from the at least one probe according to the subscription relationship between the subject of the collection task and the probe, and the subject of the target collection task; The probe proxy server sends the first MQTT publishing message to the first probe. 4. method according to claim 3, is characterized in that, described method also comprises: The probe proxy server receives the first MQTT subscription message sent by each of the probes, and the first MQTT subscription message is used to request to subscribe to the subject of the acquisition task corresponding to each of the probes; The probe proxy server constructs a subscription relationship between the subject of the collection task and the probe according to the first MQTT subscription message of each probe. 5. The method according to claim 1, wherein the method further comprises: The probe proxy server receives the third MQTT publishing messages sent in batches by the probe analysis server. 6. The method according to any one of claims 2-4, wherein the method further comprises: The probe proxy server receives the third MQTT subscription message sent by the probe analysis server, and the third MQTT subscription message is used to request to subscribe to the subject of the target data collection; The probe proxy server constructs a subscription relationship between the probe analysis server and the subject of target data collection according to the third MQTT subscription message of the probe analysis server; The probe proxy server sends the second MQTT publishing message to the probe analysis server, including: The probe proxy server sends the second MQTT publishing message to the probe analysis server according to the subscription relationship between the probe analysis server and the subject of target data collection. 7. The method according to any one of claims 1-4, wherein both the first MQTT release message and the second MQTT release message are sent in a QoS2 manner. 8. The method according to any one of claims 1-4, wherein the first probe is a software probe deployed on a client of the target network link, and the first probe and the The probe proxy servers are connected through websockets, and MQTT messages are transmitted between the first probe and the probe proxy servers through an HTTP upgrade process. 9. A method for acquiring network link quality, characterized in that it is applied to a probe analysis server, and a probe proxy server is respectively connected to the probe analysis server and at least one probe, the method comprising: The probe analysis server sends a first MQTT publishing message based on the message queue telemetry transport protocol to the probe proxy server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link; The probe analysis server receives the second MQTT publishing message sent by the probe proxy server, and the second MQTT publishing message is used to instruct the first probe to analyze the target network link based on the target collection task. The target network link data is obtained through the test, and the first probe is a probe that is in the target network link and subscribes to the target collection task among the at least one probe; The probe analysis server acquires the quality result of the target network link according to the second MQTT publishing message; Wherein, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the method also includes: The probe analysis server sends the third MQTT publishing message in batches to the probe proxy server, and the payload of the third MQTT publishing message is a preset size, which is used for the first probe based on the first 3. Acquiring the bandwidth of the target network link according to the reception status of the MQTT publishing message. 10. The method according to claim 9, wherein the variable header of the first MQTT release message carries the subject of the target collection task, and the payload of the first MQTT release message carries a Detailed information of the target acquisition task; The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries the target network link data. 11. The method according to claim 9 or 10, wherein, before the probe analysis server receives the second MQTT publishing message sent by the probe proxy server, further comprising: The probe analysis server sends a third MQTT subscription message to the probe proxy server, and the third MQTT subscription message is used to request to subscribe to the subject of the target collection data. 12. The method according to claim 9 or 10, wherein both the first MQTT release message and the second MQTT release message are sent in a QoS2 manner. 13. The method according to claim 9 or 10, wherein the target network link between the first probe and the target node has a first routing path and a second routing path, and the first The probe to the target test node currently adopts a first routing path, and the target collection task is used to collect target network link data when a second routing path is used between the first probe and the target test node; Before the probe analysis server sends the first MQTT publishing message to the probe proxy server, the method also includes: The probe analysis server sends a first route switching request of the target network link to the network management system, where the first route switching request is used to request switching from the first routing path to the second routing path; After the probe analysis server receives the second MQTT publishing message sent by the probe proxy server, it also includes: The probe analysis server sends a second route switching request of the target network link to the network management system, where the second route switching request is used to request switching from the second routing path to the first routing path. 14. The method according to claim 9 or 10, further comprising: The probe analysis server obtains the monitoring data of the target node from the network management system when the quality result of the target network link indicates that there is a problem with the target network link; The probe analysis server generates a quality analysis report of the target network link according to the monitoring data; The probe analysis server outputs the quality analysis report. 15. A method for acquiring network link quality, characterized in that it is applied to a probe, and a probe proxy server is respectively connected to a probe analysis server and at least one of the probes, the method comprising: The first probe of the at least one probe receives the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe proxy server, and the first MQTT publishing message is used to instruct the probe to analyze A target collection task subscribed by the server, the target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link; The first probe tests the target network link based on the target acquisition task to obtain target network link data; The second MQTT publishing message sent by the first probe to the probe proxy server, so that the probe proxy server forwards the second MQTT publishing message to the probe analysis server, and the first Two MQTT publishing messages are used to indicate the target network link data; Wherein, the target network link data includes the bandwidth of the target network link, the target node is the probe proxy server; the first probe detects the target network link based on the target collection task The test obtains target network link data, including: The first probe receives the third MQTT publishing message sent in batches by the probe proxy server; the payload of the third MQTT publishing message is a preset size; The first probe acquires the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message. 16. The method according to claim 15, wherein the variable header of the first MQTT release message carries the subject of the target acquisition task, and the payload of the first MQTT release message carries a Detailed information of the target acquisition task; The variable header of the second MQTT publishing message carries the subject of the target collection data, and the payload of the second MQTT publishing message carries the target network link data. 17. The method according to claim 15 or 16, wherein the target network link data comprises the bandwidth of the target network link, and the target node is not the probe proxy server; the first The probe tests the target network link based on the target acquisition task to obtain target network link data, including: The first probe uses preset speed measurement software to measure the speed of the target network link to obtain the bandwidth of the target network link. 18. The method according to claim 15 or 16, wherein both the first MQTT release message and the second MQTT release message are sent in a QoS2 manner. 19. The method according to claim 15 or 16, wherein the first probe is a software probe deployed on a client of the target network link, and the first probe and the probe The proxy servers are connected through websockets, and MQTT messages are transmitted between the first probe and the probe proxy servers through an HTTP upgrade process. 20. A network link quality acquisition device, characterized in that the probe proxy server is connected to the probe analysis server and at least one probe respectively; the device is applied to the probe proxy server, comprising: The receiving module is configured to receive the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe analysis server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link; A sending module, configured to send a first MQTT publishing message to a first probe; the first probe is a probe in at least one probe that is on a target network link and subscribes to the above-mentioned target collection task; The receiving module is further configured to receive a second MQTT publishing message sent by the first probe, and the second MQTT publishing message is used to instruct the first probe to send information to the target network based on the target collection task. The link test obtains the link data of the target network; A sending module, further configured to send the second MQTT publishing message to the probe analysis server; Wherein, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the receiving module is also used for: Receive the second MQTT subscription message sent by the first probe; the second MQTT subscription message is used to subscribe to the third MQTT publishing message in batches; the payload of the third MQTT publishing message is a preset size , used for the first probe to obtain the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message; Sending third MQTT publishing messages to the first probe in batches. 21. A network link quality acquisition device, characterized in that the probe proxy server is connected to the probe analysis server and at least one probe respectively; the device is applied to the probe analysis server, comprising: A sending module, configured to send a first MQTT publishing message based on the message queue telemetry transport protocol to the probe proxy server, the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, the The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link; A receiving module, configured to receive a second MQTT publishing message sent by the probe proxy server, where the second MQTT publishing message is used to instruct the first probe to test the target network link based on the target collection task Obtaining target network link data, the first probe is a probe in the at least one probe that is in the target network link and subscribes to the target collection task; An obtaining module, configured to obtain the quality result of the target network link according to the second MQTT publishing message; Wherein, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the sending module is also used for: Sending the third MQTT publishing message in batches to the probe proxy server, the payload of the third MQTT publishing message is a preset size, which is used for the first probe to publish the message based on the third MQTT The receiving case obtains the bandwidth of the target network link. 22. A network link quality acquisition device, characterized in that the probe proxy server is connected to the probe analysis server and at least one probe; the device is applied to the probe, including: The receiving module is configured to receive the first MQTT publishing message based on the message queue telemetry transport protocol sent by the probe proxy server, and the first MQTT publishing message is used to indicate the target acquisition task subscribed by the probe analysis server, The target collection task is used to collect target network link data between the probe and the target node, and the target network link data is used to characterize the quality of the target network link; A collection module, configured to test the target network link based on the target collection task to obtain target network link data; The sending module is configured to send the second MQTT publishing message to the probe proxy server, so that the probe proxy server forwards the second MQTT publishing message to the probe analysis server, and the second The MQTT publish message is used to indicate the target network link data; Wherein, the target network link data includes the bandwidth of the target network link, and the target node is the probe proxy server; the acquisition module tests the target network link based on the target acquisition task When obtaining the target network link data, it is specifically used for: Receiving the third MQTT publishing message sent by the probe proxy server in batches; the payload of the third MQTT publishing message is a preset size; Acquiring the bandwidth of the target network link based on the receiving situation of the third MQTT publishing message. 23. A probe proxy server, comprising: a processor, a communication interface, and a memory; the processor is connected to the communication interface and the memory in communication; the memory stores computer-executable instructions; The communication interface communicates and interacts with external devices; The processor executes the computer-implemented instructions stored in the memory to implement the method according to any one of claims 1-8. 24. A probe analysis server, comprising: a processor, a communication interface, and a memory; the processor is connected to the communication interface and the memory in communication; the memory stores computer-executable instructions; The communication interface communicates and interacts with external devices; The processor executes the computer-implemented instructions stored in the memory to implement the method according to any one of claims 9-14. 25. A probe, characterized in that, comprising: a processor, a communication interface, and a memory; the processor is respectively connected to the communication interface and the memory in communication; the memory stores computer-executable instructions; The communication interface communicates and interacts with external devices; The processor executes the computer-implemented instructions stored in the memory to implement the method according to any one of claims 15-19. 26. A network link quality acquisition system, characterized in that the system comprises: the probe proxy server as claimed in claim 23, the probe analysis server as claimed in claim 24, at least one said probe; Wherein, the probe proxy server is respectively connected to the probe analysis server and the at least one probe. 27. A computer-readable storage medium, wherein computer-executable instructions are stored in the computer-readable storage medium, and the computer-executable instructions are used to implement any one of claims 1 to 19 when executed by a processor The method for acquiring network link quality.