CN118740749A - Flow control method and device - Google Patents

Abstract

The disclosure provides a flow control method and a flow control device, wherein the method comprises the following steps: decapsulating the received data packet according to a set frame structure to obtain a first data frame, judging the first data frame to determine the service type of the first data frame, and determining the service type of the first data frame; performing first flow control on the first data frame by adopting a first token bucket matched with the service type of the first data frame so as to determine whether the first data frame passes the first flow control or not; when the first data frame passes through the first flow control, a second token bucket matched with each service data in the first data frame is adopted to carry out second flow control on each service data in the first data frame, so that network congestion caused by excessive burst service volume can be avoided, meanwhile, homogenization of data flow control can be avoided, data transmission quality is improved, and user requirements are better met.

Description

Flow control method and device

Technical Field

The present disclosure relates to the field of satellite communication technology, and in particular to a flow control method and device.

Background Art

At present, in the distributed onboard switching equipment of low-orbit satellite Internet, onboard switching equipment is required to forward data. Due to the limited switching capacity of onboard switching equipment, data flow needs to be controlled when forwarding data. However, when a large amount of data bursts out at each port of the onboard switching equipment at the same time, it may exceed the switching capacity of the onboard switching equipment, causing congestion of the onboard switching equipment and affecting normal message forwarding. Therefore, in order to avoid congestion of the onboard switching equipment, it is very important to control the data flow.

Summary of the invention

The present disclosure aims to solve one of the technical problems in the related art at least to some extent.

To this end, the first purpose of the present disclosure is to propose a flow control method and device, so as to realize decapsulation of a received data packet according to a set frame structure to obtain a first data frame, to identify the first data frame, to determine the service type to which the first data frame belongs, and to perform a first flow control on the first data frame using a first token bucket matching the service type of the first data frame to determine whether the first data frame passes the first flow control; when the first data frame passes the first flow control, a second token bucket matching each service data in the first data frame is used to perform a second flow control on each service data in the first data frame, thereby, when forwarding data, the set frame structure can be used to decapsulate the forwarded data to generate a first data frame, and the first data frame is identified to determine the service type of the forwarded data, and a flow control strategy matching the service type of the forwarded data is used to perform flow control on the forwarded data in a targeted and refined manner, thereby meeting the needs of different services, and avoiding network congestion caused by excessive burst business volume, while also avoiding the uniformity of data flow control, thereby improving the quality of data transmission, so as to better meet user needs.

The second objective of the present disclosure is to provide a flow control device.

A third objective of the present disclosure is to provide an electronic device.

A fourth objective of the present disclosure is to provide a computer-readable storage medium.

A fifth object of the present disclosure is to provide a computer program product.

To achieve the above-mentioned purpose, the first aspect of the present disclosure proposes a flow control method, including: decapsulating the received data packet according to the set frame structure to obtain a first data frame; distinguishing the first data frame to determine the service type to which the first data frame belongs; using a first token bucket matching the service type of the first data frame to perform a first flow control on the first data frame to determine whether the first data frame passes the first flow control; when the first data frame passes the first flow control, using a second token bucket matching each service data in the first data frame to perform a second flow control on each service data in the first data frame.

The flow control method of the disclosed embodiment decapsulates the received data packet according to the set frame structure to obtain the first data frame; discriminates the first data frame to determine the service type to which the first data frame belongs; uses the first token bucket matching the service type of the first data frame to perform the first flow control on the first data frame to determine whether the first data frame passes the first flow control; when the first data frame passes the first flow control, uses the second token bucket matching the service data in the first data frame to perform the second flow control on the service data in the first data frame. Thus, when forwarding data, the set frame structure can be used to decapsulate the forwarded data to generate the first data frame, and the first data frame can be discriminated to determine the service type of the forwarded data, and the flow control strategy matching the service type of the forwarded data is used to control the forwarded data in a targeted and refined manner, so as to meet the needs of different services, and avoid network congestion caused by excessive burst business volume, and at the same time, it can also avoid the uniformity of data flow control, improve the data transmission quality, and better meet the needs of users.

To achieve the above-mentioned purpose, the second aspect embodiment of the present disclosure proposes a flow control device, including: a decapsulation module, used to decapsulate the received data packet according to the set frame structure to obtain a first data frame; a discrimination module, used to discriminate the first data frame to determine the service type to which the first data frame belongs; a first flow control module, used to perform a first flow control on the first data frame using a first token bucket matching the service type of the first data frame to determine whether the first data frame passes the first flow control; a second flow control module, used to perform a second flow control on each service data in the first data frame using a second token bucket matching the each service data in the first data frame when the first data frame passes the first flow control.

To achieve the above-mentioned purpose, the third aspect embodiment of the present disclosure proposes an electronic device, including a memory, a processor, and a computer program stored in the memory and executable on the processor, and when the processor executes the program, the flow control method as described in the first aspect embodiment of the present disclosure is implemented.

In order to achieve the above-mentioned objectives, the fourth aspect embodiment of the present disclosure proposes a computer-readable storage medium, on which a computer program is stored. When the computer program is executed by a processor, the flow control method as described in the first aspect embodiment of the present disclosure is implemented.

In order to achieve the above-mentioned purpose, the fifth embodiment of the present disclosure proposes a computer program product. When the instruction processor in the computer program product executes, it implements the flow control method as described in the first embodiment of the present disclosure.

Additional aspects and advantages of the present disclosure will be given in part in the following description and in part will be obvious from the following description or learned through practice of the present disclosure.

BRIEF DESCRIPTION OF THE DRAWINGS

The above and/or additional aspects and advantages of the present disclosure will become apparent and easily understood from the following description of the embodiments in conjunction with the accompanying drawings, in which:

FIG1 is a schematic diagram of a token bucket generating tokens and forwarding data in the related art;

FIG2 is a flow chart of a flow control method provided by an embodiment of the present disclosure;

FIG3 is a schematic diagram of a frame structure provided by an embodiment of the present disclosure;

FIG4 is a schematic diagram of the structure of a data unit provided in an embodiment of the present disclosure;

FIG5 is a flow chart of another flow control method provided by an embodiment of the present disclosure;

FIG6 is a schematic diagram of priorities in a second sub-token bucket provided by an embodiment of the present disclosure;

FIG7 is a flow chart of another flow control method provided by an embodiment of the present disclosure;

FIG8 is a flow chart of another flow control method provided by an embodiment of the present disclosure;

FIG9 is a flow chart of another flow control method provided by an embodiment of the present disclosure;

FIG10 is a flow chart of another flow control method provided by an embodiment of the present disclosure;

FIG11 is a schematic diagram of the structure of a flow control system provided by an embodiment of the present disclosure;

FIG12 is a schematic structural diagram of a flow control device provided in an embodiment of the present disclosure;

Fig. 13 is a block diagram of an electronic device for flow control according to an exemplary embodiment.

