CN106803806A - Data message transmission method and system, communication system - Google Patents

Abstract

The present invention provides a data message transmission method and system, and a communication system. The method includes: when the aggregation group sends the data message, sends the data message through other aggregation groups in the data message transmission system; and/or, When the aggregation group receives the data message, it receives the data message through other aggregation groups in the data message transmission system. Through the implementation of the present invention, at least two aggregation groups are used, and the aggregation group can use the air interfaces of other aggregation groups to transmit data packets, so that the transmission rate of the aggregation group is not limited by the number of its internal air interfaces, and can meet high requirements. transfer rate requirements.

Description

Data message transmission method and system, communication system

technical field

The present invention relates to the communication field, in particular to a data message transmission method and system, and a communication system.

Background technique

With the rapid development of the Internet, the data transmission rate is getting higher and higher. However, due to resource constraints, traditional methods such as increasing bandwidth and improving spectrum utilization efficiency have encountered bottlenecks, which cannot meet the requirements of microwave systems for rapid growth in transmission rates. Based on this requirement, the application of carrier equalization technology was born, which can aggregate multiple air interfaces in the frame for transmission. However, with the further improvement of transmission rate requirements, the aggregation group formed by the link aggregation realized by the limited air interfaces in the frame is not enough. Requirements, resulting in the transmission rate of data packets being limited.

Therefore, how to provide a data packet transmission method that can solve the problem that the transmission rate of the existing aggregation group is limited by the number of its internal air interfaces is a technical problem to be solved urgently by those skilled in the art.

Contents of the invention

The invention provides a data message transmission method, system and communication system to solve the problem that the transmission rate of the existing convergence group is limited by the number of its internal air interfaces.

The present invention provides a data message transmission method, which is used in a data message transmission system including at least two aggregation groups, where the aggregation group is formed by the aggregation of at least two physical links; the data message transmission method includes: the aggregation group is When sending data packets, send data packets through other aggregation groups in the data packet transmission system; and/or, when the aggregation group receives data packets, receive data packets through other aggregation groups in the data packet transmission system .

Further, before the aggregation group sends data packets through other aggregation groups in the data packet transmission system, it also includes: the aggregation group judges whether the air interface traffic of its internal physical links meets the air interface traffic requirements for sending data packets, and if it meets , the data message is only sent through the air interface of the physical link in it, and if not satisfied, the data message is sent through the air interface of the physical link in other aggregation groups in the data message transmission system.

Further, at least two aggregation groups include a main aggregation group and at least one slave aggregation group; the data message transmission method also includes: marking the aggregation group that needs to process and send the data message as the main aggregation group, and the main aggregation group is based on The transmission requirement of the data message selects at least one slave aggregation group, and sends the data message through the master aggregation group and the selected slave aggregation group. .

Further, it also includes: the aggregation group removes the recoverable field in the data message before sending the data message; and/or, the aggregation group recovers the recoverable field in the data message after receiving the data message.

Further, sending data packets by the aggregation group through other aggregation groups in the data packet transmission system includes: performing slicing and framing processing on the data packets to generate data frames, and sending the data frames that need to be sent to corresponding nodes of other aggregation groups through other aggregation groups. Air interface; the data frame includes the air interface identification and its position information in the data message; and/or the aggregation group receives the data message through other aggregation groups in the data message transmission system including: receiving the data frame of the data message through the air interface, According to the position information of the data frame in the data message, the data frame is deframed and rectified to generate a data message.

The present invention provides a data message transmission system, which includes at least two aggregation groups formed by aggregation of at least two physical links;

The aggregation group includes a sending module, which is used to send the data message through other aggregation groups in the data message transmission system when sending the data message;

and / or,

The aggregation group includes a receiving module, configured to receive the data message through other aggregation groups in the data message transmission system when receiving the data message.

Further, the aggregation group also includes a judging module, which is used to judge whether the air interface traffic of the physical link in the data packet transmission system meets the air interface traffic requirements for sending data packets before sending data packets through other aggregation groups in the data packet transmission system, If it is satisfied, the data message is only sent through the air interface of the physical link in it, and if it is not satisfied, the data message is sent through the air interface of the physical link in other aggregation groups in the data message transmission system.

