CN117014384A

CN117014384A - Message transmission method and message forwarding equipment

Info

Publication number: CN117014384A
Application number: CN202210467067.0A
Authority: CN
Inventors: 肖杰; 查敏; 牛乐宏; 张小俊
Original assignee: Huawei Technologies Co Ltd
Current assignee: Huawei Technologies Co Ltd
Priority date: 2022-04-29
Filing date: 2022-04-29
Publication date: 2023-11-07
Also published as: WO2023207628A1

Abstract

The embodiment of the application discloses a message transmission method and message forwarding equipment, which are used for avoiding that a plurality of messages contained in the same data stream are continuously scheduled and transmitted, and reducing interference among multiple paths of data streams transmitted by the message forwarding equipment. The method of the embodiment of the application comprises the following steps: the message forwarding equipment receives a first data unit of a first data stream; the message forwarding equipment acquires a first parameter, wherein the first parameter is the bit number of a first data unit; the message forwarding equipment acquires a second parameter, wherein the second parameter is the difference value between a preset threshold value and the first parameter; the message forwarding device acquires a third parameter once every unit time, wherein the third parameter is the difference between the second parameter and a target bit number, and the target bit number is the bit number of the first data unit sent by the message forwarding device in unit time; and under the condition that the third parameter is smaller than a preset threshold value, the message forwarding equipment sends the first data unit.

Description

Message transmission method and message forwarding equipment

Technical Field

The present application relates to the field of communications technologies, and in particular, to a message transmission method and a message forwarding device.

Background

In the case of aggregate transmission of multiple data streams, the multiple data streams may multiplex the same physical link of the message forwarding device. Each data stream may transmit multiple messages in succession.

The message forwarding device may implement a credit-based shaping mechanism (CBS) to smooth the transmission of the transmitted multiple data streams and reduce interference between different data streams. The credit-based CBS sets up one credit recorder for each data stream. The credit recorder does not set an upper limit. For example, when the message forwarding device forwards the target data stream, the increase of the credit value stored by the credit recorder corresponding to the target data stream is equal to the bandwidth of the message to be transmitted currently by the target data stream. It is known that the credit value stored by the credit recorder is continuously incremented. When there is no message to be transmitted at the current time of the target data stream, the credit value stored by the credit recorder is constrained to be 0. When the credit value of the target data stream is not negative, the message transmitted by the target data stream can be scheduled for transmission. The credit value of the target data stream is subtracted from the size of the message scheduled for transmission every time the message is scheduled for transmission. That is, the credit value of the target data stream is 0, and the target data stream can schedule the transmission message. However, once the credit value of the target data stream is negative, the target data stream cannot continue to schedule transmission messages.

However, credit-based CBS does not set an upper limit due to the credit value. For example, the credit value of the target data stream may be accumulated to be large, so that the target data stream is continuously scheduled to transmit a plurality of messages, and further the target data stream monopolizes the transmission resources of the physical link for a period of time, and other data streams cannot obtain the opportunity of scheduled transmission, so that isolation between different data streams is poor.

Disclosure of Invention

The embodiment of the invention provides a message transmission method and message forwarding equipment, which effectively avoid that a plurality of messages included in the same data stream are continuously scheduled and transmitted, and can reduce interference among multiple paths of data streams transmitted by the message forwarding equipment.

The first aspect of the embodiment of the invention provides a message transmission method, which comprises the following steps: the message forwarding equipment receives a first data unit of a first data stream; the message forwarding device obtains a first parameter, wherein the first parameter is the bit number of the first data unit; the message forwarding device obtains a second parameter, wherein the second parameter is a difference value between a preset threshold value and the first parameter; the message forwarding device obtains a third parameter once every unit time, wherein the third parameter is the difference between the second parameter and a target bit number, and the target bit number is the bit number of the first data unit sent by the message forwarding device in unit time; and under the condition that the third parameter is smaller than the preset threshold value, the message forwarding device sends the first data unit.

By adopting the method shown in the scheme, the message forwarding device ensures that the message forwarding device only sends one data unit included in one data stream to the next hop device at the same time based on the third parameter, and the condition that a plurality of data units included in the same data stream are continuously sent to the next hop device can not occur.

Based on the first aspect, in an optional implementation manner, after the packet forwarding device receives the first data unit of the first data flow, the method further includes: the message forwarding device receives a second data unit of a second data stream; and the message forwarding device sends the second data unit under the condition that the third parameter is equal to the preset threshold value.

By adopting the method in the aspect, under the condition that the third parameter is equal to the preset threshold, the message forwarding device determines that the transmission of the first data unit of the first data stream is completed, and then the message forwarding device can send the second data unit of the second data stream to the next hop device, so that the message forwarding device is prevented from continuously transmitting a plurality of data units of the same data stream. Therefore, a plurality of data units included in the first data stream cannot be continuously transmitted to the next hop device, so that the waiting time required by the second data stream to be transmitted is effectively reduced, the interference between the first data stream and the second data stream is reduced, the time delay of the second data stream to be transmitted is reduced, the isolation between the first data stream and the second data stream is effectively ensured, the stable transmission of each data stream is ensured, and the transmission burst is avoided.

Based on the first aspect, in an optional implementation manner, the sending, by the packet forwarding device, the first data unit, and the sending, by the packet forwarding device, the second data unit includes: if the message forwarding device determines that the priority of the first data unit is higher than the priority of the second data unit, the message forwarding device firstly sends the first data unit and then sends the second data unit; or if the message forwarding device determines that the priority of the second data unit is higher than the priority of the first data unit, the message forwarding device sends the second data unit first and then sends the first data unit.

By adopting the method, the message forwarding device determines the time sequence of the next hop device in the first data unit and the second data unit based on the priority, thereby effectively ensuring the timely transmission of the high-priority data unit.

Based on the first aspect, in an optional implementation manner, after the packet forwarding device receives a first data unit of a first data stream and the packet forwarding device receives a second data unit of a second data stream, the method further includes: the message forwarding device determines that the first data unit carries a first channel identifier, and the first channel identifier corresponds to a first channel of the message forwarding device; the message forwarding device determines that the second data unit carries the first channel identifier; and the message forwarding device sends the first data unit and the second data unit through the first channel according to the first channel identifier.

By adopting the method, the message forwarding equipment is prevented from continuously transmitting a plurality of data units of the same data stream in the process of transmitting multiple paths of data streams of the same channel of the message forwarding equipment. Therefore, a plurality of data units included in the first data stream cannot be continuously transmitted to the next hop device, so that the waiting time required by the second data stream to be transmitted is effectively reduced, the interference between the first data stream and the second data stream is reduced, the time delay of the second data stream to be transmitted is reduced, the isolation between the first data stream and the second data stream is effectively ensured, the stable transmission of each data stream is ensured, and the transmission burst is avoided.

Based on the first aspect, in an optional implementation manner, the method further includes: the message forwarding device receives a third data unit; the message forwarding device determines that the third data unit carries a second channel identifier, and the second channel identifier corresponds to a second channel of the message forwarding device; if the message forwarding device determines that the priority of the first channel is higher than the priority of the second channel, the message forwarding device firstly sends the first data unit and the second data unit through the first channel according to the first channel identifier, and then sends the third data unit through the second channel according to the second channel identifier; or if the message forwarding device determines that the priority of the second channel is higher than the priority of the first channel, the message forwarding device sends the third data unit through the second channel according to the second channel identifier, and then sends the first data unit and the second data unit through the first channel according to the first channel identifier.

In this embodiment, the message forwarding device determines the transmission timing of different data units transmitted via different channels based on the priority. Specifically, the message forwarding device determines, based on the priority, which channel of the data units transmitted by the first channel and the data units transmitted by the second channel are sent first, and which channel of the data units is sent later, so that timely transmission of the high-priority data units is effectively ensured.

