如何用Netty 4.0.x检测新的传入连接？

Question

如何检测Netty 4.0.x的新传入连接？下面是一个简单服务器的代码：

public static void main(String[] args) {
    EventLoopGroup bossGroup = new NioEventLoopGroup();
    EventLoopGroup workerGroup = new NioEventLoopGroup();
    try {
        ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup, workerGroup)
         .channel(NioServerSocketChannel.class)
         .childHandler(new ChannelInitializer<SocketChannel>() {
             @Override
             public void initChannel(SocketChannel ch) throws Exception {
                 System.out.println("Init channel");

                 ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {

                    @Override
                    public void channelRegistered(ChannelHandlerContext ctx) {
                        System.out.println("Channel registered");
                    }

                    @Override
                    public void channelActive(final ChannelHandlerContext ctx) {
                        System.out.println("Channel active");
                    }

                    @Override
                    public void channelRead(ChannelHandlerContext ctx, Object msg) {
                        System.out.println("Channel read");
                        ctx.writeAndFlush((ByteBuf) msg);
                    }

                    @Override
                    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
                        System.out.println("Channel exception caught");
                        cause.printStackTrace();
                        ctx.close();
                    }

                 });
             }
         })
         .option(ChannelOption.SO_BACKLOG, 128)
         .childOption(ChannelOption.SO_KEEPALIVE, true);

        ChannelFuture f;
        try {
            f = b.bind("127.0.0.1", 8080).sync();
            f.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    } finally {
        workerGroup.shutdownGracefully();
        bossGroup.shutdownGracefully();
    }
}

问题是我无法检测到连接建立的时刻。所有System.Out.Printlns仅在客户端向服务器发送某些信息后调用。这意味着在客户端向服务器发送数据之前，服务器不能向客户端发送任何数据。

null

null

有什么方法可以达到这样的行为？

Answer 1

您可以在客户端连接到服务器时发送一些数据，因此可以在channelRegistered或channelActive方法中使用CTX.WriteAndFlush(msg)。如果您的客户没有收到任何数据，您应该确保编码的类型是正确的。