Further, at least two aggregation groups include a main aggregation group and at least one slave aggregation group; the aggregation group that needs to process and send data messages is marked as the main aggregation group, and the main aggregation group selects at least one according to the transmission requirements of the data message The slave aggregation group sends data packets through the master aggregation group and the selected slave aggregation group in the master-slave aggregation group.

Further, the aggregation group also includes a removal module, which is used to remove the recoverable field in the data message before sending the data message; and/or, the aggregation group also includes a recovery module, which is used to restore the data message after receiving the data message. A recoverable field in a datagram.

Further, the aggregation group also includes a processing module, which is used to slice and frame the data packets to generate data frames, which will need to be sent through the corresponding air interfaces of other aggregation groups through other aggregation groups; The position information in the data message; and/or, the aggregation group also includes a processing module, which is used to receive the data frame of the data message through the air interface, and deframe and rectify the data frame according to the position information of the data frame in the data message Generate a datagram.

The present invention provides a communication system, which uses the data message transmission system provided by the present invention to transmit data.

Beneficial effects of the present invention:

The present invention provides a data message transmission method, which uses at least two aggregation groups, and a certain aggregation group can use the air interfaces of other aggregation groups to transmit data messages, so that the transmission rate of the aggregation group is not restricted by The limitation of the number of internal air interfaces can meet the requirements of high transmission rate; further, data packets can also be processed by removing recoverable fields, which reduces the amount of data transmission and waste of resources. To a certain extent, it can make Aggregation groups with a certain number of air interfaces have higher transmission rates.

Description of drawings

FIG. 1 is a schematic structural diagram of a data packet transmission system provided by a first embodiment of the present invention;

FIG. 2 is a flow chart of a data message transmission method provided by a second embodiment of the present invention;

FIG. 3 is a schematic structural diagram of a communication system provided by a third embodiment of the present invention;

FIG. 4 is a schematic diagram of data packet transmission in the first scenario in the third embodiment of the present invention;

FIG. 5 is a schematic diagram of data packet transmission in a second scenario in the third embodiment of the present invention.

detailed description

The present invention will be further explained by means of specific embodiments in combination with the accompanying drawings.

First embodiment:

Fig. 1 is a schematic structural diagram of the data packet transmission system provided by the first embodiment of the present invention. As can be seen from Fig. 1, in this embodiment, the data packet transmission system provided by the present invention includes at least two aggregation groups 1, the aggregation group It is formed by the aggregation of at least two physical links; for any one of the two aggregation groups 1,

The aggregation group 1 includes a sending module 11, which is used to send the data message through other aggregation groups in the data message transmission system when sending the data message;

and / or,

The aggregation group 1 includes a receiving module 12, configured to receive data packets through other aggregation groups in the data packet transmission system when receiving data packets.

As shown in Figure 1, in some embodiments, the aggregation group 1 in the above embodiment also includes a judging module 13, which is used to judge the physical Whether the air interface flow of the link meets the air interface flow requirements for sending data packets. If so, the data packet is only sent through the air interface of the physical link within it. If not, the data packet is transmitted through other aggregation groups in the system. The air interface of the internal physical link sends data packets.

As shown in Figure 1, in some embodiments, at least two aggregation groups in the above-mentioned embodiments include a master-slave aggregation group, and the sending module 11 of the master aggregation group in the master-slave aggregation group is used to , send the data message through the slave aggregation group in the master-slave aggregation group; and/or, the receiving module 12 of the master aggregation group in the master-slave aggregation group The aggregation group and the selected data packets are received from the aggregation group.

In some embodiments, at least two aggregation groups in the above embodiments may be master-slave aggregation groups for each other. In this way, the air interfaces of all aggregation groups can be fully used.

As shown in Figure 1, in some embodiments, the aggregation group 1 in the above embodiment further includes a removal module 14, which is used to remove the recoverable field in the data message before sending the data message; and/or, the aggregation The group also includes a recovery module 15, configured to recover the recoverable fields in the data message after receiving the data message.

