CN104811402B - 授权数值处理方法、装置和网络系统 - Google Patents

Abstract

本发明公开了一种授权数值处理方法、装置和网络系统，属于网络技术领域。所述方法包括：当接收端缓存的数据量大于反压阈值时产生反压；根据第一类队列当前的授权请求数值确定第一授权数值；向第一类队列下发第一授权数值，第一授权数值为所述第一类队列当前的授权请求数值与第一请求阈值之间的差值；所述第一请求阈值不小于所述发送端的预设最大授权数值与流控阈值之间的差值。本发明能够提前下发授权数值，缩短了从接收端撤销反压到发送端开始发送数据所耗费的时间，缩短了从发送端产生流控到开始发送数据所耗费的时间，降低了发送端的丢弃率。在接收端产生反压的时间段内所下发的第一授权数值能够保证发送端不会发送数据，避免了流量突发。

Description

授权数值处理方法、装置和网络系统

技术领域

本发明涉及网络技术领域，特别涉及一种授权数值处理方法、装置和网络系统。

背景技术

网络系统包括接收端和发送端，接收端可以向发送端下发授权数值，发送端获得授权数值后，根据接收端所下发的授权数值向接收端发送数据，由接收端缓存该数据，后续再从缓存中释放该数据，对该数据进行处理。

然而，接收端能够缓存的数据量是有限的，当接收端缓存的数据量大于反压阈值时，接收端会产生反压，停止下发授权数值，则发送端将不能获得新的授权数值，只能根据已有的授权数值发送数据，且发送端的剩余授权数值会随着数据的发送而逐渐减少。当发送端的剩余授权数值不大于流控阈值时，会产生流控，停止发送数据，则接收端将不会再接收到发送端发送的数据，而随着缓存数据的逐渐释放，接收端的数据量会逐渐减小，当接收端的数据量不大于该反压阈值时，接收端会撤销反压，重新向发送端下发授权数值，发送端累积接收端下发的授权数值，直至剩余授权数值大于该流控阈值时，发送端撤销流控，继续发送数据。

在实现本发明的过程中，发明人发现现有技术至少存在以下问题：

接收端撤销反压，重新向发送端下发授权数值后，发送端还需要一段时间来累积授权数值，才能保证剩余授权数值大于该流控阈值，才会撤销流控，开始发送数据，从接收端撤销反压到发送端开始发送数据所耗费的时间过长。

进一步地，发送端能够缓存的数据量是有限的，从发送端产生流控到开始发送数据的这段时间内，发送端未向接收端发送数据，发送端的数据被堵住，一旦发送端的数据量超出了能够缓存的最大数据量，所超出的数据量会被丢弃，丢弃率很高。

发明内容

为了解决现有技术的问题，本发明实施例提供了一种授权数值处理方法。所述技术方案如下：

第一方面，提供了一种授权数值处理方法，所述方法包括：

当接收端缓存的数据量大于反压阈值时，所述接收端产生反压；

所述接收端根据第一类队列当前的授权请求数值，确定第一授权数值，所述授权请求数值用于表示发送端当前为所述第一类队列请求的授权数值，由所述第一类队列的预设最大授权数值与当前的剩余授权数值之间的差值确定，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

所述接收端向所述第一类队列下发所述第一授权数值，所述第一授权数值为所述第一类队列当前的授权请求数值与所述第一请求阈值之间的差值；

所述接收端将所述第一类队列的授权请求数值更新为所述第一请求阈值；

其中，所述第一请求阈值不小于所述发送端的预设最大授权数值与流控阈值之间的差值。

结合第一方面，在第一方面的第一种可能实现方式中，所述方法还包括：

当所述接收端缓存的数据量不大于所述反压阈值时，所述接收端撤销反压；

所述接收端向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于所述第一请求阈值的队列；

所述接收端将所述第二类队列的授权请求数值更新为所述第二类队列当前的授权请求数值与所述预设授权数值之间的差值。

结合第一方面或第一方面的第一种可能实现方式，在第一方面的第二种可能实现方式中，所述方法还包括：

所述接收端接收所述发送端发送的报文，所述报文至少携带队列当前的授权请求数值；

如果所述队列当前的授权请求数值大于所述第一请求阈值，将所述队列确定为第一类队列；

如果所述队列当前的授权请求数值不大于所述第一请求阈值，将所述队列确定为第二类队列。

结合第一方面的第二种可能实现方式，在第一方面的第三种可能实现方式中，所述如果所述队列当前的授权请求数值不大于所述第一请求阈值，将所述队列确定为第二类队列，包括：

如果所述队列当前的授权请求数值不大于所述第一请求阈值，且大于第二请求阈值，将所述队列确定为第二类队列，所述第二请求阈值小于所述第一请求阈值。

结合第一方面，在第一方面的第四种可能实现方式中，当接收端的数据量大于反压阈值时，所述接收端产生反压之后，所述方法还包括：

当所述接收端已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列；

所述接收端根据所述调度出的第一类队列当前的授权请求数值，确定所述第一授权数值；

所述接收端向所述调度出的第一类队列下发所述第一授权数值；

所述接收端将所述调度出的第一类队列的授权请求数值更新为所述第一请求阈值。

