CN118714039A - Network quality detection method, device, electronic device and storage medium - Google Patents

Abstract

A method, device, electronic device and storage medium for network quality detection, receiving an original reply message sent by a destination end in kernel state, judging whether third attribute information carried by the original reply message meets a preset filtering condition; when it is determined that the third attribute information meets the preset filtering condition, determining that the original reply message is a target reply message; transmitting the target reply message from kernel state to user state, judging whether first attribute information carried by the target reply message is the same as second attribute information carried by a target measurement message; when it is determined that the first attribute information is the same as the second attribute information, performing round-trip delay calculation on a first timestamp sent by the target measurement message and a second timestamp received by the target reply message to obtain a round-trip delay calculation result; storing the round-trip delay calculation result; and when it is determined that the number of stored round-trip delay calculation results meets a preset number condition, calculating all stored round-trip delay calculation results to obtain a network quality score.

Description

Network quality detection method, device, electronic device and storage medium

Technical Field

The present disclosure relates to the field of data processing technology, and in particular to a method, device, electronic device and storage medium for network quality detection.

Background Art

In recent years, with the vigorous development of the digital economy, data centers have become larger and larger, and more and more digital services are running on them. In the future, people will rely more and more on digital services, which can also be called computing power. The network quality inside the data center determines whether digital services can be stably supplied. Therefore, how to quickly and accurately check the network quality has become an important issue.

In the related technology, an efficient method is proposed for the TCP port scanning scenario. On the one hand, the sending thread and the receiving thread are used concurrently. On the other hand, the efficiency is improved based on the TCP message rather than the TCP three-way handshake mechanism. By quickly constructing the TCP handshake request detection message and separating the dual-channel sending and receiving, the message is quickly sent and processed and analyzed. In this way, the host's TCP port opening status can be detected and recorded in a very short time, thereby ensuring the port identification accuracy and port identification speed. However, due to the inaccurate filtering conditions of the sending and receiving process, all TCP messages, including a large number of invalid and unnecessary TCP messages, will be copied from the kernel state to the user state for comparison, which will also cause a waste of resources.

Summary of the invention

The present disclosure provides a method, device, electronic device and storage medium for network quality detection. Its main purpose is to provide a mechanism for accurate screening at the kernel level, ensuring the resource occupancy of the host machine when a large number of detection targets are detected. In addition, the sending, receiving, calculating and outputting of measurement messages are decoupled, and the asynchronous processing of each link is realized based on technical capabilities such as multithreading and lock-free blocking queues, so as to achieve the maximum degree of concurrent detection and improve the throughput of the entire measurement system.

According to a first aspect of the present disclosure, a method for network quality detection is provided, comprising:

Receiving, in kernel mode, an original reply message sent by the destination end, and determining whether the third attribute information carried by the original reply message meets a preset filtering condition;

When it is determined that the third attribute information meets the preset filtering condition, determining the original reply message as the target reply message;

Transmitting the target reply message from the kernel state to the user state, and determining whether the first attribute information carried by the target reply message is the same as the second attribute information carried by the target measurement message;

When it is determined that the first attribute information is the same as the second attribute information, performing round-trip delay calculation on a first timestamp sent by the target measurement message and a second timestamp received by the target reply message to obtain a round-trip delay calculation result;

Storing the round-trip delay calculation result;

When it is determined that the number of the stored round-trip delay calculation results meets the preset number condition, all the stored round-trip delay calculation results are calculated to obtain a network quality score.

Optionally, after storing the round-trip delay calculation result, the method includes:

Sequentially checking whether there is an element in the bidirectional list that meets a preset timeout condition, the element being a target measurement message stored in the bidirectional list before the target measurement message is sent;

When it is determined that there is a target element in the bidirectional list that meets the preset timeout condition, checking whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted;

When it is determined that the fourth attribute information and the third timestamp are not deleted, determining that the target reply message corresponding to the target element is lost, and storing the packet loss result in the first target storage queue;

The target element is deleted from the bidirectional list and the fourth attribute information and the third timestamp are deleted.

Optionally, after checking whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted, the method includes:

When it is determined that both the fourth attribute information and the third timestamp are deleted, the target element is deleted from the bidirectional list.

Optionally, after calculating all stored round-trip delay calculation results to obtain a network quality score, the method includes:

After performing multiple network quality tests on the destination end, multiple network quality scores are obtained, and the multiple network quality scores are calculated to obtain an aggregate index;

Storing the aggregated indicator in a target storage queue;

When it is determined that the size of the target storage queue meets a preset size condition or the storage time of the first aggregation indicator stored in the target storage queue meets a preset time window condition, compressing all the aggregation indicators stored in the target storage queue;

All the compressed aggregate indicators are transmitted to the analysis module.

Optionally, transmitting all the compressed aggregate indicators to the analysis module includes:

Determining whether the network link corresponding to the aggregation indicator is an important network link;

If it is determined that the network link corresponding to the aggregation index is a non-important network link, then when the network link is abnormal, all the compressed aggregation indexes are transmitted to the analysis module;

If it is determined that the network link corresponding to the aggregation index is an important network link, all the compressed aggregation indexes are transmitted to the analysis module when the network link is normal or abnormal.

Optionally, after storing the round-trip delay calculation result, the method includes:

Delete the first timestamp and the second attribute information.

Optionally, when it is determined that the number of the stored round-trip delay calculation results meets a preset number condition, calculating all stored round-trip delay calculation results includes:

When it is determined that the number of target measurement messages sent to the destination end is the same as the number of the stored round-trip delay calculation results, all stored round-trip delay calculation results are calculated to obtain the network quality score.

Optionally, if the target measurement message is a UDP protocol message, the receiving in the kernel state an original reply message sent by the destination end includes:

If the original reply message sent by the original port of the destination end is not received, the network quality detection is performed on other ports of the destination end by switching until the original reply message is received from the other ports of the switching.

Optionally, if the target measurement message is a TCP protocol message, the receiving in the kernel state an original reply message sent by the destination end includes:

If the target reply message sent by the original port of the destination end is a synchronization confirmation message of the TCP protocol, the network quality detection of other ports of the destination end is switched until a reset message of the TCP protocol is received from the other switched ports.