Based on the first aspect, in an optional implementation manner, the determining, by the packet forwarding device, that the first data unit carries the first channel identifier includes: and if the message forwarding device determines that the first data unit carries a target field, determining that the first data unit carries the first channel identifier, wherein the target field is used for carrying the first channel identifier.

Based on the first aspect, in an optional implementation manner, the determining, by the packet forwarding device, that the first data unit carries the first channel identifier includes: the message forwarding device adds a first field in the first data unit, where the first field is used to carry the first channel identifier, or the message forwarding device multiplexes a second field included in the first data unit, where the second field is used to carry the first channel identifier.

Based on the first aspect, in an optional implementation manner, the first data unit is a first packet included in the first data flow, and the second data unit is a second packet included in the second data flow.

Based on the first aspect, in an optional implementation manner, the first data flow includes a first packet, the first packet includes a header, a payload, and a trailer, and the receiving, by the packet forwarding device, a first data unit of the first data flow includes: the message forwarding device receives the first message; the message forwarding device divides the payload into N divided payloads, wherein N is a positive integer greater than 1; the message forwarding device obtains N first data units, where each first data unit in the N first data units includes the header, one divided payload in the N divided payloads, and the trailer.

Based on the first aspect, in an optional implementation manner, the receiving, by the packet forwarding device, the first data unit includes: the message forwarding device receives the first message; the message forwarding device divides the first message into M divided messages, wherein M is a positive integer greater than 1; the message forwarding device obtains M first data units, where the first data units include a divided message of the M divided messages and a segment header, and the segment header carries the first channel identifier.

By adopting the method, the message forwarding equipment can divide each message into a plurality of data units, so that in the process of sending the message, the message forwarding equipment can independently schedule for sending based on each data unit, so that the scheduling degree of the message is finer, the transmission of different messages is smoother, the interference among different messages is lower, and the isolation is better.

A second aspect of the embodiment of the present invention provides a packet forwarding device, where the packet forwarding device includes a processor and a transceiver connected to the processor; the transceiver is configured to receive a first data unit of a first data stream; the processor is configured to: acquiring a first parameter, wherein the first parameter is the bit number of the first data unit; acquiring a second parameter, wherein the second parameter is a difference value between a preset threshold value and the first parameter; obtaining a third parameter once every unit time, wherein the third parameter is the difference between the second parameter and a target bit number, and the target bit number is the bit number of the first data unit sent by the message forwarding device in unit time; the transceiver is further configured to send the first data unit if the third parameter is less than the preset threshold.

For an explanation of the beneficial effects of this aspect, please refer to the first aspect, and detailed descriptions thereof are omitted.

Based on the second aspect, in an optional implementation manner, the transceiver is further configured to: receiving a second data unit of a second data stream; and transmitting the second data unit under the condition that the third parameter is equal to the preset threshold value.

Based on the second aspect, in an optional implementation manner, the processor is configured to determine that the priority of the first data unit is higher than the priority of the second data unit, and the transceiver is configured to send the first data unit first and then send the second data unit; or, the processor is configured to determine that the priority of the second data unit is higher than the priority of the first data unit, and the transceiver is configured to transmit the second data unit first and then transmit the first data unit.

Based on the second aspect, in an optional implementation manner, the processor is further configured to: determining that the first data unit carries a first channel identifier, wherein the first channel identifier corresponds to a first channel of the message forwarding device; determining that the second data unit carries the first channel identifier; the transceiver is further configured to send the first data unit and the second data unit through the first channel according to the first channel identifier.

Based on the second aspect, in an optional implementation manner, the transceiver unit is further configured to: receiving a third data unit;

the processor is further configured to determine that the third data unit carries a second channel identifier, where the second channel identifier corresponds to a second channel that the packet forwarding device has; the processor is configured to determine that the priority of the first channel is higher than the priority of the second channel, and the transceiver is configured to send the first data unit and the second data unit through the first channel according to the first channel identifier, and then send the third data unit through the second channel according to the second channel identifier; or if the processor is configured to determine that the priority of the second channel is higher than the priority of the first channel, the transceiver is configured to send the third data unit through the second channel according to the second channel identifier, and then send the first data unit and the second data unit through the first channel according to the first channel identifier.

Based on the second aspect, in an optional implementation manner, the processor is further configured to determine that the first data unit carries a target field, and determine that the first data unit carries the first channel identifier, where the target field is used to carry the first channel identifier.

Based on the second aspect, in an optional implementation manner, the processor is further configured to add a first field to the first data unit, where the first field is used to carry the first channel identifier, or multiplex a second field that is already included in the first data unit, where the second field is used to carry the first channel identifier.

Based on the second aspect, in an optional implementation manner, the first data unit is a first packet included in the first data flow, and the second data unit is a second packet included in the second data flow.

Based on the second aspect, in an optional implementation manner, the first data stream includes a first packet, where the first packet includes a header, a payload, and a trailer; the transceiver is configured to receive the first packet; the processor is configured to divide the payload into N divided payloads, where N is a positive integer greater than 1; and the method is further used for acquiring N first data units, wherein each first data unit in the N first data units comprises the header, one divided payload in the N divided payloads and the trailer.

Based on the second aspect, in an optional implementation manner, the transceiver is configured to receive the first packet by using the packet forwarding device; the processor is configured to divide the first packet into M divided packets, where M is a positive integer greater than 1; the method is also used for obtaining M first data units, wherein the first data units comprise one divided message in the M divided messages and a segmentation head, and the segmentation head carries the first channel identifier.

A third aspect of an embodiment of the present application provides a computer readable storage medium comprising instructions which, when run on a computer, cause the computer to perform the method according to any one of the first aspects described above.

Drawings

Fig. 1 is a diagram showing a first configuration example of a communication device according to an embodiment of the present application;

fig. 2 is an exemplary diagram of a packet forwarding device according to an embodiment of the present application transmitting multiple data streams;

fig. 3 is a diagram illustrating a first scheduling example of packet transmission according to an embodiment of the present application;

fig. 4 is a diagram illustrating a second scheduling example of a message transmission method according to an embodiment of the present application;

fig. 5 is a flowchart illustrating steps of a first embodiment of a method for transmitting a message according to an embodiment of the present application;

Fig. 6 is a flowchart illustrating steps of a second embodiment of a method for transmitting a message according to an embodiment of the present application;

fig. 7 is a diagram illustrating a third scheduling example of a message transmission method according to an embodiment of the present application;

fig. 8 is a process example diagram of a first embodiment of a packet forwarding device performing packet transmission according to the present application;

fig. 9 is a flowchart illustrating steps of a third embodiment of a method for transmitting a message according to an embodiment of the present application;

fig. 10a is a diagram illustrating a first structural example of a first packet according to an embodiment of the present application;

fig. 10b is a diagram illustrating a second structural example of the first packet according to the embodiment of the present application;

fig. 11 is a diagram showing a second configuration example of a communication device according to an embodiment of the present application;

fig. 12 is a flowchart illustrating steps of a fourth embodiment of a method for transmitting a message according to an embodiment of the present application;

fig. 13a is a diagram illustrating a first structural division example of a first packet according to an embodiment of the present application;

fig. 13b is a diagram illustrating a second structural division of the first packet according to an embodiment of the present application;

fig. 14 is a diagram illustrating a configuration of a communication device according to an embodiment of the present application.

Detailed Description

The following description of the embodiments of the present application will be made clearly and completely with reference to the accompanying drawings, in which it is apparent that the embodiments described are only some embodiments of the present application, but not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments of the application without making any inventive effort, are intended to fall within the scope of the application.

