Netty编码器未执行

Question

我用Netty制作了一个服务器，但我遇到了一个问题。我创建的编码器没有被执行。

我在服务器上的管道:

            bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(SocketChannel ch) throws Exception {
                ch.pipeline().addLast("encoder", new PacketEncoder());
                ch.pipeline().addLast("decoder", new PacketDecoder());
                ch.pipeline().addLast(new LoginServerChannel());
            }
        });

我的编码器：

public class PacketEncoder extends MessageToByteEncoder<Packet> {

@Override
protected void encode(ChannelHandlerContext channelHandlerContext, Packet packet, ByteBuf byteBuf) throws Exception {
    System.out.println("Encoding");
}

我的解码器:

public class PacketDecoder extends ReplayingDecoder<DecoderState> {

@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
    ...
}

我的通道处理程序：

public class LoginServerChannel extends SimpleChannelInboundHandler<Packet> {

@Override
protected void channelRead0(ChannelHandlerContext channelHandlerContext, Packet packet) throws Exception {
    channelHandlerContext.writeAndFlush(packet.encode());

    System.out.println("Sending");
}

调用解码器，然后调用通道处理程序，但不调用编码器。我试图改变管道中的顺序，但同样的问题也试图使用fireChannelRead(...)和同样的问题。

谢谢

Answer 1

您的编码器扩展了< code>MessageToByteEncoder

在逻辑处理程序中，您可以

 channelHandlerContext.writeAndFlush( packet.encode() );

我假设< code>encode()返回一个字节数组，所以您编码器会忽略它，什么也不做。

你可能应该做这样的事情：

channelHandlerContext.writeAndFlush( packet );