DETAILED DESCRIPTION

Embodiments of the present disclosure are described in detail below, examples of which are shown in the accompanying drawings, wherein the same or similar reference numerals throughout represent the same or similar elements or elements having the same or similar functions. The embodiments described below with reference to the accompanying drawings are exemplary and are intended to be used to explain the present disclosure, and should not be construed as limiting the present disclosure.

In order to avoid network congestion caused by excessive burst traffic, a token bucket algorithm is used in the related art to control the flow of forwarded data. The basic process of the token bucket algorithm is described below in conjunction with Figure 1. Figure 1 is a schematic diagram of a token bucket generating tokens and forwarding data in the related art.

As shown in Figure 1, the basic process of the token bucket algorithm is as follows: the user configures the average sending rate to be r, and adds a token to the bucket every 1/r seconds; the bucket can store a maximum of b tokens, and if the token bucket is full, the newly arrived token will be discarded; when an n-byte datagram arrives, n tokens are deleted from the token bucket and the data packet is sent to the network; if the number of tokens is less than n, the token is not deleted and the data packet is considered to be outside the flow limit. The algorithm allows data bursts of up to b bytes and limits the average output rate of the port to r. Data packets that exceed the flow limit are stored in the on-chip cache and discarded if the cache capacity is insufficient.

In the related art, the flow control technology of the token bucket algorithm temporarily stores data packets that exceed the flow limit, thereby evenly distributing the burst services. By increasing the cache size or using an off-chip cache, the burst data volume that the token bucket can tolerate can be increased. However, the traditional token bucket algorithm cannot guarantee the communication quality of high-priority services, and cannot achieve absolute occupation of bandwidth resources by high priority during traffic congestion. If the cache area is filled with low-priority services, the high-priority services that arrive later will be discarded. At the same time, it cannot support various rate services.

In view of the above problems, the present disclosure proposes a flow control method and device. It should be noted that the flow control method of the embodiment of the present disclosure can be applied to the flow control device of the embodiment of the present disclosure, and the device can be configured in an electronic device, and the electronic device can be a satellite-borne switching device.

The flow control method and device according to the embodiments of the present disclosure are described below with reference to the accompanying drawings.

FIG2 is a flow chart of a flow control method provided in an embodiment of the present disclosure.

As shown in FIG2 , the flow control method may include the following steps:

Step 201, decapsulate the received data packet according to the set frame structure to obtain a first data frame.

In the embodiment of the present disclosure, the received data packet may include service data of at least one data type, for example, the service data may be voice, picture, short message, navigation data or video, etc. Then, the received data packet is decapsulated according to the set frame structure. As an example, as shown in FIG3 , the set frame structure may include synchronization information, frame header information and data part.

The data part can be classified according to the data type and data volume of the service data. As an example, the data part can be divided into 4 low-speed services, 1 medium-speed service and 1 high-speed service, wherein the data volume corresponding to the high-speed service is greater than the data volume corresponding to the medium-speed service, and the data volume corresponding to the medium-speed service is greater than the data volume corresponding to the low-speed service. For example, the low-speed service is pictures, the medium-speed service is voice, and the high-speed service is video. The frame header information in the frame structure may include a frame count bit (32 bits), a priority (3 bits), a service type (1 bit, designated service or non-designated service), low-speed service indication information (2 bits), medium-speed service indication information (1 bit), and high-speed service indication information (1 bit); in addition, the service type may include 0 and 1, wherein 1 may represent a designated service (special service), and 0 may represent a non-designated service (ordinary service). The designated service may be a service with a high delay requirement, and the non-designated service may be a service other than the designated service. The priority of the designated service is higher than that of the non-designated service. The low-speed service indication information may be used to indicate the number of low-speed services in the frame structure, such as the low-speed service indication information is 00, indicating that the frame structure contains one low-speed service, the low-speed service indication information is 01, indicating that the frame structure contains two low-speed services, the low-speed service indication information is 10, indicating that the frame structure contains three low-speed services, and the low-speed service indication information is 11, which can be used to indicate that the frame structure contains four low-speed services. Similarly, the medium-speed service indication information is used to indicate the number of medium-speed services in the frame structure, and the high-speed service information is used to indicate the number of high-speed services in the frame structure.

As an example, as shown in FIG4 , the data in the data part may be composed of data units, for example, a low-speed service may be composed of 1 data unit, a medium-speed service may be composed of 10 to 100 data units, and a high-speed service may be composed of 1000 to 10000 data units, wherein each data unit may include an information frame header, data, and invalid information (100 bits); for designated services, the information frame header in each data unit is 8 bits, wherein 1 bit indicates whether there is data or no data, and the remaining 7 bits may not be defined; for non-designated services, the information frame header in each data unit is 8 bits, wherein 1 bit indicates whether there is data or no data, 4 bits indicate the corresponding data type (such as 0000 for voice, 0001 for IoT data, 0010 for short message, etc.), and 3 bits indicate the priority; wherein it should be noted that the invalid information in each data unit can be used to protect against inter-satellite jitter.

Step 202: Identify the first data frame to determine the service type to which the first data frame belongs.

In the embodiment of the present disclosure, the service type of the first data frame can be determined according to the information indicating the service type in the frame header information of the first data frame to obtain the service type to which the first data frame belongs. The service type may include designated services and non-designated services.

For example, the information used to indicate the service type in the frame header information of the first data frame is 0, and the service type of the first data frame is non-specified service; the information used to indicate the service type in the frame header information of the first data frame is 1, and the service type of the first data frame is specified service.

Step 203: Perform a first flow control on the first data frame using a first token bucket that matches the service type of the first data frame to determine whether the first data frame passes the first flow control.

In order to meet the needs of different services and avoid network congestion caused by excessive burst business volume, in an embodiment of the present disclosure, a first token bucket matching the business type of the forwarded data can be used to perform a first flow control on the first data frame to determine whether the first data frame passes the first flow control, wherein the first token bucket can be used to limit the data output flow of the physical port.

Step 204, when the first data frame passes through the first flow control, a second token bucket matching each service data in the first data frame is used to perform a second flow control on each service data in the first data frame.

In order to achieve refined flow control, flow control can be performed separately for each business data in the first data frame. In the embodiment of the present disclosure, when the first data frame passes through the first flow control, a second token bucket matching the business data in the first data frame is used to perform second flow control on each business data in the first data frame.

It should be noted that the second token bucket may be used to limit the output flow of the logical port, and service data exceeding the flow limit may be discarded.