The present embodiment provides a communication system as shown in fig. 1, where fig. 1 is a diagram illustrating a first structural example of a communication device according to an embodiment of the present application. The present embodiment is exemplified by application of the communication system 100 to an industrial network. The communication system 100 includes a production network 101, a management network 102, and a monitoring network 103. Each network includes one or more messaging devices, each messaging device being coupled to transport network 110. The production network 101 is configured to collect and send, via the transmission network 110, a message related to production information to the message receiving device, where the production information includes, but is not limited to, information related to raw materials, auxiliary materials, and equipment, and links of production, manufacturing, transportation, and sales. The management network 102 is used to collect and send information related to production management to the message receiving device via the transmission network 110. The monitoring network 103 collects and transmits relevant monitoring data for monitoring the industrial environment to the message receiving device via the transmission network 110. The transport network 110 includes one or more packet forwarding devices. The transmission network 110 is connected to a plurality of message receiving devices 121, and a message forwarding device included in the transmission network 110 is configured to send a message to the message receiving devices 121. The application scenario of the communication network 100 is not limited in this embodiment, and the communication network 100 can be applied to fields such as data centers, internet technology (internet technology, IT), cloud computing, data communication, and the like. The message forwarding device may be a switch, a router or a data gateway.

Taking any packet forwarding device included in the transport network 110 as an example, referring specifically to fig. 2, fig. 2 is an exemplary diagram of a packet forwarding device transmitting multiple data flows according to an embodiment of the present application. The packet forwarding device 201 receives multiple data streams, such as data stream L1, data stream L2, and data stream L3, and each data stream may continuously transmit multiple packets. The data stream L1, the data stream L2 and the data stream L3 share the transmission bandwidth 202 at the network outlet of the packet forwarding device 201. Under the condition that the message forwarding device 201 executes the message transmission method provided by the application, the message forwarding device 201 can restrict the transmission mode of each data stream, thereby ensuring good isolation between multiple paths of data streams transmitted by the message forwarding device. The packet forwarding device 201 as shown in fig. 2 sequentially transmits a packet L21 of the data stream L2, a packet L11 of the data stream L1, and a packet L31 of the data stream L3. Because the message L21, the message L11 and the message L31 are in a state of sequential transmission, a plurality of messages included in one path of data flow are effectively prevented from being in a state of being continuously scheduled to be sent to the message receiving device. If multiple packets included in one data stream are continuously scheduled for transmission, long waiting time is required for transmission of other data streams, resulting in greater interference between the data streams. For example, if the plurality of messages included in the data stream L1 are continuously scheduled for transmission, a long waiting time is required for the messages of the data stream L2 to be scheduled, and the longer the data stream L2 waits for the scheduled transmission, the greater the interference between the data stream L1 and the data stream L2, and the greater the transmission delay of the data stream L2, which reduces the timeliness of the transmission of the data stream L2. Therefore, when the message forwarding device shown in the embodiment transmits the data stream, good isolation between multiple paths of data streams transmitted by the message forwarding device can be ensured, stable transmission of each path of data stream transmitted by the message forwarding device can be ensured, and interference to transmission of other data streams can be reduced by transmission of each path of data stream.

The execution process of the message transmission method provided by the present application will be described with reference to fig. 3 to 5, where fig. 3 is a first scheduling example diagram of message transmission provided by an embodiment of the present application. Fig. 4 is a diagram illustrating a second scheduling example of a message transmission method according to an embodiment of the present application. Fig. 5 is a flowchart illustrating steps of a first embodiment of a method for transmitting a message according to an embodiment of the present application. The execution process of the message transmission method is shown in the following steps:

step 501, the message forwarding device receives a first data stream.

And under the condition that the message forwarding equipment receives the first data stream, caching the first data stream. The packet forwarding device shown in this embodiment configures a shaper (DBS) for each data stream. As shown in fig. 3, the packet forwarding device 300 configures DBS1 for the first data stream L1. The DBS1 is used for transmission control of the first data stream L1. The message forwarding device 300 also configures DBS2 for the second data stream L2. The DBS2 is used for transmission control of the second data stream L2. The embodiment of the application takes DBS as an example for realizing the data stream transmission control function, and the description of specific names is only an optional example and is not limited.

Step 502, the message forwarding device obtains a first parameter of a first message.

Specifically, the DBS1 obtains a first parameter, where the first parameter is the number of bits of the first packet. If the first data stream includes a plurality of messages, the first message is the first message to be sent in the first data stream. For example, the first data stream L1 includes, from early to late, a message a1, a message a2, and a message a3 in order according to the sending time, and then the first message is the message a1. It can be understood that the first parameter is the number of bits of the first message a1.

Step 503, the message forwarding device obtains the second parameter of the first message.

Specifically, the preset threshold is pre-stored in the DBS1, and the preset threshold in this embodiment may be named as debt (debt), and the specific name is not limited in the present application, and for better understanding, DBS1 is pre-stored as a debt. In this embodiment, the initial value of the default is taken as an example with 0, and it should be clear that the size of the initial value of the default is not limited in this embodiment.

The DBS1 acquires a second parameter, wherein the second parameter is the difference value between the default and the first parameter.

Referring to fig. 4, in the duration from time 0 to time t1, the packet forwarding device has not received the first data stream, and then the value of the bit value stored in the DBS1 is always maintained to be 0 (i.e. a preset threshold value) in the duration from time 0 to time t 1. At time t1, the message forwarding device receives the first data stream L1, and the message forwarding device obtains a second parameter of a first message a1 of the first data stream L1. In the case where the number of bits of the first packet a1 is pktSize, it can be understood that the second parameter=debt-the first parameter=0-pktsize= -pktSize.

Step 504, if the message forwarding device determines that the third parameter is smaller than the preset threshold, the message forwarding device sends the first message.

The packet forwarding device in this embodiment performs self-addition calculation with the bandwidth of the first packet a1 as the self-addition rate based on the second parameter. Specifically, the self-adding calculation means that the DBS1 obtains a third parameter once every unit time, where the third parameter is a difference between the second parameter and a target bit number (i.e. the bandwidth of the first packet), and it can be understood that the target bit number is the bit number of the first packet sent by the packet forwarding device through the unit time. Referring to fig. 4, in the duration from time t1 to time t2, the message forwarding device obtains the third parameter once every unit time. In case the message forwarding device determines that the third parameter is smaller than 0 (preset threshold), the message forwarding device performs step 504. And under the condition that the message forwarding device judges that the third parameter is larger than 0 (a preset threshold value), the message forwarding device continues to send the first message.

If the next hop device of the message forwarding device is the message receiving device, the message forwarding device directly sends the first message to the message receiving device. If the next hop device of the message forwarding device is another message forwarding device included in the transmission network, the message forwarding device directly sends the first message to the other message forwarding device.

Step 505, if the message forwarding device determines that the third parameter is equal to the preset threshold, the message forwarding device sends the second message.

The message forwarding device in this embodiment receives a second data stream L2, where the second data stream L2 includes a plurality of messages, and then the second message is a message that needs to be sent first in the second data stream. For example, the second data stream L2 includes, in order from early to late, a packet b1, a packet b2, a packet b3, a packet b4, and a packet b5 according to the transmission time. Then, the second message is message b1.

As can be seen from the foregoing steps, the second parameter is the difference between the default and the first parameter, and it can be understood that the maximum value of the second parameter is the number of bits of the first message, and along with the process of sending the first message by the message forwarding device, the message forwarding device needs to acquire the third parameter once every unit time, that is, the target number of bits needs to be subtracted from the second parameter once every unit time, then the maximum value of the third parameter is 0 (i.e., the preset threshold value), that is, it is indicated that the message forwarding device has sent the complete first message a1 to the next hop device. Since the maximum value of the third parameter is 0, the third parameter does not occur to be greater than 0. And if the message forwarding device determines that the third parameter is equal to 0, the message forwarding device sends the second message when the message forwarding device receives or caches the second message.

