CN100459586C - Device and method for data flux control - Google Patents

Abstract

The invention relates to a data flux controller and a relative control method. Wherein, said device comprises distribution transfer module for calculating the average time space of nearby data packs sent to the target address based on the contract flux information of user information and the average pack length of data pack of target address sent to the user, and based on the average time space controlling the send of data pack. The inventive method comprises: judging if the sending time difference between present time and the last data pack of same queue is higher than preset average time space; if it is, sending the first data pack, then processing the next queue; or else, directly processing the next queue; the queue stores the data packs with same target address. The invention can accurately control the sending of data pack, to control the bandwidth of user terminal. And it can avoid impact flux, to reduce the cost of core network.

Description

Data flow control device and flow control method

technical field

The invention relates to a network data transmission technology, in particular to a data flow control device and a flow control method.

Background technique

With the development of modern electronic technology, the performance of various processors has been rapidly improved. In the field of telecom network core network, with the development of VOIP (voice over IP, IP telephony) technology, the traditional switching technology with TDM (Time Division Multiplex, time division multiplexing) switching as the core is turning to packet switching with IP technology as the core Technology advances. Judging from the data transmitted by the switching network, the original connection-based data flow has gradually evolved into an IP-based connectionless data flow. Since the all-IP network system has the characteristics of high standardization, low R&D costs, and short development cycle, it will become the development trend of the future network.

In the prior art, flow classification technology and priority scheduling technology are usually used to control the flow of IP data packets (referred to as flow control). Among them, the flow classification technology is usually used to divide the data flow into three types according to the business type: Premium Service (PS), Assured Service (Assured Service, AS) and Best Effort (BE). PS implements delay-sensitive services, and its goal is to minimize the waiting time of packets in the queue of network nodes, and at the same time have the characteristics of low jitter, low packet loss rate, and bandwidth guarantee, such as: IP telephony; AS implements bandwidth-sensitive services, and assigns users A certain amount of bandwidth that cannot be strictly guaranteed can be forwarded preferentially by marking its packet with a relatively high forwarding priority, such as: video conferencing applications; BE is the traditional service provided by the Internet, and it does not provide users with any QOS (Quality of service, service quality) guarantee, for example: FTP (File Transfer Protocol, file transfer protocol), E-mail. When performing flow control according to priority scheduling technology, different services are scheduled according to priority, and data with high priority is sent first, and services with low priority are sent later. However, due to the variable length of IP data packets, it is difficult to calculate accurate traffic; it is bursty, there is no fixed traffic, and it is difficult to predict; although simple classification technology can be implemented, it is difficult to meet the occasions with high real-time requirements. For example: voice, real-time image transmission, etc., when the traffic is very large and exceeds the system performance, it is difficult to guarantee the QOS requirements, so that the prior art has the following defects and deficiencies in the flow control of IP data packets:

1. It is impossible to control the delay of data streams with the same priority within the allowable range;

2. When the data flow with higher priority is relatively large, many data with lower priority cannot be sent, resulting in some data packets with low real-time performance, such as: network management information, short messages, etc. being discarded. Under the action of the upper layer retransmission mechanism (such as TCP), a large number of data packets are retransmitted, which leads to network congestion;

3. It is impossible to accurately control the bandwidth of end users, which is not conducive to the operation and management of operators.

Contents of the invention

The technical problem to be solved by the present invention is to provide a data flow control device and a flow control method to address the defects and deficiencies in the prior art that cannot accurately control the bandwidth of end users when performing flow control on IP data packets. The defects and deficiencies existing in the prior art are overcome.

Data flow control In order to solve the above-mentioned technical problem, a kind of data flow control method provided by the present invention, it is carried out: Step 1, judges whether the difference between the sending time of the last data packet in the current moment and the current queue is greater than the preset average time interval, the queue is used to store data packets with the same destination address, if yes, send the first data packet in the queue, and then process the next queue; otherwise, directly process the next queue.