According to a second aspect of the present disclosure, a network quality detection device is provided, including:

A first judgment unit is used to receive the original reply message sent by the destination end in the kernel state, and judge whether the third attribute information carried by the original reply message meets the preset filtering condition;

A determination unit, configured to determine that the original reply message is the target reply message when it is determined that the third attribute information meets the preset filtering condition;

A first transmission unit, used for transmitting the target reply message from the kernel state to the user state;

A second judgment unit, configured to judge whether the first attribute information carried by the target reply message is the same as the second attribute information carried by the target measurement message;

A first calculation unit, configured to, when determining that the first attribute information is the same as the second attribute information, perform round-trip delay calculation on a first timestamp sent by the target measurement message and a second timestamp received by the target reply message to obtain a round-trip delay calculation result;

A first storage unit, used to store the round-trip delay calculation result;

The second calculation unit is used to calculate all the stored round-trip delay calculation results to obtain a network quality score when it is determined that the number of the stored round-trip delay calculation results meets a preset number condition.

Optionally, the device comprises:

A first checking unit, configured to sequentially check whether there is an element in the bidirectional list that meets a preset timeout condition, wherein the element is a target measurement message stored in the bidirectional list before the target measurement message is sent;

A second checking unit is used to check whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted when it is determined that there is a target element that meets the preset timeout condition in the bidirectional list;

a determining unit, configured to determine that a target reply message corresponding to the target element is lost if it is determined that the fourth attribute information and the third timestamp are not deleted, and store the packet loss result in the first target storage queue;

The first deleting unit is used to delete the target element from the bidirectional list and delete the fourth attribute information and the third timestamp.

Optionally, the device comprises:

The second deleting unit is configured to delete the target element from the bidirectional list when it is determined that both the fourth attribute information and the third timestamp are deleted.

Optionally, the device comprises:

A third calculation unit is used to obtain a plurality of network quality scores after performing multiple network quality detections on the destination end, and calculate the plurality of network quality scores to obtain an aggregation index;

A second storage unit, used for storing the aggregation indicator in a target storage queue;

A compression unit, configured to compress all the aggregation indicators stored in the target storage queue when it is determined that the size of the target storage queue meets a preset size condition or the storage time of the first aggregation indicator stored in the target storage queue meets a preset time window condition;

The transmission unit is used to transmit all the compressed aggregation indicators to the analysis module.

Optionally, the transmission unit includes:

A judgment module, used to judge whether the network link corresponding to the aggregation indicator is an important network link;

A transmission module, configured to transmit all the compressed aggregation indicators to the analysis module when it is determined that the network link corresponding to the aggregation indicator is a non-important network link and when the network link is abnormal;

The transmission module is also used to transmit all the compressed aggregation indicators to the analysis module when it is determined that the network link corresponding to the aggregation indicator is an important network link and when the network link is normal or abnormal.

Optionally, the device comprises:

The third deleting unit is used to delete the first timestamp and the second attribute information.

Optionally, the second computing unit is further used for:

When it is determined that the number of target measurement messages sent to the destination end is the same as the number of the stored round-trip delay calculation results, all stored round-trip delay calculation results are calculated to obtain the network quality score.

Optionally, the first judgment unit is also used to switch to perform network quality detection on other ports of the destination end when the target reply message sent by the original port of the destination end is not received, until the target reply message is received from the other switched ports.

Optionally, the switching module is also used to switch to perform network quality detection on other ports of the destination end when the target reply message sent by the original port of the destination end is a synchronization confirmation message of the TCP protocol until a reset message of the TCP protocol is received from the other switched ports.

According to a third aspect of the present disclosure, there is provided an electronic device, including:

at least one processor; and

a memory communicatively connected to the at least one processor; wherein,

The memory stores instructions that can be executed by the at least one processor, and the instructions are executed by the at least one processor to enable the at least one processor to perform the method described in the first aspect.

According to a fourth aspect of the present disclosure, a non-transitory computer-readable storage medium storing computer instructions is provided, wherein the computer instructions are used to enable the computer to execute the method described in the first aspect.

According to a fifth aspect of the present disclosure, a computer program product is provided, comprising a computer program, wherein when the computer program is executed by a processor, the computer program implements the method as described in the first aspect above.

In summary, this embodiment can achieve the following effects:

1. A precise screening mechanism at the kernel level is proposed for ICMP/TCP/UDP detection. At the same time, TCP detection avoids the half-open connection problem caused by the three-way handshake, ensuring the resource usage of the host machine when a large number of detection targets are detected.

2. A detailed measurement plan is proposed for ICMP/TCP/UDP detection, which decouples the sending, receiving, calculation, and result output of measurement messages. Based on multi-threading, lock-free blocking queues and other technical capabilities, asynchronous processing of each link is realized, achieving maximum concurrent detection and improving the throughput of the entire measurement system.

3. Calculate the round-trip delay calculation result based on the first timestamp and the second timestamp, and then calculate the network quality score based on the round-trip delay calculation result, thereby realizing the detection of network quality.

4. A round-trip message mapping mechanism is proposed for TCP/UDP detection. It does not require any configuration of the detection target and does not rely on the payload of the reply message, thus reducing the cost of incorporating the measurement object into the measurement.

5. In order to efficiently output large quantities of detection results, a multi-dimensional compression scheme is proposed, which includes indicator compression based on detection purpose, quantity compression based on time or quantity windows, and strategy compression based on monitoring level classification, thereby reducing the bandwidth occupied by the result output.

It should be understood that the content described in this section is not intended to identify the key or important features of the embodiments of the present application, nor is it intended to limit the scope of the present application. Other features of the present application will become easily understood through the following description.

BRIEF DESCRIPTION OF THE DRAWINGS

The accompanying drawings are used to better understand the present solution and do not constitute a limitation of the present disclosure.

FIG1 is a flow chart of a method for detecting network quality provided by an embodiment of the present disclosure;

FIG2 is a schematic diagram of the structure of a network quality detection device provided by an embodiment of the present disclosure;

FIG3 is a schematic diagram of the structure of another network quality detection device provided by an embodiment of the present disclosure;