Continuing to refer to fig. 4, in the duration from time t0 to time t1, both the first message a1 and the second message b1 are in a state that the message forwarding device does not receive the message. At time t1, the message forwarding device needs to send the first message a1, and for this reason, the message forwarding device performs the above steps, and the obtained third parameters are all smaller than 0 (i.e. the preset threshold value) in the duration from time t1 to time t3, so that the message forwarding device continues to send the first message a1 in the duration from time t1 to time t 3. And at time t3, the third parameter obtained by the message forwarding device is equal to 0 (i.e. a preset threshold value), which indicates that at time t3, the message forwarding device completely sends the first message a1 to the next hop device.

At time t2 (time t2 is within the duration of time t1 to time t 3), the message forwarding device receives the second message b1, and at time t2, the message forwarding device determines that the third parameter is smaller than 0, and even if the message forwarding device receives the second message b1, the message forwarding device does not send the second message b1 but continues to send the first message a1 if the third parameter is smaller than 0. When the message forwarding device determines that the third parameter is equal to 0 at time t3, the message forwarding device further determines that, when the message forwarding device completely sends the first message a1 to the next hop device at time t3, the message forwarding device performs sending of the second message b1 at time t3, and the message forwarding device sends the second message b1 within a duration from time t3 to time t4, please refer to the above-mentioned process that the message forwarding device sends the first message a1 within a duration from time t1 to time t3, which is not described in detail.

It may be understood that the message forwarding device shown in this embodiment sends the message to the next-hop device according to the scheduled sequence, for example, if the message forwarding device sends the first message a1 via the first scheduling and then sends the second message b1 via the second scheduling, then the message forwarding device sends the first message a1 and the second message b1 to the next-hop device sequentially.

By adopting the method shown in the embodiment, the message forwarding device ensures that the message forwarding device only sends one message included in one data stream to the next-hop device at the same time based on the third parameter, and the situation that a plurality of messages included in the same data stream are continuously sent to the next-hop device does not occur. And under the condition that the third parameter is equal to the preset threshold value, the message forwarding device determines that the first message transmission of the first data stream is completed, so that the message forwarding device can send the second message of the second data stream to the next hop device, and the message forwarding device is prevented from continuously transmitting a plurality of messages of the same data stream. It can be seen that the plurality of messages included in the first data stream are not continuously transmitted to the next hop device, for example, after the message forwarding device finishes transmitting the first message a1 included in the first data stream, the message forwarding device transmits the second message b1 included in the second data stream, and the first message a1 and the second message b1 need to be transmitted, so that the first message a1 and the second message a2 included in the first data stream are prevented from being continuously transmitted, the waiting time required for transmitting the second data stream is effectively reduced, the mutual interference between the first data stream and the second data stream is reduced, the time delay for transmitting the second data stream is reduced, the isolation between the first data stream and the second data stream is effectively ensured, the smooth transmission of each data stream is ensured, and the transmission burst is avoided.

In the above embodiment, the message forwarding device sends the message to the next hop device according to the scheduled sequence, and the message forwarding device shown in this embodiment can send the message to the next hop device based on the priority of the message. The present embodiment will be described with reference to fig. 6 and 7. Fig. 6 is a flowchart illustrating steps of a second embodiment of a method for transmitting a message according to an embodiment of the present application. Fig. 7 is a diagram illustrating a third scheduling example of a message transmission method according to an embodiment of the present application.

Step 601, the message forwarding device receives a first data stream.

Step 602, the message forwarding device obtains a first parameter of a first message.

Step 603, the message forwarding device obtains the second parameter of the first message.

For the description of the execution process of steps 601 to 603 in this embodiment, please refer to steps 501 to 503 corresponding to fig. 5, which is not described in detail.

Step 604, if the message forwarding device determines that the third parameter is smaller than the preset threshold, the forwarding device schedules the first message.

The process of determining that the third parameter is smaller than the preset threshold by the message forwarding device in this embodiment is shown in step 504 corresponding to fig. 5, which is not described in detail.

Referring to fig. 7, the message forwarding device 700 schedules a first message means that, when the DBS1 determines that the third parameter is smaller than the preset threshold, the DBS1 sends the first message a1 to the inter-data-stream message priority scheduling module, so as to implement scheduling of the first message a 1.

It can be seen that, in comparison with step 504 corresponding to fig. 5, the difference between step 604 shown in this embodiment is that, in the case where the packet forwarding device determines that the third parameter is smaller than the preset threshold, the packet forwarding device does not directly send the first packet to the next hop device, but schedules the first packet to the inter-data-flow packet priority scheduling module.

Step 605, if the message forwarding device determines that the third parameter is equal to the preset threshold, the message forwarding device schedules the second message.

The process of determining, by the message forwarding device, that the third parameter is equal to the preset threshold in the embodiment is shown in step 505 corresponding to fig. 5, which is not described in detail.

Referring to fig. 7, the message forwarding device 700 schedules the second message means that, when the DBS2 determines that the third parameter is equal to the preset threshold, the DBS2 sends the second message b1 to the inter-data-stream message priority scheduling module, so as to implement scheduling the second message b2 to the inter-data-stream message priority scheduling module.

It can be seen that, in the case where the packet forwarding device determines that the third parameter is equal to the preset threshold, the step 605 shown in this embodiment is different from the step 505 corresponding to fig. 5 in that the packet forwarding device does not directly send the second packet to the next hop device, but schedules the second packet.

In step 606, the message forwarding device sends the message with the highest priority first and then sends the message with the lowest priority in the first message and the second message.

In this embodiment, the packet forwarding device determines, based on the priority, a transmission timing sequence of the scheduled first packet and the scheduled second packet. Specifically, the message forwarding device determines, based on the priority, who sends the first message and who sends the second message after the first message and the second message are scheduled. Referring to fig. 7, the inter-data-stream packet priority scheduling module has received a first packet a1 from DBS1 and a second packet b1 from DBS 2. The inter-data-stream message priority scheduling module sends a message with the highest priority first and then sends a message with the lowest priority in the first message a1 and the second message b1.

For example, the inter-data-stream packet priority scheduling module determines the priority based on the packet traffic characteristics, for example, the inter-data-stream packet priority scheduling module determines the priority based on the delay, and specifically, if the inter-data-stream packet priority scheduling module determines that the delay required for transmitting the first packet a1 is smaller than the delay required for transmitting the second packet b1, the inter-data-stream packet priority scheduling module sends the first packet a1 to the next hop device before sending the second packet b1. For another example, the inter-data-stream message priority scheduling module determines the priority based on the importance of the message, and specifically, if the inter-data-stream message priority scheduling module determines that the importance of the second message b1 is greater than the importance of the first message a1, the inter-data-stream message priority scheduling module sends the second message b1 to the next hop device first, and then sends the first message a1. Optionally, the message sending device may set indication information for indicating importance of the message in the first message a1 and the second message b1, and the inter-data-stream message priority scheduling module determines priority among the first message a1 and the second message b1 according to the indication information based on importance of the message, and optionally, the inter-data-stream message priority scheduling module determines priority based on service types carried by the first message a1 and the second message b1 respectively.

It should be clear that, in this embodiment, the description of the manner in which the message forwarding device determines who has the highest priority in the first message a1 and the second message b1 is an optional example, and is not limited.