结合第一方面的第一种可能实现方式，在第一方面的第五种可能实现方式中，当所述接收端的数据量不大于所述反压阈值时，所述接收端撤销反压之后，所述方法还包括：

当所述接收端已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列；

所述接收端向所述调度出的第二类队列下发所述预设授权数值；

所述接收端将所述调度出的第二类队列的授权请求数值更新为所述调度出的第二类队列当前的授权请求数值与所述预设授权数值之间的差值。

第二方面，提供了一种授权数值处理装置，所述装置包括：

控制模块，用于当缓存的数据量大于反压阈值时，产生反压；

授权数值确定模块，用于根据第一类队列当前的授权请求数值，确定第一授权数值，所述授权请求数值用于表示发送端当前为所述第一类队列请求的授权数值，由所述第一类队列的预设最大授权数值与当前的剩余授权数值之间的差值确定，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

下发模块，用于向所述第一类队列下发所述第一授权数值，所述第一授权数值为所述第一类队列当前的授权请求数值与所述第一请求阈值之间的差值；

数值更新模块，用于将所述第一类队列的授权请求数值更新为所述第一请求阈值；

其中，所述第一请求阈值不小于所述发送端的预设最大授权数值与流控阈值之间的差值。

结合第二方面，在第二方面的第一种可能实现方式中，

所述控制模块，还用于当所述数据量不大于所述反压阈值时，撤销反压；

所述下发模块，还用于向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于所述第一请求阈值的队列；

所述数值更新模块，还用于将所述第二类队列的授权请求数值更新为所述第二类队列当前的授权请求数值与所述预设授权数值之间的差值。

结合第二方面或第二方面的第一种可能实现方式，在第二方面的第二种可能实现方式中，所述装置还包括：

接收模块，用于接收所述发送端发送的报文，所述报文至少携带队列当前的授权请求数值；

分类模块，用于如果所述队列当前的授权请求数值大于所述第一请求阈值，将所述队列确定为第一类队列，如果所述队列当前的授权请求数值不大于所述第一请求阈值，将所述队列确定为第二类队列。

结合第二方面的第二种可能实现方式，在第二方面的第三种可能实现方式中，所述分类模块还用于如果所述队列当前的授权请求数值不大于所述第一请求阈值，且大于第二请求阈值，将所述队列确定为第二类队列，所述第二请求阈值小于所述第一请求阈值。

结合第二方面，在第二方面的第四种可能实现方式中，所述装置还包括：

第一调度模块，用于当已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列。

结合第二方面的第一种可能实现方式，在第二方面的第五种可能实现方式中，所述装置还包括：

第二调度模块，用于当已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列。

第三方面，提供了一种网络系统，所述网络系统包括：接收端和发送端；

所述接收端用于当缓存的数据量大于反压阈值时产生反压；

所述发送端用于根据预设最大授权数值和每个队列当前的剩余授权数值，确定每个队列当前的授权请求数值，所述授权请求数值用于表示发送端当前为队列请求的授权数值；

所述接收端还用于根据第一类队列当前的授权请求数值，确定第一授权数值，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

所述接收端还用于向所述第一类队列下发所述第一授权数值，所述第一授权数值为所述第一类队列当前的授权请求数值与所述第一请求阈值之间的差值；

所述接收端还用于将所述第一类队列的授权请求数值更新为所述第一请求阈值；

所述发送端用于当任一队列的剩余授权数值小于流控阈值时产生流控；

所述发送端还用于接收所述接收端为所述第一类队列下发的所述第一授权数值，根据所述第一授权数值和所述预设最大授权数值，对所述第一类队列的授权请求数值进行更新。

其中，所述第一请求阈值不小于所述预设最大授权数值与所述流控阈值之间的差值。

本发明实施例提供的技术方案带来的有益效果是：

本发明实施例提供的方法、装置和网络系统，通过在接收端产生反压时未停止下发授权数值，而是向当前请求的授权数值较大的第一类队列下发第一授权数值，且第一授权数值为该队列当前的授权请求数值与第一请求阈值之间的差值，能够在接收端撤销反压之前提前下发授权数值，使得接收端撤销反压后发送端能够快速地累积授权数值，快速地撤销流控，使得发送端能够快速地开始发送数据，缩短了从接收端撤销反压到发送端开始发送数据所耗费的时间。进一步地，缩短了从发送端产生流控到开始发送数据所耗费的时间，降低了数据量超出最大数据量的概率，降低了丢弃率。且在接收端产生反压的时间段内，接收端所下发的第一授权数值能够保证该队列剩余的授权数值小于发送端的流控阈值，保证发送端不会撤销流控，不会向接收端发送数据，避免了流量突发。

附图说明

为了更清楚地说明本发明实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1是本发明实施例提供的一种授权数值处理方法的流程图；

图2是本发明实施例提供的一种授权数值处理方法的流程图；

图3A是本发明实施例提供的一种发送端的处理流程示意图；

图3B是本发明实施例提供的一种接收端调度流程示意图；

图4是本发明实施例提供的一种授权数值处理装置的结构示意图；

图5是本发明实施例提供的一种网络系统的结构示意图。

具体实施方式

下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。

图1是本发明实施例提供的一种授权数值处理方法的流程图。该发明实施例的执行主体为网络系统的接收端，参见图1，该方法包括：

