netty tcp

Netty 是一款高性能、异步事件驱动的网络应用框架，可以用于快速开发可扩展的服务器和客户端程序。在 Netty 中，TCP 协议是默认支持的，因为它提供了可靠的、面向连接的数据传输方式。如果你想使用 Netty 来编写 TCP 服务器或客户端，可以通过以下步骤来实现：

1. 引入 Netty 的依赖：

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.48.Final</version>
</dependency>

2. 编写服务器端代码：

EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap bootstrap = new ServerBootstrap();
    bootstrap.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     ch.pipeline().addLast(new YourServerHandler());
                 }
             })
             .option(ChannelOption.SO_BACKLOG, 128)
             .childOption(ChannelOption.SO_KEEPALIVE, true);

    ChannelFuture future = bootstrap.bind(port).sync();
    future.channel().closeFuture().sync();
} finally {
    workerGroup.shutdownGracefully();
    bossGroup.shutdownGracefully();
}

3. 编写客户端代码：

EventLoopGroup group = new NioEventLoopGroup();
try {
    Bootstrap bootstrap = new Bootstrap();
    bootstrap.group(group)
             .channel(NioSocketChannel.class)
             .handler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     ch.pipeline().addLast(new YourClientHandler());
                 }
             });

    ChannelFuture future = bootstrap.connect(host, port).sync();
    future.channel().closeFuture().sync();
} finally {
    group.shutdownGracefully();
}

其中，`YourServerHandler` 和 `YourClientHandler` 是自定义的处理器，用于接收和处理数据。在处理器中可以使用 Netty 提供的各种工具类来简化开发，例如 `ByteBuf`、`ChannelHandlerContext` 等。