By adopting the method shown in the embodiment, the message forwarding device ensures that the message forwarding device only schedules one message included in one data stream at the same time based on the third parameter, and the situation that a plurality of messages are scheduled does not occur. And under the condition that the third parameter is equal to the preset threshold value, the message forwarding device determines that the first message of the first data stream is scheduled, so that the message forwarding device can schedule the second message of the second data stream, and the message forwarding device is prevented from continuously scheduling a plurality of messages of the same data stream. It can be seen that the plurality of messages included in the first data stream are not continuously scheduled, for example, after the message forwarding device schedules the message a1 included in the first data stream, the message forwarding device schedules the message b1 included in the second data stream, and scheduling of the message a2 included in the first data stream needs to wait for completion of scheduling of the message a1 and the message b1, so that continuous scheduling of the message a1 and the message a2 included in the first data stream is avoided, waiting time of scheduling of the second data stream is effectively reduced, interference between the first data stream and the second data stream is reduced, scheduling time delay of the second data stream is reduced, isolation between the first data stream and the second data stream is effectively ensured, stable transmission of each data stream is ensured, and transmission burst is avoided. And the message forwarding device determines the time sequence of sending the first message and the second message to the next hop device based on the priority, thereby effectively ensuring the timely transmission of the high-priority message.

The following describes a scenario in which the message transmission method provided by the present application is applied to ethernet. Specifically, the multiple data streams multiplex the bandwidth of the same output port of the message forwarding device, so that the multiple data streams compete for the bandwidth of the output port, and the transmission performance of the multiple data streams through the output port cannot be guaranteed.

Fig. 8 is a process example diagram of a first embodiment of a packet forwarding device according to the present application to perform packet transmission. The message forwarding device includes a media Layer (801), a Physical Layer (802), and a media access control Layer (media access control, MAC) 803. For example, as shown in fig. 8, the MAC803 includes two channels, i.e., the first channel 811 and the second channel 812, it should be clear that the description of the number of channels included in the MAC803 in this embodiment is an optional example, and is not limited. The following describes the execution process of the method provided in this embodiment with reference to fig. 9, where fig. 9 is a flowchart illustrating steps of a third embodiment of the method for transmitting a message provided in this embodiment.

Step 901, the message forwarding device receives a first data stream.

For a specific description of the first data flow shown in the embodiment, please refer to step 501 corresponding to fig. 5, which is not repeated.

Optionally, different channels of the packet forwarding device shown in this embodiment are connected to different packet receiving devices, and then a first channel of the packet forwarding device receives the first data stream, where the first channel is one channel of the packet forwarding device.

In order to ensure successful transmission of the first data stream, the message forwarding device sets a first channel identifier in each message included in the first data stream when the first channel receives the first data stream. The first channel identifier corresponds to the first channel. For example, in the case that the first data stream sequentially includes, from early to late, a packet a1, a packet a2, and a packet a3 according to the transmission time, the packet forwarding device sets the first channel identifier in the packet a1, the packet a2, and the packet a3, respectively.

Still optionally, before the message sending device that sends the first data stream to the message forwarding device, a first channel identifier is set in each message included in the first data stream. After the message forwarding device receives the first data stream, the message forwarding device determines to transmit the first data stream through the first channel because the first channel identifier carried by each message of the first data stream corresponds to the first channel.

An alternative manner of setting the first channel identifier in the first message by the message sending device is described below with reference to fig. 10a and fig. 10b, where fig. 10a is a first structural example diagram of the first message provided by the embodiment of the present application, and fig. 10b is a second structural example diagram of the first message provided by the embodiment of the present application.

As shown in fig. 10a, the first packet shown in fig. 10a includes a field 1001 for carrying a destination MAC address, a field 1002 for carrying a source MAC address, a field 1003 for carrying an EtherType (EtherType), a payload 1004, and a field 1005 for carrying a cyclic redundancy check code (cyclic redundancy check, CRC), which are described in detail with reference to the existing ethernet frame format.

In this embodiment, a first field 1006 is added to the first packet, where the first field 1006 is used to carry the first channel identifier. Optionally, a type field 1007 may be further added to the first packet, where the value of the type field 1007 is used to indicate the type of the first packet, so that the packet forwarding device determines, according to the indication of the type field 1007, that the method shown in this embodiment needs to be executed for transmitting the first packet. Optionally, a priority field 1008 may be further added to the first message, where the value of the priority field 1008 is used to indicate the priority of the first message, and details of the description of the priority of the first message are omitted herein for please refer to the description of the corresponding embodiment of fig. 5.

As shown in fig. 10b, the first packet shown in fig. 10b includes a field 1011 for carrying the destination MAC address, a field 1012 for carrying the source MAC address, a field 1013 for carrying EtherType, a payload1014 and a field 1015 for carrying CRC, which are shown in fig. 10a and will not be described in detail.

The first packet shown in this example further includes a local area network TAG (virtual local area network TAG, VLAN TAG) field 1016, where the VLAN TAG1016 specifically includes a TAG protocol identification (TAG protocol identifier, TPID) field 1021, a Priority (PRI) field 1022 that indicates the Priority of the data frame, a standard format indicator bit (canonical format indicator, CFI) field 1023, and a VLAN ID, VID field 1024 that indicates the number of the VLAN to which the data frame belongs.

The second field included in the first packet may be multiplexed in this embodiment, for example, the second field may be a VID field, where the VID field further carries the first channel identifier. In this embodiment, the VID field carries the first channel identifier as an example, and in other examples, the first channel identifier may also be carried by other fields included in the first packet. Optionally, the PRI field 1022 may be used to indicate the type of the first packet.

It can be seen that, in the case where the packet sending device sends the first packet to the packet forwarding device, the packet forwarding device determines, based on the target field carried by the first packet, that the first packet needs to be transmitted through the first channel of the packet forwarding device, where the target field may be a first field shown in fig. 10a, or the target field may be a second field shown in fig. 10 b.

In the above example, the first channel identifier is set in the first message by the message sending device, and in other examples, the first channel identifier may also be set in the first message by the message forwarding device, and the description of setting the first channel identifier in the first message by the message forwarding device is referred to the description of setting the first channel identifier in the first message by the message sending device shown above, which is not specifically described in detail.

Step 902, the message forwarding device obtains a first parameter of a first message.

Step 903, the message forwarding device obtains a second parameter of the first message.

Step 904, if the message forwarding device determines that the third parameter is smaller than the preset threshold, the message forwarding device schedules the first message.

For a description of the execution process of steps 902 to 904 shown in this embodiment, please refer to steps 602 to 604 corresponding to fig. 6, and refer to fig. 8, in which the DBS1 executes steps 902 to 904, and the message forwarding device transmits the first message through the first channel corresponding to the first channel identifier carried by the first message.

Step 905, if the message forwarding device determines that the third parameter is equal to the preset threshold, the message forwarding device schedules the second message.

The second message shown in the embodiment is a message included in the second data stream, and the description of the second data stream is shown in the embodiment corresponding to fig. 6, which is not repeated in detail. In this embodiment, the first data stream and the second data stream are both transmitted through the same first channel 811 of the packet forwarding device. For a description of the execution process of step 905 performed by the packet forwarding device in this embodiment, please refer to step 605 corresponding to fig. 6, which is not described in detail. It can be appreciated that the message forwarding device transmits the second message via a first channel corresponding to the first channel identifier carried by the second message.

Step 906, the message forwarding device receives the third message.

The third packet in this embodiment is a packet of a third data flow, where the third data flow is a packet that needs to be transmitted through the second channel 812 of the packet forwarding device. Specifically, the third message shown in the embodiment carries the second channel identifier corresponding to the second channel, and the description of the process in which the third message carries the second channel identifier is referred to in the description of the process in which the first message shown in step 901 carries the first channel identifier, which is not described in detail.