101、当接收端缓存的数据量大于反压阈值时，该接收端产生反压。

102、该接收端根据第一类队列当前的授权请求数值，确定第一授权数值，该授权请求数值用于表示发送端当前为该第一类队列请求的授权数值，由该第一类队列的预设最大授权数值与当前的剩余授权数值之间的差值确定，第一类队列是指当前的授权请求数值大于第一请求阈值的队列。

103、该接收端向该第一类队列下发该第一授权数值，该第一授权数值为该第一类队列当前的授权请求数值与该第一请求阈值之间的差值。

104、该接收端将该第一类队列的授权请求数值更新为该第一请求阈值。

其中，该第一请求阈值不小于该发送端的预设最大授权数值与流控阈值之间的差值。假设预设最大授权数值为max，发送端的流控阈值为VOQ_TH，则VOQ_TH可以属于[-max，max]范围内的任一数值，本发明实施例对此不做限定。

另外，假设队列当前的授权请求数值为req，第一请求阈值为BP_TH，且该第一请求阈值BP_TH不小于该预设最大授权数值max与流控阈值VOQ_TH之间的差值。

则该队列的剩余授权数值为max-req，如果授权请求数值req大于第一请求阈值BP_TH，则该队列为第一类队列，该接收端在产生反压时向该队列下发第一授权数值，该第一授权数值为该队列的授权请求数值req与该第一请求阈值BP_TH之间的差值，即req-BP_TH，则下发后该队列的剩余授权数值会变为(max-req)+(req-BP_TH)＝max-BP_TH，由于第一请求阈值BP_TH不小于预设最大授权数值max与流控阈值VOQ_TH之间的差值，则max-BP_TH不大于该流控阈值VOQ_TH，保证了发送端不会撤销流控，不会向接收端发送数据。

本发明实施例提供的方法，通过在接收端产生反压时未停止下发授权数值，而是向当前请求的授权数值较大的第一类队列下发第一授权数值，且第一授权数值为该队列当前的授权请求数值与第一请求阈值之间的差值，能够在接收端撤销反压之前提前下发授权数值，使得接收端撤销反压后发送端能够快速地累积授权数值，快速地撤销流控，使得发送端能够快速地发送数据，缩短了从接收端撤销反压到发送端开始发送数据所耗费的时间。进一步地，缩短了从发送端产生流控到开始发送数据所耗费的时间，降低了数据量超出最大数据量的概率，降低了丢弃率。且在接收端产生反压的时间段内，接收端所下发的第一授权数值能够保证该队列剩余的授权数值小于发送端的流控阈值，保证发送端不会撤销流控，不会向接收端发送数据，避免了流量突发。

可选地，该方法还包括：

当该接收端缓存的数据量不大于该反压阈值时，该接收端撤销反压；

该接收端向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于该第一请求阈值的队列；

该接收端将该第二类队列的授权请求数值更新为该第二类队列当前的授权请求数值与该预设授权数值之间的差值。

可选地，该方法还包括：

该接收端接收该发送端发送的报文，该报文至少携带队列当前的授权请求数值；

如果该队列当前的授权请求数值大于该第一请求阈值，将该队列确定为第一类队列；

如果该队列当前的授权请求数值不大于该第一请求阈值，将该队列确定为第二类队列。

可选地，该如果该队列当前的授权请求数值不大于该第一请求阈值，将该队列确定为第二类队列，包括：

如果该队列当前的授权请求数值不大于该第一请求阈值，且大于第二请求阈值，将该队列确定为第二类队列，该第二请求阈值小于该第一请求阈值。

可选地，当接收端的数据量大于反压阈值时，该接收端产生反压之后，该方法还包括：

当该接收端已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列；

该接收端根据该调度出的第一类队列当前的授权请求数值，确定该第一授权数值；

该接收端向该调度出的第一类队列下发该第一授权数值；

该接收端将该调度出的第一类队列的授权请求数值更新为该第一请求阈值。

可选地，当该接收端的数据量不大于该反压阈值时，该接收端撤销反压之后，该方法还包括：

当该接收端已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列；

该接收端向该调度出的第二类队列下发该预设授权数值；

该接收端将该调度出的第二类队列的授权请求数值更新为该调度出的第二类队列当前的授权请求数值与该预设授权数值之间的差值。

上述所有可选技术方案，可以采用任意结合形成本发明的可选实施例，在此不再一一赘述。

图2是本发明实施例提供的一种授权数值处理方法的流程图。该发明实施例的交互主体为网络系统中的接收端和发送端，参见图2，该方法包括：

201、当接收端缓存的数据量大于反压阈值时，该接收端产生反压。

在本发明实施例中，接收端采用授权机制，与发送端进行通信，即接收端向发送端的队列下发授权数值，发送端的队列只有得到接收端的授权数值才能基于该授权数值向接收端发送报文。当该发送端向该接收端发送该队列中的报文时，会消耗与该报文的数据量相等的授权数值，随着报文的发送，该队列剩余的授权数值会变小。当队列的授权数值不大于流控阈值时，产生流控，不允许向接收端发送该队列的报文。

