使用 netty-socketio 服务器限制 websocket

Question

我们正在使用https://github.com/mrniko/netty-socketio。

应用场景：服务器通过websocket高速向客户端推送消息。

最近我们遇到了一个问题，客户端无法处理来自 socket.io 服务器的所有事件消息。 websocket 消息开始堆积，客户端无响应。在 Chrome 开发者工具中，我们可以看到客户端内存逐渐增加。

使用wireshark分析tcpdump发现有很多重传发生，客户端无法应对。

我们计划在服务器端有一个节流机制。是否有任何事件/回调可用于检测慢速客户端，以便我们可以在服务器端针对这个特定的 websocket 开始节流？

Answer 1

是的。 Channel.isWritable() 是一个很好的起点。为了简化一点，当通道的出站缓冲区中有太多待处理的出站字节时，它会返回false。您可以继续发送直到Channel.isWritable() 返回false。当通道的可写性发生变化时，您的处理程序会收到channelWritabilityChanged() 事件的通知。然后，您可以继续传输。

public void generateTraffic(ChannelHandlerContext ctx) {
    while (ctx.channel().isWritable()) {
        ctx.write(...);
    }
}

public void channelWritabilityChanged(ChannelHandlerContext ctx) {
    generateTraffic(ctx);
}

在实际应用程序中，您需要维护一些有状态的信息来确定应该在何时发送什么消息。

另外，请查看ChannelConfig.writeBufferHigh/LowWatermark 属性以配置isWritable() 何时应该开始返回false 或true。