CN116915694A - Data transmission method, gateway, communication device, and computer-readable storage medium - Google Patents

Abstract

The present invention provides a data transmission method, a gateway, a communication device and a computer-readable storage medium. The method on the first gateway side of the terminal side includes: receiving a data flow to be transmitted; and determining the said data flow according to the diversion strategy of the data flow. Each data frame of the data flow corresponds to a target link; add a link identifier of the target link corresponding to the data frame to each data frame of the data flow, and the data frame carries timestamp information. ; Send the data frame with the link identifier added to the second gateway on the server side through the target link. The solution of the present invention realizes multi-link split transmission of data streams and improves link usage efficiency.

Description

Data transmission method, gateway, communication equipment and computer-readable storage medium

Technical field

The present invention relates to the field of communication technology, and in particular, to a data transmission method, gateway, communication equipment and computer-readable storage medium.

Background technique

Traditional data communication networks can realize data transmission offloading through PBR (Policy Based Routing, Policy Routing), MultiPathTCP (Multipath Transmission Control Protocol), TAN (Time Aware Network, Time Aware Network) technology, etc.;

However, these solutions still have the following problems:

The traditional link status measurement solution requires sending a large number of detection packets and cannot ensure real-time and accurate measurement of the link status with low network overhead;

PBR has the problem of high configuration complexity. It needs to be configured point-to-point according to the actual situation of the on-site network. It cannot realize multi-link data offloading of a single connection and cannot provide more complete bandwidth or transmission guarantee for a single data stream;

MultiPath TCP requires the transformation and interconnection of communication equipment, that is, the MultiPathTCP function needs to be implemented at the dual-end application layer. It cannot realize multi-link data offloading and cannot provide more complete bandwidth or transmission guarantee for data flow.

Contents of the invention

The invention provides a data transmission method, a gateway, a communication device and a computer-readable storage medium. It can improve link usage efficiency and provide transmission guarantee for data flow.

In order to solve the above technical problems, the technical solutions of the present invention are as follows:

A data transmission method, applied to the first gateway on the terminal side, the method includes:

Receive the data stream to be transmitted;

According to the offloading strategy of the data flow, determine the target link corresponding to each data frame of the data flow;

Add the link identifier of the target link corresponding to the data frame in each data frame of the data flow, and the data frame carries timestamp information;

The data frame with the link identifier added is sent to the second gateway on the server side through the target link.

Optionally, the method includes:

Obtain link status of multiple links connected to the first gateway;

Determine a distribution strategy for the data flow according to the link status of the multiple links.

Optionally, obtaining link status of multiple links connected to the first gateway includes:

According to a preset period, receive the second link status information measurement result sent by the second gateway; the second link status information measurement result includes link identifiers of multiple links and the link identifier corresponding to each link identifier. At least one link indicator measurement value of the link within a preset time period, the plurality of links being communication links between the first gateway and the second gateway;

Update the local first link status information set according to the second link status information measurement result. The first link status information set includes link identifiers of multiple links and the link corresponding to each link identifier. At least one link indicator value within the preset time period;

Obtain the link status of multiple links connected to the first gateway according to at least one link indicator value in the first link status information set;

sending the first link status information measurement result to the second gateway according to a preset period, so that the second gateway updates the local second link status information set according to the first link status information measurement result, The first link status information measurement result includes link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period; the second link The status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within the preset time period.

Optionally, determine the offloading strategy of the data flow according to the link status of the multiple links, including:

Determine the data flow according to at least one link index value among the delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to the link identifiers of the multiple links in the first link status information set. diversion strategy.

Optionally, when the data flow is two or more data flows, the delay, jitter, and packet loss rate of the link respectively corresponding to the link identifiers of the multiple links in the first link status information set are , at least one link indicator value in the transmission bandwidth, determines the offloading strategy of the data flow, including:

Filter the data characteristics of multiple data streams through preset mapping rules to obtain at least one data stream filtering group;

At least one of the delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to at least one of the data flow filtering groups and the link identifiers of multiple links in the first link status information set. The necklace link indicator value determines the diversion strategy of the data flow.

Optionally, add the link identifier of the target link corresponding to the data frame in each data frame of the data flow, including:

When it is determined that the link identifier of the link mark of the first gateway is consistent with the link identifier of the link mark of the second gateway, add the target link corresponding to the data frame in the data frame of the data flow. The link identifier of the road.

Optionally, add the link identifier of the target link corresponding to the data frame in the data frame of the data flow, including:

Add the link identifier of the target link to a reserved field in the data frame of the data flow.

Embodiments of the present invention also provide a data transmission method applied to the second gateway on the server side. The method includes:

Receive at least one data frame of the data flow sent by the first gateway on the terminal side through at least one target link; the data frame carries the link identification and timestamp information of the target link that transmits the data frame;

The at least one data frame is restored to the data stream according to the link identification and timestamp information in the at least one data frame.

Optionally, after receiving at least one data frame of the data stream sent by the first gateway on the terminal side through at least one target link, the method further includes:

Obtain a second link status information measurement result according to at least one link indicator measurement value of the data frame transmitted in the target link received within a preset time period; the second link status information measurement result including link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period;

According to a preset period, the second link status information measurement result is sent to the first gateway, so that the first gateway updates the local first link status information set according to the second link status information measurement result. ;The first link status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within a preset time period;

According to a preset period, receive the first link status information measurement result sent by the first gateway. The first link status information measurement result includes link identifiers of multiple links and the link corresponding to each link identifier. At least one link indicator measurement value of the road within a preset time period;

A local second link state information set is updated according to the first link state information measurement result. The second link state information set includes link identifiers of multiple links and links corresponding to each link identifier. At least one link index value within the preset time period.

An embodiment of the present invention also provides a first gateway, including:

The first transceiver module is used to receive the data stream to be transmitted;

The first processing module is configured to determine the target link corresponding to each data frame of the data flow according to the offloading strategy of the data flow; and add the corresponding target link of the data frame to each data frame of the data flow. The link identifier of the target link, and the data frame carries timestamp information;

The first transceiver module is also configured to send the data frame with the link identifier added to the second gateway on the server side through the target link.

An embodiment of the present invention also provides a second gateway, including:

The second transceiver module is configured to receive at least one data frame of the data stream sent by the first gateway on the terminal side through at least one target link; the data frame carries the link identifier of the target link that transmits the data frame and timestamp information;

The second processing module is configured to restore the at least one data frame into the data stream according to the link identification and timestamp information in the at least one data frame.

An embodiment of the present invention also provides a communication device, including: a processor and a memory storing a computer program. When the computer program is run by the processor, the method as described above is executed.

Embodiments of the present invention also provide a computer-readable storage medium that stores instructions that, when executed on a computer, cause the computer to perform the method described above.

The above solution of the present invention at least includes the following beneficial effects:

The solution of the present invention receives the data stream to be transmitted; determines the target link corresponding to each data frame of the data stream according to the diversion strategy of the data stream; in each data frame of the data stream Add the link identifier of the target link corresponding to the data frame, and the data frame carries timestamp information; send the data frame with the link identifier added to the server side through the target link. The second gateway: realizes multi-link split transmission of data frames of data streams, improves link usage efficiency, and provides guarantee for data stream transmission.

Description of the drawings

Figure 1 is a flow chart of a data transmission method applied to the first gateway on the terminal side provided by an embodiment of the present invention;

Figure 2 is a schematic diagram of offload transmission of data frames of a data stream between a first gateway on the terminal side and a second gateway on the server side provided by a specific embodiment of the present invention;