参见图3A，该接收端为发送端的队列下发授权数值，对于该发送端的任一队列来说，当该队列的剩余授权数值大于流控阈值VOQ_TH时，该发送端可以向该接收端发送该队列的报文，而当该队列的剩余授权数值不大于VOQ_TH时，该发送端产生流控，不再向该接收端发送该队列的报文。

接收端接收到发送端发送的报文时，可以对报文中携带的数据进行缓存，以便于后续对该数据进行处理。但接收端能够缓存的数据量是有限的，当接收端缓存的数据量大于反压阈值时会产生反压。其中，该反压阈值可以由开发人员预先设定，本发明实施例对此不做限定。

202、该接收端根据该发送端当前为每个队列请求的授权请求数值，确定第一类队列，第一类队列是指当前的授权请求数值大于第一请求阈值的队列。

与现有技术不同的是，在本发明实施例中，接收端产生反压后并未停止向发送端下发授权数值，而是选择性地向发送端的第一类队列下发授权数值。

在该步骤202之前，该方法还包括：发送端根据预设最大授权数值和每个队列当前的剩余授权数值，确定每个队列当前的授权请求数值，将每个队列的授权请求数值发送给该接收端。

具体地，发送端包括多个队列，对于每个队列来说，发送端将该预设最大授权数值与该队列当前的剩余授权数值之间的差值作为该队列当前的授权请求数值，该授权请求数值可以表示该队列当前需要的授权数值是多少，该队列的授权请求数值越大，表示该队列的剩余授权数值越小。

其中，该预设最大授权数值可以由该发送端与该接收端协商确定，本发明实施例对此不做限定。可选地，该预设最大授权数值可以根据该发送端的输出带宽和该接收端与该发送端之间的往返时间确定。该往返时间是指从该接收端向该发送端下发授权数值，该发送端接收到该授权数值后向该接收端发送报文，直至该接收端接收到该报文所用的时间。

例如，该发送端可以根据该发送端的输出带宽和该接收端与该发送端之间的往返时间，采用以下公式，确定该预设最大授权数值：

max＝OutputBandwidth×RTT；

其中，max表示该预设最大授权数值，OutputBandwidth表示该发送端的输出带宽，单位为bps(比特/秒)，RTT表示该接收端与该发送端之间的往返时间。

该发送端可以向该接收端发送报文，该报文可以携带该队列当前的授权请求数值，以便该接收端获取该队列当前的授权请求数值。另外，该报文还可以携带该队列的队列标识，该队列标识用于确定唯一的队列，该接收端接收到该报文时，可以根据该队列标识确定该队列是哪一个队列。其中，该队列标识可以为队列编号、队列名称等，本发明实施例对此不做限定。

该接收端接收到该发送端发送的数据时，将数据写入缓存中，并根据队列的队列标识进入相应的队列。对于每个队列来说，当该接收端获取到该队列当前的授权请求数值时，判断该队列当前的授权请求数值是否大于第一请求阈值，如果该队列当前的授权请求数值大于该第一请求阈值，则该接收端将该队列确定为第一类队列，表示该队列当前所需的授权数值较大。如果该队列当前的授权请求数值不大于该第一请求阈值，则该接收端将该队列确定为第二类队列，表示该队列当前所需的授权数值较小。

进一步地，该接收端还可以确定第二请求阈值，该第二请求阈值小于该第一请求阈值，如果该队列当前的授权请求数值大于该第二请求阈值，且不大于该第一请求阈值，则将该队列确定为第二类队列。

其中，该第一请求阈值和该第二请求阈值可以由该接收端预先确定，该第一请求阈值可以为8字节(Byte)、16字节或者其他数值，该第二请求阈值可以为0、1字节或者其他数值，本发明实施例对此不做限定。可选地，以max表示该预设最大授权数值，则该第一请求阈值可以属于[1，2*max]范围内的任一数值，优选的，该第一请求数值为max+1。

该接收端通过对队列的授权请求数值进行判断，可以确定所需的授权数值较大的第一类队列和所需的授权数值较小的第二类队列，将所有的队列分成了两类。

需要说明的是，本发明实施例中，该接收端在产生反压时对每个队列的授权请求数值进行判断，以确定第一类队列。而在实际应用过程中，每当该接收端接收到该发送端发送的报文时，即可根据该报文携带的授权请求数值进行判断，以确定该报文对应的队列是第一类队列还是第二类队列。且，每当该接收端为该发送端的任一队列下发授权数值后，该队列的剩余授权数值会发生变化，则该队列当前的授权请求数值也会发生变化，此时该接收端可以根据该队列变化后的授权请求数值，重新确定该队列是第一类队列还是第二类队列。或者，当该接收端撤销反压时对每个队列的授权请求数值进行判断，确定当前的第一类队列和第二类队列。本发明实施例对该接收端进行判断以确定第一类队列和第二类队列的时机不做限定。

203、该接收端根据该第一类队列当前的授权请求数值，确定第一授权数值，该第一授权数值为该第一类队列当前的授权请求数值与该第一请求阈值之间的差值。

204、该接收端向该第一类队列下发该第一授权数值。

本发明实施例中，为了缩短后续接收端撤销反压后队列累积授权数值的时间，当该接收端产生反压时，可以向授权请求数值较大的第一类队列下发授权数值。