In the above method, before the step 1, the operation of setting the average time interval is also performed, and the operation includes: step A, calculating the average packet length of the data packets in the queue; step B, comparing the average packet length and the The subscription traffic in the user information corresponding to the queue is calculated to obtain an average time interval for the queue to send adjacent data packets. Wherein, the step A specifically includes: obtaining the sample number of data packets from the description information of the queue, dejittering the data packets of the sample number, and then calculating the average of the packet lengths of the dejittered data packets.

Before the step A, it is also performed: receiving a data packet, detecting the parameter information of the data packet, the parameter information including destination address and packet length information; storing the data packet in a pre-established queue corresponding to its destination address At the same time, according to the parameter information of the data packet, the description information of the data packet is established, and the description information of the data packet includes the packet length information of the data packet and the address information of the description information of the next data packet; Describe the descriptive information of the data packets in the queue corresponding to the destination address and the user information to establish the descriptive information of the queue, the descriptive information of the queue includes the user’s subscription traffic, the number of samples, the average packet length of the data packets of the sample number, the sample The longest packet length of the number of data packets, the shortest packet length of the sample number of data packets, the sending time of the last data packet and the address information of the first data packet in the queue.

In addition, before receiving data packets, an operation of establishing a queue based on the destination address is also performed.

The destination address is a destination port number, a destination IP address or a destination MAC (Media Access Control, Media Access Control) address or any combination thereof.

In addition, when a new data packet is received in the queue, the address information of the description information of the next data packet in the description information of the previous data packet in the queue is updated.

In the step 1, after the first data packet is sent, it is also executed: update the average packet length of the data packets of the number of samples in the description information of the queue, the longest packet length of the data packets of the number of samples, the The shortest packet length of the data packets with the number of samples, the sending time of the last data packet and the address information of the first data packet in the queue.

A data flow control device provided by the present invention includes a dispatching and forwarding module, which is used to poll the queue for storing data packets, and the difference between the current moment and the sending time of the last data packet in the current queue is greater than the preset average During the time interval, send the first packet in the queue, and then poll the next queue, otherwise, directly poll the next queue; the calculation processing module is connected with the scheduling and forwarding module, and is used to calculate the number of data packets in the queue. The average packet length, and the subscription flow information of the user whose address is the same as the destination address of the data packet are obtained, and the average time interval for sending adjacent data packets in the queue is calculated by quotienting the average packet length and the subscription flow.

In addition, the above-mentioned devices also include:

The configuration management module is used to receive the data packet, and detect the parameter information of the data packet, and the parameter information includes destination address and packet length information;

The monitoring and management module is connected to the configuration management module and the calculation processing module respectively, and is used to store the received data packet in the queue corresponding to its destination address, and at the same time, establish the The descriptive information of the data packet and the descriptive information of the queue, and the descriptive information of the updated data packet and the descriptive information of the queue;

An information storage module, connected to the monitoring management module and the computing processing module, respectively, for storing the description information of the data packet and the description information of the queue;

A user information storage module is connected to the monitoring management module and the computing processing module respectively, and is used to store the user information;

A queue storage module is connected to the monitoring management module and the dispatching and forwarding module respectively, and is used to store the queue.

Based on the above technical scheme, the present invention has the following beneficial effects:

1. Strictly control the sending of data packets according to the preset time conditions, so as to realize accurate control of end-user bandwidth and ensure the accuracy of flow control;

2. Calculate the average time interval for sending data packets to the user according to the user's subscription traffic and the flow of received data packets, which effectively guarantees the user's QOS, avoids burst traffic, and reduces the impact of burst traffic on the core network , reducing the core network investment; at the same time, avoiding the core network congestion caused by retransmission of data packets that are not real-time;

3. By polling the queue sent to each user to send data packets, it avoids competing for bandwidth between access layer users and improves the quality of operation;

4. Flow control can be performed based on the destination port number, destination IP address or destination MAC address or any combination thereof, with high flexibility.

The technical solutions of the present invention will be described in further detail below with reference to the accompanying drawings and embodiments.

Description of drawings