FIG. 4 is a schematic block diagram of an example electronic device 300 provided according to an embodiment of the present disclosure.

DETAILED DESCRIPTION

The following is a description of exemplary embodiments of the present disclosure in conjunction with the accompanying drawings, including various details of the embodiments of the present disclosure to facilitate understanding, which should be considered as merely exemplary. Therefore, it should be recognized by those of ordinary skill in the art that various changes and modifications may be made to the embodiments described herein without departing from the scope and spirit of the present disclosure. Similarly, for the sake of clarity and conciseness, descriptions of well-known functions and structures are omitted in the following description.

The following describes the network quality detection method, device, electronic device and storage medium according to the embodiments of the present disclosure with reference to the accompanying drawings.

FIG1 is a flow chart of a method for detecting network quality provided in an embodiment of the present disclosure.

As shown in Figure 1, the method comprises the following steps:

Step 101, receiving an original reply message sent by a destination end in a kernel state, and determining whether the third attribute information carried by the original reply message meets a preset filtering condition;

Step 102: when it is determined that the third attribute information meets the preset filtering condition, determining the original reply message as the target reply message;

In order to facilitate the understanding of the above detailed description, this embodiment provides an exemplary description, including: when the computer is performing a message receiving action, the CPU will process all the data sent by the network card, and will first process it at high speed in the kernel's memory. If an application needs to use a specific message, these messages will be copied to the memory requested by the program, that is, the so-called user state, and then the program will judge whether the message needs further processing. In order to minimize the loss, the preset filtering conditions of the original reply message are set based on the interface capabilities opened by the operating system to filter the original reply message in the kernel state. Only the original reply message that meets the preset filtering conditions will be copied to the user state for further analysis.

In some embodiments, if network quality detection is performed based on the ICMP protocol, the preset filtering condition can be set as the identifier being the process number, that is, when it is determined that the identifier in the third attribute information carried by the original reply message is equal to the process number, it means that the original reply message meets the preset filtering condition, and the original reply message is then transmitted from the kernel state to the user state, and the process number is the process number of the program for performing network quality detection.

A precise screening mechanism at the kernel level is proposed for ICMP/TCP/UDP detection respectively. At the same time, TCP detection avoids the half-open connection problem caused by the three-way handshake and ensures the resource usage of the host machine when a large number of detection targets are detected.

Step 103: transmitting the target reply message from the kernel state to the user state and determining whether the first attribute information carried by the target reply message is the same as the second attribute information carried by the target measurement message;

As a refinement of the above step 103, in order to determine whether the target reply message and the target measurement message correspond to each other, after the execution end sends the target measurement message to the destination end, the destination end responds to the target measurement message, thereby sending a response message, i.e., the target reply message, to the execution end, and the execution end receives the target reply message sent by the destination end, and determines whether the first attribute information carried by the target reply message and the second attribute information carried by the target measurement message are the same, so as to determine whether the target reply message and the target measurement message correspond to each other.

Step 104: when it is determined that the first attribute information is the same as the second attribute information, a round trip delay calculation is performed on a first timestamp sent by the target measurement message and a second timestamp received by the target reply message to obtain a round trip delay calculation result;

As a refinement of the above step 104, in order to obtain an indicator that can describe the network quality, the round-trip delay corresponding to the first timestamp of sending the target measurement message and the second timestamp of receiving the target reply message is calculated to obtain the round-trip delay calculation result, and the round-trip delay calculation result can be used to describe the network quality at the current moment.

The network quality is detected by calculating the round-trip delay calculation result based on the first timestamp and the second timestamp, and then calculating the network quality score based on the round-trip delay calculation result.

Step 105, storing the round trip delay calculation result;

As a refinement of the above step 105, the calculated round-trip delay calculation result is stored, wherein the storage method includes but is not limited to queue storage, stack storage, heap storage, and tree storage. By storing the round-trip delay calculation result, the richness of the round-trip delay calculation result as a sample in the storage structure is increased.

Step 106: When it is determined that the number of the stored round-trip delay calculation results meets a preset number condition, all stored round-trip delay calculation results are calculated to obtain a network quality score.

As a refinement of the above step 106, when it is determined that the number of the stored round-trip delay calculation results meets the preset number condition, that is, it is determined that the richness of the stored round-trip delay calculation results as samples reaches the preset standard. In the above case, all the stored round-trip delay calculation results are calculated to obtain the network quality score that can better describe the network quality, wherein, when the round-trip delay calculation results are stored in any storage structure, the number of the round-trip delay calculation results stored in the storage structure will increase, and when the number of the round-trip delay calculation results stored in the storage structure is greater than or equal to the preset number condition, it is determined that the number of the stored round-trip delay calculation results meets the preset number condition. It should be understood that the foregoing description is only exemplary and does not constitute a limitation on the judgment of meeting the preset number condition described in the present disclosure.

A precise screening mechanism at the kernel level is proposed for ICMP/TCP/UDP detection respectively. At the same time, TCP detection avoids the half-open connection problem caused by the three-way handshake and ensures the resource usage of the host machine when a large number of detection targets are detected.

As a refinement of the above embodiment, after the round-trip delay calculation result is stored, the method may also adopt but is not limited to the following implementation methods, for example: sequentially checking whether there are elements in the bidirectional list that meet the preset timeout condition, and the element is the target measurement message stored in the bidirectional list before the target measurement message is sent; when it is determined that there is a target element in the bidirectional list that meets the preset timeout condition, checking whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted; when it is determined that neither the fourth attribute information nor the third timestamp has been deleted, determining that the target reply message corresponding to the target element is lost, and storing the packet loss result in the first target storage queue; deleting the target element from the bidirectional list and deleting the fourth attribute information and the third timestamp.