In summary, the received data packet is decapsulated according to the set frame structure to obtain the first data frame; the first data frame is identified to determine the service type to which the first data frame belongs; the first token bucket matching the service type of the first data frame is used to perform the first flow control on the first data frame to determine whether the first data frame passes the first flow control; when the first data frame passes the first flow control, the second token bucket matching the service data in the first data frame is used to perform the second flow control on the service data in the first data frame. Therefore, when forwarding data, the forwarding data can be decapsulated using the set frame structure to generate the first data frame, and the first data frame can be identified to determine the service type of the forwarding data, and the flow control strategy matching the service type of the forwarding data is used to control the forwarding data in a targeted and refined manner, so as to meet the needs of different services, and avoid network congestion caused by excessive burst business volume, and at the same time, it can also avoid the uniformity of data flow control, improve the quality of data transmission, and better meet user needs.

In order to clearly illustrate how the above embodiment uses a first token bucket matching the service type of the first data frame to perform a first flow control on the first data frame to determine whether the first data frame passes the first flow control, the present disclosure proposes another flow control method.

FIG5 is a flow chart of another flow control method provided in an embodiment of the present disclosure.

As shown in FIG5 , the flow control method may include the following steps:

Step 501: decapsulate the received data packet according to the set frame structure to obtain a first data frame.

Step 502: Identify the first data frame to determine the service type to which the first data frame belongs.

Step 503, when the service type to which the first data frame belongs is a designated service, first flow control is performed on the first data frame according to the number of first real-time tokens in the first sub-token bucket to determine whether the first data frame passes the first flow control.

The priority of the specified service type is greater than or equal to a set level threshold.

In an embodiment of the present disclosure, the first token bucket may include a first sub-token bucket and a second sub-token bucket. The first sub-token bucket may be used for first flow control of designated services, and the second sub-token bucket may be used for first flow control of non-designated services.

As an example, when the service type to which the first data frame belongs is a designated service, the first real-time token number in the first sub-token bucket is compared with the number of tokens required for the first data frame. When the first real-time token number is greater than or equal to the number of tokens required for the first data frame, the first data frame passes the first flow control; when the first real-time token number is less than the number of tokens required for the first data frame, the first data frame fails to pass the first flow control, that is, the first data frame that exceeds the flow limit of the physical port is accumulated in the shared cache of the queue management.

Step 504, when the service type to which the first data frame belongs is a non-designated service, perform first flow control on the first data frame according to the second real-time token number in the second sub-token bucket and the priority of the first data frame to determine whether the first data frame passes the first flow control.

Among them, the priority of the non-designated service is less than the level threshold.

In order to avoid the uniformity of burst services during flow control and realize the absolute occupation of bandwidth resources by high priority during traffic congestion, as an example, when the service type to which the first data frame belongs is a non-specified service, the first flow control can be performed on the first data frame according to the second real-time token number in the second sub-token bucket combined with the priority of the first data frame to determine whether the first data frame passes the first flow control.

As an example, determine a first ratio of the second real-time token in the second sub-token bucket to the set total number of cards in the second sub-token bucket; when the first ratio is greater than or equal to (n-i)/n, determine whether the priority of the first data frame is greater than i; when the priority of the first data frame is greater than, determine that the first data frame passes the first flow control; when the priority of the first data frame is less than or equal to i, determine that the first data frame does not pass the first flow control; wherein n is the set number of priorities, i=0,1,2,…,(n-1).

For example, as shown in Figure 6, the first data frame sets 8 priorities. When the second real-time token number is greater than 7/8 of the total token number set in the second sub-token bucket, the first data frames of all priorities are allowed to consume tokens and send; when the second real-time token number is less than 7/8 of the total token number set in the second sub-token bucket, and the second real-time token number is greater than 6/8 of the total token number set in the second sub-token bucket, the first data frame with the lowest priority is prohibited from sending; and so on, when the second real-time token number is greater than 1/8 of the total token number set in the second sub-token bucket, only the first data frame with the highest priority is allowed to consume tokens and send. The data packets that are prohibited from sending are stored in the on-chip cache and discarded if the cache capacity is insufficient.

Step 505 , when the first data frame passes through the first flow control, a second token bucket matching each service data in the first data frame is used to perform a second flow control on each service data in the first data frame.

It should be noted that the execution process of steps 501 to 502 and step 505 can be implemented in any manner in the embodiments of the present disclosure, and the embodiments of the present disclosure do not limit this and will not be described in detail.

In summary, when the service type to which the first data frame belongs is a designated service, the first flow control is performed on the first data frame according to the first real-time token number in the first sub-token bucket to determine whether the first data frame passes the first flow control; when the service type to which the first data frame belongs is a non-designated service, the first flow control is performed on the first data frame according to the second real-time token number in the second sub-token bucket and the priority of the first data frame to determine whether the first data frame passes the first flow control. Therefore, the first flow control is performed on the first data frame using a flow control strategy that matches the service type to which the first data frame belongs, which can meet different business needs and also avoid network congestion caused by excessive burst business volume.

In order to clearly illustrate how the above embodiment uses a second token bucket matching each business data in the first data frame to perform second flow control on each business data in the first data frame when the first data frame passes the first flow control, the present disclosure proposes another flow control method.

FIG. 7 is a flow chart of another flow control method provided in an embodiment of the present disclosure.

As shown in FIG. 7 , the flow control method may include the following steps:

Step 701, decapsulate the received data packet according to the set frame structure to obtain a first data frame.

Step 702: Identify the first data frame to determine the service type to which the first data frame belongs.

Step 703: Perform a first flow control on the first data frame using a first token bucket that matches the service type of the first data frame to determine whether the first data frame passes the first flow control.

Step 704, when the service type to which the first data frame belongs is a designated service and the first data frame passes the first flow control, a second flow control is performed on each service data in the first data frame according to the number of third real-time tokens in a third sub-token bucket that matches each service data in the first data frame.

In an embodiment of the present disclosure, the second token bucket may include a third sub-token bucket and a fourth sub-token bucket, the third sub-token bucket may be used for second flow control of designated services, and the fourth sub-token bucket may be used for second flow control of non-designated services.

In order to achieve refined flow control, the second flow control may be performed on each service data in the first data frame.

As an example, when the first data frame passes the first flow control, each business data can be read from the first data frame according to the set frame structure, and for any business data, identification information of any business data can be obtained; when the identification information of any business data indicates that any business data is valid, a third sub-token bucket matching the data volume is determined according to the data volume of any business data.

That is to say, when the first data frame passes through the first flow control, based on the set frame structure, each business data is read from the first data frame. Since each business data may be invalid data, after reading each business data, it is possible to determine whether the business data is valid based on the identification information (e.g., the information frame header) in each business data. When the business data is determined to be valid based on the identification information, the type corresponding to the business data (e.g., low speed, medium speed, or high speed) can be determined based on the data volume of the business data, and a third sub-token bucket matching the type is selected based on the type corresponding to the business data. For example, if the type corresponding to the data volume of the business data is low-speed business, a low-speed third sub-token bucket is selected; for another example, if the type corresponding to the data volume of the business data is medium-speed business, a medium-speed third sub-token bucket is selected; for another example, if the type corresponding to the data volume of the business data is high-speed business, a high-speed third sub-token bucket is selected. It should be noted that the total number of tokens in the low-speed third sub-token bucket is less than the total number of tokens in the medium-speed third sub-token bucket, and the total number of tokens in the medium-speed third sub-token bucket is less than the total number of tokens in the high-speed third sub-token bucket.

