CN112804166B - Message receiving and sending method, device and storage medium - Google Patents
Message receiving and sending method, device and storage medium Download PDFInfo
- Publication number
- CN112804166B CN112804166B CN201911106131.7A CN201911106131A CN112804166B CN 112804166 B CN112804166 B CN 112804166B CN 201911106131 A CN201911106131 A CN 201911106131A CN 112804166 B CN112804166 B CN 112804166B
- Authority
- CN
- China
- Prior art keywords
- aggregation group
- scheduling
- message
- port
- service quality
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 38
- 230000002776 aggregation Effects 0.000 claims abstract description 176
- 238000004220 aggregation Methods 0.000 claims abstract description 176
- 238000004590 computer program Methods 0.000 claims description 3
- 238000010586 diagram Methods 0.000 description 11
- 238000007726 management method Methods 0.000 description 10
- 238000005516 engineering process Methods 0.000 description 5
- 230000006870 function Effects 0.000 description 5
- 230000008859 change Effects 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 230000005540 biological transmission Effects 0.000 description 2
- 230000009471 action Effects 0.000 description 1
- 230000006978 adaptation Effects 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012545 processing Methods 0.000 description 1
- 238000011160 research Methods 0.000 description 1
- 238000007493 shaping process Methods 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/50—Queue scheduling
- H04L47/62—Queue scheduling characterised by scheduling criteria
- H04L47/625—Queue scheduling characterised by scheduling criteria for service slots or service orders
- H04L47/6275—Queue scheduling characterised by scheduling criteria for service slots or service orders based on priority
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/24—Multipath
- H04L45/245—Link aggregation, e.g. trunking
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/50—Queue scheduling
- H04L47/60—Queue scheduling implementing hierarchical scheduling
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/70—Admission control; Resource allocation
- H04L47/80—Actions related to the user profile or the type of traffic
- H04L47/805—QOS or priority aware
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The application provides a message receiving and transmitting method, a message receiving and transmitting device and a storage medium. The method comprises the following steps: determining an output port of a message; if the output port is an aggregation group, the message is sent to a queue corresponding to the aggregation group to carry out service quality scheduling at the aggregation group level; and sending the messages which are not discarded after the service quality scheduling of the aggregation group level to a queue corresponding to the member port of the aggregation group, and performing the service quality scheduling of the member port level. And carrying out service quality scheduling of aggregation group level on the message through the aggregation group queue, thereby avoiding the need of using member port hardware resources to replace the aggregation group to realize hierarchical service quality scheduling for realizing service quality service on an aggregation group port.
Description
Technical Field
The present application relates to wireless communication networks, and in particular, to a method, an apparatus, and a storage medium for transmitting and receiving a message.
Background
With the continuous expansion of network size, the ethernet link aggregation technology and QOS (Quality of Service quality of service) technology are widely used in the background of the ever-increasing demands of operators on network transmission rate and reliability.
The Ethernet link aggregation is abbreviated as link aggregation, and the purpose of increasing the link bandwidth is realized by binding a plurality of Ethernet physical links together into one logic link. Meanwhile, the links which are bound together can effectively improve the total bandwidth and the reliability of the links through mutual dynamic backup. These bundled links are referred to as an aggregation group, and each physical link is referred to as an aggregation group member port.
QOS main functions are traffic classification and marking, congestion management, congestion avoidance, traffic policing, traffic shaping, etc. The most common functions are traffic classification, marking and congestion management, namely dividing data messages into a plurality of priorities, and when congestion occurs in a network, respectively processing the messages with different priorities by using a queue technology, wherein high messages are processed preferentially, so that the service quality with high priority is ensured.
Therefore, how to increase bandwidth by applying the link aggregation technology and simultaneously ensure network service quality becomes a hot spot of industry research, and QOS is realized on the aggregation group port, so that on one hand, the QOS requirement of users is met, and on the other hand, the advantages of the aggregation group port are well reflected. Generally, QOS service is implemented on an aggregation group port, and member physical port hardware resources are required to replace the aggregation group to implement QOS scheduling, so that aggregation group and member port hierarchical QOS scheduling cannot be supported.
Disclosure of Invention
The application provides a message receiving and transmitting method, a message receiving and transmitting device and a storage medium, which are used for realizing hierarchical service quality scheduling.
The embodiment of the application provides a message receiving and transmitting method, which comprises the following steps:
Determining an output port of a message;
If the output port is an aggregation group, the message is sent to a queue corresponding to the aggregation group to carry out service quality scheduling at the aggregation group level;
And sending the messages which are not discarded after the service quality scheduling of the aggregation group level to a queue corresponding to the member port of the aggregation group, and performing the service quality scheduling of the member port level.
The embodiment of the application provides a message receiving and transmitting device, which comprises:
the determining module is used for determining the output port of the message;
The first scheduling module is used for sending the message to a queue corresponding to the aggregation group for performing service quality scheduling at the aggregation group level if the output port is the aggregation group;
And the second scheduling module is used for sending the messages which are not discarded after the service quality scheduling of the aggregation group level to the queues corresponding to the member ports of the aggregation group, and carrying out the service quality scheduling of the member port level.
The embodiment of the application also provides a computer readable storage medium, and the computer readable storage medium stores a computer program which realizes the message receiving and transmitting method when being executed by a processor.
With respect to the above embodiments and other aspects of the application and implementations thereof, further description is provided in the accompanying drawings, detailed description and claims.
Drawings
FIG. 1 is a flowchart of a method for sending and receiving messages according to an embodiment of the present application;
FIG. 2 is a diagram of an example message provided in an embodiment of the present application;
FIG. 3 is a diagram of an example message provided in an embodiment of the present application;
FIG. 4 is a flowchart of another method for sending and receiving messages according to an embodiment of the present application;
Fig. 5 is a schematic structural diagram of a message transceiver according to an embodiment of the present application;
fig. 6 is a schematic structural diagram of a message device according to an embodiment of the present application;
fig. 7 is a schematic diagram of queue hooking of a virtual loopback interface according to an embodiment of the present application.
Detailed Description
For the purpose of making the objects, technical solutions and advantages of the present application more apparent, embodiments of the present application will be described in detail hereinafter with reference to the accompanying drawings. It should be noted that, without conflict, the embodiments of the present application and features of the embodiments may be arbitrarily combined with each other. It should be further noted that, for convenience of description, only some, but not all of the structures related to the present application are shown in the drawings.
The existing service quality scheduling service on the aggregation group port needs to use member physical port hardware resources to replace the aggregation group to realize service quality scheduling, so that the cross-chip aggregation group cannot be supported, and the aggregation group and member port hierarchical service quality scheduling cannot be supported. According to the message transceiving method, the aggregation group level service quality scheduling is carried out on the message through the aggregation group queue, the condition that the service quality service is realized on an aggregation group port by using member physical port hardware resources instead of the aggregation group is avoided, and the hierarchical service quality scheduling is completed through independently distributing the service quality scheduling hardware resources of the aggregation group and the member ports.
The method of the embodiment of the application is applied to the switching equipment, namely the switching chip or the switching equipment with a plurality of switching chips.
Fig. 1 is a flowchart of a method for transmitting and receiving a message according to an embodiment, as shown in fig. 1, where the method for transmitting and receiving a message according to the embodiment includes steps 110, 120, and 130.
In step 110, the egress port of the message is determined.
In step 120, if the output port is an aggregation group, the message is sent to a queue corresponding to the aggregation group to perform service quality scheduling at the aggregation group level.
In step 130, the packets that are not discarded after the qos scheduling at the aggregation group level are sent to the queues corresponding to the member ports of the aggregation group, so as to perform the qos scheduling at the member port level.
In this embodiment, taking a two-layer switching process as an example, the message at least includes a mac address and vlanid, and the message output port is determined according to the mac address and vlanid.
In an embodiment, the sending the message to the queue corresponding to the aggregation group to perform service quality scheduling at the aggregation group level includes: and after the message is added with the aggregation group identifier, sending the message to a queue corresponding to the aggregation group to carry out service quality scheduling at the aggregation group level.
In this embodiment, if the output port is an aggregation group, a corresponding queue is searched according to a queue identifier in a message, and an aggregation group identifier is added to the message, and the message added with the aggregation group identifier is sent to the queue corresponding to the aggregation group to perform service quality scheduling at an aggregation group level. Queue identification is understood to mean in particular a mark or label identifying a queue, for example, there may be a plurality of queues in an aggregate group, each of which is recorded with a different number to distinguish between the different queues. The message body carries priority identification, after the corresponding queue is searched according to the queue identification in the message, the queue identification is sequentially sent into the aggregation group queue according to the priority identification of the message, the message in the queue sequentially completes dequeuing operation according to a first-in first-out rule, data transmission is carried out according to the bandwidth allocated by the system, the first-out message preferentially allocates the bandwidth until no bandwidth can be allocated, and the rest message cannot be sent out.
In an embodiment, the sending, to a queue corresponding to a member port of the aggregation group, a packet that is not discarded after the scheduling of the quality of service at the aggregation group level includes: determining a member port of the aggregation group according to the aggregation group identifier and the corresponding aggregation group load; and removing the aggregation group identifier from the messages which are not discarded after the service quality scheduling of the aggregation group level, and sending the messages to a queue corresponding to the member port of the aggregation group.
In this embodiment, the non-discarded message may be specifically understood as a message sent out after performing the qos scheduling of the aggregation group level, where a portion of the messages with high priority level may be sent out when performing the qos scheduling of the aggregation group level, and a portion of the messages with low priority level may not be sent out and thus discarded. The aggregation group identifier can be specifically understood as a label for marking the aggregation group, and as a plurality of aggregation groups exist at the same time, the aggregation groups into which the message enters need to be distinguished and marked; the load of the aggregation group can be specifically understood as a load sharing algorithm of the aggregation group; and determining the corresponding member ports of the aggregation group and the queues corresponding to the member ports according to the aggregation group identification and the corresponding aggregation group load algorithm, removing the outer aggregation group identifier from the undelivered message, sending the outer aggregation group identifier to the queues corresponding to the member ports of the aggregation group, and carrying out service quality scheduling at the level of the member ports.
In an embodiment, before the packet that is not discarded after the qos scheduling at the aggregation group level is sent to the queue corresponding to the member port of the aggregation group, the method further includes: and if the member port of the aggregation group is a member port of other message receiving and transmitting devices, transmitting the messages which are not discarded after the service quality scheduling of the aggregation group level to the other message receiving and transmitting devices.
In an embodiment, before sending the packet that is not discarded after the qos scheduling at the aggregation group level to other packet transceiver devices, the method further includes: and adding a system forwarding head to the non-discarded message.
By way of example, fig. 2 provides an exemplary diagram of a message, where the message is marked by adding a source chip number, a source port number, a destination chip number, and a destination port number, so as to implement forwarding of the message across boards.
In one embodiment, the system forwarding head includes a source chip number, a source port number, a destination chip number, and a destination port number.
In this embodiment, if the final member port of the aggregation group is not the member port of the local plate, a system forwarding head needs to be added to the undelivered message, and according to the system forwarding head, a destination chip corresponding to the member port can be determined and the message is sent to the destination chip; the target chip analyzes the port, determines that the message is from other chips, removes the system forwarding head, and sends the message to the queue of the corresponding member port to finish the member port-level service quality scheduling; and the system forwarding head is added to send the message to other message receiving and transmitting devices, so that the service quality scheduling of the member port level of the cross-board aggregation group is realized.
In one embodiment, the aggregate group identification is a virtual local area network tag.
In this embodiment, the aggregation group identifier may be that a layer vlantag is added to the outer layer of the two-layer message, and the aggregation groups are identified by vlanid carried in vlantag, and this method can support at least 4095 aggregation groups in the system. Illustratively, FIG. 3 provides an exemplary diagram of messages, with an added vlanid to identify aggregate groups.
According to the message transceiving method, the aggregation group queue is used for carrying out aggregation group-level service quality scheduling on the message, so that the condition that the service quality service is realized on an aggregation group port by using member physical port hardware resources to replace the aggregation group is avoided, and the support of aggregation group and member port hierarchical service quality scheduling is realized; and the system forwarding head is added to send the message to other message receiving and transmitting devices, so that the service quality scheduling of the member port level of the cross-board aggregation group is realized.
Fig. 4 is a flowchart of another method for sending and receiving messages according to an embodiment, as shown in fig. 4, the method includes steps 210 to 240.
In step 210, an aggregate group of qos scheduling resources and queues, and a member port of qos scheduling resources and queues are allocated, the aggregate group of qos scheduling resources and the member port of qos scheduling resources being independent of each other, and the aggregate group of queues and the member port of queues being independent of each other.
In step 220, the egress port of the message is determined.
In step 230, if the output port is an aggregation group, the message is sent to a queue corresponding to the aggregation group to perform service quality scheduling at the aggregation group level.
In step 240, the packets that are not discarded after the qos scheduling at the aggregation group level are sent to the queues corresponding to the member ports of the aggregation group, so as to perform the qos scheduling at the member port level.
In this embodiment, when the aggregation group and the member ports perform qos scheduling, qos scheduling resources and queues, that is, network bandwidth allocated by the system when transmitting information, are required. The quality of service scheduling resources and queues of the member ports are based on the function of the member ports; unlike the member ports, the quality of service scheduling resources and queues of the aggregate group are based on the bearer roles of the aggregate group queues.
According to the message transceiving method, the service quality scheduling resources and the queues are independently distributed to the aggregation group and the member ports, and when the members of the port of the aggregation group change, the service quality resources of the aggregation group do not need to correspondingly change, so that the scheduling and the member port change decoupling are achieved; the service quality hardware resources of the aggregation group and the member ports are distributed independently, so that hierarchical service quality scheduling is realized; and the system forwarding head is added to send the message to other message receiving and transmitting devices, so that the service quality scheduling of the member port level of the cross-board aggregation group is realized.
The embodiment of the application also provides a message receiving and transmitting device. Fig. 5 is a schematic structural diagram of a message transceiver according to an embodiment. As shown in fig. 5, the message transceiver device includes: a determining module 310, a first scheduling module 320, a second scheduling module 330.
A determining module 310, configured to determine an output port of the packet.
And the first scheduling module 320 is configured to send the message to a queue corresponding to the aggregation group for performing service quality scheduling at the aggregation group level if the output port is the aggregation group.
And the second scheduling module 330 is configured to send the packet that is not discarded after the qos scheduling at the aggregation group level to a queue corresponding to a member port of the aggregation group, and perform the qos scheduling at the member port level.
The message receiving and transmitting device of the embodiment carries out service quality scheduling of aggregation group level on the message through the aggregation group queue, avoids the need of using member physical port hardware resources to replace the aggregation group to realize service quality scheduling when realizing service quality service on an aggregation group port, and realizes supporting the hierarchical service quality scheduling of the aggregation group and the member ports.
In an embodiment, the first scheduling module 320 is further configured to send the packet to a queue corresponding to the aggregation group for performing quality of service scheduling at the aggregation group level after the aggregation group identifier is added to the packet.
In an embodiment, the second scheduling module 330 includes:
a determining unit, configured to determine a member port of the aggregation group according to the aggregation group identifier and a corresponding aggregation group load;
and the sending unit is used for removing the aggregation group identifier from the messages which are not discarded after the service quality scheduling of the aggregation group level and sending the messages to the queues corresponding to the member ports of the aggregation group.
In an embodiment, the sending unit is further configured to send a message that is not discarded after the quality of service scheduling at the aggregation group level to other messaging devices if the member port of the aggregation group is a member port of the other messaging devices.
In an embodiment, the second scheduling module 330 further includes:
And the forwarding unit is used for adding a system forwarding head to the non-discarded message.
In one embodiment, the system forwarding head includes a source chip number, a source port number, a destination chip number, and a destination port number.
In one embodiment, the aggregate group identification is a virtual local area network tag.
In an embodiment, the system further includes an allocation module, configured to allocate qos scheduling resources and queues of an aggregate group, and qos scheduling resources and queues of a member port, where the qos scheduling resources of the aggregate group and the qos scheduling resources of the member port are independent of each other, and the queues of the aggregate group and the queues of the member port are independent of each other.
Fig. 6 is a schematic structural diagram of a message transceiver, which is specifically described in detail below:
The device comprises: the system comprises a receiving module, a searching and modifying module, an inter-board forwarding module, a flow control module and a virtual loopback interface.
Before receiving and transmitting the message, the exchange chip allocates QOS scheduling resources and queues for the aggregation group in advance and also allocates the QOS scheduling resources and queues for the physical port; QOS scheduling resources and queues are allocated on the traffic management module; the QOS scheduling resources and queues of common physical ports are based on physical port functioning; unlike physical ports, the QOS scheduling resources and queues of the aggregate group are based on virtual loopback interfaces functioning;
the virtual loop back port can be an independent physical port or a logic port in the internal forwarding flow of the switching chip, and can be used as a carrier of an aggregation group queue and a scheduler; for the case that a plurality of aggregation groups exist in a system, one possible way is to enable hierarchical scheduling at the virtual loopback port, and a specific implementation method of the hierarchical scheduling level is that each aggregation group monopolizes a group of queues, and the priority scheduling among the queues in the aggregation group is implemented under a weighted fair Queuing (wfq) scheduler; wfq schedulers used by all aggregation groups are hung under a Fair queue (fq) scheduler to realize balanced scheduling among the aggregation groups; virtual loopback interfaces are key modules in this embodiment.
Illustratively, FIG. 7 provides a queue hooking diagram of a virtual loopback interface for enabling balanced scheduling of aggregated components by hooking onto a scheduler.
After receiving the message, the receiving module takes a common two-layer exchange process as an example, and analyzes the mac address and vlanid of the message and provides the mac address and vlanid of the message to the searching and modifying module.
The searching and modifying module searches a destination outlet port according to the mac address + vlanid of the message; if the output port aggregates the group, the searching and modifying module adds an aggregation group identifier in the message; one possible aggregation group identifier is provided, wherein a layer vlantag is added on the outer layer of the two-layer message, and the aggregation groups are identified through vlanid carried in vlantag, so that at least 4095 aggregation groups can be supported in the system; the modified message is sent to a flow management module;
The flow management module sends the message priority identification into a queue of an aggregation group to complete enqueuing and scheduling to realize QOS; the message completing QOS will be sent out through the virtual loop back port and enter the receiving module again; this step is the key to implement hierarchical QOS, and is just the loopback action of the virtual loopback interface, so that the message can walk twice to find the forwarding flow, and thus QOS occurs twice.
The receiving module receives the message for the second time, recognizes that the source port is a virtual loopback port, and analyzes the outer layer vlanid as an aggregation group identifier and provides the aggregation group identifier to the searching and modifying module; the searching and modifying module combines the currently effective member ports according to the aggregation group identification and the load sharing algorithm configured by the aggregation group to obtain the final member ports; meanwhile, the searching and modifying module removes the outer layer vlantag in the message and sends the message to the flow management module.
The flow management module sends the message priority identification into a queue of a member port to complete enqueuing and scheduling to realize QOS; the message completing QOS is sent out through the member port, that is, the physical port, and the whole forwarding and QOS process is completed.
The essential condition of the cross-board aggregation group is a cross-board forwarding module which analyzes a system forwarding head carried by a message and forwards the system forwarding head to a corresponding chip; one possible system forwarding head includes at least a source chip number, a source port number, a destination chip number, a destination port number.
If the searching and modifying module finds out that the final group member port is not the physical port of the board, the searching and modifying module adds a system forwarding head to the message and sends the system forwarding head to the cross-board forwarding module; the cross board forwarding module sends the data to the target chip according to the system forwarding.
The receiving module of the target chip analyzes that the input port is from the cross board forwarding module, and analyzes that the output port is provided for the searching and modifying module;
The searching and modifying module removes the system forwarding head and sends the system forwarding head to the flow management module; the flow management module sends the flow management module to the queue of the corresponding physical port to finish QOS scheduling of the physical port level; thereby implementing QOS scheduling across the physical port levels of the aggregate group of boards.
The message transceiver device provided in this embodiment and the message transceiver method provided in the foregoing embodiments belong to the same inventive concept, and technical details not described in detail in this embodiment can be seen in any of the foregoing embodiments, and this embodiment has the same beneficial effects as those of executing the message transceiver method.
Embodiments of the present application also provide a storage medium containing computer-executable instructions that, when executed by a computer processor, are for performing a cloud billing method.
From the above description of embodiments, those skilled in the art will appreciate that the present application may be implemented by software and general purpose hardware, or may be implemented by hardware. Based on such understanding, the technical solution of the present application may be embodied in a software product, where the software product may be stored in a computer readable storage medium, such as a floppy disk, a Read-Only Memory (ROM), a random access Memory (Random Access Memory, RAM), a FLASH Memory (FLASH), a hard disk, or an optical disk of a computer, where the instructions include a plurality of instructions for causing a computer device (which may be a personal computer, a server, or a network device, etc.) to perform a method according to any embodiment of the present application.
The foregoing description is only exemplary embodiments of the application and is not intended to limit the scope of the application.
The block diagrams of any of the logic flows in the figures of this application may represent program steps, or may represent interconnected logic circuits, modules, and functions, or may represent a combination of program steps and logic circuits, modules, and functions. The computer program may be stored on a memory. The memory may be of any type suitable to the local technical environment and may be implemented using any suitable data storage technology, such as, but not limited to, read Only Memory (ROM), random Access Memory (RAM), optical storage devices and systems (digital versatile disk DVD or CD optical disk), etc. The computer readable medium may include a non-transitory storage medium. The data processor may be of any type suitable to the local technical environment, such as, but not limited to, general purpose computers, special purpose computers, microprocessors, digital Signal Processors (DSPs), application Specific Integrated Circuits (ASICs), programmable logic devices (FGPAs), and processors based on a multi-core processor architecture.
The foregoing detailed description of exemplary embodiments of the application has been provided by way of exemplary and non-limiting examples. Various modifications and adaptations to the above embodiments may become apparent to those skilled in the art without departing from the scope of the application, which is defined in the accompanying drawings and claims. Accordingly, the proper scope of the application is to be determined according to the claims.
Claims (10)
1. A method for sending and receiving messages, comprising:
Determining an output port of a message;
If the output port is an aggregation group, the message is sent to a queue corresponding to the aggregation group to carry out service quality scheduling at the aggregation group level;
the messages which are not discarded after the service quality scheduling of the aggregation group level are sent to the queues corresponding to the member ports of the aggregation group, and the service quality scheduling of the member ports level is carried out;
the QoS scheduling resources of the aggregation group and the QoS scheduling resources of the member ports are independent of each other, and the queues of the aggregation group and the queues of the member ports are independent of each other.
2. The method of claim 1, wherein the sending the message to the queue corresponding to the aggregation group for performing quality of service scheduling at an aggregation group level includes:
and after the message is added with the aggregation group identifier, sending the message to a queue corresponding to the aggregation group to carry out service quality scheduling at the aggregation group level.
3. The method of claim 2, wherein the sending the packets not discarded after the quality of service scheduling at the aggregation group level to the queue corresponding to the member port of the aggregation group comprises:
determining a member port of the aggregation group according to the aggregation group identifier and the corresponding aggregation group load;
and removing the aggregation group identifier from the messages which are not discarded after the service quality scheduling of the aggregation group level, and sending the messages to a queue corresponding to the member port of the aggregation group.
4. The method of claim 3, wherein the step of sending the packet that is not discarded after the qos scheduling at the aggregation group level to the queue corresponding to the member port of the aggregation group after removing the aggregation group identifier includes:
And if the member port of the aggregation group is a member port of other message receiving and transmitting devices, transmitting the messages which are not discarded after the service quality scheduling of the aggregation group level to the other message receiving and transmitting devices.
5. The method of claim 4, wherein sending the messages that are not discarded after the aggregate group level qos scheduling to other messaging devices further comprises:
And adding a system forwarding head to the non-discarded message.
6. The method of claim 5, wherein the system forwarding head comprises a source chip number, a source port number, a destination chip number, and a destination port number.
7. The method according to any of claims 1 to 6, wherein the aggregation group identification is a virtual local area network tag.
8. The method according to any one of claims 1 to 6, further comprising, prior to determining the egress port of the message:
and allocating the QoS scheduling resources and queues of the aggregation group and the QoS scheduling resources and queues of the member ports.
9. A messaging device, comprising:
the determining module is used for determining the output port of the message;
The first scheduling module is used for sending the message to a queue corresponding to the aggregation group for performing service quality scheduling at the aggregation group level if the output port is the aggregation group;
the second scheduling module is used for sending the messages which are not discarded after the service quality scheduling of the aggregation group level to the queues corresponding to the member ports of the aggregation group, and carrying out the service quality scheduling of the member port level;
the QoS scheduling resources of the aggregation group and the QoS scheduling resources of the member ports are independent of each other, and the queues of the aggregation group and the queues of the member ports are independent of each other.
10. A computer readable storage medium having stored thereon a computer program, which when executed by a processor implements the messaging method of any of claims 1-8.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201911106131.7A CN112804166B (en) | 2019-11-13 | 2019-11-13 | Message receiving and sending method, device and storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201911106131.7A CN112804166B (en) | 2019-11-13 | 2019-11-13 | Message receiving and sending method, device and storage medium |
Publications (2)
Publication Number | Publication Date |
---|---|
CN112804166A CN112804166A (en) | 2021-05-14 |
CN112804166B true CN112804166B (en) | 2024-05-28 |
Family
ID=75803157
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201911106131.7A Active CN112804166B (en) | 2019-11-13 | 2019-11-13 | Message receiving and sending method, device and storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN112804166B (en) |
Families Citing this family (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114448916B (en) * | 2021-12-24 | 2024-08-20 | 锐捷网络股份有限公司 | TIPC message processing method, device, equipment and storage medium |
Citations (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101035050A (en) * | 2007-03-15 | 2007-09-12 | 中兴通讯股份有限公司 | Processing method of the virtual LAN aggregation |
CN101657029A (en) * | 2009-09-15 | 2010-02-24 | 杭州华三通信技术有限公司 | Method and terminal for sending terminal polymerization media access control protocol data unit frames |
CN103716252A (en) * | 2012-09-29 | 2014-04-09 | 中兴通讯股份有限公司 | Flow-distribution link aggregation and device |
CN107896192A (en) * | 2017-11-20 | 2018-04-10 | 电子科技大学 | The QoS control method of differentiated service priority in a kind of SDN |
CN110365580A (en) * | 2019-07-26 | 2019-10-22 | 新华三大数据技术有限公司 | Service quality scheduling method, device, electronic equipment and computer readable storage medium |
Family Cites Families (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US8155158B2 (en) * | 2008-11-12 | 2012-04-10 | Patricio Humberto Saavedra | System, apparatus and method for providing aggregated network connections |
-
2019
- 2019-11-13 CN CN201911106131.7A patent/CN112804166B/en active Active
Patent Citations (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN101035050A (en) * | 2007-03-15 | 2007-09-12 | 中兴通讯股份有限公司 | Processing method of the virtual LAN aggregation |
CN101657029A (en) * | 2009-09-15 | 2010-02-24 | 杭州华三通信技术有限公司 | Method and terminal for sending terminal polymerization media access control protocol data unit frames |
CN103716252A (en) * | 2012-09-29 | 2014-04-09 | 中兴通讯股份有限公司 | Flow-distribution link aggregation and device |
CN107896192A (en) * | 2017-11-20 | 2018-04-10 | 电子科技大学 | The QoS control method of differentiated service priority in a kind of SDN |
CN110365580A (en) * | 2019-07-26 | 2019-10-22 | 新华三大数据技术有限公司 | Service quality scheduling method, device, electronic equipment and computer readable storage medium |
Non-Patent Citations (1)
Title |
---|
LTE载波聚合的系统侧参数优化研究;张儒申;电信科学;全文 * |
Also Published As
Publication number | Publication date |
---|---|
CN112804166A (en) | 2021-05-14 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN105511954B (en) | Message processing method and device | |
US8155134B2 (en) | System-on-chip communication manager | |
US7227841B2 (en) | Packet input thresholding for resource distribution in a network switch | |
US9094231B2 (en) | Router | |
US9426099B2 (en) | Router, method for controlling router, and program | |
US9185047B2 (en) | Hierarchical profiled scheduling and shaping | |
US8149846B2 (en) | Data processing system and method | |
US7406041B2 (en) | System and method for late-dropping packets in a network switch | |
US20170237672A1 (en) | Network server systems, architectures, components and related methods | |
EP2378721B1 (en) | Bandwidth allocation method and routing apparatus | |
JP2014522202A (en) | Method, apparatus, and system for reconstructing and reordering packets | |
WO2020087523A1 (en) | Network communication method and apparatus, and electronic device | |
EP3296884A1 (en) | Distributed processing in a network | |
CN101471854A (en) | Method and device for forwarding message | |
EP2670085A1 (en) | System for performing Data Cut-Through | |
CN115622952A (en) | Resource scheduling method, device, equipment and computer readable storage medium | |
Lee et al. | MC-SDN: Supporting mixed-criticality real-time communication using software-defined networking | |
CN112804166B (en) | Message receiving and sending method, device and storage medium | |
CN110365580B (en) | Service quality scheduling method and device, electronic equipment and computer readable storage medium | |
CN111970149B (en) | Shared bandwidth implementation method based on hardware firewall QOS | |
US11012378B2 (en) | Methods and apparatus for shared buffer allocation in a transport node | |
CN113010464A (en) | Data processing apparatus and device | |
CN110601996B (en) | Looped network anti-starvation flow control method adopting token bottom-preserving distributed greedy algorithm | |
WO2022147762A1 (en) | Data packet sequencing method and apparatus | |
CN118509399B (en) | Message processing method and device, electronic equipment and storage medium |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |