LengthFieldBasedFrameDecoder не вызывает следующий обработчик - PullRequest
Новая
       19

LengthFieldBasedFrameDecoder не вызывает следующий обработчик

1 голос
/ 27 марта 2019

Я использую LengthFieldBasedFrameDecoder в качестве моего первого обработчика для входящего трафика, который отправляется с клиента.

Длина: 4 байта Полезная нагрузка: Hello - 5 байтов

[0, 0, 0, 9, 72, 101, 108, 108, 111]

ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
    .channel(NioServerSocketChannel.class)
    .childHandler(new ChannelInitializer<SocketChannel>() {
        @Override
        public void initChannel(SocketChannel ch) throws Exception {
            ch.pipeline().addLast("frameDecoder", new PacketFrameDecoder());
            ch.pipeline().addLast(new GameServerHandler());
        }
    })
    .option(ChannelOption.SO_BACKLOG, 128)
    .childOption(ChannelOption.SO_KEEPALIVE, true);

// Bind and start to accept incoming connections.
ChannelFuture f = b.bind(port).sync();

In ByteToMessageDecoder Я вижу, что fireChannelRead(ctx, out, size) вызывается с пустым значением out и размером 0. Кажется, исключение не выдается. Я пробовал оба порядка байтов в декодере. 

public class PacketFrameDecoder extends LengthFieldBasedFrameDecoder {

    //Constants
    private static final int MAX_FRAME_LENGTH = Integer.MAX_VALUE;
    private static final int LENGTH_FIELD_OFFSET = 0;
    private static final int LENGTH_FIELD_LENGTH = 4;
    private static final int LENGTH_FIELD_ADJUSTMENT = 0;
    private static final int INITIAL_BYTES_TO_STRIP = 4;

    //Constructors
    public PacketFrameDecoder() {
        super(MAX_FRAME_LENGTH, LENGTH_FIELD_OFFSET, LENGTH_FIELD_LENGTH,
            LENGTH_FIELD_ADJUSTMENT, INITIAL_BYTES_TO_STRIP);

    }

}

После этого я хочу обработать свое тело / полезную нагрузку в GameServerHandler, который расширяет ChannelInboundHandlerAdapter. 

public class GameServerHandler extends ChannelInboundHandlerAdapter {

    /**
     * This method is called with the received message, whenever new data is received from a client.
     * @param context
     * @param message
     */
    @Override
    public void channelRead(ChannelHandlerContext context, Object message) {
        Log.i("GameServerHandler"); //Breakpoint here
        ByteBuf in = (ByteBuf) message;
        try {
            String test = in.toString(io.netty.util.CharsetUtil.US_ASCII);
            Log.i(test);
        } finally {
            ReferenceCountUtil.release(message);
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext context, Throwable cause) {
        // Close the connection when an exception is raised.
        cause.printStackTrace();
        context.close();
    }

}

Но channelRead в моем GameServerHandler не вызывается и не запускается. Понятия не имею, что я делаю не так.

1 Ответ

1 голос
/ 27 марта 2019

Я только что узнал, что проблема, похоже, связана с регулировкой длины. Мои заголовки (4 байта) включены в общую длину, поэтому есть 2 варианта:

  1. Вычтите длину заголовка из настройки поля длины: LENGTH_FIELD_ADJUSTMENT = -4
  2. Не инкапсулировать длину заголовка при отправке сообщения и содержать только полезную нагрузку
...