java netty 实现tcp通信

Java Netty 是一款高性能、异步事件驱动的网络框架，主要设计用于简化网络服务器和客户端的编程，并且能够处理高并发连接。它基于 NIO（非阻塞 I/O）技术，利用多路复用（例如 Selector）实现了对单个线程高效地管理大量并发连接的能力。Netty 框架提供了一系列高级功能，包括缓冲区管理和协议编码/解码（Codec），使得开发者可以专注于业务逻辑而无需过多关注底层网络细节。

### Java Netty 实现 TCP 通信的基本步骤：

#### 1. **构建项目**
- 创建一个新的 Java 项目，在 Maven 或 Gradle 中添加相应的依赖库 `netty-all` 和 `netty-tcnative-full`。

#### 2. **配置服务端**
- 定义一个服务端 `ServerBootstrap` 类型的对象，用于初始化服务端实例并绑定到特定的 IP 地址和端口。
- 使用 `ChannelPipelineFactory` 配置管道，这通常包含了接收数据、处理数据以及发送响应的过程。
- 设置必要的处理器，如 `ServerSocketChannelHandler` 负责接收新连接请求，然后创建新的 `Channel` 对象。
- 启动服务端，监听指定端口并开始接受连接。

public class MyServer {
    public static void main(String[] args) throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup)
             .channel(NioServerSocketChannel.class)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 protected void initChannel(SocketChannel ch) throws Exception {
                     ChannelPipeline p = ch.pipeline();
                     // 添加你的处理器链在这里，比如定义的自定义编码器Decoder和解码器Encoder等
                     p.addLast(new YourCustomDecoder());
                     p.addLast(new YourCustomEncoder());
                     p.addLast("handler", new MyServerHandler());
                 }
             })
             .option(ChannelOption.SO_BACKLOG, 100)
             .childOption(ChannelOption.SO_KEEPALIVE, true);

            b.bind(8080).sync().channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
        }
    }
}

#### 3. **配置客户端**
- 定义一个客户端类，使用 `ClientBootstrap` 初始化客户端实例。
- 设置 `ChannelFutureListener` 来处理连接状态的变化。
- 发送数据到服务器并读取服务器返回的数据。

public class MyClient {
    private final String host;
    private final int port;

    public MyClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void connect() throws Exception {
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ClientBootstrap b = new ClientBootstrap();
            b.group(workerGroup);
            b.channel(NioSocketChannel.class);
            b.option(ChannelOption.SO_KEEPALIVE, true);
            b.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                protected void initChannel(SocketChannel ch) throws Exception {
                    ChannelPipeline p = ch.pipeline();
                    // 添加你的处理器链，比如定义的自定义编码器Decoder和解码器Encoder等
                    p.addLast(new YourCustomDecoder());
                    p.addLast(new YourCustomEncoder());
                    p.addLast("handler", new MyClientHandler());
                }
            });

            SocketAddress remoteAddress = new InetSocketAddress(host, port);
            ChannelFuture f = b.connect(remoteAddress);
            f.syncUninterruptibly(); // 等待连接完成

            // 如果需要，从这里开始发送数据和接收响应的操作
        } finally {
            workerGroup.shutdownGracefully();
        }
    }
}

#### 4. **处理数据和异常**
- 编写自定义的编码器和解码器，以及处理异常的逻辑。

###