1

これまでのところ、アップグレード中に最終的な問題に遭遇するまで、Netty バージョン 3.5.7.Final から 4.0.0CR3 へのアップグレードについて詳しく説明してきました.... LengthFieldBasedFrameDecoder です。使用可能な各コンストラクターには、Integer.MAX_VALUE に設定した maxFrameLength が必要ですが、クライアント/サーバーを実行すると、Integer.MAX_VALUE を超えた (2147483647) ことを示す複数のスタック トレース (以下に示す 1 つ) が表示されます。API ドキュメントの ChannelConfig クラスやその他のさまざまなスタックオーバーフローの投稿を掘り下げて、最大チャネル バッファ サイズを設定しようとしましたが、まだ普及していません。私が設定できる欠落しているオプションがあるかどうか、または読み取りがこれほど高くならないようにする方法があるかどうか、誰かが知っていますか?

スタックトレース：

io.netty.handler.codec.TooLongFrameException: Adjusted frame length exceeds 2147483647: 4156555235 - discarded
at io.netty.handler.codec.LengthFieldBasedFrameDecoder.fail(LengthFieldBasedFrameDecoder.java:486)
at io.netty.handler.codec.LengthFieldBasedFrameDecoder.failIfNecessary(LengthFieldBasedFrameDecoder.java:462)
at io.netty.handler.codec.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:397)
at io.netty.handler.codec.LengthFieldBasedFrameDecoder.decode(LengthFieldBasedFrameDecoder.java:352)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:111)
at io.netty.handler.codec.ByteToMessageDecoder.inboundBufferUpdated(ByteToMessageDecoder.java:69)
at io.netty.channel.ChannelInboundByteHandlerAdapter.inboundBufferUpdated(ChannelInboundByteHandlerAdapter.java:46)
at io.netty.channel.DefaultChannelHandlerContext.invokeInboundBufferUpdated(DefaultChannelHandlerContext.java:1031)
at io.netty.channel.DefaultChannelHandlerContext.fireInboundBufferUpdated0(DefaultChannelHandlerContext.java:998)
at io.netty.channel.DefaultChannelHandlerContext.fireInboundBufferUpdated(DefaultChannelHandlerContext.java:978)
at io.netty.handler.timeout.IdleStateHandler.inboundBufferUpdated(IdleStateHandler.java:257)
at io.netty.channel.DefaultChannelHandlerContext.invokeInboundBufferUpdated(DefaultChannelHandlerContext.java:1057)
at io.netty.channel.DefaultChannelHandlerContext.fireInboundBufferUpdated0(DefaultChannelHandlerContext.java:998)
at io.netty.channel.DefaultChannelHandlerContext.fireInboundBufferUpdated(DefaultChannelHandlerContext.java:978)
at io.netty.channel.DefaultChannelPipeline.fireInboundBufferUpdated(DefaultChannelPipeline.java:828)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:118)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:429)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:392)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:322)
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:114)
at java.lang.Thread.run(Thread.java:680)

私のクライアントは次のように構成されています。

peerClient.bootstrap = new Bootstrap();

peerClient.bootstrap.group(new NioEventLoopGroup())
          .channel(NioSocketChannel.class)
          .option(ChannelOption.ALLOCATOR, UnpooledByteBufAllocator.DEFAULT)
          .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 120000)
          .option(ChannelOption.SO_KEEPALIVE, true)
          .option(ChannelOption.TCP_NODELAY, true)
          .option(ChannelOption.SO_REUSEADDR, true)
          .handler(PeerInitializer.newInstance());

私のサーバー構成:

result.serverBootstrap = new ServerBootstrap();

result.serverBootstrap.group(new NioEventLoopGroup(), new NioEventLoopGroup())
      .channel(NioServerSocketChannel.class)
      .handler(new LoggingHandler(LogLevel.INFO))
      .childHandler(PeerInitializer.newInstance())
      .childOption(ChannelOption.ALLOCATOR, UnpooledByteBufAllocator.DEFAULT);

ChannelInitializer を拡張するカスタム クラスでオーバーライドされた initChannel メソッド

public class PeerInitializer extends ChannelInitializer<SocketChannel>

@Override
protected void initChannel(SocketChannel ch) throws Exception {
    final ChannelPipeline pipeline = ch.pipeline();

    pipeline.addLast(
            messageEncoder,
            HandshakeDecoder.newInstance(),
            connectionHandler,
            handshakeHandler,
            new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4),
            messageHandler);
}
4

1 に答える 1

0

netty では、4 バイトの長さフィールドを unsigned int (実際には long) に変換します。

LengthFieldBasedFrameDecoder.java

private long getFrameLength(ByteBuf in, int actualLengthFieldOffset) {
    in = in.order(byteOrder);
    long frameLength;
    switch (lengthFieldLength) {
    case 1:
        frameLength = in.getUnsignedByte(actualLengthFieldOffset);
        break;
    case 2:
        frameLength = in.getUnsignedShort(actualLengthFieldOffset);
        break;
    case 3:
        frameLength = in.getUnsignedMedium(actualLengthFieldOffset);
        break;
    // This Code
    case 4:
        frameLength = in.getUnsignedInt(actualLengthFieldOffset);
        break;
    case 8:
        frameLength = in.getLong(actualLengthFieldOffset);
        break;
    default:
        throw new Error("should not reach here");
    }
    return frameLength;
}

AbstractByteBuf.java

@Override
public long getUnsignedInt(int index) {
    return getInt(index) & 0xFFFFFFFFL;
}

4156555235 は -138412061 です。

コード：

int i = 0xF7BFFFE3;
System.out.println(i);

長さフィールドの値を確認してください。

これを試して：

あなたの ChannelInitializer

public class PeerInitializer extends ChannelInitializer<SocketChannel>

@Override
protected void initChannel(SocketChannel ch) throws Exception {
    final ChannelPipeline pipeline = ch.pipeline();

    pipeline.addLast(
            new ByteLoggingHandler(LogLevel.INFO), // add
            messageEncoder,
            HandshakeDecoder.newInstance(),
            connectionHandler,
            handshakeHandler,
            new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4),
            messageHandler);
}

お役に立てれば。

于 2013-06-05T04:43:29.893 に答える