Furthermore, the number of third real-time tokens in the third sub-token bucket is compared with the number of tokens required for the corresponding business data. When the number of third real-time tokens in the third sub-token bucket is greater than the number of tokens required for the corresponding business data, the corresponding business data passes through the second flow control.

It should be noted that the third sub-token bucket can be used to limit the output flow of the logical port, and the service data exceeding the flow limit can be discarded.

Step 705, when the service type to which the first data frame belongs is non-designated service and the first data frame passes the first flow control, the second flow control is performed on each service data in the first data frame according to the number of fourth real-time tokens in the fourth sub-token bucket that matches each service data in the first data frame and the priority of each service data.

In order to achieve refined flow control and improve the service quality of non-designated services, in the embodiment of the present disclosure, when the data packet passes the first flow control, the second flow control can be performed on each service data in the first data frame.

As an example, when the first data frame passes the first flow control, each business data can be read from the first data frame according to the set frame structure, and for any business data, the identification information of any business data can be obtained; when the identification information of any business data indicates that any business data is valid, the fourth sub-token bucket matching the data volume is determined according to the data volume of any business data.

That is to say, when the first data frame passes through the first flow control, based on the set frame structure, each business data is read from the first data frame. Since each business data may be invalid data, after reading each business data, it is possible to determine whether the business data is valid based on the identification information (e.g., the information frame header) in each business data. When the business data is determined to be valid based on the identification information, the type corresponding to the business data (e.g., low speed, medium speed, or high speed) can be determined based on the data volume of the business data, and a fourth sub-token bucket matching the type is selected based on the type corresponding to the business data. For example, if the type corresponding to the data volume of the business data is low-speed business, the fourth sub-token bucket with a low rate is selected; for another example, if the type corresponding to the data volume of the business data is medium-speed business, the fourth token bucket with a medium rate is selected; for another example, if the type corresponding to the data volume of the business data is high-speed business, the fourth sub-token bucket with a high rate is selected. It should be noted that the total number of tokens in the fourth sub-token bucket with a low rate is less than the total number of tokens in the fourth sub-token bucket with a medium rate, and the total number of tokens in the fourth sub-token bucket with a medium rate is less than the total number of tokens in the fourth sub-token bucket with a high rate.

In order to avoid the uniformity of burst services during flow control and achieve absolute occupation of bandwidth resources by high priority during traffic congestion, as an example, when the first data frame passes the first flow control, the second flow control can be performed on each business data in the first data frame based on the number of fourth real-time tokens in the fourth sub-token bucket matching each business data in the first data frame and the priority of each business data.

As an example, for any business data in the first data frame, determine the second ratio of the fourth real-time token number in the fourth sub-token bucket matching any business data to the set total token number in the fourth sub-token bucket; when the second ratio is greater than or equal to (n-i)/n, determine whether the priority of any business data is greater than i; when the priority of any business data is greater than i, determine that any business data passes the corresponding second flow control; when the priority of any business data is less than or equal to i, determine that any business data does not pass the corresponding second flow control; wherein n is the set number of priorities, i=0,1,2,…,(n-1).

For example, if any service data in the first data frame is set with 8 priorities, when the fourth real-time token number is greater than 7/8 of the total token number set in the fourth sub-token bucket, service data of all priorities corresponding to the fourth real-time token number are allowed to consume tokens and be sent; when the fourth real-time token number is less than 7/8 of the total token number set in the fourth sub-token bucket, and the fourth real-time token number is greater than 6/8 of the total token number set in the fourth sub-token bucket, the service data with the lowest priority corresponding to the fourth real-time token number is prohibited from being sent; and so on, when the fourth real-time token number is greater than 1/8 of the total token number set in the fourth sub-token bucket, only the service data with the highest priority corresponding to the fourth real-time token number is allowed to consume tokens and be sent. The service data prohibited from being sent is stored in the on-chip cache and discarded if the cache capacity is insufficient.

It should be noted that the execution process of steps 701 to 703 can be implemented in any way in the embodiments of the present disclosure, and the embodiments of the present disclosure do not limit this and will not be described in detail.

In summary, when the service type to which the first data frame belongs is a designated service and the first data frame passes the first flow control, the second flow control is performed on each service data in the first data frame according to the third real-time token number in the third sub-token bucket that matches each service data in the first data frame; when the service type to which the first data frame belongs is a non-designated service and the first data frame passes the first flow control, the second flow control is performed on each service data in the first data frame according to the fourth real-time token number in the fourth sub-token bucket that matches each service data in the first data frame and the priority of each service data. Therefore, when the second flow control is performed on the first data frame, the third sub-token bucket or the fourth sub-token bucket that matches each service data is used to perform the second flow control on each service data, thereby realizing the refined flow control of the first data frame. At the same time, when the service type to which the first data frame belongs is a non-designated service, the second flow control is performed on each service data in the first data frame according to the fourth real-time token number in the fourth sub-token bucket that matches each service data in the first data frame and the priority of each service data, thereby avoiding the uniformity of burst services during flow control and realizing the absolute occupation of bandwidth resources by high priority during traffic congestion.

In order to achieve accurate control of the delay of the designated service, when the first data frame passes the first flow control, according to the third real-time token number in the third sub-token bucket matching the service data in the first data frame, after the second flow control is performed on each service data in the first data frame, the first target service data passing the second flow control can be encapsulated based on the set frame structure, and the encapsulated data frame can be scheduled. The above process is described in detail below in conjunction with FIG8.

FIG8 is a flow chart of another flow control method provided in an embodiment of the present disclosure.

As shown in FIG8 , the flow control method may include the following steps:

Step 801, decapsulate the received data packet according to the set frame structure to obtain a first data frame.

Step 802: Identify the first data frame to determine the service type to which the first data frame belongs.

Step 803, when the service type to which the first data frame belongs is a designated service, first flow control is performed on the first data frame according to the number of first real-time tokens in the first sub-token bucket to determine whether the first data frame passes the first flow control.

The priority of the specified service type is greater than or equal to a set level threshold.

Step 804, when the first data frame passes the first flow control, second flow control is performed on each service data in the first data frame according to the number of third real-time tokens in the third sub-token bucket matching each service data in the first data frame.

Step 805: Determine first target service data that passes the second flow control from each service data of the first data frame.