Figure 3 is a schematic diagram of the implementation framework of multi-link offloading during data transmission provided by an embodiment of the present invention;

Figure 4 is a schematic flowchart of the first gateway and the second gateway updating the real-time status information set in the embodiment of the present invention;

Figure 5 is a schematic flowchart of filtering data streams in an embodiment of the present invention;

Figure 6 is an implementation framework diagram of link offloading when transmission quality is satisfied in the embodiment of the present invention;

Figure 7 is an implementation framework diagram of link offloading when the transmission bandwidth is satisfied in the embodiment of the present invention;

Figure 8 is an implementation framework diagram of multi-link offloading when transmission quality and transmission bandwidth are satisfied in the embodiment of the present invention;

Figure 9 is a schematic flowchart of adding a link identifier through manual configuration mode according to an embodiment of the present invention;

Figure 10 is a schematic flowchart of adding a link identifier through server distribution mode according to an embodiment of the present invention;

Figure 11 is a schematic diagram of the location of the link identifier and timestamp information in the data frame in the embodiment of the present invention;

Figure 12 is a flow chart of a data transmission method applied to the second gateway on the server side provided by an embodiment of the present invention;

Figure 13 is a schematic diagram of the module structure of the first gateway provided by an embodiment of the present invention;

Figure 14 is a schematic module structure diagram of the second gateway provided by an embodiment of the present invention.

Detailed ways

Exemplary embodiments of the present disclosure will be described in more detail below with reference to the accompanying drawings. Although exemplary embodiments of the invention are shown in the drawings, it should be understood that the invention may be embodied in various forms and should not be limited to the embodiments set forth herein. Rather, these embodiments are provided to provide a thorough understanding of the invention, and to fully convey the scope of the invention to those skilled in the art.

As shown in Figure 1, an embodiment of the present invention provides a data transmission method, which is applied to the first gateway on the terminal side. The method includes:

Step 11, receive the data stream to be transmitted;

Step 12: Determine the target link corresponding to each data frame of the data flow according to the offloading strategy of the data flow;

Step 13: Add the link identifier of the target link corresponding to the data frame in each data frame of the data flow, and the data frame carries timestamp information;

Step 14: Send the data frame with the link identifier added to the second gateway on the server side through the target link.

In this embodiment, after receiving the data stream to be transmitted, the first gateway on the terminal side determines a shunt strategy for the data stream. The shunt strategy is used to provide a preferred transmission scheme for link selection for data stream transmission. Through the determination of the shunt strategy Optimized scheduling of real-time link selection can be achieved to improve various basic communication indicators during data stream transmission;

After determining the offloading strategy, each data frame in the data stream can be transmitted through the corresponding target link according to the offloading strategy. Before transmitting the data stream, add a link identifier to each data frame. The link identifier is the second link. The gateway indicates the transmission link of the data frame. At the same time, each data frame also carries timestamp information. The timestamp information enables the first gateway and the second gateway to synchronize their clocks, and is further used to provide the receiving end (i.e. the above-mentioned second gateway) with clock synchronization. Gateway) indicates the sending time of the data frame; the first gateway sends the data frame carrying timestamp information and link identification to the second gateway on the server side through the corresponding target link;

