写入通道的消息未进入管道

Question

因此，服务器和客户端都发生这种情况。我有来自通道活动方法的通道处理程序上下文，我正在尝试使用写入AndFlush（对象消息）方法向其写入对象，但似乎消息永远不会进入创建的管道。

下面是我的客户端处理程序的样子(我重写了包解码器和编码器中的一些方法来调试)

public ChannelHandlerContext channel;
...
...
(method to start client is called)


EventLoopGroup workerGroup = new NioEventLoopGroup();
Bootstrap b = new Bootstrap();
            b.group(workerGroup);
            b.channel(NioSocketChannel.class);
            b.option(ChannelOption.SO_KEEPALIVE, true);

b.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                protected void initChannel(SocketChannel ch) {
                    ch.pipeline().addLast(
                            new PacketDecoder(clientRegistries){
                                @Override
                                protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
                                    List<Packet> packets = PacketHelper.handle(in, ctx, super.serverRegistries);
                                    packets.forEach(packet -> {
                                        System.out.println(packet.getClass());
                                    });
                                }

                                @Override
                                public void channelActive(ChannelHandlerContext ctx) throws Exception {
                                    channel = ctx;
                                    ctx.fireChannelActive();
                                }
                            },
                            new PacketEncoder(){
                                @Override
                                protected void encode(ChannelHandlerContext ctx, Pair<PacketRegistry, Packet> msg, ByteBuf out) throws Exception {
                                    System.out.println("message encoded on client sent to server");
                                    super.encode(ctx, msg, out);
                                }
                            }
                    );

                }
            });

ChannelFuture f = b.connect(host, port).sync();

这是我如何写入ChannelHandlerContext通道变量

    public void sendPacket(PacketRegistry registry, Packet p) {
        System.out.println("data written to server from client");
        channel.writeAndFlush(new Pair<>(registry, p));
    }

当我运行我的代码时，“从客户端写入服务器的数据”是打印机，但“在客户端上编码的消息发送到服务器”永远不会打印。

我想知道我做错了什么，任何帮助都将不胜感激。就像上面所说的，当我尝试使用channelActive方法中的ChannelHandlerContext编写时，服务器上也会发生同样的事情。

Answer 1

好的，所以我找到了答案，它很简单。我需要使用channelRegistered方法（用于tcp）而不是channelActive方法（用于udp）。