Since the service type to which the first data frame belongs is a designated service type, and when the first data frame passes the first flow control, the second flow control is performed on each service data in the first data frame according to the number of third real-time tokens in the third sub-token bucket that matches each service data in the first data frame. Therefore, in order to achieve precise control of the delay of the designated service, in the embodiment of the present disclosure, the service data passing the second flow can be encapsulated into a second data frame, and the second data frame can be scheduled. As an example, the service data passing the second flow control is obtained from each service data of the first data frame, and the service data passing the second flow control is used as the first target service data. Among them, the first target service data may include: at least one of low-speed service, medium-speed service and high-speed service.

Step 806: encapsulate the first target service data based on the frame structure to obtain a second data frame.

Further, according to the set frame structure, the first target service data is encapsulated to obtain a second data frame, wherein it should be noted that since the first target service data may include at least one of low-speed service, medium-speed service and high-speed service, the service data in the frame structure may include 4 low-speed services, 1 medium-speed service and 1 high-speed service, and the service data in the frame structure that is not included in the first target service data may be filled with invalid information. For example, the first target service data only includes medium-speed service and high-speed service, and when the first target service is encapsulated, the 4 low-speed services in the frame structure may be filled with invalid information.

Step 807: Use the set first gating strategy to periodically schedule the second data frame.

In order to achieve accurate control of the delay, for a designated service, the first gating may be periodically opened to schedule the second data frame.

It should be noted that the execution process of steps 801 to 804 can be implemented in any way in the embodiments of the present disclosure, and the embodiments of the present disclosure do not limit this and will not be described in detail.

In summary, by determining the first target business data through the second flow control from the business data of the first data frame; encapsulating the first target business data based on the frame structure to obtain the second data frame; and adopting the set first gating strategy to periodically schedule the second data frame, the delay of the specified business can be accurately controlled, thereby improving the service quality of the specified business.

In order to improve the service quality of non-designated services, in the embodiment of the present disclosure, when the first data frame passes the first flow control, according to the fourth real-time token number in the fourth sub-token bucket matching the service data in the first data frame and the priority of each service data, after the second flow control is performed on each service data in the first data frame, the second gating strategy can be adopted to schedule the service data passing the second flow control. The above process is described in detail below in conjunction with FIG. 9.

FIG9 is a flow chart of another flow control method provided in an embodiment of the present disclosure.

As shown in FIG9 , the flow control method may include the following steps:

Step 901: decapsulate the received data packet according to the set frame structure to obtain a first data frame.

Step 902: Identify the first data frame to determine the service type to which the first data frame belongs.

Step 903, when the service type to which the first data frame belongs is a non-designated service, the first data frame is subjected to a first flow control according to the number of second real-time tokens in the second sub-token bucket and the priority of the first data frame to determine whether the first data frame passes the first flow control.

Among them, the priority of the non-designated service is less than the level threshold.

Step 904, when the first data frame passes the first flow control, the second flow control is performed on each business data in the first data frame according to the number of fourth real-time tokens in the fourth sub-token bucket matching each business data in the first data frame and the priority of each business data.

Step 905: Determine second target service data that passes the second flow control from each service data of the first data frame.

Since the service type to which the first data frame belongs is a non-specified service type, and when the first data frame passes the first flow control, the second flow control is performed on each service data in the first data frame according to the fourth real-time token number in the fourth sub-token bucket that matches each service data in the first data frame and the priority of each service data. Therefore, in order to achieve accurate synchronization of each designated service data, the service data that passes the second flow control can be encapsulated into a data frame, and the encapsulated data frame can be scheduled. In the embodiment of the present disclosure, the second target service data that passes the second flow control can be obtained from each service data of the first data frame, and the service data that passes the second flow control can be used as the second target service data.

Step 906: encapsulate the second target service data based on the set frame structure to obtain a third data frame.

Furthermore, the second target service data is encapsulated according to the set frame structure to obtain a second data frame.

Step 907: use the set second gating strategy to schedule the third data frame.

In order to improve the service quality of non-designated services, in the embodiment of the present disclosure, the first gating may be periodically opened to schedule the third data frame.

It should be noted that the execution process of steps 901 to 904 can be implemented in any way in the embodiments of the present disclosure, and the embodiments of the present disclosure do not limit this and will not be described in detail.

In summary, by determining the second target business data through the second flow control from the business data of the first data frame; encapsulating the second target business data based on the set frame structure to obtain the third data frame; and adopting the set second gating strategy to schedule the third data frame, thereby achieving accurate synchronization of each business data in the non-designated business, and improving the service quality of the non-designated business.

In order to clearly illustrate how to decapsulate the received data packet according to the set frame structure in the above embodiment to obtain the first data frame, the present disclosure proposes a flow chart of another flow control method.

FIG. 10 is a flow chart of another flow control method provided in an embodiment of the present disclosure.

As shown in FIG10 , the flow control method may include the following steps:

Step 1001, determining the data type of each service data in the data packet.

In the embodiment of the present disclosure, the business data in the data can be identified to determine the data type of each business data in the data packet. It should be noted that the data packet may include business data of at least one data type, for example, the business data may be voice, short message, navigation data or video.

Step 1002: Determine the location information of each service data in the frame structure according to the data type and data volume corresponding to each service data.

As an example, the set frame structure may include synchronization information, frame header information and data part, wherein the data part may be classified according to the data type and data volume of the service data. As an example, the data part may be divided into 4 low-speed services, 1 medium-speed service and 1 high-speed service, wherein the data volume corresponding to the high-speed service is greater than the data volume corresponding to the medium-speed service, and the data volume corresponding to the medium-speed service is greater than the data volume corresponding to the low-speed service. For example, the low-speed service is pictures, the medium-speed service is voice, and the high-speed service is video. Furthermore, according to the data type and data volume corresponding to each service data, the position information of each service data in the frame structure may be determined. For example, pictures correspond to low-speed services in the frame structure, voice corresponds to medium-speed services in the frame structure, and video corresponds to high-speed services in the frame structure.

Step 1003: decapsulate each service data according to the position information of each service data in the frame structure to obtain a first data frame.

Then, each service data can be decapsulated according to the position information in the frame structure, so as to obtain the first data frame. It should be noted that when the service data in the data part of the frame structure does not exist in the service data of the data packet, invalid information can be used to fill it to avoid inter-satellite jitter. For example, the data packet includes medium-speed services and high-speed services. When decapsulating each service data, the four low-speed services in the data part of the frame structure can be filled with invalid information.

Step 1004: Identify the first data frame to determine the service type to which the first data frame belongs.

Step 1005: Perform a first flow control on the first data frame using a first token bucket that matches the service type of the first data frame to determine whether the first data frame passes the first flow control.

Step 1006: When the first data frame passes through the first flow control, a second token bucket matching each service data in the first data frame is used to perform a second flow control on each service data in the first data frame.

It should be noted that the execution process of steps 1004 to 1006 can be implemented in any way in the embodiments of the present disclosure, and the embodiments of the present disclosure do not limit this and will not be described in detail.

