java - 多个连接包同时到达的Netty CorruptedFrameException

Question

我在使用 Netty 的程序中遇到了一个非常奇怪的问题。

我正在监听端口并解析消息(使用 FrameDecoder 实现)。如果我接收到一个连接，一切正常，但是当我在同一个端口上接收到两个连接时(每个连接都来自不同的服务器)，我遇到了一种罕见但严重的情况，我得到了 corruptedFrameException

当我的程序收到具有完全相同时间戳的 TCP 数据包时(以非常高的速率发送信息时)如下所示，就会出现此问题

1. 来自服务器 1 的 TCP 数据包
2. 来自服务器 2 的 TCP 数据包
3. 来自服务器 1 的 TCP 数据包(它是项目符号 1 中开始的消息的延续)
4. 来自服务器 2 的 TCP 数据包(它是项目符号 2 中加星标的消息的延续)

我的程序试图将 1 和 2 解析为消息，而不是知道实际消息是 1 & 3 和 2 & 4我在某处读到，也许我需要为每个 channel 连接实例化一个新的 FrameDecoder，但我不知道该怎么做。我在启动时将解码器添加到管道中，但我不知道如何将新解码器添加到特定 channel

我遇到的异常是:

org.jboss.netty.handler.codec.frame.CorruptedFrameException: Adjusted frame length (0) is less than lengthFieldEndOffset: 2
    at org.jboss.netty.handler.codec.frame.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:340) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:282) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:214) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:345) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:332) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:323) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:275) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:196) ~[netty-3.1.5.GA.jar:]
    at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46) ~[netty-3.1.5.GA.jar:]
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651) [na:1.5.0]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676) [na:1.5.0]
    at java.lang.Thread.run(Thread.java:595) [na:1.5.0]

和

org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 4096: 8224
        at org.jboss.netty.handler.codec.frame.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:296) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:282) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:216) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:345) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:332) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:323) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:275) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:196) ~[netty-3.1.5.GA.jar:]
        at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46) ~[netty-3.1.5.GA.jar:]
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651) [na:1.5.0]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676) [na:1.5.0]
        at java.lang.Thread.run(Thread.java:595) [na:1.5.0]

Answer 1

您需要将帧解码器的新对象添加到您的新(第二个？) channel 。重复异常是因为您使用的是相同的 channel 。

1. 服务器 Bootstrap 采用管道工厂，它将使用适当的编码器和解码器配置所有新 channel 。
2. 每当远程客户端连接到您的服务器时，它都会创建自己的 channel 对象。
3. 在您正在使用的 Channel PipelineFactory 实现中。确保每次调用 pipeline() 方法时都创建帧解码器的新实例。
4. @Sharable 注释仅用于文档目的。即使你使用它，它也不会影响任何东西，因为它不是代码/逻辑。只是一个标记而已。