FIG. 1 is a flow chart of Embodiment 1 of the data flow control method of the present invention.

FIG. 2 is a schematic structural diagram of Embodiment 1 of the data flow control device of the present invention.

FIG. 3 is a flow chart of Embodiment 2 of the data flow control method of the present invention.

FIG. 4 is a schematic structural diagram of Embodiment 2 of the data flow control device of the present invention.

FIG. 5 is a flow chart of Embodiment 3 of the data flow control method of the present invention.

FIG. 6 is a schematic structural diagram of Embodiment 3 of the data flow control device of the present invention.

Detailed ways

The present invention is a method for controlling the flow of IP data packets. Its core idea is: to pre-set the average time interval between two adjacent data packets sent to the user, and sequentially store the data sent to the user If the current queue meets the average time interval condition, the first data packet in the queue will be sent to the user, and then the next queue will be processed; if the current queue does not meet the average time interval condition, it will not be sent to the user packet and proceed directly to the next queue.

Fig. 1 shows the flow chart of Embodiment 1 of the data flow control method of the present invention, which executes:

Step 101, judge whether the difference between the current time and the sending time of the last data packet in the current queue is greater than the preset average time interval, if yes, execute step 102; otherwise, execute step 103, the queue is used to store the same destination address For data packets, the destination address may be a destination port number, a destination IP address, a destination MAC address, or any combination thereof. Wherein, the average time interval can be set by the data traffic control manager according to actual needs, or can be set according to the subscription traffic of the user corresponding to the destination address.

Step 102, sending the first data packet in the queue.

In step 103, the next queue is polled, and step 101 is executed.

The time condition for sending data packets is limited by the preset average time interval, so as to strictly control the sending of data packets, realize the accuracy of end-user bandwidth control, ensure the accuracy of flow control; and avoid burst traffic , reducing the impact of burst traffic on the core network and reducing the core network investment.

FIG. 2 is a schematic structural diagram of Embodiment 1 of the data flow control device of the present invention that can be used to implement the method described in FIG. The queue for storing data packets is polled. When the difference between the current time and the sending time of the previous data packet in the current queue is greater than the preset average time interval, the first data packet in the queue is sent, and then the next one is polled. queue, otherwise, directly poll the next queue.

Fig. 3 shows the flow chart of the second embodiment of the data flow control method of the present invention. Before the flow shown in Fig. 1, this embodiment also executes the operation of setting the average time interval for sending adjacent data packets in the same queue, specifically It is: Step 301, calculate the average packet length of the data packets in the queue. Step 302, obtain the subscription traffic information of the user whose address is the same as the destination address of the data packet, and calculate the average packet length and the subscription traffic to obtain the average time interval for the queue to send adjacent data packets.

In this embodiment, step 301 is specifically: obtaining the number of samples of data packets preset by the user from the description information of the queue, de-jittering the data packets with the number of samples, and then averaging the packet lengths of the de-jittered data packets value.

According to the user's subscription traffic to limit the time conditions for sending data packets to the user, so as to strictly control the sending of data packets, ensure the accuracy of flow control, and effectively guarantee QOS; according to the user's subscription traffic and the received data packet The average time interval for sending data packets to users is calculated based on traffic conditions, which avoids burst traffic, reduces the impact of burst traffic on the core network, and reduces core network investment; at the same time, it avoids the loss of data packets that are not real-time Core network congestion caused by retransmission.

Fig. 4 is a schematic structural diagram of Embodiment 2 of the data flow control device of the present invention that can be used to implement the method described in Fig. 3. In this embodiment, on the basis of the embodiment shown in Fig. 2, a scheduling and forwarding module is added 1 connected calculation processing module 2, which is used to calculate the average packet length of the data packets in the queue, and obtain the subscription traffic information of the user whose address is the same as the destination address of the data packet, and calculate the average packet length and the subscription traffic The quotient is used to calculate the average time interval between sending adjacent packets in the queue.