In summary, by determining the data type of each business data in the data packet; determining the position information of each business data in the frame structure according to the data type and data volume corresponding to each business data; and decapsulating each business data according to the position information of each business data in the frame structure to obtain the first data frame, it is possible to effectively decapsulate each business data in the data packet according to the set frame structure to obtain the first data frame.

As a possible implementation of the embodiment of the present disclosure, the flow control method provided by the embodiment of the present disclosure may be implemented based on a flow control system. For example, the structure of the flow control system may be as shown in FIG. 11 , and the flow control system may implement the flow control method provided by the embodiment of the present disclosure in the following steps:

1. In order to facilitate interaction with other communication devices, the time slot counter can be started to count the co-track, off-track, and feeding data received by the payload by time slot. At the same time, the received data is judged by the service discriminator. If it is a designated service, it is sent to the refined shaping module 1-4; if it is a non-designated service, it is sent to the refined shaping module 5-8; at the same time, the time slot counter is judged. If it exceeds a frame length specified time slot (such as 1024), it is cleared and counted again;

2. For the data sent to the refined shaping module, a method of combining a first-level token bucket with a variable-rate token bucket is used to implement refined flow control. The first-level token bucket is used to limit the output flow of the physical port. Data packets that exceed the flow limit are accumulated in the shared cache of the queue management, and data packets that do not exceed the flow limit are sent to the corresponding variable-rate token bucket (the third sub-token bucket corresponding to each service data in the designated service, and the fourth sub-token bucket corresponding to each service data in the non-designated service). The variable-rate token bucket is used to limit the output flow of the logical port. Data packets that exceed the flow limit are discarded, and data packets that do not exceed the flow limit are sent to the gating scheduling module;

3. Finally, for the data sent to the gating scheduling, the gating table is scheduled according to the counter and ephemeris, and the data output is controlled through the gating table; among them, the gating of designated services (special services) is periodically opened; the non-designated services (ordinary services) are always open, and the non-designated services are transmitted according to the service quality level of the non-designated services. Among them, the gating scheduling module is divided into gating 1-4 for designated services and gating 5-8 for non-designated services. It mainly controls whether the gating is opened by reading the gating table value through the ephemeris and counter, thereby controlling whether the data frames in each queue are transmitted. Among them, the gating of designated services is periodically opened by four gatings; the gating of non-designated services is always open. The gating table is shown in Table 1. In the gating table, Y represents gating opening and N represents gating closing.

Table 1 Gating table

Serial number time Gate (1-8) status 1 0us Y-N-N-N-Y-Y-Y-Y 2 10us N-Y-N-N-Y-Y-Y-Y 3 20us N-N-Y-N-Y-Y-Y-Y 4 30us N-N-N-Y-Y-Y-Y-Y

The flow control method of the embodiment of the present disclosure decapsulates the received data packet according to the set frame structure to obtain the first data frame; distinguishes the first data frame to determine the service type to which the first data frame belongs; uses a first token bucket matching the service type of the first data frame to perform a first flow control on the first data frame to determine whether the first data frame passes the first flow control; when the first data frame passes the first flow control, uses a second token bucket matching each service data in the first data frame to perform a second flow control on each service data in the first data frame. Therefore, when forwarding data, the set frame structure can be used to decapsulate the forwarded data to generate the first data frame, and the first data frame is distinguished to determine the service type of the forwarded data. A flow control strategy matching the service type of the forwarded data is used to perform flow control on the forwarded data in a targeted and refined manner, thereby meeting the needs of different services, and avoiding network congestion caused by excessive burst business volume. At the same time, it can also avoid the uniformity of data flow control, improve the data transmission quality, and better meet user needs.

In order to implement the above embodiments, the present disclosure also proposes a flow control device.

FIG. 12 is a schematic structural diagram of a flow control device provided in an embodiment of the present disclosure.

As shown in FIG. 12 , the flow control device 1200 includes: a decapsulation module 1210 , a determination module 1220 , a first flow control module 1230 , and a second flow control module 1240 .

Among them, the decapsulation module 1210 is used to decapsulate the received data packet according to the set frame structure to obtain the first data frame; the identification module 1220 is used to identify the first data frame to determine the service type to which the first data frame belongs; the first flow control module 1230 is used to perform a first flow control on the first data frame using a first token bucket matching the service type of the first data frame to determine whether the first data frame passes the first flow control; the second flow control module 1240 is used to perform a second flow control on each service data in the first data frame using a second token bucket matching each service data in the first data frame when the first data frame passes the first flow control.

As a possible implementation method of the embodiment of the present disclosure, the first token bucket includes a first sub-token bucket and a second sub-token bucket, and the first flow control module 1230 is specifically used to: when the service type to which the first data frame belongs is a designated service, according to the first real-time token number in the first sub-token bucket, perform a first flow control on the first data frame to determine whether the first data frame passes the first flow control; wherein the priority of the designated service type is greater than or equal to the set level threshold; when the service type to which the first data frame belongs is a non-designated service, according to the second real-time token number in the second sub-token bucket and the priority of the first data frame, perform a first flow control on the first data frame to determine whether the first data frame passes the first flow control; wherein the priority of the non-designated service is less than the level threshold.

As a possible implementation method of the embodiment of the present disclosure, the second token bucket includes a third sub-token bucket and a fourth sub-token bucket, and the second flow control module 1240 is specifically used to: when the business type to which the first data frame belongs is a designated business and the first data frame passes the first flow control, perform second flow control on each business data in the first data frame according to the third real-time token number in the third sub-token bucket that matches each business data in the first data frame; when the business type to which the first data frame belongs is a non-designated business and the first data frame passes the first flow control, perform second flow control on each business data in the first data frame according to the fourth real-time token number in the fourth sub-token bucket that matches each business data in the first data frame and the priority of each business data.

As a possible implementation method of the embodiment of the present disclosure, the first flow control module 1230 is also used to: determine a first ratio of the second real-time token in the second sub-token bucket to the set total number of cards in the second sub-token bucket; when the first ratio is greater than or equal to (n-i)/n, determine whether the priority of the first data frame is greater than i; when the priority of the first data frame is greater than, determine that the first data frame passes the first flow control; when the priority of the first data frame is less than or equal to i, determine that the first data frame does not pass the first flow control; wherein n is the set number of priorities, i=0,1,2,…,(n-1).

As a possible implementation method of the embodiment of the present disclosure, the second flow control module 1240 is also used to: for any business data in the first data frame, determine the second ratio of the fourth real-time token in the fourth sub-token bucket matching any business data to the set total number of cards in the fourth sub-token bucket; when the second ratio is greater than or equal to (n-i)/n, determine whether the priority of any business data is greater than i; when the priority of any business data is greater than i, determine that any business data passes the corresponding second flow control; when the priority of any business data is less than or equal to i, determine that any business data does not pass the corresponding second flow control; wherein n is the set number of priorities, i=0,1,2,…,(n-1).

