好的，下面是一篇关于 Netty基础入门 的详细介绍，适合初学者快速掌握 Netty 的核心概念和基本用法。

Netty 基础入门指南

一、什么是 Netty？

Netty 是一个基于 Java 的异步事件驱动网络应用框架，用于快速开发高性能、高可靠性的网络服务器和客户端程序。它封装了底层的 Java NIO，简化了网络编程的复杂性。

二、Netty 的核心特点

• 异步非阻塞：基于事件驱动，性能高效。
• 高性能：减少系统调用和内存复制。
• 易用性强：丰富的 API 设计和强大的 ChannelPipeline 机制。
• 支持多种协议：TCP/UDP，支持自定义协议编码解码。
• 可扩展性好：通过 Handler 机制灵活处理业务逻辑。

三、Netty 的核心组件

四、Netty 编程模型简述

• 事件驱动：所有操作均为异步，通过事件回调通知结果。
• Handler链条：通过 ChannelPipeline 组织多个 ChannelHandler，完成数据处理、编解码、业务逻辑。
• 线程模型：分为 Boss 线程（负责连接建立）和 Worker 线程（负责读写数据）。

五、简单的 Netty 服务器示例

public class NettyServer {

    public static void main(String[] args) throws Exception {
        // 创建两个线程组：boss 负责接收连接，worker 负责处理数据
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class) // 使用 NIO 的服务端通道实现
                .childHandler(new ChannelInitializer<SocketChannel>() { // 处理新连接的 Handler
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
                        ChannelPipeline pipeline = ch.pipeline();
                        // 添加自定义处理器
                        pipeline.addLast(new SimpleServerHandler());
                    }
                });

            // 绑定端口，开始接受连接
            ChannelFuture future = bootstrap.bind(8080).sync();
            System.out.println("Netty 服务器启动，监听端口 8080");

            // 等待服务器关闭
            future.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

六、自定义处理器示例

public class SimpleServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        ByteBuf buf = (ByteBuf) msg;
        byte[] bytes = new byte[buf.readableBytes()];
        buf.readBytes(bytes);

        String received = new String(bytes, CharsetUtil.UTF_8);
        System.out.println("服务器收到消息: " + received);

        // 回复客户端
        ctx.writeAndFlush(Unpooled.copiedBuffer("消息已收到", CharsetUtil.UTF_8));
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

七、Netty 客户端简单示例

public class NettyClient {

    public static void main(String[] args) throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();

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

            // 连接服务器
            ChannelFuture future = bootstrap.connect("localhost", 8080).sync();

            // 发送消息
            future.channel().writeAndFlush(Unpooled.copiedBuffer("Hello Netty", CharsetUtil.UTF_8));

            // 等待关闭
            future.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully();
        }
    }
}

八、简单客户端 Handler 示例

public class SimpleClientHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {
        ByteBuf buf = (ByteBuf) msg;
        byte[] bytes = new byte[buf.readableBytes()];
        buf.readBytes(bytes);

        System.out.println("客户端收到消息: " + new String(bytes, CharsetUtil.UTF_8));
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

九、总结

• Netty 是高性能网络编程框架，封装 NIO 异步非阻塞编程。
• 通过 Bootstrap/ServerBootstrap 启动客户端/服务端。
• ChannelPipeline 和 ChannelHandler 是处理数据的核心。
• 事件驱动模型，提升性能，适合高并发场景。