In order to facilitate the understanding of the above detailed description, this embodiment provides an exemplary description, for example: when performing network quality detection based on the ICMP protocol, including: when measuring the round-trip time (RTT), by using the Echo and Reply in the ICMP query message. Among them, the ICMP query message refers to the target measurement message. In the content of the ICMP query message, the type and code are fixed and constrained by the protocol standard. In its identifier field, fill in the PID (process number) of the measurement program to ensure global uniqueness within the server range; the sequence number starts from 1 to ensure the uniqueness and one-to-one correspondence of each ICMP measurement message, and the Payload part is filled with a fixed number of bytes according to the size of the detection message. The information of the IP layer and data link layer under the ICMP is filled in normally, mainly writing the correct source and destination IP and source and destination MAC. Before the ICMP inquiry message is sent to the destination, two data structures need to be used to store relevant information in the memory. One is to use a hash table. The key of the hash table is composed of the identifier and sequence number of the ICMP inquiry message, and the value is the timestamp when the ICMP inquiry message is sent. The data stored in the hash table is the attribute information of the ICMP inquiry message, that is, the second attribute information carried by the target measurement message; the second is to use a two-way list to store the ICMP inquiry message in order to facilitate subsequent calculation and analysis. After completion, the ICMP inquiry message is immediately sent to the destination. The destination responds to the ICMP inquiry message to reply the target reply message, and in the process of receiving the target reply message to the kernel state at the execution end, there will be other types of messages mixed in it. Therefore, the received original reply message is filtered by the above preset filtering conditions to obtain the target reply message. After receiving the target reply message, the second timestamp of receiving the target reply message is saved, and the first attribute information of the target reply message is extracted and stored in the attribute information storage queue. This embodiment does not limit the storage structure for storing the attribute information to a queue. By continuously consuming the first attribute information stored in the attribute information storage queue based on a background target thread, each time the attribute information is taken out, it will be compared and calculated with the second attribute information stored in the memory. If the identifier (filled with PID) and sequence number of the ICMP inquiry message and the target reply message are consistent, they are considered to be a pair of round-trip messages. At this time, the round-trip delay will be calculated, and the calculation result will be placed in the calculation result storage queue, and then the corresponding information in the hash table will be deleted. The aforementioned process of calculating the round trip delay is described in step 102. In the process of measuring network quality through the ICMP protocol, the calculation of the round trip delay is used as an exemplary description. In addition, in addition to consuming the attribute information storage queue, the target thread will continuously check the bidirectional list created and continuously filled in the ICMP query message sending stage, and check in sequence whether there are elements that meet the timeout period. When there is a timeout target element, it is checked whether the target measurement message, i.e., the ICMP query message, still exists in the hash table. If it exists, it is considered that the target reply message of the target measurement message, i.e., the ICMP query message, has not been received in time, and it is judged as packet loss. The packet loss result is written into the calculation result storage queue, and the ICMP query message is removed from the hash table and the bidirectional list. If it does not exist, it is considered that the target reply message of the target measurement message, i.e., the ICMP query message, has been received, and the ICMP query message information in the bidirectional list is normally removed. In particular, due to the orderliness of the queue, the scanning can be stopped when the first element that has not reached the timeout period is scanned to prevent subsequent meaningless scanning operations.

As a refinement of the above embodiment, after checking whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted, the method may also adopt but is not limited to the following implementation, for example: when it is determined that both the fourth attribute information and the third timestamp have been deleted, the target element is deleted from the bidirectional list. The contents involved in the above detailed description have been involved in the above exemplary description, and this embodiment will not be repeated here.

After calculating all the stored round-trip delay calculation results to obtain the network quality score, the method can also adopt but is not limited to the following implementation methods, for example: after performing multiple network quality detections on the destination end, multiple network quality scores are obtained, and the multiple network quality scores are calculated to obtain an aggregation index; the aggregation index is stored in a target storage queue; when it is determined that the size of the target storage queue meets a preset size condition or the storage time of the first aggregation index stored in the target storage queue meets a preset time window condition, all the aggregation indicators stored in the target storage queue are compressed; and all the compressed aggregation indicators are transmitted to the analysis module.

In order to facilitate the understanding of the above detailed description, this embodiment provides an exemplary description, for example: after obtaining the network quality detection result of each destination, that is, the network quality score, if the network quality score is directly sent to the analysis module, it will occupy a higher network bandwidth. In order to minimize the occupation of resources by non-business systems, a compressed sending mechanism can be adopted. First, based on the compression of the destination, the network quality score obtained by multiple detections of the same destination is calculated to calculate the average, maximum, minimum and other aggregation indicators; secondly, based on the number of compression, the aggregation indicators are written into the target storage queue. When the size of the target storage queue meets the preset size condition or meets the preset time window condition, all the aggregation indicators stored in the target storage queue are packaged based on the compression algorithm and transmitted to the analysis module.

As a refinement of the above embodiment, when executing the transmission of all the compressed aggregate indicators to the analysis module, the following implementation methods may also be adopted but are not limited to, for example: determine whether the network link corresponding to the aggregate indicator is an important network link; if it is determined that the network link corresponding to the aggregate indicator is an unimportant network link, then when the network link is abnormal, all the compressed aggregate indicators are transmitted to the analysis module; if it is determined that the network link corresponding to the aggregate indicator is an important network link, then when the network link is normal or abnormal, all the compressed aggregate indicators are transmitted to the analysis module. That is, a grading strategy can be implemented for the monitored links, and unimportant links do not need to be transmitted to the upper layer when they are in a normal state. Only when they are abnormal will specific indicators be sent up, and for important links, indicators will be sent up regardless of whether they are abnormal or not, and the distinction between normal and abnormal is based on whether the link packet loss and delay meet certain conditions.

As a refinement of the above embodiment, after the round-trip delay calculation result is stored, the method may also adopt but is not limited to the following implementation methods, for example: deleting the first timestamp and the second attribute information. The process involved in this embodiment has been described in the above exemplary description taking the ICMP protocol as an example, that is, after the round-trip delay calculation result is stored, the first timestamp and the second attribute information are deleted. In the exemplary description taking ICMP as an example, the information stored in the hash table is deleted. As a refinement of the above embodiment, when executing step 101, when determining that the number of the stored round-trip delay calculation results meets the preset number condition, when calculating all the stored round-trip delay calculation results, it may also be adopted but is not limited to the following implementation methods, for example: when determining that the number of target measurement messages sent to the destination end is the same as the number of the stored round-trip delay calculation results, all the stored round-trip delay calculation results are calculated to obtain the network quality score.