As shown in Figure 1, in some embodiments, the aggregation group 1 in the above embodiment also includes a processing module 16, which is used to perform slicing and framing processing on data packets to generate data frames, which will need to pass through other aggregation group data frames. The corresponding air interface of other aggregation groups sends; the data frame includes the air interface identification and its position information in the data message; and/or, the data frame used to receive the data message through the air interface, according to the Position information, deframing and rectifying the data frame to generate a data message.

Correspondingly, the present invention provides a communication system, which uses the data packet transmission system 1 provided by the present invention to transmit data.

Second embodiment:

Fig. 2 is the flow chart of the data message transmission method provided by the second embodiment of the present invention, as can be seen from Fig. 2, in this embodiment, the data message transmission method provided by the present invention comprises the following steps:

S201: When the aggregation group sends the data message, send the data message through other aggregation groups in the data message transmission system; and/or,

S202: When the aggregation group receives the data message, it receives the data message through other aggregation groups in the data message transmission system.

In some embodiments, before the aggregation group sends data packets through other aggregation groups in the data packet transmission system, the method in the above embodiment further includes: the aggregation group judges whether the air interface traffic of the physical link in it satisfies sending If the air interface flow requirements of the data message are met, the data message will only be sent through the air interface of the physical link in it; if not, the data message will be sent through the air interface of other physical links in the data message transmission system message.

In some embodiments, at least two aggregation groups in the above embodiment include a master-slave aggregation group, and the data packet transmission method further includes: when the master aggregation group in the master-slave aggregation group sends a data packet, the master-slave The master aggregation group in the aggregation group and the selected slave aggregation group send data packets; and/or, when the master aggregation group in the master-slave aggregation group receives the data packet, it receives the data packet through the slave aggregation group in the master-slave aggregation group. datagram.

In some embodiments, the method in the above embodiment further includes: making at least two aggregation groups mutually master-slave aggregation groups.

In some embodiments, the method in the above embodiment further includes: before the aggregation group sends the data packet, removing the recoverable field in the data packet; and/or, after the aggregation group receives the data packet, restores the data packet Recoverable fields in the text.

In some embodiments, sending data packets by the aggregation group in the above embodiment through other aggregation groups in the data packet transmission system includes: performing slicing and framing processing on the data packets to generate data frames, which will need to be transmitted through other aggregation groups The frame is sent to the corresponding air interface of other aggregation group; the data frame includes the air interface identification and its position information in the data packet; and/or, the aggregation group receives the data packet through other aggregation groups in the data packet transmission system including: through The air interface receives the data frame of the data message, and according to the position information of the data frame in the data message, deframes and rectifies the data frame to generate a data message.

The present invention will be further explained in combination with specific application scenarios.

Third embodiment:

In order to overcome the defect that the number of aggregation air interfaces in the existing physical layer link aggregation system is limited to the frame, this embodiment provides a scalable physical layer link aggregation method and device that can break the limitation of the physical frame of the system.

The cross-frame physical layer link aggregation method adopted by the present invention includes the following steps: the cross-frame physical layer link aggregation is divided into a main aggregation group and a slave aggregation group, and the main aggregation group realizes the forward slicing and reverse grouping of the physical layer link aggregation The modular function realizes the expansion of the air interface link from the aggregation group. When the air interface traffic demand is small, only the main aggregation group can be used to implement it. When the traffic demand is large and one box cannot meet the traffic expansion, the slave aggregation group should be used for traffic expansion.

The forward direction mentioned below refers to the direction of sending to the air interface, and the reverse direction refers to the direction of receiving from the air interface. This embodiment redefines the functional modules of the message transmission system. As shown in Figure 3, the data message transmission system of the present invention Includes the following modules:

The forward scheduling module 30 enables the slice operation according to the status information of the air interface, including air interface quality, bandwidth and other information, and guides the assembly and transmission of the slice message;

The forward rectification module 31 performs shaping on the message to be transmitted, and adds various information required for message recovery, stores it in the FIFO and waits for the slice to be sent;

The forward slicing module 32 performs a unified length of 2 to the nth power of the data stream stored in the FIFO according to the slicing indication signal sent by the scheduling module, such as a slicing operation of 256Bytes size;

The forward framing module 33, according to the direction indication sent by the scheduling module, adds the MAC address and the slice ID corresponding to the air interface on the basis of the 256-byte slice, forms a message, and sends it to the switch chip;