The execution timing between step 906 and steps 901 to 905 is not limited in this embodiment.

Step 907, the message forwarding device obtains the first parameter of the third message.

Step 908, the message forwarding device obtains the second parameter of the third message.

Step 909, if the message forwarding device determines that the third parameter of the third message is smaller than the preset threshold, the message forwarding device schedules the third message.

The message forwarding device in this embodiment schedules the execution process of the third message through steps 907 to 909, please refer to steps 602 to 604 corresponding to fig. 6, which are not described in detail.

In step 910, the message forwarding device sends, in the first channel and the second channel, a message of a channel with the highest priority, and then sends a message of a channel with the lowest priority.

In this embodiment, the packet forwarding device determines, based on the priority, the transmission timing of different packets transmitted via different channels. Specifically, the message forwarding device determines, based on the priority, which channel of the messages transmitted by the first channel and the messages transmitted by the second channel are sent first, and which channel of the messages is sent later. It can be understood that, if the message forwarding device determines that the priority of the first channel is higher than the priority of the second channel, the message forwarding device sends the first message and the second message through the first channel according to the first channel identifier, and then sends the third message through the second channel according to the second channel identifier. Or if the message forwarding device determines that the priority of the second channel is higher than the priority of the first channel, the message forwarding device sends the third message through the second channel according to the second channel identifier, and then sends the first message and the second message through the first channel according to the first channel identifier.

Referring to fig. 8, the inter-channel message priority scheduling module is configured to receive a message from each channel of the message forwarding device. For example, the inter-lane message priority scheduling module receives a first message and a second message from the first lane 811. The inter-channel message priority scheduling module also receives a third message from the second channel 812. The inter-channel message priority scheduling module determines who first sends the message in the first channel 811 and the second channel 812 based on the priority.

For example, the inter-channel message priority scheduling module determines the priority based on the traffic characteristics of the message, for example, the inter-channel message priority scheduling module determines the priority based on the time delay, specifically, if the inter-channel message priority scheduling module determines that the time delay required for the transmission of the first channel 811 is smaller than the time delay required for the transmission of the second channel 812, then the inter-channel message priority scheduling module sends the first message and the second message transmitted by the first channel 811 to the next hop device. And then sends the third message transmitted by the second channel 812 to the next hop device.

The inter-channel message priority scheduling module determines priorities among different channels to determine a process of sending a message timing sequence to the next-hop device, please refer to the inter-data stream message priority scheduling module shown in fig. 7 for determining priorities among different data streams to determine a process of sending a message timing sequence to the next-hop device, which will not be described in detail.

Optionally, the message forwarding device shown in this embodiment may further include an inter-data flow message priority scheduling module for determining a sending time sequence of the first message and the second message, where the inter-data flow message priority scheduling module sends the message to the inter-channel message priority scheduling module according to the sending time sequence of the message, and the inter-channel message priority scheduling module performs the determination of the priority between channels, and the detailed description of the inter-data flow message priority scheduling module is please refer to the corresponding description of fig. 7, and is not described in detail.

By adopting the method shown in the embodiment, the message forwarding device can ensure that the messages transmitted by each channel only schedule one message included in one data stream at the same time, and the condition that a plurality of messages are scheduled in the same channel can not occur. And the condition that a plurality of messages included in the same data stream of the same channel are continuously scheduled can not occur, so that the interference among different data streams in the same channel is effectively reduced. The independent transmission of each channel is ensured by the data streams transmitted by different channels of the message forwarding device, the condition of competing the bandwidths of the output ports of the message forwarding device cannot occur, and the transmission performance of the data streams transmitted by different channels is effectively ensured. The message forwarding equipment determines the sending time sequence of the messages transmitted by different channels based on the priority, and effectively ensures the timely transmission of the messages with high priority.

The method provided by the application can also improve the stability of each message sent by the message forwarding device, and first please refer to fig. 11, fig. 11 is a diagram showing a second structural example of the communication device provided by the embodiment of the application.

The transmission network 1100 shown in this embodiment is connected between the message sending device 1101 and the message receiving device 1121, and for the description of the message sending device 1101 and the message receiving device 1121, please refer to the corresponding description of fig. 1, details are not repeated. The transport network 1100 shown in this embodiment includes a plurality of packet forwarding devices, such as the ingress edge packet forwarding device 1111 shown in fig. 11, which is connected to the packet sending device 1101 and is configured to receive a data stream from the packet sending device 1101. The transport network 1100 also includes an egress edge message forwarding device 1114 coupled to the message receiving device 1121 for sending messages to the message receiving device 1121. The transport network 1100 further includes one or more intermediate message forwarding devices coupled between the ingress edge message forwarding device 1111 and the egress edge message forwarding device 1114, in this embodiment, the intermediate message forwarding device 1112 and the intermediate message forwarding device 1113 are coupled between the ingress edge message forwarding device 1111 and the egress edge message forwarding device 1114 in sequence.

Based on the communication system shown in fig. 11, the execution process of this embodiment is described below with reference to fig. 12, and fig. 12 is a flowchart illustrating steps of a fourth embodiment of the message transmission method according to the embodiment of the present application.

Step 1201, the ingress edge packet forwarding device receives a first data stream from the packet sending device.

Step 1202, the ingress edge packet forwarding device divides the first packet into a plurality of first data units.

In this embodiment, in the case where the ingress edge packet forwarding device receives each packet of the first data flow, in order to improve stability of forwarding each packet by the ingress edge packet forwarding device, the ingress edge packet forwarding device may divide each packet included in the first data flow to divide each packet into a plurality of data units, and description is given below with respect to a procedure of dividing the first packet by the ingress edge packet forwarding device, where details of the first packet are described with reference to an embodiment corresponding to fig. 6, and details of the description of the first packet are not repeated. The embodiment provides two alternative ways of dividing the first message.

Alternative 1 is shown in connection with fig. 13a, where fig. 13a is a first structural division example diagram of a first packet according to an embodiment of the present application.

The first message shown in this embodiment includes a Header (Header), a payload (payload), and a trailer, which may also be referred to as a frame check sequence (frame check sequence, FCS).

Firstly, the ingress edge message forwarding device only divides the payload included in the first message, specifically, the ingress edge message forwarding device divides the payload into N divided payloads, where N is a positive integer greater than 1. The present embodiment is exemplified by the same byte size of the divided payloads. As shown in fig. 13a, the ingress edge forwarding device divides the payload of the first message into N divided payloads (i.e., data1, data2, data3, and so on as shown in fig. 13 a). The specific number of bytes of each divided payload is not limited in this embodiment, and for example, the number of bytes of each divided payload is 64 bytes.

And secondly, the entry edge message forwarding device acquires N first data units, wherein each first data unit in the N first data units comprises the header, and one divided payload in the N divided payloads and the trailer. For example, the first Data unit 1301 includes a first partitioned payload (i.e., data 1) that is partitioned, and also includes a header and a trailer. It can be appreciated that the ingress edge message forwarding device replicates N shares of the message and trailer, respectively, so as to form N first data units together with the N divided payloads. For a description of the structure of the other first data units divided by the ingress edge packet forwarding device, please refer to the description of the structure of the first data unit 1301, and a detailed description is omitted.

Alternative 2 is shown in connection with fig. 13b, where fig. 13b is a diagram illustrating a second structural division of the first packet according to an embodiment of the present application.