As a possible implementation of the embodiment of the present disclosure, the flow control device 1200 further includes: a first determination module, a first encapsulation module and a first scheduling module.

Among them, the first determination module is used to determine the first target business data through the second flow control from the various business data of the first data frame; the first encapsulation module is used to encapsulate the first target business data based on the frame structure to obtain the second data frame; the first scheduling module is used to adopt the set first gating strategy to periodically schedule the second data frame.

As a possible implementation manner of the embodiment of the present disclosure, the flow control device 1200 further includes: a second determination module, a second encapsulation module and a second scheduling module.

Among them, the second determination module is used to determine the second target business data through the second flow control from the various business data of the first data frame; the second encapsulation module is used to encapsulate the second target business data based on the set frame structure to obtain the third data frame; the second scheduling module is used to schedule the third data frame using the set second gating strategy.

As a possible implementation method of the embodiment of the present disclosure, the determination module 1220 is used to: obtain frame header information of the first data frame; determine the target business type from multiple reference business types based on the frame header information, wherein the target business type matches the frame header information; and use the target business type as the business type to which the first data frame belongs.

As a possible implementation method of the embodiment of the present disclosure, the decapsulation module 1210 is used to: determine the data type of each business data in the data packet; determine the position information of each business data in the frame structure according to the data type and data volume corresponding to each business data; decapsulate each business data according to the position information of each business data in the frame structure to obtain a first data frame.

The flow control device of the disclosed embodiment decapsulates the received data packet according to the set frame structure to obtain the first data frame; discriminates the first data frame to determine the service type to which the first data frame belongs; uses the first token bucket matching the service type of the first data frame to perform the first flow control on the first data frame to determine whether the first data frame passes the first flow control; when the first data frame passes the first flow control, uses the second token bucket matching the service data in the first data frame to perform the second flow control on the service data in the first data frame. Thus, when forwarding data, the set frame structure can be used to decapsulate the forwarded data to generate the first data frame, and the first data frame can be discriminated to determine the service type of the forwarded data, and the flow control strategy matching the service type of the forwarded data is used to control the forwarded data in a targeted and refined manner, so as to meet the needs of different services, and avoid network congestion caused by excessive burst business volume, and at the same time, it can also avoid the uniformity of data flow control, improve the data transmission quality, and better meet the needs of users.

It should be noted that the above explanation of the flow control method embodiment is also applicable to the flow control device of this embodiment, and will not be repeated here.

In order to implement the above embodiments, the present application further proposes an electronic device, as shown in FIG13 . FIG13 is a block diagram of an electronic device for flow control according to an exemplary embodiment.

As shown in FIG. 13 , the electronic device 1300 includes:

The memory 1310 and the processor 1320, a bus 1330 connecting different components (including the memory 1310 and the processor 1320), the memory 1310 stores a computer program, and when the processor 1320 executes the program, the flow control method described in the embodiment of the present disclosure is implemented.

Bus 1330 represents one or more of several types of bus structures, including a memory bus or memory controller, a peripheral bus, an accelerated graphics port, a processor or a local bus using any of a variety of bus architectures. For example, these architectures include but are not limited to Industry Standard Architecture (ISA) bus, Micro Channel Architecture (MAC) bus, Enhanced ISA bus, Video Electronics Standards Association (VESA) local bus and Peripheral Component Interconnect (PCI) bus.

The electronic device 1300 typically includes a variety of electronic device readable media. These media can be any available media that can be accessed by the electronic device 1300, including volatile and non-volatile media, removable and non-removable media.

The memory 1310 may also include computer system readable media in the form of volatile memory, such as random access memory (RAM) 1340 and/or cache memory 1350. The electronic device 1300 may further include other removable/non-removable, volatile/non-volatile computer system storage media. By way of example only, the storage system 1360 may be used to read and write non-removable, non-volatile magnetic media (not shown in FIG. 13 , commonly referred to as a “hard drive”). Although not shown in FIG. 13 , a disk drive for reading and writing a removable non-volatile disk (such as a “floppy disk”) and an optical disk drive for reading and writing a removable non-volatile optical disk (such as a CD-ROM, DVD-ROM or other optical media) may be provided. In these cases, each drive may be connected to the bus 1330 via one or more data medium interfaces. The memory 1310 may include at least one program product having a set (e.g., at least one) of program modules that are configured to perform the functions of the various embodiments of the present disclosure.

A program/utility 1380 having a set (at least one) of program modules 1370 may be stored, for example, in the memory 1310, such program modules 1370 including, but not limited to, an operating system, one or more application programs, other program modules, and program data, each of which or some combination may include an implementation of a network environment. The program modules 1370 generally perform the functions and/or methods of the embodiments described in the present disclosure.

The electronic device 1300 may also communicate with one or more external devices 1390 (e.g., keyboards, pointing devices, displays, etc.), may communicate with one or more devices that enable a user to interact with the electronic device 1300, and/or may communicate with any device that enables the electronic device 1300 to communicate with one or more other computing devices (e.g., network cards, modems, etc.). Such communication may be performed via an input/output (I/O) interface 1392. Furthermore, the electronic device 1300 may also communicate with one or more networks (e.g., local area networks (LANs), wide area networks (WANs), and/or public networks, such as the Internet) via a network adapter 1393. As shown in FIG. 13 , the network adapter 1393 communicates with other modules of the electronic device 1300 via a bus 1330. It should be understood that, although not shown in FIG. 13 , other hardware and/or software modules may be used in conjunction with the electronic device 1300, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAID systems, tape drives, and data backup storage systems, etc.

The processor 1320 executes various functional applications and data processing by running the programs stored in the memory 1310 .

It should be noted that the implementation process and technical principles of the electronic device of this embodiment refer to the aforementioned explanation of the flow control of the embodiment of the present disclosure, and will not be repeated here.

In order to implement the above embodiments, the present application also proposes a computer-readable storage medium on which a computer program is stored. When the computer program is executed by a processor, the flow control method described in the above embodiments is implemented.

In order to implement the above embodiments, the present disclosure further provides a computer program product. When an instruction processor in the computer program product is executed, the flow control method described in the above embodiments is executed.

In the description of this specification, the terms "first" and "second" are used for descriptive purposes only and cannot be understood as indicating or implying relative importance or implicitly indicating the number of the indicated technical features. Therefore, the features defined as "first" and "second" may explicitly or implicitly include at least one of the features. In the description of this application, the meaning of "plurality" is at least two, such as two, three, etc., unless otherwise clearly and specifically defined.