For the second gateway on the server side, after receiving the data frame, it can locate the target link that transmits the data frame and determine the time when the target link transmits the data frame based on the link identification and timestamp information carried by the data frame. Link indicator measurement values (such as transmission delay, packet loss rate, jitter, bandwidth and other indicators; according to the link identification, record the transmission delay, packet loss rate, jitter, transmission bandwidth and other indicators to the second link status information Among the measurement results, the second link status information measurement result is maintained by the second gateway, which records the latest link status information of each link between the first gateway on the terminal side and the second gateway on the server side; Based on the link status information, both ends can realize real-time monitoring and management of the link status, select the transmission link of the data frame according to the link status, realize multi-link data split transmission, improve the link usage efficiency, and rely on multiple The link transmission capability provides maximum transmission guarantee for data flow.

The link state information measurement results can be a data table, or other data forms that can be used to represent multiple link state information measurement result sets. This application is not limited to this;

It is worth noting that a data stream in this application consists of multiple data frames, and the data frame is preferably a TAN data frame, but is not limited to this, and may also be a TCP (Transmission Control Protocol, Transmission Control Protocol) data frame.

As shown in Figure 2, in a specific embodiment, the mobile terminal gateway (i.e., the above-mentioned first gateway) and the server-side gateway (i.e., the above-mentioned second gateway) perform data interaction, using the sending end data frame mark and the receiving end link status. Information statistics are used to optimize data transmission links. The links between the mobile gateway and the server gateway include 5G path 1, 5G path 2, WiFi path and optical fiber path, a total of 4, but of course not limited to 4. ;

When the mobile gateway transmits data stream X to the server gateway, data stream X includes data frame 8, data frame 7, data frame 6, data frame 5, data frame 4, data frame 3, data frame 2, and data frame 1; The mobile gateway determines the offloading strategy based on data flow X, and determines the target link for each data frame as:

Data frame 2 and data frame 1 are transmitted through 5G path 1 (link identification 001);

Data frame 8 and data frame 7 are transmitted through 5G path 2 (link identification 002);

Data frame 4 and data frame 3 are transmitted through the WiFi path (link identification 003);

Data frame 6 and data frame 5 are transmitted through the optical fiber path (link identification 004);

The mobile gateway adds the link identification of the corresponding target link to each data frame, and transmits the data frame carrying the timestamp information and link identification to the server gateway through the corresponding target link;

Further, the server gateway can locate the target link of the data frame based on the link identification carried in the data frame, determine the transmission delay of the target link based on the timestamp information, and record the transmission delay to In the link status information measurement table maintained by the server-side gateway, the link status information in the table is fed back to the mobile-side gateway so that the mobile-side gateway can update the latest link status information to provide information for the next data stream transmission. To ensure maximum transmission guarantee;

Similarly, when the server-side gateway transmits data flow Y to the mobile-side gateway, data flow Y includes data frame a8, data frame a7, data frame a6, data frame a5, data frame a4, data frame a3, data frame a2, data Frame a1; the mobile gateway determines the offloading strategy based on data flow Y, and determines the target link for each data frame as:

Data frame a6 and data frame a5 are transmitted through 5G path 1 (link identification 001);

Data frame a4 and data frame a3 are transmitted through 5G path 2 (link identification 002);

Data frame a8 and data frame a7 are transmitted through the WiFi path (link identification 003);

Data frame a2 and data frame a1 are transmitted through the optical fiber path (link identification 004);

The server-side gateway adds the link identification of the corresponding link to each data frame, and transmits the data frame carrying the timestamp information and link identification to the mobile-side gateway through the corresponding target link;

The mobile gateway can locate the target link of the data frame based on the link identification carried in the data frame, and determine the transmission delay, packet loss rate, jitter, bandwidth and other indicators of the target link based on the timestamp information. Based on the link identification , record the transmission delay, packet loss rate, jitter, bandwidth and other indicators into the link status information measurement table maintained by the mobile terminal gateway, and feed back the link status information in the table to the server-side gateway, which can be the server-side gateway Update the latest link status information;

The above-mentioned data transmission process between the mobile gateway and the server gateway improves the usage efficiency, transmission bandwidth and reliability of multi-links. At the same time, there is no need to carry out any adaptation upgrades on the sending side and the receiving side, and it can be detected faster. Changes in link status information and adjust the offloading strategy.

In an optional embodiment of the present invention, after step 11, it also includes:

Step 111: Obtain the link status of multiple links connected to the first gateway;

Step 112: Determine a distribution strategy for the data flow according to the link status of the multiple links.

In this embodiment, the offloading strategy is determined by the latest link status information of multiple links connected to the first gateway. The determination of the offloading strategy can be determined by a virtual scheduler set on the gateway side; each scheduler It includes a distribution module and a link indicator calculation module. The link indicator calculation module can calculate and update the transmission delay of the link and other link status information. The distribution module in the scheduler is responsible for the real-time multi-link distribution of user plane data. Processing, that is, the latest link status information obtained by the link indicator calculation module can be used. The link status is determined by multiple link indicators, and the traffic distribution strategy can be determined based on different link indicators.

Next, the execution process of the offload module and the link index calculation module in the scheduler during data stream transmission is explained:

As shown in Figures 2 and 3, the data transmission interaction between the first gateway on the terminal side (i.e., the mobile terminal gateway in Figure 2) and the second gateway on the server side (i.e., the server-side gateway in Figure 2) is performed by The scheduler deployed at the gateway is executed. The virtual scheduler of the first gateway is the first scheduler, and the virtual scheduler of the second gateway is the second scheduler. Each scheduler is composed of a shunt module and a link index calculation module. It consists of two parts; here, the link through which the first gateway transmits data to the second gateway is set as an uplink, and the link through which the second gateway transmits data to the first gateway is set as a downlink; the first gateway and There are n links between the second gateways (the link identifiers are divided into 1, 2, 3, .., n);

When the first gateway transmits the data flow The real-time link indicator table includes the latest uplink indicators, and the first splitter selects the uplink with the best link indicator for each data frame;

For example, the criterion for the quality of the first link index is: the higher the index value, the optimal link. If the link index value of the link with link ID 1 is x1, and x1 is greater than that of all other uplinks. If the link index value is specified, you can choose to shunt the data frame to the link with link ID 1;

The above-mentioned real-time link indicator table of the uplink is updated by the first link indicator calculation module. The first link indicator calculation module updates the link status information based on the real-time status information table of the uplink, through the indicator calculation function (such as , function f (Input link status)) calculates the link indicators of each link corresponding to the latest link status information, and updates the link indicators of each link to the real-time link indicator table for use by the first offload module;

In the same way, the execution process of the second virtual scheduler when the second gateway on the server side transmits the data flow Y to the first gateway will not be described in detail. Intelligent data frame processing is realized through the first scheduler and the second scheduler. Traffic offloading, and link indicators (such as business traffic requirements, real-time link load conditions, channel quality and other link indicators).

In an optional embodiment of the present invention, step 111 includes:

Step 1111: Receive the second link status information measurement result sent by the second gateway according to a preset period; the second link status information measurement result includes link identifiers of multiple links and the corresponding link identifiers of each link. At least one link indicator measurement value of a link within a preset time period, the plurality of links being communication links between the first gateway and the second gateway;

Step 1112: Update the local first link status information set according to the second link status information measurement result. The first link status information set includes link identifiers of multiple links and the corresponding link identifiers of each link. At least one link index value of the link within the preset time period;

Step 1113: Obtain the link status of multiple links connected to the first gateway based on at least one link indicator value in the first link status information set.

In the embodiment of the present invention, the first gateway receives the second link status information measurement result sent by the second gateway according to a preset period. The second link status information measurement result includes link identifiers of multiple links and the link status information. multiple link indicator values of the link corresponding to the road identifier, and update the local first link status information set according to the link indicator value, so that the link status information of the first gateway and the second gateway remains consistent, while ensuring The link status information based on which the first gateway transmits the data frame next time is the latest; and the link status is determined based on the updated local first link status information set. In the same way as the link state information measurement results, the link state information set can also be a data table, or other data forms that can be used to represent multiple link state information measurement result sets. This application is not limited to this. ;

It should be noted that in order to ensure synchronization of updated link status information between the first gateway and the second gateway, it is necessary to ensure that high-precision clock synchronization is maintained between the first gateway and the second gateway.

In an optional embodiment of the present invention, after step 1113, it may also include:

Step 1114: Send the first link status information measurement result to the second gateway according to a preset period, so that the second gateway updates the local second link status according to the first link status information measurement result. Information set, the first link status information measurement result includes link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period; the third link status information measurement result includes: The second link status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within the preset time period.

In this embodiment, since the link index value in step 121 is determined by updating the local link status information set based on the link status information measurement results of the opposite side, in order to ensure the link status of the link during the data stream transmission process Information is updated and monitored in real time. The first gateway will send the first link status information measurement result to the second gateway according to the preset period, so that the second gateway updates the local second link status based on the first link status information measurement result. Information set; the second link state information set can be used as a basis for determining the target link when the second gateway sends a data flow to the first gateway.

It is worth noting that the local second link status information set at the gateway is updated according to the preset period (T1 in Figure 3), and the real-time link indicator set in the scheduler at the gateway is updated according to the preset indicator period. (T2 in Figure 3) updated, the preset indicator period is preferably smaller than the preset period to ensure that the link indicators used by the scheduler are the latest.

As shown in Figure 4, in a specific embodiment, the dynamic multi-link maintenance connection between the first gateway and the second gateway is successfully established, and the clocks at both ends maintain high-precision synchronization;

When link data is exchanged between the first gateway and the second gateway, if the first gateway sends data to the second gateway, the first data frame sent carries "link identification ID = 1 + timestamp = tsx + frame sequence number + payload", the second data frame of the sender carries "link identification ID = 2 + timestamp = tsx + frame sequence number + payload";

After receiving the first data frame and the second data frame, the second gateway calculates the transmission delay of the data frame and records it in the uplink status information table. The second gateway performs the maintenance on the uplink status information measurement table. Update, the table includes the link identification, transmission delay, etc. of each link;

The updated uplink status information measurement table is as follows:

Table 1

According to the preset period, the second gateway sends the updated uplink status information measurement table to the first gateway, so that the first gateway can update the uplink real-time status information table according to the uplink reception quality parameter;

The updated uplink real-time status information table at the first gateway is as follows:

Table 2

In the same way, if the second gateway sends data to the first gateway, the third data frame sent carries "link identification ID = 1 + timestamp = tsx + frame sequence number + payload", and the fourth data frame of the sending end carries "link Road identification ID = 3 + timestamp = tsx + frame sequence number + payload";

After receiving the third data frame and the fourth data frame, the first gateway calculates the transmission delay of the data frame and records it in the link status information table. The first gateway updates the maintained downlink status information measurement table. , this table includes the link identification, transmission delay, etc. of each link;

The updated downlink status information measurement table is as follows:

table 3

According to the preset period, the first gateway sends the downlink reception quality parameter to the second gateway based on the latest downlink status information measurement table, so that the second gateway can update the downlink real-time based on the downlink reception quality parameter. status information table;

The updated downlink real-time status information table at the second gateway is as follows:

Table 4

According to the above Table 2 and Table 4, it can be seen that after the update, the uplink real-time status information table and the downlink real-time status information table at the first gateway and the second gateway remain consistent.

In yet another optional embodiment of the present invention, step 112 includes:

Step 1121: Determine the link index value based on at least one of the link indicator values of delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to the link identifiers of the multiple links in the first link status information set. Describe the data flow diversion strategy.

In embodiments of the present invention, the link indicators corresponding to the offloading strategy may be determined according to the business requirements of the data flow of the first gateway. The link indicators include at least one of delay, jitter, packet loss rate, and transmission bandwidth.

In the case where the data flow is more than two data flows, step 1121 includes:

Step 11211: Filter the data characteristics of multiple data streams through preset mapping rules to obtain at least one data stream filtering group;

Step 11212: Determine the delay, jitter, packet loss rate, and transmission bandwidth of the link based on at least one of the data flow filtering groups and the link identifiers of multiple links in the first link status information set. At least one link indicator value determines the data flow offloading strategy.

In the embodiment of the present invention, in order to meet the diversified business requirements for transmission of different data streams (business requirements such as: the first service connection has extremely high requirements for packet loss rate, but the requirements for transmission jitter are not strict, and The second service connection has very high requirements for transmission jitter, but has a certain tolerance for delay). The sending side gateway (the first gateway) can input the data stream into the filter to filter the data characteristics of the preset mapping rules. The filter is based on The matching result transmits the data flow to the sending side gateway (second gateway). The first gateway can schedule and forward the corresponding data flow according to the preset mapping rules specified by the virtual scheduler. The preset mapping rules include Layer 2 data packet type, All or part of the IP six-tuple and at least one of other data characteristics; wherein, the preset mapping rules of these data characteristics can be configured by users according to their own needs, and this application is not limited to this;

The result of data feature filtering is at least one data flow filtering group, and each data flow filtering group includes multiple data flows with the same data feature;

The process of determining the offloading strategy of the data flows in the data flow filtering group is the same as the above steps 111 to 112, and will not be described again here.

As shown in Figure 5, in a specific embodiment, the Layer 2 data frame type of the first data stream is Profinet; the Layer 2 data frame type of the second data stream is GOOSE; and the Layer 2 data frame type of the nth data stream is Ethernet;

Set the preset mapping rules in the filter. The data flow of the second-layer data frame type Profinet will be mapped to the nth scheduler. The data flow of the second-layer data frame type GOOSE will be mapped to the second scheduler. Data flows whose layer data frame type is Ethernet will be mapped to the first scheduler.

Among them, the scheduling strategies of each scheduler are as follows:

The first scheduler: adopts the offloading strategy to increase the total transmission bandwidth,

Second scheduler: adopts a traffic offloading strategy to optimize transmission quality,

nth scheduler: adopts an offloading strategy to optimize transmission quality,

Among them, Delay0 (30ms) used in the second scheduler is greater than Delay0 (20ms) in the nth scheduler, and Jitter0 (2ms) used in the second scheduler is less than Jitter0 (5ms) in the nth scheduler. It can be seen that , the second scheduler focuses on the optimization of transmission jitter, while the nth scheduler focuses on the optimization of transmission jitter; data frames are scheduled and forwarded according to matching rules.

In the above embodiments of the present invention, according to the link identifiers of multiple links in the first link status information set, at least one of the link's delay, jitter, packet loss rate, and transmission bandwidth corresponds to Indicator values determine the offloading strategy of the data flow, including:

The first offloading strategy: According to the delay index value of the link corresponding to the link identifier of multiple links in the first link status information set, it is the data frame of the data flow that needs to meet the delay requirement. When configuring at least one first target link whose delay index value is less than the first value;

The second offloading strategy: According to the jitter index value of the link corresponding to the link identifier of the multiple links in the first link status information set, configure the jitter index value for the data frame that needs to meet the jitter requirement data flow. at least one second target link less than the second value;

The third traffic offloading strategy: According to the packet loss rate index value of the link corresponding to the link identifier of the multiple links in the first link status information set, it is the data frame of the data flow that needs to meet the packet loss rate requirement, Configure at least one third target link whose packet loss rate index value is less than the third value;

The fourth traffic offloading strategy: According to the transmission bandwidth index value of the link corresponding to the link identifier of the multiple links in the first link status information set, configure the transmission for the data frame of the data flow that needs to meet the transmission bandwidth requirement. At least one fourth target link has a bandwidth index value greater than the fourth value.

In this embodiment, the business requirements of the data flow are at least one of meeting jitter requirements, meeting jitter requirements, meeting packet loss rate requirements, and meeting transmission bandwidth requirements. The offloading strategy can be determined based on the business requirements and link status, and the offloading strategy is The target link can be selected; the selection of the target link is calculated through the offload module in the virtual scheduler deployed at the gateway, realizing optimized scheduling of real-time path selection to improve link bandwidth utilization and data flow. Basic communication indicators for transmission.

Next, the process of selecting target links for different traffic offload strategies is explained:

1) For offload strategies that require meeting delay requirements, packet loss rate requirements, or jitter requirements, preset link quality parameters (that is, set the first normalized parameter Delay ₀ and the second normalized parameter Drop ₀ and the third normalization parameter Jitter0);

