[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN112804166B - Message receiving and sending method, device and storage medium - Google Patents

Message receiving and sending method, device and storage medium Download PDF

Info

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
Application number
CN201911106131.7A
Other languages
Chinese (zh)
Other versions
CN112804166A (en
Inventor
程硕远
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
ZTE Corp
Original Assignee
ZTE Corp
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by ZTE Corp filed Critical ZTE Corp
Priority to CN201911106131.7A priority Critical patent/CN112804166B/en
Publication of CN112804166A publication Critical patent/CN112804166A/en
Application granted granted Critical
Publication of CN112804166B publication Critical patent/CN112804166B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/50Queue scheduling
    • H04L47/62Queue scheduling characterised by scheduling criteria
    • H04L47/625Queue scheduling characterised by scheduling criteria for service slots or service orders
    • H04L47/6275Queue scheduling characterised by scheduling criteria for service slots or service orders based on priority
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L45/00Routing or path finding of packets in data switching networks
    • H04L45/24Multipath
    • H04L45/245Link aggregation, e.g. trunking
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/50Queue scheduling
    • H04L47/60Queue scheduling implementing hierarchical scheduling
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic control in data switching networks
    • H04L47/70Admission control; Resource allocation
    • H04L47/80Actions related to the user profile or the type of traffic
    • H04L47/805QOS 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

Message receiving and sending method, device and storage medium
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.
CN201911106131.7A 2019-11-13 2019-11-13 Message receiving and sending method, device and storage medium Active CN112804166B (en)

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)

* Cited by examiner, † Cited by third party
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)

* Cited by examiner, † Cited by third party
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)

* Cited by examiner, † Cited by third party
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

Patent Citations (5)

* Cited by examiner, † Cited by third party
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)

* Cited by examiner, † Cited by third party
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