In some embodiments, in order to calculate the score of the network quality, the following implementation method may be used but is not limited to, for example: the target thread continuously consumes the first attribute information inserted into the attribute information storage queue, and each time the first attribute information is taken out, the number of packets received by the destination end is increased by 1. When it is equal to the number of packets sent per cycle by the destination end, it means that all reply packets in this cycle have been received. Because a packet loss result will also be generated internally due to timeout, there will always be a result in the calculation result storage queue in the end. The number of packets sent per cycle will be equal to the number of round-trip delay settlement results in the calculation result storage queue, that is, when the number of target measurement messages sent is the same as the number of stored round-trip delay calculation results, network quality scores such as average delay and packet loss rate can be calculated.

In addition to being implemented based on the ICMP protocol, the network quality detection method involved in the present disclosure can also be implemented based on the UDP protocol or the TCP protocol. Since the standards among the ICMP protocol, the UDP protocol, and the TCP protocol are not the same, when the method is implemented based on the UDP protocol or the TCP protocol, corresponding modifications are made respectively. For specific solutions, please refer to the following content.

As a refinement of the above embodiment, if the target test message and the target measurement message are UDP protocol messages, that is, the network quality measurement is implemented based on the UDP protocol, the original reply message sent by the destination end is received in the kernel state, and can also be implemented but not limited to the following methods. For example: if the original reply message sent by the original port of the destination end is not received, then switch to other ports of the destination end for network quality detection until the original reply message is received from the other switched ports.

In order to facilitate the understanding of the above content, this embodiment provides an exemplary description, wherein this exemplary description takes the UDP protocol as an example, including: the UDP protocol is a connectionless, unreliable transport layer protocol, and the server, i.e., the destination, does not necessarily have a target reply message to the client, i.e., the execution end. In many cases, UDP is only a one-way message transmission. Therefore, when using UDP messages for RTT measurement, it is necessary to rely on a feature of ICMP, that is, the ICMP error message: port unreachable. When performing network quality detection, it is detected that a destination does not have an open port, and the port of the destination will reply with an ICMP error message. The payload part of the reply ICMP error message will be filled with the sent UDP protocol message header information, i.e., the second attribute information. For example, when the execution end fills the identifier field of the UDP protocol message with 1024 when sending, the identifier field of the IP message in the payload part of the reply ICMP error message is also a 1024 field. Therefore, the identifier field of the IP message and the source and destination ports of the UDP protocol message are combined to make a one-to-one correspondence between the sent UDP protocol message and the replied ICMP error message, so as to calculate the RTT delay. In special cases, if the destination happens to have a service listening to the UDP port, the destination will not reply to the ICMP error message. At this time, if the execution end does not receive the ICMP error message, that is, the target reply message, there are two situations at this time. One is that the destination has a service listening to the specified UDP port, and the sent message is received normally, and the service at the destination will not reply to the ICMP message; the other is that the network is not connected, or the packet is lost in the middle process. The processing strategy is to mark the result of this round of network quality detection as "suspected packet loss", switch the port of the destination to another, uncommon port for detection, if it is still not connected, cycle a series of actions, and mark the detection result of the previous round as packet loss. If the ICMP error message is received, stop switching the port of the destination.

As a refinement of the above embodiment, if the target test message and target measurement message belong to TCP protocol messages, that is, the network quality measurement is implemented based on the TCP protocol, the original reply message sent by the destination end is received in the kernel state, and can also be implemented but not limited to the following methods. For example: if the target reply message sent by the original port of the destination end is a synchronization confirmation message of the TCP protocol, then switch to perform network quality detection on other ports of the destination end until a reset message of the TCP protocol is received from the other switched ports.

To facilitate understanding of the above content, this embodiment provides an exemplary description, wherein this exemplary description takes the TCP protocol as an example, including: when measuring the port connectivity of the destination end, the interaction process is that the client, i.e., the execution end, sends a SYN message, i.e., the measurement message, and the server, i.e., the destination end, replies with a SYN+ACK message, i.e., the synchronization confirmation message. Because there is no need to actually establish a TCP connection, the client will reply with a RST message, i.e., the reset message, to disconnect the connection. However, on the server, this half-open connection will exist for a certain period of time. If the number of measurements on the server is relatively large, it will cause unnecessary waste of resources.

Therefore, when it is not necessary to measure port connectivity, this process can be optimized to avoid this situation. The optimized process is as follows: the client first sends a SYN message, but the destination port is an uncommon port or a port that the server does not listen to. If the server does not listen to the port, it will directly reply with a RST message, and there will be no half-open connection. At this time, the RTT indicators of the two servers are also obtained based on the reset message. In addition, a pair of round-trip messages are identified by the source port, destination port, and flag bit (SYN/ACK). Furthermore, if the port of the destination is monitored by the service, the destination will normally reply with a SYN+ACK message. If the SYN+ACK message is received, although the RTT indicator can be obtained at this time, because the normal three-way handshake process will cause a half-open connection problem, it is necessary to first mark the result of this round of network quality detection as no packet loss and attach the calculated RTT value, and then send an RST message and switch the port of the destination to another, less commonly used port for the next round of network quality detection. If the SYN+ACK message replied by the destination is still received, the aforementioned series of processes are repeated. If a RST message is received, the switching of the port of the destination is stopped.

In some embodiments, the original reply message is filtered from the kernel state, and the preset filtering conditions involved have different designs in network quality detection schemes implemented based on different transmission protocols, wherein the specific distinction is as follows:

In the ICMP measurement scenario, the PID number of the detection program process is filled in with the identifier in the ICMP header to ensure accurate screening of the destination reply message.

In the UDP measurement scenario, the destination reply message is an ICMP error message. The payload of the ICMP error message will be filled with the header information of the sent UDP protocol message, i.e., the target test message. Therefore, the header information of the UDP protocol message in the ICMP error message is obtained through a fixed offset, and accurate screening is achieved by comparing the source port and the destination port. In the TCP scenario, the TCP RST reply message will reverse the source and destination ports and return them. Therefore, the conditions can be set directly through the source and destination port information to achieve accurate screening. In the TCP and UDP scenarios, as shown in the above content, port switching of the destination will occur in special circumstances. In order to solve the problem of filtering the original reply message during the port switching process, the destination measurement message is constructed based on a port range. That is, no matter how the switch is made, the source and destination ports will only change within the several ports included in the port range. Therefore, the screening condition can be specified as a port set.