具体地，当该接收端已确定多个第一类队列时，根据预设调度算法，从该多个第一类队列中调度出一个第一类队列，根据该调度出的第一类队列当前的授权请求数值，确定第一授权数值，向该调度出的第一类队列下发该第一授权数值。

其中，该预设调度算法可以为WRR(Weighted Round Robin，加权轮询调度)、RR(Round Robin，轮询调度)、WFQ(Weighted Fair Queue，加权公平队列)、DWFQ(DistributedWeighted Fair Queue，分布式加权公平队列)等算法，本发明实施例对此不做限定。

该接收端可以将每个队列作为调度器的调度节点，如果该队列为第一类队列，则将该第一类队列作为第一调度器的调度节点，如果该队列为第二类队列，则将该第二类队列作为第二调度器的调度节点。后续该第一调度器和该第二调度器会根据各自对应的调度节点进行调度，即该第一调度器会调度出一个第一类队列，该第二调度器会调度出一个第二类队列。当该接收端产生反压时选择该第一调度器调度的队列，当该接收端未产生反压或者撤销反压时选择该第二调度器调度的队列。

参见图3B，N表示该发送端的队列数目，req表示每个队列的授权请求数值，BP_TH表示该第一请求阈值。该接收端接收到该发送端发送的报文后，将该报文中携带的数据写入缓存，将该报文中携带的每个队列的req与BP_TH进行比较，确定req大于BP_TH的第一类队列，将该第一类队列的调度器1节点置1，即将该第一类队列作为该调度器1的调度节点，该接收端还确定req不大于BP_TH的第二类队列，将该第二类队列的调度器2节点置1，即将该第二类队列作为该调度器2的调度节点，则调度器1和调度器2分别进行调度，该接收端在产生反压时选择调度器1调度出的第一类队列，在未产生反压或者撤销反压时选择调度器2调度出的第二类队列，为选择的队列下发授权数值。

其中，该第一授权数值为该第一类队列当前的授权请求数值与该第一请求阈值之间的差值，即该第一类队列当前的授权请求数值为req，该第一请求阈值为BP_TH，则该第一授权数值为req-BP_TH。由于该预设最大授权数值为max，则可以确定该队列的剩余授权数值为max-req。接收端为该第一类队列下发该第一授权数值req-BP_TH后，该第一类队列的剩余授权数值会变为(max-req)+(req-BP_TH)＝max-BP_TH，由于BP_TH不小于max与流控阈值VOQ_TH之间的差值，则max-BP_TH不大于VOQ_TH，保证了发送端不会撤销流控，不会向接收端发送数据。

也即是，在该接收端产生反压时，向第一类队列下发授权数值，而不再向第二类队列下发授权数值，则对于第一类队列来说，该第一类队列的剩余授权数值较小，即使为该第一类队列下发了对应的第一授权数值，该第一类队列的剩余授权数值也不会超过该流控阈值，则该第一类队列会产生流控，停止发送报文。对于第二类队列来说，随着向该接收端发送报文，该第二类队列的剩余授权数值会越来越小，当该第二类队列的剩余授权数值小于该流控阈值时，该第二类队列也会产生流控，停止发送报文。则对于该接收端来说，该接收端不会再接收该发送端发送的报文，该接收端缓存的数据逐渐释放。

205、该接收端将该第一类队列的授权请求数值更新为该第一请求阈值。

该接收端向该调度出的第一类队列下发该第一授权数值后，该第一类队列的剩余授权数值会增加该第一授权数值，相应的，该第一类队列的授权请求数值也会减小该第一授权数值，则该接收端计算该第一类队列原来的授权请求数值req与该第一授权数值req-BP_TH之间的差值，作为该第一类队列更新后的授权请求数值，也即是，下发该第一授权数值后，该第一类队列的授权请求数值变为第一请求阈值BP_TH，则该接收端将该第一类队列的授权请求数值更新为该第一请求阈值，以便于下一次对该队列进行判断。

在该接收端产生反压的过程中，该接收端可以根据该预设调度算法，持续地对第一类队列进行调度，每调度出一个第一类队列，该接收端根据该调度出的第一类队列当前的授权请求数值确定第一授权数值，向该调度出的第一类队列下发该第一授权数值，使得该第一类队列的授权请求数值更新为该第一请求阈值BP_TH，此时该调度出的队列切换为第二类队列。之后，该接收端继续根据该预设调度算法，对剩余的第一类队列进行调度。

在产生反压的过程中，该接收端通过多次调度，可以为多个授权请求数值较大的第一类队列提前下发授权数值，使得这些队列的授权请求数值均变化为该第一请求阈值BP_TH。下发授权数值后，该接收端会对队列再次进行判断，重新确定第一类队列和第二类队列，对两个调度器的调度节点进行更新，用于下一次调度。

206、该发送端接收到该第一授权数值时，根据该第一授权数值和该预设最大授权数值，对该第一类队列的授权请求数值进行更新。

该接收端向该第一类队列下发该第一授权数值时会携带该第一类队列的队列标识，该发送端接收到该第一授权数值时，可以根据该第一类队列的队列标识，计算该第一类队列原来的授权请求数值与该第一授权数值之间的差值，作为该第一类队列更新后的授权请求数值，以对该第一类队列的授权请求数值进行更新。