The first gateway updates and calculates the link quality Index in real time based on the link parameter quality information in the uplink real-time status information set. At the same time, the second gateway updates and calculates the link in real time based on the link parameter quality information in the downlink real-time status information set. Quality Index; the gateway forwards the data stream according to the calculation result of the link transmission quality parameter at the current moment. Each data frame in the data stream will be forwarded to the link with the optimal link quality parameter at the current moment (that is, the smaller the link transmission quality value) target link for transmission.

It is worth mentioning that delay, jitter and packet loss rate jointly affect the transmission quality of the link. The transmission quality can be used as a reference value for the link indicator. The data flow selects the target link after passing through the first scheduler of the first gateway. When, the data frame will always be forwarded to the location where the transmission quality (i.e., at least one of delay, jitter, and packet loss rate) at the current moment is optimal or the link index satisfies the preset value (the above-mentioned first value, second value, and third value). ) target link; among them, the quantitative judgment method of link transmission quality includes:

by formula The link transmission quality is measured; among them, Q _Index is the link transmission quality. The smaller the link transmission quality value, the better the link transmission quality. Delay is the real-time transmission delay of the link, and Drop is the link transmission quality. The real-time packet loss rate of the link, Jitter is the real-time transmission delay jitter of the link, Delay ₀ is the first normalized parameter, Drop ₀ is the second normalized parameter, Jitter ₀ is the third normalized parameter, α ₁ is the transmission delay weight parameter, α ₂ is the packet loss rate weight parameter, α ₃ is the transmission delay jitter weight parameter, each weight parameter can be set according to the actual situation, the smaller the weight parameter, the corresponding indicator accounts for the transmission quality The _{greater the} proportion _of 1; α ₂ =2, α ₃ =3.

If the offloading policy is a data frame that needs to meet the delay requirements, and when configuring at least one first target link with a delay index smaller than the first value, you can choose to set the weight corresponding to the real-time packet loss rate and real-time transmission delay jitter to 0;

If the offloading policy is for data frames that need to meet jitter requirements, and when configuring at least one second target link with a jitter index smaller than the second value, you can choose to set the real-time transmission delay and the weight corresponding to the real-time transmission delay jitter to 0;

If the offloading policy is for data frames that need to meet packet loss rate requirements, and when configuring at least one third target link with a packet loss rate index smaller than the third value, you can choose to set the weights corresponding to the real-time packet loss rate and real-time transmission delay. is 0;

Therefore, based on the above formula, the target link for the data frame can be selected according to the offloading strategy, and the target link that meets at least one of the requirements of delay, packet loss rate, and jitter can be simultaneously achieved according to actual needs.

As shown in Figure 6, in a specific embodiment, the first gateway on the terminal side transmits the data stream The link is used for transmission. After calculation, the uplink transmission quality of the first link is 0.5, the uplink transmission quality of the second link is 3, and the uplink transmission quality of the third link is 30. Since the link The smaller the transmission quality value of the link, the better the transmission quality of the link, then the first scheduler selects the first link to transmit the data frame in the data stream X;

