Netty接收WebSocket消息被截断在4096字节问题排查

嘿，你遇到的这个问题太典型了——Netty的WebSocket默认配置没跟上大帧需求，而OkHttp悄悄帮你做了适配。我来帮你拆解下可能的问题点和解决办法：

1. 显式设置握手器的最大帧负载大小 #

你用WebSocketClientHandshakerFactory.newHandshaker()创建握手器的时候，有没有注意到它有个重载版本支持指定maxFramePayloadSize？Netty 4.1.11.Final里这个参数的默认值刚好是4096字节，这就是为什么你的消息总是在这个位置截断！

修改你的握手器初始化代码，显式设置足够大的阈值（比如90KB）：

WebSocketClientHandshaker handshaker = WebSocketClientHandshakerFactory.newHandshaker(
        uri,
        WebSocketVersion.V13,
        null,
        true,
        new DefaultHttpHeaders(),
        90 * 1024); // 这里设置成你需要的大帧大小

2. 添加WebSocket帧聚合器处理分片 #

如果服务器把大帧拆分成了多个分片帧（比如ContinuationFrame），Netty不会自动合并，这时候你需要在Pipeline里添加WebSocketFrameAggregator来帮你把分片拼成完整的帧：

在初始化客户端ChannelPipeline的时候，加上这个处理器：

ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast(sslCtx.newHandler(ch.alloc(), uri.getHost(), uri.getPort()));
pipeline.addLast(new HttpClientCodec());
pipeline.addLast(new HttpObjectAggregator(8192)); // 这个是HTTP握手用的，保留即可
pipeline.addLast(new WebSocketFrameAggregator(90 * 1024)); // 新增这个处理WebSocket分片
pipeline.addLast(handler);

有了这个聚合器，你在自定义WebSocketClientHandler里就能直接拿到完整的大帧，不用手动拼接分片了。

3. 检查自定义Handler的消息处理逻辑 #

如果你没加聚合器，那得确保你的Handler能正确处理分片帧。比如维护一个缓冲区来拼接ContinuationFrame的内容，直到收到最终分片：

private ByteBuf contentBuffer;

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    if (msg instanceof TextWebSocketFrame) {
        // 处理完整文本帧
        TextWebSocketFrame frame = (TextWebSocketFrame) msg;
        System.out.println("完整消息：" + frame.text());
        frame.release();
    } else if (msg instanceof ContinuationWebSocketFrame) {
        ContinuationWebSocketFrame frame = (ContinuationWebSocketFrame) msg;
        if (contentBuffer == null) {
            contentBuffer = ctx.alloc().buffer();
        }
        contentBuffer.writeBytes(frame.content());
        
        if (frame.isFinalFragment()) {
            // 拼接完成，处理完整内容
            System.out.println("拼接后的消息：" + contentBuffer.toString(CharsetUtil.UTF_8));
            contentBuffer.release();
            contentBuffer = null;
        }
        frame.release();
    } else {
        // 其他类型消息交给父类处理
        super.channelRead(ctx, msg);
    }
}

不过还是推荐用WebSocketFrameAggregator，省心又不容易出错。

4. 考虑升级Netty版本 #

Netty 4.1.11.Final是比较老的版本了，虽然上面的配置应该能解决问题，但如果还是有奇怪的bug，可以试试升级到4.1.x系列的较新版本（比如4.1.87.Final），新版本修复了不少WebSocket相关的小问题。

先试试前两个步骤——设置握手器的最大帧大小+添加聚合器，应该就能解决你的4096字节截断问题了！

内容的提问来源于stack exchange，提问作者T. Marks