在该接收端产生反压时，随着该接收端缓存的数据逐渐释放，其所缓存的数据量越来越小，当该接收端所缓存的数据量不大于该反压阈值时，该接收端会撤销反压。

该接收端撤销反压后，该方法还包括：该接收端向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于该第一请求阈值的队列，该接收端将该第二类队列的授权请求数值更新为该第二类队列原来的授权请求数值与该预设授权数值之间的差值。该发送端接收到为该第二类队列下发的预设授权数值时，也会将该第二类队列的授权请求数值更新为该第二类队列原来的授权请求数值与该预设授权数值之间的差值。其中，该预设授权数值由该接收端预先设定，该预设授权数值越小，调度带宽越小，精度越大。

具体地，当该接收端撤销反压后，对于该发送端的每个队列，判断该队列当前的授权请求数值是否大于第一请求阈值，如果该队列当前的授权请求数值大于该第一请求阈值，则该接收端将该队列确定为第一类队列，如果该队列当前的授权请求数值不大于该第一请求阈值，则该接收端将该队列确定为第二类队列。当该接收端已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列，向该调度出的第二类队列下发该预设授权数值。

下发该预设授权数值后，该调度出的第二类队列的剩余授权数值会增大该预设授权数值，相应的，该调度出的第二类队列的授权请求数值会减小该预设授权数值，则该接收端将该调度出的第二类队列的授权请求数值更新为该调度出的第二类队列原来的授权请求数值与该预设授权数值之间的差值。同理，该发送端接收到该预设授权数值时，也会将该调度出的第二类队列的授权请求数值更新为该调度出的第二类队列原来的授权请求数值与该预设授权数值之间的差值。

本发明实施例中根据该接收端的反压状态，为该发送端的队列下发不同的授权数值。当该接收端产生反压时未停止下发授权数值，而是为剩余授权数值较小的队列提前下发第一授权数值，使得这些队列可以在该接收端产生反压期间提前累积授权数值，且不会撤销流控，避免了流量突发。当该接收端撤销反压后，对剩余授权数值较大的队列下发固定的预设授权数值，使得该发送端的队列可以快速累积授权数值，快速撤销流控，缩短了从接收端撤销反压到发送端开始发送数据所耗费的时间。且从发送端产生流控到开始发送数据所耗费的时间也相应缩短，降低了数据量超出该发送端的最大数据量的概率，降低了丢弃率，保护了该发送端的缓存数据。

本发明实施例提供的方法，通过在接收端产生反压时未停止下发授权数值，而是向当前请求的授权数值较大的第一类队列下发第一授权数值，且第一授权数值为该队列当前的授权请求数值与第一请求阈值之间的差值，能够在接收端撤销反压之前提前下发授权数值，使得接收端撤销反压后发送端能够快速地累积授权数值，快速地撤销流控，使得发送端能够快速地开始发送数据，缩短了从接收端撤销反压到发送端开始发送数据所耗费的时间。进一步地，缩短了从发送端产生流控到开始发送数据所耗费的时间，降低了数据量超出最大数据量的概率，降低了丢弃率。且在接收端产生反压的时间段内，接收端所下发的第一授权数值能够保证该队列剩余的授权数值小于发送端的流控阈值，保证发送端不会撤销流控，不会向接收端发送数据，避免了流量突发。

图4是本发明实施例提供的一种授权数值处理装置的结构示意图，参见图4，该装置包括：

控制模块401，用于当缓存的数据量大于反压阈值时，产生反压；

授权数值确定模块402，用于根据第一类队列当前的授权请求数值，确定第一授权数值，该授权请求数值用于表示发送端当前为该第一类队列请求的授权数值，由该第一类队列的预设最大授权数值与当前的剩余授权数值之间的差值确定，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

下发模块403，用于向该第一类队列下发该第一授权数值，该第一授权数值为该第一类队列当前的授权请求数值与该第一请求阈值之间的差值；

数值更新模块404，用于将该第一类队列的授权请求数值更新为该第一请求阈值；

其中，该第一请求阈值不小于该发送端的预设最大授权数值与流控阈值之间的差值。

本发明实施例提供的装置，通过在产生反压时未停止下发授权数值，而是向当前请求的授权数值较大的第一类队列下发第一授权数值，且第一授权数值为该队列当前的授权请求数值与第一请求阈值之间的差值，能够在撤销反压之前提前下发授权数值，使得撤销反压后发送端能够快速地累积授权数值，快速地撤销流控，使得发送端能够快速地开始发送数据，缩短了从该装置撤销反压到发送端开始发送数据所耗费的时间。进一步地，缩短了从发送端产生流控到开始发送数据所耗费的时间，降低了数据量超出最大数据量的概率，降低了丢弃率。且在产生反压的时间段内所下发的第一授权数值能够保证该队列剩余的授权数值小于发送端的流控阈值，保证发送端不会撤销流控，不会向该装置发送数据，避免了流量突发。

可选地，该控制模块401，还用于当该数据量不大于该反压阈值时，撤销反压；

该下发模块403，还用于向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于该第一请求阈值的队列；