The data flow control manager can pre-set the number of samples N corresponding to a certain destination address, and the dejitter parameters A and B. After the parameters N, A and B are set, they can be modified at any time. For example: You can choose the default value of A and B to be 1 or 2. And store the number of samples in the user information corresponding to the destination address, where the destination address may be a destination port number, destination IP address, destination MAC address or any combination thereof. Each queue for storing data packets with the same destination address is established in advance based on the destination address. When the data packet is received, the data flow control method provided by the present invention can be used to control the flow of the data packet sending. FIG. 5 is a flow chart of Embodiment 3 of the data flow control method of the present invention, which includes the following steps:

Step 501, receiving a data packet, detecting the parameter information of the data packet, including the destination address and packet length information of the data packet, for example: the destination IP address is 10.10.10.101, and the packet length information is 64K.

Step 502, the data packet is stored in the queue whose destination IP address is 10.10.10.101; meanwhile, its description information is established according to the parameter information of the data packet, and the description information includes the packet length information of the data packet and the next data packet The address information of the descriptive information, and store the descriptive information of the data packet in the location where the destination IP address is 10.10.10.101; at the same time, obtain the user information with the IP address 10.10.10.101, and establish the destination IP address based on the descriptive information and user information The description information of the queue with the address 10.10.10.101, the description information of the queue includes the user's subscription traffic, the number of samples N, the average packet length of the data packets with the sample number N, and the longest packet length of the data packets with the sample number N , the shortest packet length of the data packets with the sample number N, the sending time of the last data packet and the address information of the first data packet in the queue. Table 1 below is an example of the description information of a data packet with a certain destination address, and Table 2 below is an example of the content of the description information of a queue with a certain destination address.

Table 1

Table 2

Tprev (the moment when the last data packet was sent) Pkt_desc (the address of the first packet in the queue)

In Table 1, since the next data packet with the same destination address as the data packet has not been received when a data packet is received, Pkt_next in the description information of the data packet is temporarily set to 0. For the next data packet, the Pkt_next is updated according to the address of the description information of the next data packet.

In Table 2, Tc is pre-applied by the user, saved in the user information, can be obtained from the user information, and its value can be adjusted dynamically. If Tc is 0, it means that the user is an invalid user. N can be set by the administrator of the data flow control device when creating the queue, and can be adjusted dynamically. For ease of calculation, the value of N is best configured as 2 to the nth power, and n is a positive integer, for example: 2, 4, 8, 32 ,... Len_avg is the average packet length of the first N data packets in the queue after dejittering.

Step 503: Obtain the sample number N of data packets preset by the user and the de-jitter parameters A and B from the descriptive information of the queue, and de-jitter the first N data packets in the queue, that is, remove the data packets according to the preset parameters. A longest packet length and B shortest packet length in the first N data packets (A, B are positive integers, and N>A+B), and then N-(A+B) data after dejittering The packet length of the packet is averaged, and the average value can be recorded as Len_avg, and the Len_avg is written into the description information of the queue.

Step 504, obtain the subscription traffic Tc of the user from the description information of the queue, use the formula 1/(8*Len_avg/Tc) to calculate the average packet length Len_avg and the subscription traffic Tc, and obtain the current adjacent traffic in the queue Average time interval T_int of data packets.

Step 505, judge whether the difference between the current time and Tprev in the descriptive information of the queue is greater than the calculated current T_int of the queue, if yes, go to step 506; otherwise, go to step 508.

Step 506, send the first data packet in the queue to its destination address.

Step 507, update Len_max, Len_min, and Pkt_desc in the descriptive information of the queue according to the descriptive information of the data packets in the queue, update Tprev in the descriptive information of the queue with the current time when the first data packet is sent, and at the same time, Use the formula ((N-1)*Len_avg+Pkt_len-Len_max-Len_min)/(N-2) to recalculate the average value of the packet lengths of the first (N-1) data packets in the queue, and use the average value to update the queue Len_avg in the description information.

Step 508, poll the next queue, and execute steps 504 to 507 for the next queue.

