2

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

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

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

  1. 来自服务器 1 的 TCP 数据包
  2. 来自服务器 2 的 TCP 数据包
  3. 来自服务器 1 的 TCP 数据包（这是项目符号 1 中开始的消息的延续）
  4. 来自服务器 2 的 TCP 数据包（这是项目符号 2 中开始的消息的延续）

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

我遇到的例外是：

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]
4

2 回答 2

1

您需要将一个新的帧解码器对象添加到您的新（第二个？）通道。重复异常是因为您使用的是同一频道。

  1. 服务器引导程序采用管道工厂，它将使用适当的编码器和解码器配置所有新通道。
  2. 每当远程客户端连接到您的服务器时，它都会创建自己的通道对象。
  3. 在您使用的 Channel PipelineFactory 实现中。确保每次调用 pipeline() 方法时都会创建新的帧解码器实例。
  4. @Shareable 注释仅用于文档目的。即使您使用它，它也不会影响任何事情，因为它不是代码/逻辑。只是一个标记而已。
于 2012-06-05T05:58:55.937 回答
0

您需要在通道之间“不共享” FrameDecoder。FrameDecoder 未使用 @Sharable 注释，因此您无法共享它。这就是你的问题的原因在这里..

于 2012-06-04T13:33:14.980 回答