The reverse analysis module 34 receives the slice message sent by the opposite end from the switch chip, extracts the 256-byte valid data and the slice ID, and sends the reverse buffer module;

The reverse cache module 35 sorts the slices according to the parsed IDs, and sends the data to the reverse flow recovery module in turn;

The reverse flow restoration module 36 restores the slice data to a data flow state consistent with the forward rectification module;

The reverse frame recovery module 37 restores the Ethernet message according to the message header indication and the message length in the data stream;

The sub-port processing module 38 of the main aggregation group divides the Ethernet physical port into a plurality of sub-ports according to the number of air interfaces of the aggregation group, forward processing identifies different air interfaces according to the slice MAC address, and adds a VLAN (Virtual Local Area Network (virtual local area network) 4-byte type indication, use the ID field to indicate different ports; reverse the type indication to remove, and replace the MAC address of the corresponding air interface, through this conversion, the slave aggregation group air interface is for the master The processing module of the aggregation group PLA (Physical Link Aggregation, Physical Link Aggregation) is invisible, and from the configuration of the aggregation group, it is only necessary to ensure that the number of sub-ports and the sub-port ID are consistent, and other configurations do not need to be concerned.

The sub-port processing module 39 of the slave aggregation group has the opposite function to that of the sub-port processing module of the main aggregation group. Identify the subport ID in the forward direction, and replace the MAC address of the slice with the content that can be identified from the air interface of the aggregation group; identify different air interfaces according to the MAC address of the slice in the reverse direction, and add the corresponding subport indication field.

In combination with the communication system shown in Figure 3, the method specifically includes the following steps:

Step 1. After the Ethernet data enters the physical link aggregation function, the packet shaping is first performed, and the recoverable fields that affect the throughput are removed, such as the access channel management parameter Premble and part of the CRC (Cyclical Redundancy Check, cyclic redundancy check) of the data packet code check), and use the SFD (Start Frame Delimiter, frame first delimiter) field as the header index, and then add a 2-byte message length field to find the end of the message, and store the data stream in the FIFO after shaping ( First Input First Output, first in first out queue).

Step 2. The air interface sends the status information to the reverse frame analysis module by sending the Request message. The module verifies the air interface information and generates a slice enable indication and a slice message sending direction indication. Specifically, for the Request message sent from the aggregation group, first enter the sub-port processing module of the aggregation group, add sub-port information; then enter the main aggregation group through the wired connection between the master-slave aggregation group, and process the sub-port The module identifies the subport information, replaces the MAC address of the Request message with the MAC address that can be identified by the main aggregation group corresponding to the subport, and then sends it to the reverse frame analysis module through switching to generate a slice enable indication and a slice message sending direction indication .

Step 3. The forward slicing module slices according to the slicing enable instruction, reads 256 Bytes data from the FIFO used in step 1, and sends it to the forward framing module.

Step 4. The forward framing module receives the 256Byts data sent by the slice, sequentially adds the MAC (Machine Aided Cognition) address corresponding to the sending direction of the slice, and adds an incremental 2Bytes slice ID field after the MAC address, Sent to the switch and forwarded to the air interface bound to the MAC. For the sliced message triggered by the sub-aggregation group Request, it will enter the main aggregation group sub-port processing module, add the corresponding sub-port information according to the MAC address, and then send it to the sub-aggregation group through a wired connection, and the sub-port of the sub-aggregation group The processing module will remove the sub-port information and add the corresponding MAC address information that can be identified by the aggregation group, send it to the switch, and forward it to the air interface of the aggregation group bound by the MAC.

Step 5. After the slice message is sent to the peer end, it will enter the reverse frame analysis module through exchange. This module extracts the slice 256Bytes data and slice ID, and sends it to the reverse cache module. For sliced packets coming from the air interface of the aggregation group, first enter the sub-port processing module of the sub-aggregation group, add sub-port information; then enter the main aggregation group through the wired connection between the master and slave aggregation groups, and identify the sub-port processing module Subport information, replace the MAC address of the sliced message with an address that can be recognized by the main aggregation group corresponding to the subport, and then send it to the reverse frame analysis module through switching.