By polling the queues sent to each user to send data packets, users at the access layer avoid competing for bandwidth and improve the quality of operation; in addition, the present invention can be based on the destination port number, destination IP address or destination MAC address or any combination thereof for flow control, with high flexibility.

In order to avoid unnecessary follow-up operations and reduce the working efficiency of the data flow control device, before performing step 504, first inquire whether the Tc in the current queue is zero, if yes, do not send the data packets in the queue, and poll the next queue, that is, go to step 508; otherwise, go to step 504.

FIG. 6 is a schematic structural diagram of Embodiment 3 of the data flow control device of the present invention that can be used to implement the method described in FIG. 5. This embodiment is based on the embodiment shown in FIG. The connected monitoring management module 3 and the configuration management module 7 connected with the monitoring management module 3 are additionally provided with an information storage module 5 and a user information storage module 6 connected with the computing processing module 2 and the monitoring management module 3 respectively, and respectively connected with The monitoring management module 3 and the queue storage module 4 connected to the scheduling and forwarding module 1 are connected. Wherein, configuration management module 7 is used for receiving data packet, detects the parameter information of this data packet, comprises: the destination address of data packet (can be destination port number, destination IP address or destination MAC address or its arbitrary combination) and data packet packet length, and send the data packet and its parameter information to the monitoring and management module 3, and the data packet is stored in the same queue of the destination address by the monitoring and management module 3; in addition, the configuration management module 7 also provides a human-computer interaction interface, and the user can Through this interface, enter the command to establish or delete the queue and related parameters, such as: the number of samples N and de-jitter parameters A and B; after the monitoring and management module 3 receives the data packet, it is used to store the data according to the parameter information of the data packet and user information. The user information stored in the module 6 includes: port number, IP address or MAC address or any combination thereof, and the number of samples N and the dejitter parameters A and B, and the description information of the data packet is established, including the destination address information and Packet length information of the data packet; at the same time, according to the parameter information of the data packet and user information, the description information of the queue is established and updated, including: the user's subscription traffic, the number of samples, the average packet length of the data packets of the sample number, the sample number The longest packet length of the data packet, the shortest packet length of the sample number of data packets, the sending time of the last data packet and the address information of the first data packet in the queue, and store the received data packet in the corresponding In the queue corresponding to the destination address; the calculation processing module 2 is used to dejitter the data packets in each queue, calculate its average packet length, and obtain the subscription traffic information of the user whose address is the same as the destination address of the data packet, and pass the The average packet length and the contract traffic are calculated to calculate the average time interval for sending adjacent data packets in the queue; the dispatching and forwarding module 1 is used to poll the queue for storing data packets according to the average time interval calculated by the calculation processing module 2, When the difference between the current moment and the sending time of the previous data packet in the current queue is greater than the average time interval, send the first data packet in the queue, and then poll the next queue, otherwise, directly poll the next queue; queue The storage module 4 is used for storing each queue; the information storage module 5 is used for storing the description information of the data packet and the description information of the queue; the user information storage module 6 is used for storing user information.

In each of the above data flow control devices, the information storage module 5, the queue storage module 4 and/or the user information storage module 6 may be integrated. In addition, the information storage module 5 , the queue storage module 4 and/or the user information storage module 6 can also be integrated with the monitoring management module 3 ; the monitoring management module 3 can also be integrated with the configuration management module 7 .

The above-mentioned embodiments provided by the present invention can not only be applied to the flow control based on the port number, IP address and/or MAC address at the access layer, but also can be applied to the flow control based on the port number at the core layer.

Total Beneficial Effects:

1. It can strictly control the sending of data packets, ensuring the accuracy of flow control and effectively guaranteeing QOS;

2. It avoids the sudden flow of IP data packets, reduces the impact of sudden flow on the core network, and reduces the investment in the core network; at the same time, it avoids the loss of real-time data packets caused by the retransmission of the core network. congestion;

3. It avoids competing for bandwidth between users at the access layer and improves the quality of operation;

4. Flow control can be performed based on the destination port number, destination IP address or destination MAC address or any combination thereof, with high flexibility.