The second gateway on the server side transmits data flow Y downlink to the first gateway. The offloading strategy corresponding to the data frame of this data flow is to select the link with the best link transmission quality at the current moment for transmission. After calculation, the first link The downlink transmission quality of the second link is 0.9, the downlink transmission quality of the second link is 1.6, and the downlink transmission quality of the third link is 7. Since the smaller the link transmission quality value, the lower the transmission quality of the link. The better the quality, the second scheduler selects the first link to transmit the data frame in data Y.

2) For the offloading strategy that needs to meet the transmission bandwidth requirements, the offloading strategy that increases the total transmission bandwidth can evenly offload the traffic of the same business connection to each link. That is, using this offloading strategy, multiple links can be used together. For the transmission requirements of data streams carrying such services, the offload ratio of each link is determined by its buffer congestion degree, specifically as follows:

by formula Calculate the buffer congestion degree; where M ₀ represents the buffer congestion degree of the link numbered 0. The greater the buffer congestion value, the more congested the transmission bandwidth of the corresponding link. Each data frame is sent after When the port's scheduler forwards, it will always select the link with the smallest congestion degree (that is, the smaller the buffer congestion degree value) as the target link for forwarding;

When the first gateway transmits data to the second gateway according to the offloading strategy that meets the transmission bandwidth requirements, the first gateway calculates the uplink buffer congestion degree based on the uplink buffer usage in the link status information. Forwarding the data stream according to the degree value, each data frame will be forwarded to the channel with the smallest congestion degree in the uplink buffer at that time or the link index is greater than the fourth value for transmission;

In the same way, when the second gateway transmits data to the first gateway according to the offloading strategy that meets the transmission bandwidth requirements, the second gateway calculates the downlink buffer congestion degree based on the usage of the downlink buffer, and the second gateway calculates the downlink buffer congestion degree parameter value based on the downlink buffer usage. Forwarding the data stream, each data frame will be forwarded to the channel with the smallest downstream buffer congestion at that time or the link index is greater than the fourth value for transmission; among them, the smaller the buffer congestion, the better the channel.

As shown in Figure 7, in a specific embodiment, the transmission of AI (Artificial Intelligence, artificial intelligence) video detection data requires a huge transmission bandwidth, and single-channel 5G (5th Generation Mobile Communication Technology, fifth generation mobile communication technology) transmission Bandwidth capacity sometimes cannot independently meet the transmission needs of AI video detection;

When the data stream X is transmitted through the first gateway on the terminal side, there are four links between the first gateway and the second gateway on the server side that can jointly carry the transmission requirements of the data stream +5G", "5G+WiFi" and other uplink coordinated transmission;

The data frames transmitted by data flow The uplink buffer congestion degree of the three links is 0.4, and the uplink buffer congestion degree of the fourth link is 1.8. Therefore, the first link, the second link, and the third link can be selected at the same time to evenly distribute the data flow. Diversion, and because the link of the fourth link cannot meet the transmission bandwidth requirement, that is, the link is blocked, the first scheduler chooses not to allocate the traffic of upstream data flow X on this link;

Similarly, when the data flow Y is transmitted through the second gateway on the server side, there are four links between the second gateway and the first gateway on the terminal side that can jointly carry the transmission requirements of the data flow X. These links can realize Coordinated transmission of downlink;

The data frames transmitted by data flow Y are data flow a1, data flow a2, data flow a3, and data flow a4. After calculating the uplink buffer congestion degree of each link, the first link, the second link and the third link are obtained. The uplink buffer congestion degree of the three links is 0.3, and the uplink buffer congestion degree of the fourth link is 1.5. Therefore, the first link, the second link, and the third link can be selected at the same time to evenly distribute the data flow. Diversion, and because the link of the fourth link cannot meet the transmission bandwidth requirement, that is, the link is blocked, the second scheduler does not allocate the traffic of the downlink data flow Y on this link.

3) For the offloading strategy that needs to meet the transmission bandwidth requirements, meet the delay requirements, meet the packet loss rate requirements, or meet the jitter requirements, the link quality parameters and link transmission quality conditions are preset; the link transmission quality conditions here are preferred. Q _{Index_max} is obtained by setting an upper limit of link transmission quality (calculated based on one of the above-mentioned first value, second value or third value), that is, the link transmission quality condition is Q _Index <Q _{Index_max} ;

At the same time, the first gateway calculates the uplink buffer congestion degree based on the usage of the uplink buffer, and the first gateway calculates the link quality parameters in real time based on the link parameter quality information in the uplink real-time status information table; the second gateway calculates the link quality parameters based on the downlink real-time status information table. The buffer usage is used to calculate the downlink buffer congestion degree, and the second gateway updates and calculates the link quality parameters in real time based on the link parameter quality information in the downlink real-time status information table;

31) When the first gateway forwards the data stream according to the calculation result of the upstream buffer congestion parameter, each data frame is forwarded to the link with the smallest upstream buffer congestion at the current moment and satisfies Q _Index < Q _{Index_max} for transmission. ;

32) When the second gateway forwards the data flow according to the calculation result of the downlink buffer congestion parameter, each data frame is forwarded to the link with the smallest downlink buffer congestion at the current moment and satisfies Q _Index < Q _{Index_max} for transmission. .

The above-mentioned offloading strategy determined based on the total transmission bandwidth and transmission quality (jitter, delay, packet loss rate, etc.) of the data frame, when the transmission quality satisfies the preset quantitative conditions (first value, second value, third value) In the case of this indicator, the traffic of the data flow will be diverted; the user can preset quantitative link transmission quality conditions, and the scheduler will choose to divert the transmission traffic of the data flow when the link transmission quality conditions are met. Transmitting through a non-congested (determined according to the fourth value) link realizes multiplexing of link bandwidth while ensuring a certain transmission quality.

As shown in Figure 8, in another specific embodiment, when the data flow X is transmitted through the first gateway on the terminal side, there are 4 links between the first gateway and the second gateway on the server side that can jointly carry the data. According to the transmission requirements of stream X, these links can perform collaborative transmission; the data frames transmitted by data stream By calculating the congestion degree of the uplink buffer, we can obtain the link that meets the link transmission quality conditions and is not congested for transmission. Therefore, it can be determined that the first link and the second link meet the link transmission quality conditions, and the first link , the second link and the third link meet the conditions for uniform distribution of data flows, but because the third link cannot meet the link transmission quality condition (i.e. Q _Index <5), therefore, only the first link and the third link can be selected. The second link splits the transmission data stream X;

Similarly, when the data flow Y is transmitted through the second gateway on the server side, there are four links between the second gateway and the first gateway on the terminal side that can jointly bear the transmission requirements of the data flow Y. These links can carry out Coordinated transmission; the data frames transmitted by data stream Y are a1, a2, a3, a4 in sequence; the upper limit of link transmission quality is set to 7. After calculating the uplink buffer congestion degree of each link, it is obtained that the link meets the The link transmission quality conditions are met, and non-congested links carry out transmission. Therefore, it can be determined that the first link and the second link meet the link transmission quality conditions, while the first link, the second link and the third link meet the link transmission quality conditions. The conditions for the data stream to be evenly distributed, but because the third link cannot meet the link transmission quality condition (ie, Q _Index <7), therefore, the first link and the second link can only be selected to distribute and transmit the data stream Y.

In an optional embodiment of the present invention, step 13 includes:

Step 131: When it is determined that the identification of the link mark by the first gateway is consistent with the identification of the link mark by the second gateway, add the target link corresponding to the data frame in the data frame of the data flow. link identifier.