In some embodiments, the network quality detection involved in the present application further supports detecting the quality of service interfaces and supports application layer protocols such as HTTP and HTTPS.

Corresponding to the above-mentioned network quality detection method, the present invention also provides a network quality detection device. Since the device embodiment of the present invention corresponds to the above-mentioned method embodiment, the details not disclosed in the device embodiment can be referred to the above-mentioned method embodiment, and will not be repeated in the present invention.

FIG. 2 is a schematic diagram of the structure of a network quality detection device provided by an embodiment of the present disclosure, as shown in FIG. 2 , comprising:

The first judgment unit 21 is used to receive the original reply message sent by the destination end in the kernel state, and judge whether the third attribute information carried by the original reply message meets the preset filtering condition;

A determination unit 22, configured to determine that the original reply message is the target reply message when it is determined that the third attribute information meets the preset filtering condition;

A first transmission unit 23, used for transmitting the target reply message from the kernel state to the user state;

A second judgment unit 24 is used to judge whether the first attribute information carried by the target reply message is the same as the second attribute information carried by the target measurement message;

A first calculation unit 25 is configured to, when it is determined that the first attribute information is the same as the second attribute information, calculate a round trip delay for a first timestamp sent by the target measurement message and a second timestamp received by the target reply message to obtain a round trip delay calculation result;

A first storage unit 26, used to store the round-trip delay calculation result;

The second calculation unit 27 is used to calculate all the stored round-trip delay calculation results to obtain a network quality score when it is determined that the number of the stored round-trip delay calculation results meets a preset number condition.

A precise screening mechanism at the kernel level is proposed for ICMP/TCP/UDP detection respectively. At the same time, TCP detection avoids the half-open connection problem caused by the three-way handshake and ensures the resource usage of the host machine when a large number of detection targets are detected.

A detailed measurement plan is proposed for ICMP/TCP/UDP detection, which decouples the sending, receiving, calculation and result output of measurement messages. Based on multi-threading, lock-free blocking queue and other technical capabilities, asynchronous processing of each link is realized, achieving maximum concurrent detection and improving the throughput of the entire measurement system.

The network quality is detected by calculating the round-trip delay calculation result based on the first timestamp and the second timestamp, and then calculating the network quality score based on the round-trip delay calculation result.

Furthermore, in a possible implementation of the embodiment of the present disclosure, as shown in FIG3 , the device includes:

A first checking unit 28 is used to sequentially check whether there is an element in the bidirectional list that meets a preset timeout condition, wherein the element is a target measurement message stored in the bidirectional list before the target measurement message is sent;

A second checking unit 29 is configured to check whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted when it is determined that the target element that meets the preset timeout condition exists in the bidirectional list;

A determining unit 210 is configured to determine that a target reply message corresponding to the target element is lost when it is determined that the fourth attribute information and the third timestamp are not deleted, and store the packet loss result in the first target storage queue;

The first deleting unit 211 is used to delete the target element from the bidirectional list and delete the fourth attribute information and the third timestamp.

Furthermore, in a possible implementation of the embodiment of the present disclosure, as shown in FIG3 , the device includes:

The second deleting unit 212 is configured to delete the target element from the bidirectional list when it is determined that both the fourth attribute information and the third timestamp are deleted.

Furthermore, in a possible implementation of the embodiment of the present disclosure, as shown in FIG3 , the device includes:

A third calculation unit 213 is used to obtain a plurality of network quality scores after performing multiple network quality detections on the destination end, and calculate the plurality of network quality scores to obtain an aggregation index;

A second storage unit 214, configured to store the aggregation indicator in a target storage queue;

A compression unit 215, configured to compress all the aggregate indicators stored in the target storage queue when it is determined that the size of the target storage queue meets a preset size condition or the storage time of the first aggregate indicator stored in the target storage queue meets a preset time window condition;

The second transmission unit 216 is used to transmit all the compressed aggregation indicators to the analysis module.

Further, in a possible implementation of the embodiment of the present disclosure, as shown in FIG3 , the transmission unit 216 includes:

A judging module 2161 is used to judge whether the network link corresponding to the aggregation indicator is an important network link;

The transmission module 2162 is used to transmit all the compressed aggregation indicators to the analysis module when it is determined that the network link corresponding to the aggregation indicator is a non-important network link and when the network link is abnormal;

The transmission module 2162 is also used to transmit all the compressed aggregation indicators to the analysis module when it is determined that the network link corresponding to the aggregation indicator is an important network link and when the network link is normal or abnormal.

Furthermore, in a possible implementation of the embodiment of the present disclosure, as shown in FIG3 , the device includes:

The third deleting unit 217 is used to delete the first timestamp and the second attribute information.

Furthermore, in a possible implementation of the embodiment of the present disclosure, as shown in FIG3 , the second calculation unit 27 is further configured to:

When it is determined that the number of target measurement messages sent to the destination end is the same as the number of the stored round-trip delay calculation results, all stored round-trip delay calculation results are calculated to obtain the network quality score.

Furthermore, in a possible implementation method of the embodiment of the present disclosure, as shown in Figure 3, the first judgment unit 21 is also used to switch to other ports of the destination end for network quality detection when the original reply message sent by the original port of the destination end is not received, until the original reply message is received from the other switched ports.

Furthermore, in a possible implementation method of the embodiment of the present disclosure, as shown in Figure 3, the first judgment unit 21 is also used to switch to perform network quality detection on other ports of the destination end when the target reply message sent by the original port of the destination end is a synchronization confirmation message of the TCP protocol until a reset message of the TCP protocol is received from the other switched ports.

It should be noted that the above explanation of the method embodiment is also applicable to the device of the embodiment of the present disclosure, and the principle is the same, which is no longer limited in the embodiment of the present disclosure.

According to an embodiment of the present disclosure, the present disclosure also provides an electronic device, a readable storage medium, and a computer program product.