Finally, it should be noted that: the above examples are only used to illustrate the technical solutions of the present invention, rather than limiting the understanding of the present invention. Although the present invention has been described in detail with reference to the above-mentioned preferred embodiments, those skilled in the art should understand that: it can still modify or replace the technical solution of the present invention, and such modification or replacement does not depart from the technology of the present invention. The spirit and scope of the programme.

Claims (10)

1. A data flow control method, characterized in that: Step 1, judging whether the difference between the current time and the sending time of the last data packet in the current queue is greater than the preset average time interval, the queue is used to store the data packets with the same destination address, and if yes, send the first data packet in the queue A data packet, then process the next queue; otherwise, directly process the next queue. 2. The method according to claim 1, wherein said setting said average time interval comprises: Step A, calculating the average packet length of the data packets in the queue; Step B: Quotient the average packet length and the subscription traffic in the user information corresponding to the queue to obtain an average time interval for the queue to send adjacent data packets. 3. The method according to claim 2, wherein the step A is specifically: Obtain the sample number of data packets from the description information of the queue, dejitter the data packets with the sample number, and calculate the average value of the packet lengths of the dejittered data packets. 4. The method according to claim 3, characterized in that, before the step A, further execute: Receiving a data packet, detecting parameter information of the data packet, the parameter information including destination address and packet length information; storing the data packet in a pre-established queue corresponding to its destination address; at the same time, establishing the description information of the data packet according to the parameter information of the data packet, and the description information of the data packet includes the packet length information of the data packet and the address information of the description information of the next data packet; at the same time, according to the description information of the data packet in the queue corresponding to the destination address and the user information, the description information of the queue is established, and the description information of the queue includes the subscription traffic of the user , the number of samples, the average packet length of the data packets of the sample number, the longest packet length of the data packets of the sample number, the shortest packet length of the data packets of the sample number, the sending time of the last data packet and the first Address information of a data packet. 5. The method according to claim 4, wherein before receiving the data packet, an operation of establishing a queue based on the destination address is also performed. 6. The method according to any one of claims 1 to 5, wherein the destination address is a destination port number, a destination IP address or a destination MAC address or any combination thereof. 7. The method according to claim 6, further comprising: When a new data packet is received in the queue, update the address information of the description information of the next data packet in the description information of the previous data packet in the queue. 8. The method according to any one of claims 1 to 5, characterized in that, in step 1, after sending the first data packet, further execute: Update the average packet length of the sample number of data packets in the description information of the queue, the longest packet length of the sample number of data packets, the shortest packet length of the sample number of data packets, the last data packet The sending time and the address information of the first packet in the queue. 9. A data flow control device, characterized in that it comprises: The scheduling and forwarding module is used to poll the queue for storing data packets, and when the difference between the current moment and the sending time of the previous data packet in the current queue is greater than the preset average time interval, send the first data in the queue package, then poll the next queue, otherwise, directly poll the next queue; The calculation processing module is connected with the dispatching and forwarding module, and is used to calculate the average packet length of the data packets in the queue, and obtain the subscription traffic information of the user whose address is the same as the destination address of the data packet, and compare the average packet length with the Subscribe traffic quotient to calculate the average time interval between sending adjacent packets in the queue. 10. The apparatus of claim 9, further comprising: The configuration management module is used to receive the data packet, and detect the parameter information of the data packet, and the parameter information includes destination address and packet length information; The monitoring and management module is connected to the configuration management module and the calculation processing module respectively, and is used to store the received data packet in the queue corresponding to its destination address, and at the same time, establish the The descriptive information of the data packet and the descriptive information of the queue, and the descriptive information of the updated data packet and the descriptive information of the queue; An information storage module, connected to the monitoring management module and the computing processing module, respectively, for storing the description information of the data packet and the description information of the queue; A user information storage module is connected to the monitoring management module and the computing processing module respectively, and is used to store the user information; A queue storage module is connected to the monitoring management module and the dispatching and forwarding module respectively, and is used to store the queue.

Images