java - Netty channel 读取未调用

Question

我正在尝试让多个 Netty 客户端相互通信。我在尝试这个时遇到了问题。当我写入 channel 时，它不会调用 NettyClientHandler#channelRead。

NettyClient 类:

public class NettyClient
{
    private static NettyClient client;
    private int port;
    private Channel channel;

    public NettyClient(int port)
    {
        this.port = port;
    }

    public static void start(final int port)
    {
        BungeeCord.getInstance().getScheduler().runAsync(AzideaCord.getInstance(), new Runnable()
        {
            @Override
            public void run()
            {
                client = new NettyClient(port);
                client.run();
            }
        });
    }

    private void run()
    {
        EventLoopGroup group = new NioEventLoopGroup();

        try
        {
            Bootstrap bootstrap = new Bootstrap()
                .group(group)
                .channel(NioSocketChannel.class)
                .handler(new NettyClientInitializer());

            channel = bootstrap.bind(port).sync().channel();
            System.out.println("[Netty] Connected to localhost:" + port + ".");
            channel.write("test" + "\r\n");
        }
        catch(InterruptedException e)
        {
            e.printStackTrace();
        }
        finally
        {
            group.shutdownGracefully();
        }
    }
}

NettyClientHandler 类:

public class NettyClientHandler extends ChannelInboundHandlerAdapter
{
    // Never called
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
    {
        System.out.println("Msg: " + msg); 
    }
}

NettyClientInitializer 类:

public class NettyClientInitializer extends ChannelInitializer<SocketChannel>
{
    @Override
    protected void initChannel(SocketChannel channel) throws Exception
    {
        ChannelPipeline pipeline = channel.pipeline();
        pipeline.addLast(new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
        pipeline.addLast(new StringDecoder());
        pipeline.addLast(new StringEncoder());
        pipeline.addLast(new NettyClientHandler());
    }
}

Answer 1

您需要更换:

channel.write("test" + "\r\n");

channel.writeAndFlush("test" + "\r\n");