In the embodiment of the present invention, there are multiple links between the first gateway and the second gateway. The link may be a 5G link, a WiFi (wireless communication technology) link, or a limited optical fiber Ethernet. This application is not limited by this;

The multiple links upstream from the first gateway to the second gateway or downlink from the second gateway to the first gateway are distinguished by link identifiers, that is, the link identifiers can be used to mark the transmission links through which data frames pass; the link identifiers need to Obtained by the first gateway and the second gateway after bidirectional registration. The bidirectional registration process is used to coordinate the function of enabling multiple link identifiers at both ends, and is used to confirm the allocation of sequence numbers (link identifiers) of multiple links; When it is determined that the identification of the link mark by the first gateway is consistent with the identification of the link mark by the second gateway, the link identification can be added to the data frame of the data flow, so that the gateway on the receiving side can The link identifier is positioned to the target link without divergence.

In yet another optional embodiment of the present invention, the process of determining in step 131 that the identification of the link mark by the first gateway is consistent with the identification of the link mark by the second gateway includes:

Step 1311: Determine whether the identification of the link mark by the first gateway and the identification of the link mark by the second gateway are consistent, and obtain a judgment result; if the judgment result is consistent, send a message to the second gateway. Confirm the frame, otherwise, send an error signal;

Step 1312: When the first gateway determines that the identification of the link mark is consistent with the identification of the link mark by the second gateway, receive the detection message sent by the second gateway;

Step 1313: Feed back a response signal to the second gateway according to the detection message.

In the embodiment of the present invention, the link identifier is preferably allocated according to the link information of "access mode + IP (Internet Protocol Address) addresses of the two gateways", for example: WiFi-IP1-IP2 corresponds to the link The link identifier is assigned as 1, and the link identifier of the 5G-IP3-IP4 corresponding link is assigned as 2;

The configuration modes of link identification include manual configuration mode and server distribution mode;

As shown in Figure 9, the manual configuration process includes:

Step 91: The administrator marks the same link on the first gateway and the second gateway respectively. For example, the first gateway marks the link "WiFi-IP1-IP2" as 1 and "5G- The link identifier of "IP3-IP4" is 2; the second gateway identifies the link of "WiFi-IP1-IP2" as 1, and the link of "5G-IP3-IP4" as 2;

Step 92: After the multi-path marking is completed, the second gateway on the server side sends the multi-link identification rule to the first gateway, so that the first gateway can confirm the consistency of the sequence number marking results for the multi-link;

Step 93a, if the two-end identifier serial number marks are consistent (that is, the judgment result is consistent), the first gateway returns a multi-link identifier consistency check confirmation frame;

Step 93b, if the serial number marks at both ends are inconsistent, an error signal is returned to remind the administrator to perform reconfiguration, and the link identifier allocation fails. At the same time, return to step 71 for re-registration;

Step 94: The second gateway sends Hello detection messages on multiple links respectively (the data frame of the message carries the negotiated link identifier and a randomly generated sequence number);

Step 95: The first gateway responds with a response message (ACK) to the Hello detection messages received on multiple links. At this point, the manual mode multi-link device bidirectional registration process is completed;

Further, in step 96, step 94 and step 95 are performed periodically to detect the connection status of each link. If any link fails to complete the hello-ack (detection message-response message) detection process on time, the first gateway and The second gateway will adjust the connection allocation status of the link to Inactive and suspend the use of the link.

As shown in Figure 10, the process of server distribution mode includes:

Step 101: The administrator marks multiple links on the second gateway. For example, the second gateway marks the link of "WiFi-IP1-IP2" as 1 and the link of "5G-IP3-IP4". Identified as 2;

Step 102: After the multiple link marking is completed, the second gateway distributes the sequence number marking results of the multiple links to the first gateway;

Step 103a, if the two-end identifier serial number marks are consistent (that is, the judgment result is consistent), the first gateway returns a multi-link identifier consistency check confirmation frame;

Step 103b, if the serial number marks at both ends are inconsistent, an error signal is returned to remind the administrator to perform reconfiguration, and the link identifier allocation fails. At the same time, you can return to step 111 to re-register;

Step 104: The second gateway sends Hello detection messages on multiple links respectively (the data frame of the message carries the negotiated link identifier and a randomly generated sequence number);

Step 105: The first gateway responds with a response message (ACK) to the Hello detection messages received on multiple links. At this point, the manual mode multi-link device bidirectional registration process is completed;

Further, in step 106, step 104 and step 105 are performed periodically to detect the connection status of each link. If any link fails to complete the hello-ack (detection message-response message) detection process on time, the first gateway and The second gateway will adjust the connection allocation status of the link to Inactive and suspend the use of the link.

In an optional embodiment of the present invention, adding a link identifier to the data frame of the data flow in step 132 includes:

Step 1321: Add the link identifier of the target link to the reserved field in the data frame of the data flow.

In this embodiment, before the data frame is sent, in addition to adding the link identifier, it is also necessary to add a timestamp and a data frame identifier. The timestamp is used by the receiving side (i.e., the second gateway) to calculate whether the data frame is on the target link. The transmission delay from sending to receiving, and the data frame identifier is used to distinguish each data frame to avoid confusing data frames on the same target link; add the link identifier of the target link in the reserved field of the data frame;

Here, a specific implementation example is used to illustrate the location of adding the link identifier and timestamp information in the data frame:

As shown in Figure 11, in a specific embodiment, when the data frame in the data stream is a TAN data frame, the TAN data frame can use the 27th to 29th reserved bits to carry the link identification; because The link identifier is the unique identifier of each link obtained after mutual confirmation by both ends. Therefore, different link identifiers can not only sequence the target link for transmitting data frames for differentiation, but also distinguish the link identification function. ;The link representation function status here refers to whether the first gateway can add a link identifier to the data frame;

When the link identification in the TAN data frame is 000, it means that the link identification function is not enabled, and the first gateway does not add a link identification to the data frame. The first gateway cannot add "001" to the data frame until the link identification function is enabled. The serial number identifiers from " to "111" correspond to 1 to 7 links respectively, and then add link identifiers to the data frame;

In addition, due to the characteristics of the TAN data frame, the timestamp can be carried in the reserved field of the TAN header of the TAN data frame.

As shown in Figure 2, in a specific embodiment, when data transmission is required between the first gateway and the second gateway, the link identification of the four links between the dual-end gateways is unified through a two-way registration process. And peer device discovery, each data frame transmitted through these four links will be added with the necessary information for link status measurement (time stamp, link identification, data frame identification);

After the registration is completed, the scheduler enters the pre-start state and disperses all transmission data packets to each link. The receiving end of the data can rely on the timestamp, link identification, and data frame identification carried in the data frame to perform real-time link status Measurement;

The scheduler enters the offload state and offloads and forwards the data frame according to the target link corresponding to the offload policy. At the same time, the link status information is measured and updated in real time on the receiving side of the data.

The present invention receives the data stream to be transmitted; determines the target link corresponding to each data frame of the data stream according to the diversion strategy of the data stream; and adds the said data stream to each data frame of the data stream. The link identifier of the target link corresponding to the data frame, the data frame carrying timestamp information; sending the data frame with the link identifier added to the second gateway on the server side through the target link ; Realizes multi-link data split transmission, improves link usage efficiency, and provides transmission guarantee for data flow.

As shown in Figure 12, an embodiment of the present invention provides a data transmission method, which is applied to the second gateway on the server side, including:

Step 1201: Receive at least one data frame of the data stream sent by the first gateway on the terminal side through at least one target link; the data frame carries the link identifier and timestamp information of the target link that transmits the data frame;

