如何使用慢速客户端限制 netty 服务器？

Question

为了防止riemann 服务器在客户端未正确读取 ACK 时出现 OOME，我已实现 some logic 以在通道不可写时关闭通道，假设这是由于客户端未读取/确认数据包引起的足够快。

但是，这也会在发送大查询结果时关闭通道，可能是因为服务器尝试写入结果的速度比通过 TCP 发送的速度快。在我的脑海中，我认为处理这种情况的最佳方法是使用WriteTimeoutHandler 设置写入超时。

netty 中是否有一些已知的标准模式来处理这种情况？

Answer 1

基本上你会在Channel.isWritable() 返回 false 时停止写入，并在它再次返回 true 时重新开始。您可以通过覆盖 ChannelInboundHandler.channelWritabilityChanged(...) 来收到此更新的通知。