FIG. 4 shows a schematic block diagram of an example electronic device 300 that can be used to implement an embodiment of the present disclosure. The electronic device is intended to represent various forms of digital computers, such as laptop computers, desktop computers, workbenches, personal digital assistants, servers, blade servers, mainframe computers, and other suitable computers. The electronic device can also represent various forms of mobile devices, such as personal digital processing, cellular phones, smart phones, wearable devices, and other similar computing devices. The components shown herein, their connections and relationships, and their functions are merely examples and are not intended to limit the implementation of the present disclosure described and/or required herein.

As shown in FIG4 , the device 300 includes a computing unit 301, which can perform various appropriate actions and processes according to a computer program stored in a ROM (Read-Only Memory) 302 or a computer program loaded from a storage unit 308 to a RAM (Random Access Memory) 303. In the RAM 303, various programs and data required for the operation of the device 300 can also be stored. The computing unit 301, the ROM 302, and the RAM 303 are connected to each other via a bus 304. An I/O (Input/Output) interface 305 is also connected to the bus 304.

A number of components in the device 300 are connected to the I/O interface 305, including: an input unit 306, such as a keyboard, a mouse, etc.; an output unit 307, such as various types of displays, speakers, etc.; a storage unit 308, such as a disk, an optical disk, etc.; and a communication unit 309, such as a network card, a modem, a wireless communication transceiver, etc. The communication unit 309 allows the device 300 to exchange information/data with other devices through a computer network such as the Internet and/or various telecommunication networks.

The computing unit 301 may be a variety of general and/or special processing components with processing and computing capabilities. Some examples of the computing unit 301 include, but are not limited to, a CPU (Central Processing Unit), a GPU (Graphic Processing Units), various dedicated AI (Artificial Intelligence) computing chips, various computing units that run machine learning model algorithms, a DSP (Digital Signal Processor), and any appropriate processor, controller, microcontroller, etc. The computing unit 301 performs the various methods and processes described above, such as a method for network quality detection. For example, in some embodiments, the method for network quality detection may be implemented as a computer software program, which is tangibly contained in a machine-readable medium, such as a storage unit 308. In some embodiments, part or all of the computer program may be loaded and/or installed on the device 300 via the ROM 302 and/or the communication unit 309. When the computer program is loaded into the RAM 303 and executed by the computing unit 301, one or more steps of the method described above may be performed. Alternatively, in other embodiments, the computing unit 301 may be configured to execute the aforementioned network quality detection method in any other appropriate manner (for example, by means of firmware).

Various embodiments of the systems and techniques described above herein may be implemented in digital electronic circuit systems, integrated circuit systems, FPGAs (Field Programmable Gate Arrays), ASICs (Application-Specific Integrated Circuits), ASSPs (Application Specific Standard Products), SOCs (System On Chips), CPLDs (Complex Programmable Logic Devices), computer hardware, firmware, software, and/or combinations thereof. These various embodiments may include: being implemented in one or more computer programs that may be executed and/or interpreted on a programmable system including at least one programmable processor that may be a dedicated or general-purpose programmable processor that may receive data and instructions from a storage system, at least one input device, and at least one output device, and transmit data and instructions to the storage system, the at least one input device, and the at least one output device.

The program code for implementing the method of the present disclosure may be written in any combination of one or more programming languages. These program codes may be provided to a processor or controller of a general-purpose computer, a special-purpose computer, or other programmable data processing device, so that the program code, when executed by the processor or controller, implements the functions/operations specified in the flow chart and/or block diagram. The program code may be executed entirely on the machine, partially on the machine, partially on the machine and partially on a remote machine as a stand-alone software package, or entirely on a remote machine or server.

In the context of the present disclosure, a machine-readable medium may be a tangible medium that may contain or store a program for use by or in conjunction with an instruction execution system, device, or equipment. A machine-readable medium may be a machine-readable signal medium or a machine-readable storage medium. A machine-readable medium may include, but is not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, device, or device, or any suitable combination of the foregoing. More specific examples of machine-readable storage media may include an electrical connection based on one or more lines, a portable computer disk, a hard disk, a RAM, a ROM, an EPROM (Electrically Programmable Read-Only-Memory) or a flash memory, an optical fiber, a CD-ROM (Compact Dis sc Read-Only Memory), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing.

To provide interaction with a user, the systems and techniques described herein can be implemented on a computer having: a display device (e.g., a CRT (Cathode-Ray Tube) or LCD (Liquid Crystal Display) monitor) for displaying information to the user; and a keyboard and pointing device (e.g., a mouse or trackball) through which the user can provide input to the computer. Other types of devices can also be used to provide interaction with the user; for example, the feedback provided to the user can be any form of sensory feedback (e.g., visual feedback, auditory feedback, or tactile feedback); and input from the user can be received in any form (including acoustic input, voice input, or tactile input).

The systems and techniques described herein may be implemented in a computing system that includes backend components (e.g., as a data server), or a computing system that includes middleware components (e.g., an application server), or a computing system that includes frontend components (e.g., a user computer with a graphical user interface or a web browser through which a user can interact with implementations of the systems and techniques described herein), or a computing system that includes any combination of such backend components, middleware components, or frontend components. The components of the system may be interconnected by any form or medium of digital data communication (e.g., a communication network). Examples of communication networks include: LAN (Local Area Network), WAN (Wide Area Network), the Internet, and blockchain networks.

A computer system may include a client and a server. The client and the server are generally remote from each other and usually interact through a communication network. The relationship between the client and the server is generated by computer programs running on the corresponding computers and having a client-server relationship with each other. The server may be a cloud server, also known as a cloud computing server or cloud host, which is a host product in the cloud computing service system to solve the defects of difficult management and weak business scalability in traditional physical hosts and VPS services ("Virtual Private Server", or "VPS" for short). The server may also be a server of a distributed system, or a server combined with a blockchain.

It should be noted that artificial intelligence is a discipline that studies how computers can simulate certain human thought processes and intelligent behaviors (such as learning, reasoning, thinking, planning, etc.), and includes both hardware-level and software-level technologies. Artificial intelligence hardware technologies generally include technologies such as sensors, dedicated artificial intelligence chips, cloud computing, distributed storage, and big data processing; artificial intelligence software technologies mainly include computer vision technology, speech recognition technology, natural language processing technology, as well as machine learning/deep learning, big data processing technology, knowledge graph technology, and other major directions.

