Netty 连接同时到达的消息

Question

我有一个客户端连接到服务器。 TCP 会话中的通信是双向的。如果我尝试同时从服务器向客户端发送多条消息，它们会混合在一个数组中。消息在到达 ByteArrayDecoder 时已经损坏。这是我的管道：

    ChannelPipeline channelPipeline = ch.pipeline();

    channelPipeline.addLast("byteArrayEncoder", new ByteArrayEncoder());
    channelPipeline.addLast("myRequestEncoder", new MyRequestEncoder());
    channelPipeline.addLast("mySecondEncoder", new MySecondEncoder());

    channelPipeline.addLast("byteArraydDecoder", new ByteArrayDecoder());
    channelPipeline.addLast("myResponseDecoder", new MyResponseDecoder());
    channelPipeline.addLast("mySecondDecoder", new MySecondDecoder());

    channelPipeline.addLast("mytHandler", myHandler);

例如，我注意到 ByteArrayDecoder 中的字节数组长度超过 500 而不是 230。并且我看到数组的内容对应于已连接的两个或多个消息。

我只有一个频道。我曾尝试在管道中使用多个 EventExecutorGroup，但这一直在发生，我最终错过了几条入站消息。

但是，使用 1tps 一切似乎都可以正常工作。

netty 应该有这样的行为吗？我错过了什么吗？

Answer 1

TCP 是一个基于流的协议，您的应用程序应该从这个概念开始工作。 Netty 还从网络层以流的形式接收字节，应用程序的工作是将字节流转换为有用的东西。

您未能将传入的流式传输字节正确转换为您的应用程序可以处理的正确数据块。

有多种方法可以为字节引入“重构器”：

使每个数据包的长度固定

如果每个数据包都是固定长度的，你可以读取X的字节数，并将其用作简单的成帧解决方案，这使用netty真的很简单：

channelPipeline.addLast("framer", new FixedLengthFrameDecoder(512));

这会将所有传入的字节分成 512 个字节的块。

FixedLengthFrameDecoder 的参数是：

• 传入数据包的长度

发送前添加数据包长度

除了使每个数据包的大小相同之外，您还可以为数据包添加长度，以便以后拆分数据包。 Netty 还为此提供了有用的实用程序类：

channelPipeline.addLast("framer", new LengthFieldBasedFrameDecoder(Short.MAX_VALUE,0,2,0,2));
channelPipeline.addLast("framer-prepender", new LengthFieldPrepender(2, false));

LengthFieldBasedFrameDecoder 的参数是：

• 最大帧长度
• 接收帧长度数据的偏移量
• 长度字段的字节长度
• 从收到的消息中删除的字节数

LengthFieldPrepender 的参数是：

• 长度字段的字节长度