channelRead0没有被称为Netty

Question

我有一个服务器-客户端应用程序不工作。这是代码：ChatServerHandler

public static final ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

public static final ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

@Override
public void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf buf) {
    Channel incoming = channelHandlerContext.channel();
    for (Channel channel : channels) {
        if (channel != incoming){
            System.out.println(buf);
            channel.writeAndFlush("[" + incoming.remoteAddress() + "]" + buf + "\r\n");
        }
    }
    buf.release();
}

@Override
public void handlerAdded(ChannelHandlerContext ctx) {
    Channel incoming = ctx.channel();
    for (Channel channel : channels) {
        channel.writeAndFlush("[SERVER] - " + incoming.remoteAddress() + " has joined" + "\r\n");
    }
    channels.add(incoming);
}

@Override
public void handlerRemoved(ChannelHandlerContext ctx) {
    Channel incoming = ctx.channel();
    for (Channel channel : channels) {
        channel.writeAndFlush("[SERVER] - " + incoming.remoteAddress() + " has left" + "\r\n");
    }
    channels.remove(incoming);
}

ChatServerInitializer

@Override
protected void initChannel(SocketChannel channel) {
    ChannelPipeline pipeline = channel.pipeline();
    pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
    pipeline.addLast("decoder", new StringDecoder());
    pipeline.addLast("encoder", new StringDecoder());
    pipeline.addLast("handler", new ChatServerHandler());
}

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

public void run() throws Exception{
    EventLoopGroup boosGroup = new NioEventLoopGroup();
    EventLoopGroup workerGroup = new NioEventLoopGroup();
    try {
        ServerBootstrap bootstrap = new ServerBootstrap()
                .group(boosGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChatServerInitializer());
        bootstrap.bind(port).sync().channel().closeFuture().sync();
    }finally {
        boosGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}

@Override
protected void channelRead0(ChannelHandlerContext channelHandlerContext, String s) {
    System.out.println(s);
}

@Override
protected void initChannel(SocketChannel channel) {
    ChannelPipeline pipeline = channel.pipeline();
    pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
    pipeline.addLast("decoder", new StringDecoder());
    pipeline.addLast("encoder", new StringEncoder());
    pipeline.addLast("handler", new ChatClientHandler());
}

public void run() {
    EventLoopGroup group = new NioEventLoopGroup();
    try {
        Bootstrap bootstrap  = new Bootstrap()
                .group(group)
                .channel(NioSocketChannel.class)
                .handler(new ChatClientInitializer());
        Channel channel = bootstrap.connect(host, port).sync().channel();
        BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
        while(true){
            channel.write(in.readLine() + "\r\n");
        }
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        group.shutdownGracefully();
    }
}

只是要提一下，其他一切都很好，信息只是没有收到。试图使用println在channelRead打印某些内容将不起作用。所以我知道它不会被打电话。另外，对不起，如果我不应该在这里发布整个代码，但我只是没有想法。

Answer 1

您需要使用writeandflush(in.readline()+“\r\n”）；，否则它不会“刷新”到基础套接字。