It should be understood that the various forms of processes shown above can be used to reorder, add or delete steps. For example, the steps recorded in this disclosure can be executed in parallel, sequentially or in different orders, as long as the desired results of the technical solutions disclosed in this disclosure can be achieved, and this document does not limit this.

The above specific implementations do not constitute a limitation on the protection scope of the present disclosure. It should be understood by those skilled in the art that various modifications, combinations, sub-combinations and substitutions can be made according to design requirements and other factors. Any modification, equivalent substitution and improvement made within the spirit and principle of the present disclosure shall be included in the protection scope of the present disclosure.

Claims (13)

1. A method for network quality detection, characterized by comprising: Receiving, in kernel mode, an original reply message sent by the destination end, and determining whether the third attribute information carried by the original reply message meets a preset filtering condition; When it is determined that the third attribute information meets the preset filtering condition, determining the original reply message as the target reply message; Transmitting the target reply message from the kernel state to the user state, and determining whether the first attribute information carried by the target reply message is the same as the second attribute information carried by the target measurement message; When it is determined that the first attribute information is the same as the second attribute information, performing round-trip delay calculation on a first timestamp sent by the target measurement message and a second timestamp received by the target reply message to obtain a round-trip delay calculation result; Storing the round-trip delay calculation result; When it is determined that the number of the stored round-trip delay calculation results meets the preset number condition, all the stored round-trip delay calculation results are calculated to obtain a network quality score. 2. The method according to claim 1, characterized in that after storing the round-trip delay calculation result, the method comprises: Sequentially checking whether there is an element in the bidirectional list that meets a preset timeout condition, the element being a target measurement message stored in the bidirectional list before the target measurement message is sent; When it is determined that there is a target element in the bidirectional list that meets the preset timeout condition, checking whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted; When it is determined that the fourth attribute information and the third timestamp are not deleted, determining that the target reply message corresponding to the target element is lost, and storing the packet loss result in the first target storage queue; The target element is deleted from the bidirectional list and the fourth attribute information and the third timestamp are deleted. 3. The method according to claim 2, characterized in that after checking whether the fourth attribute information and the third timestamp corresponding to the target element have been deleted, the method comprises: When it is determined that both the fourth attribute information and the third timestamp are deleted, the target element is deleted from the bidirectional list. 4. The method according to claim 1, characterized in that after calculating all stored round-trip delay calculation results to obtain a network quality score, the method comprises: After performing multiple network quality tests on the destination end, multiple network quality scores are obtained, and the multiple network quality scores are calculated to obtain an aggregate index; Storing the aggregated indicator in a target storage queue; When it is determined that the size of the target storage queue meets a preset size condition or the storage time of the first aggregation indicator stored in the target storage queue meets a preset time window condition, compressing all the aggregation indicators stored in the target storage queue; All the compressed aggregate indicators are transmitted to the analysis module. 5. The method according to claim 4, characterized in that the step of transmitting all the compressed aggregate indicators to the analysis module comprises: Determining whether the network link corresponding to the aggregation indicator is an important network link; If it is determined that the network link corresponding to the aggregation index is a non-important network link, then when the network link is abnormal, all the compressed aggregation indexes are transmitted to the analysis module; If it is determined that the network link corresponding to the aggregation index is an important network link, all the compressed aggregation indexes are transmitted to the analysis module when the network link is normal or abnormal. 6. The method according to claim 1, characterized in that after storing the round-trip delay calculation result, the method comprises: Delete the first timestamp and the second attribute information. 7. The method according to claim 1, characterized in that when it is determined that the number of the stored round-trip delay calculation results meets a preset number condition, calculating all the stored round-trip delay calculation results comprises: When it is determined that the number of target measurement messages sent to the destination end is the same as the number of the stored round-trip delay calculation results, all stored round-trip delay calculation results are calculated to obtain the network quality score. 8. The method according to claim 1, wherein if the target measurement message is a UDP protocol message, the receiving in kernel mode the original reply message sent by the destination end comprises: If the original reply message sent by the original port of the destination end is not received, the network quality detection is performed on other ports of the destination end by switching until the original reply message is received from the other ports of the switching. 9. The method according to claim 1, wherein if the target measurement message is a TCP protocol message, the receiving in kernel mode the original reply message sent by the destination end comprises: If the original reply message sent by the original port of the destination end is a synchronization confirmation message of the TCP protocol, the network quality detection of other ports of the destination end is switched until a reset message of the TCP protocol is received from the other switched ports. 10. A network quality detection device, comprising: A first judgment unit is used to receive the original reply message sent by the destination end in the kernel state, and judge whether the third attribute information carried by the original reply message meets the preset filtering condition; A determination unit, configured to determine that the original reply message is the target reply message when it is determined that the third attribute information meets the preset filtering condition; A first transmission unit, used for transmitting the target reply message from the kernel state to the user state; A second judgment unit, configured to judge whether the first attribute information carried by the target reply message is the same as the second attribute information carried by the target measurement message; A first calculation unit is used to calculate the round-trip delay of a first timestamp sent by the target measurement message and a second timestamp received by the target reply message when it is determined that the first attribute information is the same as the second attribute information, so as to obtain a round-trip delay calculation result; A first storage unit, used to store the round-trip delay calculation result; The second calculation unit is used to calculate all the stored round-trip delay calculation results to obtain a network quality score when it is determined that the number of the stored round-trip delay calculation results meets a preset number condition. 11. An electronic device, comprising: at least one processor; and a memory communicatively connected to the at least one processor; wherein, The memory stores instructions that can be executed by the at least one processor, and the instructions are executed by the at least one processor to enable the at least one processor to perform the method according to any one of claims 1 to 9. 12. A non-transitory computer-readable storage medium storing computer instructions, wherein the computer instructions are used to cause the computer to execute the method according to any one of claims 1 to 9. 13. A computer program product, characterized in that it comprises a computer program, wherein when the computer program is executed by a processor, the computer program implements the method according to any one of claims 1 to 9.