Firstly, the ingress edge message forwarding device divides the complete first message, that is, the manner is different from the manner 1, the manner 1 is to divide only the payload, and the manner is to divide the complete first message (that is, including the message, the payload and the trailer) to divide the complete first message into M divided messages, where M is a positive integer greater than 1. For example, fig. 13b shows the first message divided into divided message 1311, divided message 1212, divided message 1213, and divided message 1214. The specific number of bytes of each divided message is not limited in this embodiment, for example, the number of bytes of each divided message is 64 bytes.

Next, the ingress edge message forwarding device obtains M first data units, where each first data unit (e.g., first data unit 1321) includes a divided message 1311 and a segment header. The segment header is located at the position of the segment header of the first data unit 1321, where the segment header carries the first channel identifier, and for the description of the first channel identifier, please refer to the corresponding description of fig. 6, details are not repeated. The information included in the segment header is not limited in this embodiment, as long as the segment header can indicate the message to which the first data unit belongs. The ingress edge forwarding device may also set a CRC at the end of the segment of the first data unit 1321 to achieve a check with minimal overhead.

In this embodiment, the number of bytes of each first data unit is not limited, and the smaller the first data unit is, the smoother the transmission of the first message is, and the more interference between the first data units in different data stream transmission processes can be reduced.

Step 1203, the ingress edge message forwarding device obtains a first parameter of the first data unit.

Step 1204, the ingress edge message forwarding device obtains a second parameter of the first data unit.

Step 1205, if the ingress edge packet forwarding device determines that the third parameter is less than the preset threshold, the ingress edge packet forwarding device sends the first data unit to the intermediate packet forwarding device.

For the description of the execution process of steps 1203 to 1205 in this embodiment, please refer to the description of the execution process of steps 502 to 504 corresponding to fig. 5, which is not repeated.

In step 1206, if the ingress edge packet forwarding device determines that the third parameter is equal to the preset threshold, the ingress edge packet forwarding device sends the second data unit to the intermediate packet forwarding device.

For a description of the procedure of the ingress edge message forwarding device for obtaining the second data unit of the second message, please refer to the description of the procedure of the ingress edge message forwarding device for obtaining the first data unit of the first message, which is not described in detail.

For a description of the execution process of step 1206 shown in the present embodiment, please refer to the description of the execution process of step 505 corresponding to fig. 5, which is not repeated.

As shown in fig. 11, the ingress edge forwarding device 1111 in this embodiment sends the first data unit and the second data unit to the intermediate forwarding device 1112. Optionally, the ingress edge forwarding device may further determine a timing at which the first data unit and the second data unit are sent to the intermediate forwarding device 1112 based on the priority of the message, and the description of the process of determining the sending timing based on the priority is omitted herein for details of the corresponding embodiment of fig. 6.

Step 1207, the intermediate message forwarding device sends the first data unit and the second data unit to the exit edge message forwarding device.

After the intermediate message forwarding device shown in this embodiment receives the first data unit and the second data unit, the process that the intermediate message forwarding device sends the first data unit to the exit edge message forwarding device may refer to the description of the process that the message forwarding device sends the first message in the embodiment corresponding to fig. 5 or fig. 9, and the process that the intermediate message forwarding device sends the second data unit to the exit edge message forwarding device may refer to the description of the process that the message forwarding device sends the second message in the embodiment corresponding to fig. 5 or fig. 9, which is not described in detail.

Step 1208, the egress edge message forwarding device obtains the first message according to the plurality of first data units.

Step 1209, the egress edge packet forwarding device obtains a second packet according to the plurality of second data units.

In this embodiment, if the ingress edge packet forwarding device divides the first packet to obtain a plurality of first data units in the manner shown in fig. 13a, the egress edge packet forwarding device can reassemble the plurality of first data units into the first packet according to the header included in each first data unit when the egress edge packet forwarding device receives the plurality of first data units. And by analogy, under the condition that the exit edge message forwarding device receives a plurality of second data units, the exit edge message forwarding device can reorganize the plurality of second data units into a second message according to the header included by each second data unit.

If the ingress edge packet forwarding device divides the first packet to obtain a plurality of first data units in the manner shown in fig. 13b, the egress edge packet forwarding device can reassemble the plurality of first data units into the first packet according to the segment header included in the plurality of first data units when the egress edge packet forwarding device receives the plurality of first data units. And by analogy, under the condition that the exit edge message forwarding device receives a plurality of second data units, the exit edge message forwarding device can reorganize the plurality of second data units into a second message according to segment headers included in each second data unit.

Step 1210, the exit edge message forwarding device sends a first message and a second message to the message receiving device.

In the process of sending the first message to the message receiving device by the exit edge message forwarding device shown in this embodiment, reference may be made to the description of the process of sending the first message by the message forwarding device in the embodiment corresponding to fig. 5 or fig. 9, which is not described in detail. The process of the exit edge message forwarding device sending the second message to the message receiving device may refer to the description of the process of the message forwarding device sending the second message in the embodiment corresponding to fig. 5 or fig. 9, which is not described in detail.

By adopting the method shown in the embodiment, the ingress edge message forwarding device included in the transmission network can divide each message into a plurality of data units, so that in the process of sending the message, the messages are independently scheduled for sending based on each data unit, the scheduling degree of the messages is finer, the transmission of different messages is smoother, the interference among different messages is lower, and the isolation is better.

Fig. 14 is a diagram illustrating a configuration of a communication device according to an embodiment of the present application. The communication device 1400 includes a processor 1401, a transceiver 1402 and a memory 1403. The processor 1401 is interconnected with the memory 1403 and the transceiver 1402 by lines, respectively. The processor 1401 reads and executes the computer program stored in the memory 1403 to execute the corresponding processing. The functions of the processor 1401 may be partially or wholly implemented in hardware. The processor 1401 may be one or more chips, or one or more integrated circuits. For example, the processor 1401 may be one or more field-programmable gate arrays (FPGAs), application specific integrated chips (application specific integrated circuit, ASICs), system on chips (socs), central processing units (central processor unit, CPUs), network processors (network processor, NPs), digital signal processing circuits (digital signal processor, DSPs), microcontrollers (micro controller unit, MCUs), programmable controllers (programmable logic device, PLDs) or other integrated chips, or any combination of the above chips or processors, or the like. It should be appreciated that the memory is an optional component when the processor is implemented in hardware.

In the embodiment corresponding to fig. 5, the transceiver 1402 is configured to perform step 501, step 504 and step 505, and the processor 1401 is configured to perform step 502 and step 503. In the embodiment corresponding to fig. 6, the transceiver is used to perform step 601 and step 606, and the processor 1401 is used to perform step 602, step 603 and step 604. In the corresponding embodiment of fig. 9, the transceiver 1402 is used to perform the steps 901 and 910, and the processor 1401 is used to perform the steps 902, 903, 904, 905, 906, 907, 908 and 909.

In the corresponding embodiment of fig. 12, in the case that the packet forwarding device is an ingress edge packet forwarding device, the transceiver 1402 is configured to perform step 1201, step 1205 and step 1206, and the processor 1401 is configured to perform step 1202, step 1203 and step 1204. In the case where the message forwarding device is an exit edge message forwarding device, the processor 1401 is configured to execute step 1208, step 1209, and step 1210.

The application provides a communication system. The structure of the communication system is shown in fig. 1 or fig. 11, and detailed description thereof is omitted.

The above embodiments are only for illustrating the technical solution of the present application, and are not limiting. Although the application has been described in detail with reference to the foregoing embodiments, it will be understood by those of ordinary skill in the art that: the technical scheme described in the foregoing embodiments can be modified or some of the technical features thereof can be replaced by equivalents. Such modifications and substitutions do not depart from the spirit and scope of the technical solutions of the embodiments of the present application.

Claims

1. A message transmission method, characterized in that the method includes:

The message forwarding device receives the first data unit of the first data stream;