Step 1202: Restore the at least one data frame into the data stream according to the link identification and timestamp information in the at least one data frame.

In the embodiment of the present invention, since the data frame sent by the first gateway to the second gateway carries a timestamp, a link identifier and a data frame identifier, the second gateway can use the data frame and the time when the data frame is received (by the local clock acknowledgment), the transmission delay of the data frame is calculated, and the received data frame can be restored to a data stream according to the link identification and timestamp information carried in the data frame.

Optional, after step 1201, you can also include:

Step 1203: Obtain a second link status information measurement result based on at least one link indicator measurement value of the data frame transmitted in the target link received within a preset time period; the second link status The information measurement results include link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period;

Step 1204: Send the second link status information measurement result to the first gateway according to a preset period, so that the first gateway updates the local first link according to the second link status information measurement result. Status information set; the first link status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within a preset time period.

Optionally, after step 1204, the following steps are also included:

Step 1205: Receive the first link status information measurement result sent by the first gateway according to a preset period. The first link status information measurement result includes link identifiers of multiple links and each link identifier. At least one link indicator measurement value of the corresponding link within a preset time period;

Step 1206: Update a local second link state information set according to the first link state information measurement result. The second link state information set includes link identifiers of multiple links and the corresponding link identifiers of each link. At least one link index value of the link within the preset time period. It should be noted that the method applied to the second gateway on the server side is a method corresponding to the method applied to the first gateway on the terminal side. All the methods in the embodiments of the method applied on the first gateway on the terminal side are All implementation methods are applicable to this embodiment, and the same technical effect can be achieved.

As shown in Figure 13, the embodiment of the present invention also provides a first gateway 130, which includes:

The first transceiver module 1301 is used to receive the data stream to be transmitted;

The first processing module 1302 is configured to determine the target link corresponding to each data frame of the data flow according to the offloading strategy of the data flow; and add the data frame to each data frame of the data flow. The link identifier of the corresponding target link, and the data frame carries timestamp information;

The first transceiver module 1301 is also configured to send the data frame with the link identifier added to the second gateway on the server side through the target link.

Optionally, the first processing module 1302 is also used to:

Obtain link status of multiple links connected to the first gateway;

Determine a distribution strategy for the data flow according to the link status of the multiple links.

Optionally, obtaining link status of multiple links connected to the first gateway includes:

According to a preset period, receive the second link status information measurement result sent by the second gateway; the second link status information measurement result includes link identifiers of multiple links and the link identifier corresponding to each link identifier. At least one link indicator measurement value of the link within a preset time period, the plurality of links being communication links between the first gateway and the second gateway;

Update the local first link status information set according to the second link status information measurement result. The first link status information set includes link identifiers of multiple links and the link corresponding to each link identifier. At least one link indicator value within the preset time period;

Obtain the link status of multiple links connected to the first gateway according to at least one link indicator value in the first link status information set;

sending the first link status information measurement result to the second gateway according to a preset period, so that the second gateway updates the local second link status information set according to the first link status information measurement result, The first link status information measurement result includes link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period; the second link The status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within the preset time period.

Optionally, determine the offloading strategy of the data flow according to the link status of the multiple links, including:

Determine the data flow according to at least one link index value among the delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to the link identifiers of the multiple links in the first link status information set. diversion strategy.

Optionally, when the data flow is two or more data flows, the delay, jitter, and packet loss rate of the link respectively corresponding to the link identifiers of the multiple links in the first link status information set are , at least one link indicator value in the transmission bandwidth, determines the offloading strategy of the data flow, including:

Filter the data characteristics of multiple data streams through preset mapping rules to obtain at least one data stream filtering group;

At least one of the delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to at least one of the data flow filtering groups and the link identifiers of multiple links in the first link status information set. The necklace link indicator value determines the diversion strategy of the data flow.

Optionally, add the link identifier of the target link corresponding to the data frame in each data frame of the data flow, including:

When it is determined that the link identifier of the link mark of the first gateway is consistent with the link identifier of the link mark of the second gateway, add the target link corresponding to the data frame in the data frame of the data flow. The link identifier of the road.

Optionally, add the link identifier of the target link corresponding to the data frame in the data frame of the data flow, including:

Add the link identifier of the target link to a reserved field in the data frame of the data flow.

It should be noted that the first gateway is a gateway corresponding to the above-mentioned method applied to the first gateway on the terminal side. All implementations in the above-mentioned method embodiment applied to the first gateway on the terminal side are applicable to this implementation. In this example, the same technical effect can be achieved.

As shown in Figure 14, the embodiment of the present invention also provides a second gateway 140, including:

The second transceiver module 141 is configured to receive at least one data frame of the data stream sent by the first gateway on the terminal side through at least one target link; the data frame carries the link identifier of the target link that transmits the data frame. and timestamp information;

The second processing module 142 is configured to restore the at least one data frame into the data stream according to the link identification and timestamp information in the at least one data frame.

Optionally, the second processing module 142 is also used to:

Obtain a second link status information measurement result according to at least one link indicator measurement value of the data frame transmitted in the target link received within a preset time period; the second link status information measurement result including link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period;

According to a preset period, the second link status information measurement result is sent to the first gateway, so that the first gateway updates the local first link status information set according to the second link status information measurement result. ; The first link status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within a preset time period; according to the preset period, receive all The first link status information measurement result sent by the first gateway, the first link status information measurement result includes link identifiers of multiple links and the link corresponding to each link identifier within a preset time period. At least one link indicator measurement value;

A local second link state information set is updated according to the first link state information measurement result. The second link state information set includes link identifiers of multiple links and links corresponding to each link identifier. At least one link index value within the preset time period.

It should be noted that the second gateway is a gateway corresponding to the above-mentioned method applied to the second gateway on the server side. All implementations in the above-mentioned method embodiment applied to the second gateway on the server side are applicable to this implementation. In this example, the same technical effect can be achieved.

An embodiment of the present invention also provides a communication device, including: a processor and a memory storing a computer program. When the computer program is run by the processor, the method as described above is executed. All implementations in the above method embodiment are applicable to this embodiment and can achieve the same technical effect.

Embodiments of the present invention also provide a computer-readable storage medium that stores instructions that, when executed on a computer, cause the computer to perform the method described above. All implementations in the above method embodiment are applicable to this embodiment and can achieve the same technical effect.

Those of ordinary skill in the art will appreciate that the units and algorithm steps of each example described in conjunction with the embodiments disclosed herein can be implemented with electronic hardware, or a combination of computer software and electronic hardware. Whether these functions are performed in hardware or software depends on the specific application and design constraints of the technical solution. Skilled artisans may implement the described functionality using different methods for each specific application, but such implementations should not be considered to be beyond the scope of the present invention.

Those skilled in the art can clearly understand that for the convenience and simplicity of description, the specific working processes of the systems, devices and units described above can be referred to the corresponding processes in the foregoing method embodiments, and will not be described again here.

In the embodiments provided by the present invention, it should be understood that the disclosed devices and methods can be implemented in other ways. For example, the device embodiments described above are only illustrative. For example, the division of the units is only a logical function division. In actual implementation, there may be other division methods. For example, multiple units or components may be combined or can be integrated into another system, or some features can be ignored, or not implemented. On the other hand, the coupling or direct coupling or communication connection between each other shown or discussed may be through some interfaces, and the indirect coupling or communication connection of the devices or units may be in electrical, mechanical or other forms.

The units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in one place, or they may be distributed to multiple network units. Some or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.

