用netty编写socket服务端，实现和多个客户端通信

要用 Netty 编写一个 Socket 服务端，实现和多个客户端通信，需要遵循以下步骤：

1. 创建 ServerBootstrap 实例并设置相关参数。

EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
            .channel(NioServerSocketChannel.class)
            .option(ChannelOption.SO_BACKLOG, 100)
            .handler(new LoggingHandler(LogLevel.INFO))
            .childHandler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ChannelPipeline pipeline = ch.pipeline();
                    // 添加处理器
                    pipeline.addLast(new MyServerHandler());
                }
            });

    // 绑定端口，开始接收进来的连接
    ChannelFuture f = b.bind(port).sync();

    // 等待服务器 socket 关闭 。
    // 在这个例子中，这不会发生，但你可以优雅地关闭你的服务器。
    f.channel().closeFuture().sync();
} finally {
    // 优雅地关闭线程池
    workerGroup.shutdownGracefully();
    bossGroup.shutdownGracefully();
}

2. 创建 ChannelInitializer，设置 ChannelPipeline。

public class MyServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 处理消息
        ByteBuf in = (ByteBuf) msg;
        System.out.println(in.toString(CharsetUtil.UTF_8));
        // 响应客户端
        ctx.write(in);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        // 刷新缓冲区
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        // 异常处理
        cause.printStackTrace();
        ctx.close();
    }
}

3. 在 ChannelInitializer 中添加自定义的处理器，例如 MyServerHandler。

public class MyServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        // 处理消息
        ByteBuf in = (ByteBuf) msg;
        System.out.println(in.toString(CharsetUtil.UTF_8));
        // 响应客户端
        ctx.write(in);
    }

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        // 刷新缓冲区
        ctx.flush();
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        // 异常处理
        cause.printStackTrace();
        ctx.close();
    }
}

4. 编写客户端程序，连接到服务端。

EventLoopGroup group = new NioEventLoopGroup();
try {
    Bootstrap b = new Bootstrap();
    b.group(group)
            .channel(NioSocketChannel.class)
            .option(ChannelOption.TCP_NODELAY, true)
            .handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ChannelPipeline pipeline = ch.pipeline();
                    // 添加处理器
                    pipeline.addLast(new MyClientHandler());
                }
            });

    // 连接服务器
    ChannelFuture f = b.connect(host, port).sync();

    // 发送消息
    ByteBuf buf = Unpooled.copiedBuffer("Hello, world!", CharsetUtil.UTF_8);
    f.channel().writeAndFlush(buf);

    // 等待直到连接关闭
    f.channel().closeFuture().sync();
} finally {
    // 优雅地关闭线程池
    group.shutdownGracefully();
}

这样，就可以使用 Netty 编写一个 Socket 服务端，实现和多个客户端通信。