Step 6. The reverse cache module uses DDR as the storage medium, and uses the slice ID as the index to store 256 Bytes of valid data of the slice.

Step 7. The reverse flow recovery module judges whether the corresponding 256 Bytes valid data in the cache module exists by sequentially accumulating the slice ID. If it exists, it reads from the cache and places them in the FIFO in order to reproduce the data stream generated in step 1. .

Step 8. The reverse frame recovery module reads the data when the reverse flow FIFO is not empty, finds the packet header indicated by SFD, and finds the end of the packet with the 2Bytes frame length after SFD, and adds data such as Premble and CRC Revert to a completed Ethernet message.

Using the method and system of the present invention, compared with the prior art, the number of converging air interfaces is expanded in a cross-frame manner, which can break through the limitation of the prior art that the number of converging air interfaces can only be limited in the frame, and greatly improve the microwave system throughput.

Now analyze with common application scenarios.

scene one:

As shown in FIG. 4 , the data packet transmission system can be divided into four parts, namely, a slice sending frame, a sending frame, a receiving frame, and a receiving recovery frame.

Specifically, the slicing sending frame completes the slicing and partial sending operations of the message. The specific implementation is as follows. The Ethernet message first enters the forward rectification module, sorts it into the data flow state to be sent, and stores it in the forward flow FIFO. Under the instruction of the module, the data segment is cut into uniform length. In the forward framing module, combined with the air interface instruction provided by the scheduling module, the corresponding MAC and the incremental slice ID are added, and the message sent to the air interface of the main aggregation group is directly passed through The exchange is forwarded to the corresponding air interface, and the message sent to the sub-aggregation group needs to go through the sub-port processing module of the main aggregation group to add the corresponding sub-port information, and send it to the sending frame through the interconnection line between the frames;

The sending box is used as the sub-port processing module from the aggregation group to parse the sliced message with sub-port information from the main aggregation group, and replace the MAC that can be identified by the cost box and send it to the air interface through the air interface;

The receiving box receives the segmented message from the opposite end, adds the corresponding subport information through the subport analysis module, and sends it to the receiving recovery box through the interconnection line between the boxes;

The receiving box receives the air interface of this box and the sliced messages received from the air interface of the aggregation group, extracts valid data in the reverse analysis module, and sends it to the reverse buffer module for sorting and reading by the reverse flow recovery module, and restores it into a continuous data stream. Finally, the reverse frame recovery module recovers the original Ethernet message according to the frame header and frame length indication in the data stream.

Scene two:

As shown in FIG. 5 , there is cross-frame processing at one end of the data packet transmission system, and only one frame exists at the other end.

Specifically, the sliced messages sent by the master aggregation group and the slave aggregation group through their respective air interfaces will receive the reception recovery frame of the opposite end, and the message recovery operation will be completed through unified processing.

In this scenario, the number of air interfaces in the master aggregation group at the receiving end is equal to the sum of the air interfaces in the master and slave aggregation groups at the sending end, ensuring a one-to-one correspondence; correspondingly, when the number of air interfaces in the master aggregation group at the sending end When the sum of the number of air interfaces in the group is reached, the sliced packets sent by the main aggregation group through the air interface will be received by the peer end through the master and slave aggregation groups, and the message recovery operation will be completed through unified processing through the receiving recovery box of the peer end.

In summary, through the implementation of the present invention, there are at least the following beneficial effects:

The present invention provides a data message transmission method, which uses at least two aggregation groups, and a certain aggregation group can use the air interfaces of other aggregation groups to transmit data messages, so that the transmission rate of the aggregation group is not restricted by The limitation of the number of its internal air interface can meet the requirements of high transmission rate;

Furthermore, the recoverable field can also be removed from the data message, which reduces the amount of data transmission and waste of resources. To a certain extent, the aggregation group with a certain number of air interfaces can have a higher transmission rate.

The above are only specific embodiments of the present invention, and do not limit the present invention in any form. Any simple modification, equivalent change, combination or modification made to the above embodiments according to the technical essence of the present invention still belong to this invention. The protection scope of the technical solution of the invention.

Claims (11)