该数值更新模块404，还用于将该第二类队列的授权请求数值更新为该第二类队列当前的授权请求数值与该预设授权数值之间的差值。

可选地，该装置还包括：

接收模块，用于接收该发送端发送的报文，该报文至少携带队列当前的授权请求数值；

分类模块，用于如果该队列当前的授权请求数值大于该第一请求阈值，将该队列确定为第一类队列，如果该队列当前的授权请求数值不大于该第一请求阈值，将该队列确定为第二类队列。

可选地，该分类模块还用于如果该队列当前的授权请求数值不大于该第一请求阈值，且大于第二请求阈值，将该队列确定为第二类队列，该第二请求阈值小于该第一请求阈值。

可选地，该装置还包括：

第一调度模块，用于当已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列。

可选地，该装置还包括：

第二调度模块，用于当已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列。

上述所有可选技术方案，可以采用任意结合形成本发明的可选实施例，在此不再一一赘述。

需要说明的是：上述实施例提供的授权数值处理装置在处理授权数值时，仅以上述各功能模块的划分进行举例说明，实际应用中，可以根据需要而将上述功能分配由不同的功能模块完成，即将接收端的内部结构划分成不同的功能模块，以完成以上描述的全部或者部分功能。另外，上述实施例提供的授权数值处理装置与授权数值处理方法实施例属于同一构思，其具体实现过程详见方法实施例，这里不再赘述。

图5是本发明实施例提供的一种网络系统的结构示意图，参见图5，该网络系统包括：接收端501和发送端502；

该接收端501用于当缓存的数据量大于反压阈值时产生反压；

该发送端502用于根据预设最大授权数值和每个队列当前的剩余授权数值，确定每个队列当前的授权请求数值，该授权请求数值用于表示发送端502当前为队列请求的授权数值；

该接收端501还用于根据第一类队列当前的授权请求数值，确定第一授权数值，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

该接收端501还用于向该第一类队列下发该第一授权数值，该第一授权数值为该第一类队列当前的授权请求数值与该第一请求阈值之间的差值；

该接收端501还用于将该第一类队列的授权请求数值更新为该第一请求阈值；

该发送端502用于当任一队列的剩余授权数值小于流控阈值时产生流控；

该发送端502还用于接收该接收端501为该第一类队列下发的该第一授权数值，根据该第一授权数值和该预设最大授权数值，对该第一类队列的授权请求数值进行更新。

其中，该第一请求阈值不小于该预设最大授权数值与该流控阈值之间的差值。

可选地，该接收端501还用于当缓存的数据量不大于该反压阈值时，撤销反压；

该接收端501还用于向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于该第一请求阈值的队列；将该第二类队列的授权请求数值更新为该第二类队列当前的授权请求数值与该预设授权数值之间的差值。

可选地，该接收端501还用于接收该发送端发送的报文，该报文至少携带队列当前的授权请求数值；如果该队列当前的授权请求数值大于该第一请求阈值，将该队列确定为第一类队列；如果该队列当前的授权请求数值不大于该第一请求阈值，将该队列确定为第二类队列。

可选地，该接收端501还用于如果该队列当前的授权请求数值不大于该第一请求阈值，且大于第二请求阈值，将该队列确定为第二类队列，该第二请求阈值小于该第一请求阈值。

可选地，该接收端501还用于当已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列；根据该调度出的第一类队列当前的授权请求数值，确定该第一授权数值；向该调度出的第一类队列下发该第一授权数值；将该调度出的第一类队列的授权请求数值更新为该第一请求阈值。

可选地，该接收端501还用于当已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列；向该调度出的第二类队列下发该预设授权数值；将该调度出的第二类队列的授权请求数值更新为该调度出的第二类队列当前的授权请求数值与该预设授权数值之间的差值。

上述所有可选技术方案，可以采用任意结合形成本发明的可选实施例，在此不再一一赘述。

本领域普通技术人员可以理解实现上述实施例的全部或部分步骤可以通过硬件来完成，也可以通过程序来指令相关的硬件完成，所述的程序可以存储于一种计算机可读存储介质中，上述提到的存储介质可以是只读存储器，磁盘或光盘等。

以上所述仅为本发明的较佳实施例，并不用以限制本发明，凡在本发明的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。

Claims (13)

1.一种授权数值处理方法，其特征在于，所述方法包括：

当接收端缓存的数据量大于反压阈值时，所述接收端产生反压；

所述接收端根据第一类队列当前的授权请求数值，确定第一授权数值，所述授权请求数值用于表示发送端当前为所述第一类队列请求的授权数值，由所述第一类队列的预设最大授权数值与当前的剩余授权数值之间的差值确定，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

所述接收端向所述第一类队列下发所述第一授权数值，所述第一授权数值为所述第一类队列当前的授权请求数值与所述第一请求阈值之间的差值；

所述接收端将所述第一类队列的授权请求数值更新为所述第一请求阈值；

其中，所述第一请求阈值不小于所述发送端中每个队列的预设最大授权数值与流控阈值之间的差值。

2.根据权利要求1所述的方法，其特征在于，所述方法还包括：

当所述接收端缓存的数据量不大于所述反压阈值时，所述接收端撤销反压；

所述接收端向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于所述第一请求阈值的队列；