In the description of this specification, the description with reference to the terms "one embodiment", "some embodiments", "example", "specific example", or "some examples" etc. means that the specific features, structures, materials or characteristics described in conjunction with the embodiment or example are included in at least one embodiment or example of the present application. In this specification, the schematic representations of the above terms do not necessarily refer to the same embodiment or example. Moreover, the specific features, structures, materials or characteristics described may be combined in any one or more embodiments or examples in a suitable manner. In addition, those skilled in the art may combine and combine the different embodiments or examples described in this specification and the features of the different embodiments or examples, without contradiction.

Although the embodiments of the present application have been shown and described above, it can be understood that the above embodiments are exemplary and cannot be understood as limitations on the present application. Ordinary technicians in the field can change, modify, replace and modify the above embodiments within the scope of the present application.

Claims (12)

1. A flow control method, comprising:

decapsulating the received data packet according to a set frame structure to obtain a first data frame;

judging the first data frame to determine the service type of the first data frame;

performing first flow control on the first data frame by adopting a first token bucket matched with the service type of the first data frame so as to determine whether the first data frame passes the first flow control;

And when the first data frame passes through the first flow control, adopting a second token bucket matched with each service data in the first data frame to carry out second flow control on each service data in the first data frame.

2. The method of claim 1, wherein the first token bucket comprises a first sub-token bucket and a second sub-token bucket, wherein the performing first traffic control on the first data frame with the first token bucket matching a traffic type of the first data frame to determine whether the first data frame passes the first traffic control comprises:

When the service type of the first data frame is a designated service, performing first flow control on the first data frame according to a first real-time token number in the first sub-token bucket so as to determine whether the first data frame passes through first flow control; the priority of the appointed service type is greater than or equal to a set level threshold;

When the service type of the first data frame is non-appointed service, according to the second real-time token number in the second sub-token bucket and the priority of the first data frame, performing first flow control on the first data frame to determine whether the first data frame passes through first flow control; wherein the priority of the unspecified service is less than the level threshold.

3. The method of claim 1, wherein the second token bucket comprises a third sub-token bucket and a fourth sub-token bucket, wherein the second traffic control for each traffic data in the first data frame using the second token bucket that matches each traffic data in the first data frame as the first data frame passes the first traffic control comprises:

under the condition that the service type of the first data frame is a designated service and the first data frame is controlled by a first flow, controlling the second flow of each service data in the first data frame according to the third real-time token number in a third sub-token bucket matched with each service data in the first data frame;

And under the condition that the service type of the first data frame is non-appointed service and the first data frame is controlled by a first flow, controlling the second flow of each service data in the first data frame according to the fourth real-time token number in a fourth sub-token bucket matched with each service data in the first data frame and the priority of each service data.

4. The method of claim 2, wherein when the traffic type to which the first data frame belongs is a non-designated traffic type, performing first traffic control on the first data frame according to a second real-time token number in a second sub-token bucket and a priority of the first data frame to determine whether the first data frame passes the first traffic control, comprises:

Determining a first duty ratio of a second real-time token number in the second sub-token bucket to a set total token number in the second sub-token bucket;

Determining whether the priority of the first data frame is greater than i, if the first duty cycle is greater than or equal to (n-i)/n;

Determining that the first data frame passes through the first flow control under the condition that the priority of the first data frame is greater than that of the first data frame;

determining that the first data frame does not pass the first flow control in the case that the priority of the first data frame is less than or equal to i;

Wherein n is the set number of priorities, i=0, 1,2, …, (n-1).

5. The method according to claim 3, wherein, in the case that the service type to which the first data frame belongs is a non-designated service and the first data frame is controlled by a first flow, performing a second flow control on each service data in the first data frame according to a fourth real-time token number in a fourth sub-token bucket matched with each service data in the first data frame and a priority of each service data, includes:

Determining a second duty ratio of a fourth real-time token number in a fourth sub-token bucket matched with any service data to a set total token number in the fourth sub-token bucket according to any service data in the first data frame;

Determining whether the priority of any service data is greater than i when the second duty ratio is greater than or equal to (n-i)/n;

determining any business data to pass through corresponding second flow control under the condition that the priority of any business data is larger than i;

under the condition that the priority of any business data is less than or equal to i, determining that any business data does not pass through the corresponding second flow control;

Wherein n is the set number of priorities, i=0, 1,2, …, (n-1).

6. A method according to claim 3, characterized in that the method further comprises:

reading each service data from the first data frame based on a set frame structure;

acquiring identification information of any business data aiming at any business data;

And when the identification information of any service data indicates that any service data is effective, determining a third sub-token bucket or a fourth sub-token bucket matched with the data quantity according to the data quantity of any service data.

7. The method of claim 3, wherein, in the case where the service type to which the first data frame belongs is a designated service and the first data frame is controlled by a first flow, performing second flow control on each service data in the first data frame according to a third real-time token number in a third sub-token bucket matched with each service data in the first data frame, further comprises:

determining first target service data controlled by the second flow from the service data of the first data frame;

Based on the frame structure, encapsulating the first target service data to obtain a second data frame;

And adopting a set first gating strategy to schedule the second data frame periodically.

8. The method according to claim 3, wherein, in the case that the service type to which the first data frame belongs is a non-designated service and the first data frame is controlled by a first flow, after performing a second flow control on each service data in the first data frame according to a fourth real-time token number in a fourth sub-token bucket matched with each service data in the first data frame and a priority of each service data, further comprising:

determining second target service data controlled by the second flow from the service data of the first data frame;

Based on a set frame structure, encapsulating the second target service data to obtain a third data frame;

And scheduling the third data frame by adopting a set second gating strategy.

9. The method of claim 1, wherein the determining the first data frame to determine the traffic type to which the first data frame belongs comprises:

acquiring frame header information of the first data frame;

Determining a target service type from a plurality of reference service types according to the frame header information, wherein the target service type is matched with the frame header information;

and taking the target service type as the service type to which the first data frame belongs.

10. The method according to any one of claims 1-9, wherein decapsulating the received data packet according to a set frame structure to obtain a first data frame comprises:

determining the data type of each service data in the data packet;

determining the position information of each service data in the frame structure according to the data type and the data volume corresponding to each service data;

and decapsulating each service data according to the position information of each service data in the frame structure to obtain a first data frame.

11. A flow control device, comprising:

The decapsulation module is used for decapsulating the received data packet according to a set frame structure to obtain a first data frame;

The judging module is used for judging the first data frame to determine the service type of the first data frame;

a first flow control module, configured to perform first flow control on the first data frame using a first token bucket that matches a traffic type of the first data frame, so as to determine whether the first data frame passes the first flow control;

And the second flow control module is used for carrying out second flow control on each service data in the first data frame by adopting a second token bucket matched with each service data in the first data frame when the first data frame passes through the first flow control.

12. An electronic device comprising a memory, a processor and a computer program stored on the memory and executable on the processor, the processor implementing the flow control method of any one of claims 1-10 when the program is executed.