CN102143053B - 传输数据的方法、装置和系统 - Google Patents
传输数据的方法、装置和系统 Download PDFInfo
- Publication number
- CN102143053B CN102143053B CN201010548381.9A CN201010548381A CN102143053B CN 102143053 B CN102143053 B CN 102143053B CN 201010548381 A CN201010548381 A CN 201010548381A CN 102143053 B CN102143053 B CN 102143053B
- Authority
- CN
- China
- Prior art keywords
- data
- priority
- queue length
- pressure
- output port
- 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 20
- 230000005540 biological transmission Effects 0.000 claims description 34
- GOLXNESZZPUPJE-UHFFFAOYSA-N spiromesifen Chemical compound CC1=CC(C)=CC(C)=C1C(C(O1)=O)=C(OC(=O)CC(C)(C)C)C11CCCC1 GOLXNESZZPUPJE-UHFFFAOYSA-N 0.000 claims description 20
- 230000007246 mechanism Effects 0.000 claims description 3
- 230000007774 longterm Effects 0.000 abstract description 7
- 230000006798 recombination Effects 0.000 description 10
- 238000005215 recombination Methods 0.000 description 10
- 238000004891 communication Methods 0.000 description 3
- 238000010586 diagram Methods 0.000 description 3
- 238000013507 mapping Methods 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000008569 process Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L49/00—Packet switching elements
- H04L49/50—Overload detection or protection within a single switching element
- H04L49/505—Corrective measures
- H04L49/506—Backpressure
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/24—Traffic characterised by specific attributes, e.g. priority or QoS
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/26—Flow control; Congestion control using explicit feedback to the source, e.g. choke packets
- H04L47/266—Stopping or restarting the source, e.g. X-on or X-off
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/29—Flow control; Congestion control using a combination of thresholds
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/30—Flow control; Congestion control in combination with information about buffer occupancy at either end or at transit nodes
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
本发明公开了一种传输数据的方法，包括：获取与输出端口对应队列的当前队列长度；当前队列长度满足反压条件时，根据当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，该反压信息为禁止所述所有线卡向输出端口发送数据优先级小于或等于该反压优先级的数据；发送该反压信息给线卡。本发明根据当前队列长度、和预先设置的队列长度与反压优先级的对应关系，生成反压信息，禁止所有线卡向输出端口发送数据优先级小于或等于该反压优先级的数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，增加了交换网高优先级的高吞吐量。
Description
技术领域
本发明涉及数据传输技术领域，特别涉及一种传输数据的方法、装置和系统。
背景技术
目前，大容量、高吞吐率的分组交换通信系统中，线卡和交换网间的信息传输通常采用队列反压机制，即由交换网检测各输出端口的数据发送情况，当该输出端口出现拥塞时，交换网则产生反压信息，通知所有线卡停止向该输出端口发送数据。如果两个不同业务等级的数据流是分别来自两个不同的线卡，它们将同时被停止发送，业务等级较高的数据流也不能优先的被发送出去。因此，如何保证高业务等级数据流的有效传输已成为分组交换通信的主要解决的技术问题。
发明内容
为了增加高优先级数据的缓存空间，进而提高交换网高优先级的高吞吐量，本发明实施例提供了一种传输数据的方法。所述方法包括：
获取与输出端口对应的队列的当前队列长度；
当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
本发明实施例提供了一种传输数据的装置，所述装置包括：
当前队列长度获取模块，用于获取与输出端口对应的队列的当前队列长度；
反压信息生成模块，用于当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
反压信息发送模块，用于发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
本发明实施例提供了一种传输数据的系统，所述系统包括：线卡和传输数据的装置：
所述线卡用于，向传输数据的装置发送数据，并根据所述传输数据的装置发送的反压信息传输数据；
所述传输数据的装置用于，获取与输出端口对应的队列的当前队列长度；当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
本发明实施例提供的技术方案带来的有益效果是：根据所述当前队列长度和预先设置的队列长度与优先级的对应关系生成反压信息，并将所述反压信息发送至当前交换网中的所有线卡，使所述所有线卡根据所述反压信息传输数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，进而提高了交换网的抗突发能力，增加了交换网高优先级的高吞吐量。
附图说明
图1是本发明实施例1中提供的传输数据的方法流程图；
图2是本发明实施例2中提供的另一传输数据的方法流程图；
图3是本发明实施例2中提供的传输数据网络示意图；
图4是本发明实施例3中提供的传输数据装置的结构示意图；
图5是本发明实施例3中提供的另一传输数据装置的结构示意图；
图6是本发明实施例4中提供的传输数据装置的系统示意图。
具体实施方式
为使本发明的目的、技术方案和优点更加清楚，下面将结合附图对本发明实施方式作进一步地详细描述。
实施例1
如图1所示，本发明实施例提供了一种传输数据的方法，该方法包括：
S101：获取与输出端口对应的队列的当前队列长度；
S102：当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
S103：发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
本发明实施例，根据当所述当前队列长度满足反压条件时(例如发生拥塞时)，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述所有线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据，使所述线卡接收所述反压信息后停止向所述输出端口发送小于或等于所述反压优先级的数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，进而提高了交换网的抗突发能力，增加了交换网高优先级的高吞吐量。进一步的，由于交换网各输出端口采用单一队列存储该端口接收到的数据，由于队列采用先进先出原则输出其存储的数据，使数据滞留在交换网是时间缩短，从而减少了与交换网连接的下行重组模块的排序/重组的资源，提高了重组模块的排序/重组能力降低。
实施例2，
如图2所示，本发明实施例提供了一种传输数据的方法，该方法包括：
S201：线卡发送数据，所述数据中包含所述数据将要到达的输出端口至交换网；
优选的，所述线卡使用具有不同优先级的队列存储具有相应数据优先级的数据，所述线卡采用优先级调度机制选择发送所述具有不同优先级的队列中的数据。
例如，如图3所示，线卡使用p*n个队列，对应线卡同一个出口的p个队列之间使用SP(strict priority，严格优先级)调度。其中，p为队列优先级的个数，即线卡设置为数据设置一个优先级就存在一个队列用于存储该优先级的数据；n为每个线卡的出口数
线卡1和线卡m都有流量发往交换网的端口1输出。其中，线卡1的是低优先级流量，优先等级为p，对应队列为Q1p；线卡m的是高优先级流量，优先等级为1，对应队列为Q11。
S202：交换网接收线卡发送的数据以及所述数据将要到达的输出端口；
具体的，交换网根据所述数据指定的输出端口，将所述数据存储至所述输出端口对应的队列。
例如，如图3所示，交换网的每个输出端口只配置1个队列，交换网在接收到线卡发送的数据后，获取该数据指定的输出端口，并将该数据存储至该端口对应的输出队列。线卡1发送了数据Data1，并指定该数据由交换网的输出端口1输出，则交换网将该数据1存储至输出端口1对应的队列Q1；同理，线卡m发送了数据Data M，并指定该数据由交换网的输出端口1输出，则交换网将该数据1存储至输出端口1对应的队列Q1。
S203：交换网获取与输出端口对应的队列的当前队列长度；
S204：当所述当前队列长度满足反压条件时，交换网根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息。
其中，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
可选的，预先设置的所述队列长度与反压优先级的对应关系为，队列长度值与反压优先级的对应关系。则S204具体可以为：交换网根据所述当前队列长度，查询队列长度值与反压优先级的对应关系，当存在与当前队列长度相同的队列长度值时，则判定当前队列长度满足反压条件，此时，交换网获取与当前队列长度值对应的反压优先级，并生成反压信息，禁止所有与交换网连接的线卡向所述输出端口发送优先级小于或等于所述对应反压优先级的数据的反压信息。
例如，当交换网获取到的输出端口1对应的队列Q1当前的队列长度为L1时，预先设置的队列长度与反压优先级的对应关系如表一所示，则交换网通过查询如表一所示的预先设置的队列长度与反压优先级的对应关系，获取表一所示的对应关系中存在与当前队列长度相同的队列长度，即存在L1；交换网根据L1获取到与L1对应的反压优先级为1，并生成反压信息，该反压信息为禁止所有线卡向输出端口1发送数据优先级小于或等于n的数据。
表一：
| 队列长度 | 反压优先级 |
| L1 | n |
| L2 | n-1 |
| …… | …… |
| Ln | 1 |
进一步可选的，预先设置的所述队列长度与反压优先级的对应关系还可以为队列长度区间与反压优先级的对应关系。则S204具体还可以为：交换网查询队列长度区间与反压优先级的对应关系，当存在包括当前队列长度的队列长度区间时，则判定当前队列长度满足反压条件，此时，获取所述当前队列长度所在的队列长度区间，进而获取与所述当前队列长度所在的队列长度区间对应的反压优先级，并生成反压信息，禁止所有与交换网连接的线卡向所述输出端口发送优先级小于或等于所述对应反压优先级的数据的反压信息。
例如，如图3所示，与交换网端口1对应的队列Q1存在T1～TP个队列长度区间，该队列当前的队列长度落在队列区间T3，则获取到队列长度区间T3对应的优先级为3。
其中，预先设置的队列长度值与反压优先级的对应关系中，所述反压优先级的个数小于等于所述数据的优先级的个数。该优先级，为与该交换网连接的线卡发送的数据优先级中的一个或多个，每个优先级都有一个队列长度与其一一对应，即当存在一个队列长度时，则有一个数据优先级与其对应；当存在多个队列长度时则存在多个数据优先级与各个队列长度一一对应。优选的，如图3所示，如果线卡为数据设置了p个优先级，则在交换网输出端口1的队列Q1则存在T1～TP个队列长度与各个优先级对应，即与交换网输出端口队列的队列长队对应的优先级，以及线卡发送的数据的优先级是一一对应的。进一步的，可由各个队列长度与优先级的映射关系组成该队列的队列长度区间与优先级的映射关系集。
进一步的，交换网发送该反压信息至所有线卡，所有与该交换网连接的线卡接收交换网发送的反压信息并根据所述反压信息向交换网传输数据。
具体的，交换网向与其连接的所有线卡发送禁止所有线卡向所述输出端口发送优先级小于或等于所述对应优先级的数据的反压信息。
例如，如图3所示，当生成的反压信息为禁止所有线卡向端口1发送优先级小于或等于3的数据时，交换网向线卡1～线卡m发送该反压信息，禁止线卡1～线卡m发送优先级小于或等于3的数据；线卡1～线卡m接收该反压信息后停止向端口1发送优先级小于或等于3的数据。
同时，交换网各个输出端口顺序输出存储于与其对应的队列中的数据。可选的，交换网各个输出端口按先进先出原则，从与其对应的队列中获取数据，并将数据发送出去。
另外，本发明实施例S201-S202在本实施例中的具体顺序并不限定于S203之前，即本发明实施例S203获取的输出端口对应队列的当前队列长度，即可以是将当前交换网接收到的数据存入该对应队列前的该对应队列的队列长度，也可以是存入该对应队列之后的该对应队列的队列长度。
所以可选地，上述步骤S201和S202可以不在步骤S203前进行，即本实施例的方法可以直接步骤S203开始，这时步骤S203中当前队列长度就是未将接收到的数据加入输出端口队列的队列长度。如果当前队列长度满足反压条件时执行步骤S204；如果前队列长度不满足反压条件，执行步骤S202，重复流程；
本发明实施例，根据当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述所有线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据，使所述线卡接收所述反压信息后停止向所述输出端口发送小于或等于所述反压优先级的数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，进而提高了交换网的抗突发能力，增加了交换网高优先级的高吞吐量。进一步的，由于交换网各输出端口采用单一队列存储该端口接收到的数据，由于队列采用先进先出原则输出其存储的数据，使数据滞留在交换网是时间缩短，从而减少了与交换网连接的下行重组模块的排序/重组的资源，提高了重组模块的排序/重组能力降低。
实施例3，
如图4所示，本发明实施例提供了一种传输数据的装置，该装置包括：
当前队列长度获取模块301，用于获取与输出端口对应的队列的当前队列长度；
反压信息生成模块302，用于当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
反压信息发送模块303，用于发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
本发明实施例，根据当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述所有线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据，使所述线卡接收所述反压信息后停止向所述输出端口发送小于或等于所述反压优先级的数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，进而提高了交换网的抗突发能力，增加了交换网高优先级的高吞吐量。进一步的，由于交换网各输出端口采用单一队列存储该端口接收到的数据，由于队列采用先进先出原则输出其存储的数据，使数据滞留在交换网是时间缩短，从而减少了与交换网连接的下行重组模块的排序/重组的资源，提高了重组模块的排序/重组能力降低。
实施例4，
如图5所示，本发明实施例还提供了一种传输数据的装置，该装置包括：
当前队列长度获取模块301，用于获取与输出端口对应的队列的当前队列长度；
反压信息生成模块302，用于当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
反压信息发送模块303，用于发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
优选的，所述预先设置的队列长度与反压优先级的对应关系中，所述反压优先级的个数小于等于所述数据优先级的个数。
进一步优选的，所述线卡使用具有不同优先级的队列存储具有相应数据优先级的数据，所述线卡采用优先级调度机制选择发送所述具有不同优先级的队列中的数据。
可选的，预先设置的所述队列长度与反压优先级的对应关系为，队列长度值与反压优先级的对应关系，或者队列长度区间与反压优先级的对应关系。
当预先设置的所述队列长度与反压优先级的对应关系为队列长度值与反压优先级的对应关系时，反压信息生成模块302具体还包括：
队列长度值对应的反压优先级获取单元3021，用于查询所述对应关系，获取与所述当前队列长度值对应的反压优先级；
当预先设置的所述队列长度值与反压优先级的对应关系为队列长度区间与反压优先级的对应关系时，反压信息生成模块302具体还包括：
队列长度区间对应的反压优先级获取单元3022，用于查询所述对应关系，获取与所述当前队列长度所在的队列长度区间对应的反压优先级。
可选的，所述装置还包括：
数据接收模块304，用于接收线卡发送的数据，所述数据中包含所述数据将要到达的输出端口；
数据存储模块305，用于将所述数据存储至所述输出端口对应的队列。
本发明实施例，根据当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述所有线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据，使所述线卡接收所述反压信息后停止向所述输出端口发送小于或等于所述反压优先级的数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，进而提高了交换网的抗突发能力，增加了交换网高优先级的高吞吐量。进一步的，由于交换网各输出端口采用单一队列存储该端口接收到的数据，由于队列采用先进先出原则输出其存储的数据，使数据滞留在交换网是时间缩短，从而减少了与交换网连接的下行重组模块的排序/重组的资源，提高了重组模块的排序/重组能力降低。
实施例5，
如图6所示，本发明实施例提供了一种传输数据的系统，该系统包括：线卡401和传输数据的装置402：
所述线卡401用于，向传输数据的装置发送数据，并根据所述传输数据的装置发送的反压信息传输数据；
传输数据的装置402用于，获取与输出端口对应的队列的当前队列长度；当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据。
本发明实施例，根据当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述所有线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据，使所述线卡接收所述反压信息后停止向所述输出端口发送小于或等于所述反压优先级的数据，减少了大量低优先级的数据长期的占用交换网的缓存，从而使留给较高优先级的缓存相应增多，进而提高了交换网的抗突发能力，增加了交换网高优先级的高吞吐量。进一步的，由于交换网各输出端口采用单一队列存储该端口接收到的数据，由于队列采用先进先出原则输出其存储的数据，使数据滞留在交换网是时间缩短，从而减少了与交换网连接的下行重组模块的排序/重组的资源，提高了重组模块的排序/重组能力降低。
以上实施例提供的技术方案中的全部或部分内容可以通过软件编程实现，其软件程序存储在可读取的存储介质中，存储介质例如：计算机中的硬盘、光盘或软盘。
以上所述仅为本发明的较佳实施例，并不用以限制本发明，凡在本发明的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。
Claims (9)
1.一种传输数据的方法，其特征在于，所述方法包括：
获取与输出端口对应的队列的当前队列长度，其中，每个所述输出端口只配置一个所述队列；
当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
所述输出端口按先进先出原则，从与所述输出端口对应的所述队列中获取所述数据，并将所述数据发送出去；
其中，预先设置的所述队列长度与反压优先级的对应关系为，队列长度值与反压优先级的对应关系，或者队列长度区间与反压优先级的对应关系。
2.根据权利要求1所述的方法，其特征在于，如果预先设置的所述队列长度与反压优先级的对应关系为队列长度值与反压优先级的对应关系，则所述确定当前队列长度对应的反压优先级具体包括：查询所述对应关系，获取与所述当前队列长度值对应的反压优先级；
如果预先设置的所述队列长度值与反压优先级的对应关系为队列长度区间与反压优先级的对应关系，则所述确定当前队列长度对应的反压优先级具体包括：查询所述对应关系，获取与所述当前队列长度所在的队列长度区间对应的反压优先级。
3.根据权利要求1所述的方法，其特征在于，所述预先设置的队列长度与反压优先级的对应关系中，所述反压优先级的个数小于等于所述数据优先级的个数。
4.根据权利要求1所述的方法，其特征在于，在所述获取与输出端口对应队列的当前队列长度之前包括接收线卡发送的数据，所述数据中包含所述数据将要到达的输出端口；
将所述数据存储至所述输出端口对应的队列。
5.一种传输数据的装置，其特征在于，所述装置包括：
当前队列长度获取模块，用于获取与输出端口对应的队列的当前队列长度，其中，每个所述输出端口只配置一个所述队列；
反压信息生成模块，用于当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
反压信息发送模块，用于发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；
所述装置，还包括：
用于实现所述输出端口按先进先出原则，从与所述输出端口对应的所述队列中获取所述数据，并将所述数据发送出去的模块；
其中，预先设置的所述队列长度与反压优先级的对应关系为，队列长度值与反压优先级的对应关系，或者队列长度区间与反压优先级的对应关系。
6.根据权利要求5所述的装置，其特征在于，如果预先设置的所述队列长度与反压优先级的对应关系为队列长度值与反压优先级的对应关系，则反压信息生成模块具体还包括：队列长度值对应的反压优先级获取单元，用于查询所述对应关系，获取与所述当前队列长度值对应的反压优先级；
如果预先设置的所述队列长度值与反压优先级的对应关系为队列长度区间与反压优先级的对应关系，则所述反压信息生成模块具体还包括：
队列长度区间对应的反压优先级获取单元，用于查询所述对应关系，获取与所述当前队列长度所在的队列长度区间对应的反压优先级。
7.根据权利要求5所述的装置，其特征在于，所述线卡使用具有不同优先级的队列存储具有相应数据优先级的数据，所述线卡采用优先级调度机制选择发送所述具有不同优先级的队列中的数据。
8.根据权利要求5所述的装置，其特征在于，所述装置还包括：
数据接收模块，用于接收线卡发送的数据，所述数据中包含所述数据将要到达的输出端口；
数据存储模块，用于将所述数据存储至所述输出端口对应的队列。
9.一种传输数据的系统，其特征在于，所述系统包括：线卡和传输数据的装置：
所述线卡用于，向传输数据的装置发送数据，并根据所述传输数据的装置发送的反压信息传输数据；
所述传输数据的装置用于，获取与输出端口对应队列的当前队列长度，其中，每个所述输出端口只配置一个所述队列；当所述当前队列长度满足反压条件时，根据所述当前队列长度、和预先设置的队列长度与反压优先级的对应关系，确定当前队列长度对应的反压优先级，并生成反压信息，所述反压信息为禁止所述线卡向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；发送所述反压信息给线卡，使所述线卡接收所述反压信息后停止向所述输出端口发送数据优先级小于或等于所述反压优先级的数据；所述输出端口按先进先出原则，从与所述输出端口对应的所述队列中获取所述数据，并将所述数据发送出去；其中，预先设置的所述队列长度与反压优先级的对应关系为，队列长度值与反压优先级的对应关系，或者队列长度区间与反压优先级的对应关系。
Priority Applications (4)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201010548381.9A CN102143053B (zh) | 2010-11-12 | 2010-11-12 | 传输数据的方法、装置和系统 |
| EP11783074.5A EP2477366B1 (en) | 2010-11-12 | 2011-06-02 | Data transmission method, apparatus and system |
| PCT/CN2011/075188 WO2011144157A1 (zh) | 2010-11-12 | 2011-06-02 | 传输数据的方法、装置和系统 |
| US13/469,956 US8549193B2 (en) | 2010-11-12 | 2012-05-11 | Data transmission method, device and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201010548381.9A CN102143053B (zh) | 2010-11-12 | 2010-11-12 | 传输数据的方法、装置和系统 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN102143053A CN102143053A (zh) | 2011-08-03 |
| CN102143053B true CN102143053B (zh) | 2014-08-20 |
Family
ID=44410290
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201010548381.9A Active CN102143053B (zh) | 2010-11-12 | 2010-11-12 | 传输数据的方法、装置和系统 |
Country Status (4)
| Country | Link |
|---|---|
| US (1) | US8549193B2 (zh) |
| EP (1) | EP2477366B1 (zh) |
| CN (1) | CN102143053B (zh) |
| WO (1) | WO2011144157A1 (zh) |
Families Citing this family (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103024699B (zh) * | 2011-09-22 | 2016-05-25 | 北京神州泰岳软件股份有限公司 | 一种短信发送方法和一种信息资源站实体 |
| US20130286825A1 (en) * | 2012-04-30 | 2013-10-31 | Derek Alan Sherlock | Feed-forward arbitration |
| CN108243116B (zh) * | 2016-12-23 | 2021-09-14 | 华为技术有限公司 | 一种流量控制方法及交换设备 |
| US10355978B2 (en) | 2017-06-19 | 2019-07-16 | Hewlett Packard Enterprise Development Lp | Calculating times to live for transaction requests |
| CN109818879A (zh) * | 2017-11-22 | 2019-05-28 | 华为技术有限公司 | 流量控制方法及装置 |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1633786A (zh) * | 2002-01-03 | 2005-06-29 | 英特尔公司 | 以太网体系结构中基于优先级的流控制方法和装置 |
| CN101035067A (zh) * | 2007-01-25 | 2007-09-12 | 华为技术有限公司 | 一种基于输出队列的流控实现方法及装置 |
| CN101465806A (zh) * | 2008-10-22 | 2009-06-24 | 华为技术有限公司 | 一种调度交换网数据包的方法、装置和系统 |
Family Cites Families (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US5583861A (en) * | 1994-04-28 | 1996-12-10 | Integrated Telecom Technology | ATM switching element and method having independently accessible cell memories |
| JP3492142B2 (ja) * | 1997-03-27 | 2004-02-03 | キヤノン株式会社 | 半導体基材の製造方法 |
| US7023857B1 (en) * | 2000-09-12 | 2006-04-04 | Lucent Technologies Inc. | Method and apparatus of feedback control in a multi-stage switching system |
| US7092404B1 (en) * | 2001-04-27 | 2006-08-15 | Tropic Networks Inc. | Interposer chip for protocol conversion |
| US6594234B1 (en) | 2001-05-31 | 2003-07-15 | Fujitsu Network Communications, Inc. | System and method for scheduling traffic for different classes of service |
| US7239636B2 (en) * | 2001-07-23 | 2007-07-03 | Broadcom Corporation | Multiple virtual channels for use in network devices |
| CN100550852C (zh) * | 2007-01-18 | 2009-10-14 | 华为技术有限公司 | 一种实现海量端口反压的方法及其装置 |
| US8036128B2 (en) * | 2007-09-28 | 2011-10-11 | Alcatel Lucent | Method for communicating backpressure messages in a data communications system |
| CN101340385B (zh) * | 2008-08-22 | 2012-02-29 | 华为技术有限公司 | 一种反压信息的生成方法、系统和装置 |
-
2010
- 2010-11-12 CN CN201010548381.9A patent/CN102143053B/zh active Active
-
2011
- 2011-06-02 WO PCT/CN2011/075188 patent/WO2011144157A1/zh active Application Filing
- 2011-06-02 EP EP11783074.5A patent/EP2477366B1/en active Active
-
2012
- 2012-05-11 US US13/469,956 patent/US8549193B2/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1633786A (zh) * | 2002-01-03 | 2005-06-29 | 英特尔公司 | 以太网体系结构中基于优先级的流控制方法和装置 |
| CN101035067A (zh) * | 2007-01-25 | 2007-09-12 | 华为技术有限公司 | 一种基于输出队列的流控实现方法及装置 |
| CN101465806A (zh) * | 2008-10-22 | 2009-06-24 | 华为技术有限公司 | 一种调度交换网数据包的方法、装置和系统 |
Also Published As
| Publication number | Publication date |
|---|---|
| EP2477366A4 (en) | 2012-07-18 |
| WO2011144157A1 (zh) | 2011-11-24 |
| CN102143053A (zh) | 2011-08-03 |
| EP2477366A1 (en) | 2012-07-18 |
| US20120254483A1 (en) | 2012-10-04 |
| US8549193B2 (en) | 2013-10-01 |
| EP2477366B1 (en) | 2014-08-06 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN103647726B (zh) | 一种报文调度方法及装置 | |
| CN100505676C (zh) | 智能多缓冲区管理的集中调度控制器和动态调度方法 | |
| CN102035732B (zh) | 业务调度方法及装置 | |
| CN102143053B (zh) | 传输数据的方法、装置和系统 | |
| CN103259743B (zh) | 基于令牌桶的输出流量控制的方法及装置 | |
| CN106535246B (zh) | 一种缓冲区状态报告的上报方法、装置及系统 | |
| CN104378308A (zh) | 报文发送速率检测方法及装置 | |
| CN106789726A (zh) | 一种基于业务优先级的高并发服务资源分配方法 | |
| CN101599908B (zh) | 一种带宽的自动分配方法和设备 | |
| CN102387076B (zh) | 一种结合整形的分级式队列调度方法 | |
| CN101753584B (zh) | VxWorks系统下提高智能变电站快速报文处理速度的方法 | |
| CN104780118A (zh) | 一种基于令牌的流控方法及装置 | |
| CN102821042B (zh) | 数据处理方法、装置和系统 | |
| CN101951571A (zh) | 短消息重试方法及短消息网关 | |
| CN113296976A (zh) | 消息处理方法、装置、电子设备、存储介质及程序产品 | |
| CN102347877A (zh) | 总线调度方法及装置 | |
| CN118900431B (zh) | 一种Wi-SUN通信紧急去重动态加权QoS管理方法、介质及终端 | |
| CN104639459A (zh) | 电能计量终端数据发送方法及系统 | |
| CN102281202A (zh) | 一种调度方法、服务器及系统 | |
| CN103227794A (zh) | 数据传输控制方法、装置以及系统 | |
| US20140095902A1 (en) | Power Saving Traffic Management Policies | |
| CN101478495A (zh) | 流量限制方法和装置 | |
| CN101808117B (zh) | 一种通信中时间标签业务数据的构造及服务方法 | |
| CN102882768A (zh) | 一种基于多层次用户分类的资源分配方法、装置及系统 | |
| CN101616365B (zh) | 一种基于并行队列的短消息重试系统及方法 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C14 | Grant of patent or utility model | ||
| GR01 | Patent grant |