使用netty-socketio服务器限制websockets

Question

我们使用的是https://github.com/mrniko/netty-socketio。

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

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

使用wireshark分析tcpdump表明，发生了大量重新传输，客户端无法应对。

我们计划在服务器side.Is有一个节流机制，有什么事件/回调可以用来检测慢速客户端，这样我们就可以开始在服务器端对这个特定的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。