所述接收端将所述第二类队列的授权请求数值更新为所述第二类队列当前的授权请求数值与所述预设授权数值之间的差值。

3.根据权利要求1或2所述的方法，其特征在于，所述方法还包括：

所述接收端接收所述发送端发送的报文，所述报文至少携带队列当前的授权请求数值；

如果所述队列当前的授权请求数值大于所述第一请求阈值，将所述队列确定为第一类队列；

如果所述队列当前的授权请求数值不大于所述第一请求阈值，将所述队列确定为第二类队列。

4.根据权利要求3所述的方法，其特征在于，所述如果所述队列当前的授权请求数值不大于所述第一请求阈值，将所述队列确定为第二类队列，包括：

如果所述队列当前的授权请求数值不大于所述第一请求阈值，且大于第二请求阈值，将所述队列确定为第二类队列，所述第二请求阈值小于所述第一请求阈值。

5.根据权利要求1所述的方法，其特征在于，当接收端的数据量大于反压阈值时，所述接收端产生反压之后，所述方法还包括：

当所述接收端已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列；

所述接收端根据所述调度出的第一类队列当前的授权请求数值，确定所述第一授权数值；

所述接收端向所述调度出的第一类队列下发所述第一授权数值；

所述接收端将所述调度出的第一类队列的授权请求数值更新为所述第一请求阈值。

6.根据权利要求2所述的方法，其特征在于，当所述接收端的数据量不大于所述反压阈值时，所述接收端撤销反压之后，所述方法还包括：

当所述接收端已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列；

所述接收端向所述调度出的第二类队列下发所述预设授权数值；

所述接收端将所述调度出的第二类队列的授权请求数值更新为所述调度出的第二类队列当前的授权请求数值与所述预设授权数值之间的差值。

7.一种授权数值处理装置，其特征在于，所述装置包括：

控制模块，用于当缓存的数据量大于反压阈值时，产生反压；

授权数值确定模块，用于根据第一类队列当前的授权请求数值，确定第一授权数值，所述授权请求数值用于表示发送端当前为所述第一类队列请求的授权数值，由所述第一类队列的预设最大授权数值与当前的剩余授权数值之间的差值确定，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

下发模块，用于向所述第一类队列下发所述第一授权数值，所述第一授权数值为所述第一类队列当前的授权请求数值与所述第一请求阈值之间的差值；

数值更新模块，用于将所述第一类队列的授权请求数值更新为所述第一请求阈值；

其中，所述第一请求阈值不小于所述发送端中每个队列的预设最大授权数值与流控阈值之间的差值。

8.根据权利要求7所述的装置，其特征在于，

所述控制模块，还用于当所述数据量不大于所述反压阈值时，撤销反压；

所述下发模块，还用于向第二类队列下发预设授权数值，第二类队列是指当前的授权请求数值不大于所述第一请求阈值的队列；

所述数值更新模块，还用于将所述第二类队列的授权请求数值更新为所述第二类队列当前的授权请求数值与所述预设授权数值之间的差值。

9.根据权利要求7或8所述的装置，其特征在于，所述装置还包括：

接收模块，用于接收所述发送端发送的报文，所述报文至少携带队列当前的授权请求数值；

分类模块，用于如果所述队列当前的授权请求数值大于所述第一请求阈值，将所述队列确定为第一类队列，如果所述队列当前的授权请求数值不大于所述第一请求阈值，将所述队列确定为第二类队列。

10.根据权利要求9所述的装置，其特征在于，所述分类模块还用于如果所述队列当前的授权请求数值不大于所述第一请求阈值，且大于第二请求阈值，将所述队列确定为第二类队列，所述第二请求阈值小于所述第一请求阈值。

11.根据权利要求7所述的装置，其特征在于，所述装置还包括：

第一调度模块，用于当已确定多个第一类队列时，根据预设调度算法，从多个第一类队列中调度出一个第一类队列。

12.根据权利要求8所述的装置，其特征在于，所述装置还包括：

第二调度模块，用于当已确定多个第二类队列时，根据预设调度算法，从多个第二类队列中调度出一个第二类队列。

13.一种网络系统，其特征在于，所述网络系统包括：接收端和发送端；

所述接收端用于当缓存的数据量大于反压阈值时产生反压；

所述发送端用于根据预设最大授权数值和每个队列当前的剩余授权数值，确定每个队列当前的授权请求数值，所述授权请求数值用于表示发送端当前为队列请求的授权数值；

所述接收端还用于根据第一类队列当前的授权请求数值，确定第一授权数值，第一类队列是指当前的授权请求数值大于第一请求阈值的队列；

所述接收端还用于向所述第一类队列下发所述第一授权数值，所述第一授权数值为所述第一类队列当前的授权请求数值与所述第一请求阈值之间的差值；

所述接收端还用于将所述第一类队列的授权请求数值更新为所述第一请求阈值；

所述发送端用于当任一队列的剩余授权数值小于流控阈值时产生流控；

所述发送端还用于接收所述接收端为所述第一类队列下发的所述第一授权数值，根据所述第一授权数值和所述预设最大授权数值，对所述第一类队列的授权请求数值进行更新；

其中，所述第一请求阈值不小于所述预设最大授权数值与所述流控阈值之间的差值。