In addition, each functional unit in various embodiments of the present invention can be integrated into one processing unit, or each unit can exist physically alone, or two or more units can be integrated into one unit.

If the functions are implemented in the form of software functional units and sold or used as independent products, they can be stored in a computer-readable storage medium. Based on this understanding, the technical solution of the present invention essentially or the part that contributes to the existing technology or the part of the technical solution can be embodied in the form of a software product. The computer software product is stored in a storage medium, including Several instructions are used to cause a computer device (which may be a personal computer, a server, or a network device, etc.) to execute all or part of the steps of the methods described in various embodiments of the present invention. The aforementioned storage media include: U disk, mobile hard disk, ROM, RAM, magnetic disk or optical disk and other media that can store program codes.

In addition, it should be pointed out that in the device and method of the present invention, obviously, each component or each step can be decomposed and/or recombined. These decompositions and/or recombinations should be regarded as equivalent solutions of the present invention. Furthermore, the steps for executing the above series of processes can naturally be executed in chronological order in the order described, but they do not necessarily need to be executed in chronological order, and some steps may be executed in parallel or independently of each other. For those of ordinary skill in the art, it can be understood that all or any steps or components of the method and device of the present invention can be implemented in any computing device (including processor, storage medium, etc.) or a network of computing devices in the form of hardware or firmware. , software or their combination, this can be achieved by those of ordinary skill in the art using their basic programming skills after reading the description of the present invention.

Therefore, the objects of the invention can also be achieved by running a program or a set of programs on any computing device. The computing device may be a well-known general-purpose device. Therefore, the object of the present invention can also be achieved only by providing a program product containing a program code for implementing the method or apparatus. That is, such a program product also constitutes the present invention, and a storage medium storing such a program product also constitutes the present invention. Obviously, the storage medium may be any known storage medium or any storage medium developed in the future. It should also be pointed out that in the device and method of the present invention, obviously, each component or each step can be decomposed and/or recombined. These decompositions and/or recombinations should be regarded as equivalent solutions of the present invention. Furthermore, the steps for executing the above series of processes can naturally be executed in chronological order in the order described, but do not necessarily need to be executed in chronological order. Certain steps can be performed in parallel or independently of each other.

The above is the preferred embodiment of the present invention. It should be pointed out that for those of ordinary skill in the art, several improvements and modifications can be made without departing from the principles of the present invention. These improvements and modifications can also be made. should be regarded as the protection scope of the present invention.

Claims (13)

1. A data transmission method, characterized in that it is applied to the first gateway on the terminal side, and the method includes: Receive the data stream to be transmitted; According to the offloading strategy of the data flow, determine the target link corresponding to each data frame of the data flow; Add the link identifier of the target link corresponding to the data frame in each data frame of the data flow, and the data frame carries timestamp information; The data frame with the link identifier added is sent to the second gateway on the server side through the target link. 2. The data transmission method according to claim 1, further comprising: Obtain link status of multiple links connected to the first gateway; Determine a distribution strategy for the data flow according to the link status of the multiple links. 3. The data transmission method according to claim 2, wherein obtaining the link status of multiple links connected to the first gateway includes: According to a preset period, receive the second link status information measurement result sent by the second gateway; the second link status information measurement result includes link identifiers of multiple links and the link corresponding to each link identifier. At least one link indicator measurement value of the road within a preset time period, and the plurality of links are communication links between the first gateway and the second gateway; Update the local first link status information set according to the second link status information measurement result. The first link status information set includes link identifiers of multiple links and the link corresponding to each link identifier. At least one link indicator value within the preset time period; Obtain the link status of multiple links connected to the first gateway according to at least one link indicator value in the first link status information set; sending the first link status information measurement result to the second gateway according to a preset period, so that the second gateway updates the local second link status information set according to the first link status information measurement result, The first link status information measurement result includes link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period; the second link The status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within the preset time period. 4. The data transmission method according to claim 3, characterized in that determining the offloading strategy of the data flow according to the link status of the multiple links includes: Determine the data flow according to at least one link index value among the delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to the link identifiers of the multiple links in the first link status information set. diversion strategy. 5. The data transmission method according to claim 4, characterized in that, when the data flow is two or more data flows, link identifiers of multiple links in the first link status information set correspond to Determine the offloading strategy of the data flow, including: Filter the data characteristics of multiple data streams through preset mapping rules to obtain at least one data stream filtering group; At least one of the delay, jitter, packet loss rate, and transmission bandwidth of the link corresponding to at least one of the data flow filtering groups and the link identifiers of multiple links in the first link status information set. The necklace link indicator value determines the diversion strategy of the data flow. 6. The data transmission method according to claim 1, characterized in that adding a link identifier of the target link corresponding to the data frame in each data frame of the data stream includes: When it is determined that the link identifier of the link mark of the first gateway is consistent with the link identifier of the link mark of the second gateway, add the target link corresponding to the data frame in the data frame of the data flow. The link identifier of the road. 7. The data transmission method according to claim 1 or 6, characterized in that adding the link identifier of the target link corresponding to the data frame in the data frame of the data stream includes: Add the link identifier of the target link to a reserved field in the data frame of the data flow. 8. A data transmission method, characterized in that it is applied to the second gateway on the server side, and the method includes: Receive at least one data frame of the data flow sent by the first gateway on the terminal side through at least one target link; the data frame carries the link identification and timestamp information of the target link that transmits the data frame; The at least one data frame is restored to the data stream according to the link identification and timestamp information in the at least one data frame. 9. The data transmission method according to claim 8, characterized in that after receiving at least one data frame of the data stream sent by the first gateway on the terminal side through at least one target link, it further includes: Obtain a second link status information measurement result according to at least one link indicator measurement value of the data frame transmitted in the target link received within a preset time period; the second link status information measurement result Includes link identifiers of multiple links and at least one link indicator measurement value of the link corresponding to each link identifier within a preset time period; According to a preset period, the second link status information measurement result is sent to the first gateway, so that the first gateway updates the local first link status information set according to the second link status information measurement result. ;The first link status information set includes link identifiers of multiple links and at least one link index value of the link corresponding to each link identifier within a preset time period; According to a preset period, receive the first link status information measurement result sent by the first gateway. The first link status information measurement result includes link identifiers of multiple links and the link corresponding to each link identifier. At least one link indicator measurement value of the road within a preset time period; A local second link state information set is updated according to the first link state information measurement result. The second link state information set includes link identifiers of multiple links and links corresponding to each link identifier. At least one link index value within the preset time period. 10. A first gateway, characterized in that it includes: The first transceiver module is used to receive the data stream to be transmitted; The first processing module is configured to determine the target link corresponding to each data frame of the data flow according to the offloading strategy of the data flow; and add the corresponding target link of the data frame to each data frame of the data flow. The link identifier of the target link, and the data frame carries timestamp information; The first transceiver module is also configured to send the data frame with the link identifier added to the second gateway on the server side through the target link. 11. A second gateway, characterized in that it includes: The second transceiver module is configured to receive at least one data frame of the data stream sent by the first gateway on the terminal side through at least one target link; the data frame carries the link identifier of the target link that transmits the data frame and timestamp information; The second processing module is configured to restore the at least one data frame into the data stream according to the link identification and timestamp information in the at least one data frame. 12. A communication device, characterized in that it includes: a processor and a memory storing a computer program. When the computer program is run by the processor, the method according to any one of claims 1 to 7 is executed. Methods described in 8 or 9. 13. A computer-readable storage medium, characterized in that it stores instructions that, when the instructions are run on a computer, cause the computer to perform the method of any one of claims 1 to 7 or the method of claim 8 or 9. method described.