1. a kind of data message transmission method, it is characterised in that for including at least two numbers of convergence group According to message transfer system, the convergence group is converged by least two physical links and formed；The data message is passed Transmission method includes：

Convergence group is sent out when sending datagram by other convergence groups in the data-message transmission system Send data message；

And/or,

Convergence group is connect when data message is received by other convergence groups in the data-message transmission system Receive data message.

2. data message transmission method as claimed in claim 1, it is characterised in that convergence group is passing through Before other convergence groups in the data-message transmission system send datagram, also include：The convergence Group judges whether the flow of eating dishes without rice or wine of its interior physical link meets the traffic demand of eating dishes without rice or wine for sending the data message, If meet, only by its interior physical link eat dishes without rice or wine send the data message, if it is not satisfied, then passing through In other convergence groups in the data-message transmission system physical link eat dishes without rice or wine send the data message.

3. data message transmission method as claimed in claim 1, it is characterised in that described at least two Convergence group includes a main convergence group and at least one from convergence group；The data message transmission method is also wrapped Include：The convergence group for processing and sending the data message will be needed to be designated as main convergence group, the main convergence group root According to the transmission demand selection at least one of the data message from convergence group, by the main convergence group and selected That selects described sends datagram from convergence group.

4. the data message transmission method as described in any one of claims 1 to 3, it is characterised in that also Including：Convergence group removed the field recovered in the data message before sending datagram；And/or, Convergence group recovers the field recovered in the data message after data message is received.

5. data message transmission method as claimed in claim 4, it is characterised in that

Convergence group by other convergence groups in the data-message transmission system send datagram including：It is right The data message carries out section framing processing generation data frame, it would be desirable to by other convergence group data Frame sends to the correspondence of other convergence groups and eats dishes without rice or wine；The data frame includes air interface identifier and its in the datagram Positional information in text；

And/or,

Convergence group receives data message by other convergence groups in the data-message transmission system to be included：It is logical The data frame for eating dishes without rice or wine to receive the data message is crossed, according to its position in the data message of the data frame Confidence ceases, and goes frame rectification to generate the data message to the data frame.

6. a kind of data-message transmission system, it is characterised in that including at least two convergence groups, the remittance Poly- group is converged by least two physical links and is formed；

Convergence group includes sending module, for when sending datagram, by the data-message transmission system Other convergence groups in system send datagram；

And/or,

Convergence group includes receiver module, for when data message is received, by the data-message transmission system Other convergence groups in system receive data message.

7. data-message transmission system as claimed in claim 6, it is characterised in that also include：

Convergence group also includes judge module, for other convergences in by the data-message transmission system Before group sends datagram, judge whether the flow of eating dishes without rice or wine of its interior physical link meets the transmission datagram Text traffic demand of eating dishes without rice or wine, if meet, only by its interior physical link eat dishes without rice or wine send the data message, If it is not satisfied, then by the hair of eating dishes without rice or wine of physical link in other convergence groups in the data-message transmission system Send the data message.

8. data-message transmission system as claimed in claim 6, it is characterised in that described at least two Convergence group includes a main convergence group and at least one from convergence group；Needs are processed and send the datagram The convergence group of text is designated as main convergence group, the main convergence group according to the transmission demand of the data message select to Few one from convergence group, by the main convergence group and selected principal and subordinate's convergence group from convergence group Send datagram.

9. the data-message transmission system as described in any one of claim 7 to 8, it is characterised in that converge Poly- group also includes removal module, for before sending datagram, remove in the data message can be extensive Multiple field；And/or, convergence group also includes recovery module, for after data message is received, recovering described The field recovered in data message.

10. data-message transmission system as claimed in claim 9, it is characterised in that

Convergence group also includes processing module, for carrying out section framing processing generation data to the data message Frame, it would be desirable to eat dishes without rice or wine to send by the correspondence of other convergence groups by other described data frames of convergence group；It is described Data frame includes air interface identifier and its positional information in the data message；

And/or,

Convergence group also include processing module, the data frame for receiving the data message by eating dishes without rice or wine, according to The data frame its positional information in the data message, goes frame rectification to generate described to the data frame Data message.

11. a kind of communication systems, it is characterised in that using as described in any one of claim 6 to 10 Data-message transmission system transfers data.