The message forwarding device obtains a first parameter, where the first parameter is the number of bits of the first data unit;

The message forwarding device obtains a second parameter, where the second parameter is the difference between a preset threshold and the first parameter;

The message forwarding device acquires a third parameter every unit time. The third parameter is the difference between the second parameter and a target number of bits. The target number of bits is the number of bits sent by the message forwarding device per unit time. The number of bits of the first data unit;

When the third parameter is less than the preset threshold, the message forwarding device sends the first data unit.

2. The method according to claim 1, characterized in that after the message forwarding device receives the first data unit of the first data flow, the method further includes:

The message forwarding device receives the second data unit of the second data stream;

When the third parameter is equal to the preset threshold, the message forwarding device sends the second data unit.

3. The method according to claim 2, wherein the message forwarding device sending the first data unit, and the message forwarding device sending the second data unit includes:

If the message forwarding device determines that the priority of the first data unit is higher than the priority of the second data unit, the message forwarding device first sends the first data unit and then sends the second data unit. data unit;

Or, if the message forwarding device determines that the priority of the second data unit is higher than the priority of the first data unit, the message forwarding device first sends the second data unit and then sends the The first data unit.

4. The method according to claim 2 or 3, characterized in that the message forwarding device receives the first data unit of the first data stream, and the message forwarding device receives the second data of the second data stream. After the unit, the method further includes:

The message forwarding device determines that the first data unit carries a first channel identifier, and the first channel identifier corresponds to the first channel of the message forwarding device;

The message forwarding device determines that the second data unit carries the first channel identifier;

The message forwarding device sends the first data unit and the second data unit through the first channel according to the first channel identifier.

5. The method according to claim 4, characterized in that, the method further comprises:

The message forwarding device receives the third data unit;

The message forwarding device determines that the third data unit carries a second channel identifier, and the second channel identifier corresponds to the second channel of the message forwarding device;

If the message forwarding device determines that the priority of the first channel is higher than the priority of the second channel, the message forwarding device first sends the message through the first channel according to the first channel identifier. the first data unit and the second data unit, and then sending the third data unit through the second channel according to the second channel identifier;

Or, if the message forwarding device determines that the priority of the second channel is higher than the priority of the first channel, the message forwarding device first passes the second channel through the second channel according to the second channel identifier. Send the third data unit, and then send the first data unit and the second data unit through the first channel according to the first channel identifier.

6. The method according to claim 4 or 5, characterized in that the message forwarding device determines that the first data unit carries a first channel identifier including:

If the message forwarding device determines that the first data unit carries a target field, it determines that the first data unit carries the first channel identifier, where the target field is used to carry the first channel identifier.

7. The method according to claim 4 or 5, characterized in that the message forwarding device determines that the first data unit carries a first channel identifier including:

The message forwarding device adds a first field to the first data unit, and the first field is used to carry the first channel identifier, or the message forwarding device multiplexes the first data unit. A second field has been included, and the second field is used to carry the first channel identifier.

8. The method according to any one of claims 2 to 7, characterized in that the first data unit is the first message included in the first data stream, and the second data unit is the The second packet included in the second data stream.

9. The method according to any one of claims 1 to 7, characterized in that the first data stream includes a first message, the first message includes a header, a payload and a trailer, and the message The text forwarding device receiving the first data unit of the first data stream includes:

The message forwarding device receives the first message;

The message forwarding device divides the payload into N divided payloads, where N is a positive integer greater than 1;

The message forwarding device obtains N first data units, each of the N first data units includes the header, and one of the N divided payloads The divided payload and the trailer.

10. The method according to any one of claims 4 to 7, wherein the message forwarding device receiving the first data unit includes:

The message forwarding device receives the first message;

The message forwarding device divides the first message into M divided messages, where M is a positive integer greater than 1;

The message forwarding device acquires M first data units. The first data unit includes one divided message among the M divided messages and a segment header. The segment header Carrying the first channel identifier.

11. A message forwarding device, characterized in that the message forwarding device includes a processor and a transceiver connected to the processor;

The transceiver is configured to receive the first data unit of the first data stream;

The processor is used for:

Obtain a first parameter, where the first parameter is the number of bits of the first data unit;

Obtain a second parameter, where the second parameter is the difference between a preset threshold and the first parameter;

Obtain a third parameter every unit time, the third parameter is the difference between the second parameter and a target number of bits, and the target number of bits is the first data unit sent by the message forwarding device per unit time. number of bits;

The transceiver is further configured to send the first data unit when the third parameter is less than the preset threshold.

12. The message forwarding device according to claim 11, characterized in that the transceiver is also used for:

receiving a second data unit of the second data stream;

If the third parameter is equal to the preset threshold, the second data unit is sent.

13. The message forwarding device according to claim 12, characterized in that,

The processor is configured to determine that the priority of the first data unit is higher than the priority of the second data unit, and the transceiver is configured to send the first data unit first and then send the second data unit;

Or, the processor is configured to determine that the priority of the second data unit is higher than the priority of the first data unit, and the transceiver is configured to send the second data unit first and then send the first data. unit.

14. The message forwarding device according to claim 12 or 13, characterized in that,

The processor is further configured to: determine that the first data unit carries a first channel identifier, and the first channel identifier corresponds to the first channel of the message forwarding device; determine that the second data unit carries The first channel identifier;

The transceiver is further configured to send the first data unit and the second data unit through the first channel according to the first channel identifier.

15. The message forwarding device according to claim 14, characterized in that the transceiver unit is also used to: receive a third data unit;

The processor is further configured to determine that the third data unit carries a second channel identifier, and the second channel identifier corresponds to the second channel of the message forwarding device;

The processor is used to determine that the priority of the first channel is higher than the priority of the second channel, and the transceiver is used to first send the first channel through the first channel according to the first channel identifier. data unit and the second data unit, and then send the third data unit through the second channel according to the second channel identifier;

Or, if the processor is used to determine that the priority of the second channel is higher than the priority of the first channel, the transceiver is used to first send all the information through the second channel according to the second channel identifier. The third data unit is then sent to the first data unit and the second data unit through the first channel according to the first channel identifier.

16. The message forwarding device according to claim 14 or 15, characterized in that,

The processor is further configured to determine that the first data unit carries a target field, and then determine that the first data unit carries the first channel identifier, wherein the target field is used to carry the first channel identifier. .

17. The message forwarding device according to claim 14 or 15, characterized in that,

The processor is further configured to add a first field to the first data unit, where the first field is used to carry the first channel identifier, or to multiplex the first field already included in the first data unit. Two fields, the second field is used to carry the first channel identifier.

18. The message forwarding device according to any one of claims 12 to 17, wherein the first data unit is a first message included in the first data stream, and the second data unit is the second packet included in the second data stream.

19. The message forwarding device according to any one of claims 11 to 17, characterized in that the first data stream includes a first message, and the first message includes a header, a payload and a trailer;

The transceiver is used to receive the first message;

The processor is configured to divide the payload into N divided payloads, where N is a positive integer greater than 1; and is also configured to obtain N first data units, and the N first data units are Each of the first data units of the data units includes the header, one of the N divided payloads and the trailer.

20. The message forwarding device according to any one of claims 14 to 17, characterized in that,

The transceiver is configured to receive the first message by the message forwarding device;

The processor is configured to divide the first message into M divided messages, where M is a positive integer greater than 1; and is also configured to obtain M first data units, where the first The data unit includes one divided message among the M divided messages and a segment header, where the segment header carries the first channel identifier.

21. A computer-readable storage medium comprising instructions, characterized in that, when the instructions are run on a computer, they cause the computer to perform the method according to any one of claims 1 to 10.