Netty：反向传播通道处理器管道中的压力，以降低发送器的速度

Question

我正在使用netty开发应用程序，该应用程序将通过TCP侦听特定端口。一旦接收到字节，我就有了一个带有业务逻辑的管道，可以在接收到的字节上运行。此管道由多个通道处理程序组成，如标头解码器、应用程序级碎片处理程序等。在管道末尾，一旦处理完消息，管道中的最后一个处理程序（如BufferWriter）将把处理过的消息放入阻塞队列。这个阻塞队列的作用类似于缓冲区，而BufferWriter的作用类似于生产者。注意，此阻塞队列在所有通道中共享。所以，应用程序接收到的所有数据都将写入单个队列。还有另一个计划执行器服务将作为此缓冲区的使用者。此使用者是按一定时间间隔运行的定期任务，从缓冲区中提取消息并写入文件。

我遇到的问题是，当有大量传入流量时，我的消费者线程无法跟上速度。导致缓冲队列变满。

在netty中，有没有什么方法可以减慢从套接字的读取速度，这样消费者就可以跟上生产者的步伐？例如，一旦缓冲区满了，netty就不会从套接字读取，每当缓冲区有空间时，它就会从套接字恢复读取。

请注意，在这种情况下，发送者不是用java/netty编写的。它们是c程序，它将与我的服务器形成传输控制协议并开始发送数据。我假设，当我减慢服务器套接字读取速率时，TCP将使用拥塞控制策略自动减慢发送者的速度（慢启动）

Answer 1

要控制读取，在通道中有一个名为“自动读取”的配置。您可以将其设置为false：

ctx.channel().config().setAutoRead(false);

如果这样做，则需要手动触发通道的读取：

ctx.channel().read();

您可以通过最初将autoRead设置为false，然后在读取端（入站）设置缓冲区/计数并仅在缓冲区为空时读取，直到缓冲区已满，从而降低读取速率。

在WSO2传输中，它是使用侦听器完成的。