netty 是建立在 java nio 之上的高性能异步事件驱动网络框架，它封装了底层的 channel、selector 和 buffer 等核心组件，解决了原生 nio 开发中常见的空轮询 bug、连接管理复杂以及编解码繁琐等问题。开发者在使用 netty 时，无需直接操作 selector 的注册与选择逻辑，而是通过 eventloop 和 channelpipeline 来声明式地处理 i/o 事件和业务逻辑。这种设计不仅保留了 java nio 的高吞吐特性，还大幅降低了并发网络编程的门槛。
Netty 如何封装 Java NIO 的核心组件
Netty 对 Java NIO 的封装主要体现在将底层通道抽象为统一的 Channel 接口，并将非阻塞 I/O 操作集成到线程模型中。在原生 NIO 中，开发者需要手动创建 ServerSocketChannel 并配置为非阻塞模式，然后将其注册到 Selector 上监听 OP_ACCEPT 事件。Netty 则通过 Bootstrap 类自动完成这些初始化工作，内部使用 NioServerSocketChannel 实现底层通信。对于数据读写，Netty 提供了 ByteBuf 替代原生的 ByteBuffer，解决了堆外内存管理和缓冲区扩容的问题。当 I/O 事件发生时，Netty 的 EventLoop 线程会接管后续的处理流程，避免了多线程竞争锁带来的性能损耗。
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
public class NettyNioExample {
public static void main(String[] args) throws InterruptedException {
// 创建两个 EventLoopGroup，一个用于接受客户端连接，一个用于处理 I/O 操作
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class) // 指定使用 NIO 传输方式
.childHandler(new MyChannelInitializer());
ChannelFuture f = b.bind(8080).sync();
f.channel().closeFuture().sync();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
上述代码展示了 Netty 启动服务器的基本结构。其中 NioEventLoopGroup 内部维护了一组线程，每个线程都关联一个 Selector。BossGroup 中的线程负责调用 ServerSocketChannel.accept() 获取新连接，而 WorkerGroup 中的线程则负责已建立连接的读写操作。这种分离设计使得高并发下的连接建立不会阻塞业务数据的处理。运行该程序后，服务器将在 8080 端口监听，一旦有客户端连接，相关的 I/O 事件将由 WorkerGroup 中的某个 EventLoop 线程异步处理。
立即学习“Java免费学习笔记（深入）”；
Netty 的线程模型如何解决原生 NIO 痛点
原生 NIO 开发中最显著的痛点是“惊群效应”和复杂的线程调度逻辑。在原生实现中，如果多个线程共享一个 Selector，会导致大量线程被唤醒但只有一个能成功获取连接，造成 CPU 浪费；如果每个线程拥有独立的 Selector，又难以平衡负载。Netty 采用 Reactor 线程模型，通过 NioEventLoop 实现了单线程多路复用。每个 NioEventLoop 实例只负责处理一组 Channel 的事件，确保同一时刻只有一个线程访问该 Channel 的状态，从而消除了同步锁的需求。此外，Netty 还提供了 Boss 和 Worker 线程池的分离，进一步提升了系统的可扩展性。
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
public class MyChannelInitializer extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel> {
@Override
protected void initChannel(SocketChannel ch) {
ch.pipeline().addLast(new SimpleChannelInboundHandler<ByteBuf>() {
@Override
protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) {
// 直接读取消息，无需手动管理缓冲区
System.out.println("Received: " + msg.toString(io.netty.util.CharsetUtil.UTF_8));
}
});
}
}
在 MyChannelInitializer 中，我们向 Pipeline 添加了一个处理器。当数据到达时，Netty 会自动从 Socket 读取字节流并填充到 ByteBuf 中，然后触发 channelRead0 方法。这个过程完全由 EventLoop 线程执行，开发者无需关心底层的 ByteBuffer 翻转或位置重置。相比原生 NIO 中需要手动编写循环来检查 selector.select() 的返回值并遍历 KeySet，Netty 的代码更加简洁且不易出错。这种机制确保了在高负载下，系统能够稳定地处理成千上万条并发连接，而不会出现因线程切换频繁导致的性能下降。
Netty 中 ByteBuf 与 Java NIO ByteBuffer 的区别
Netty 引入 ByteBuf 主要是为了解决 ByteBuffer 在频繁读写时的索引管理问题。原生 ByteBuffer 具有 position 和 limit 属性，每次读写后都需要手动调用 flip() 或 clear() 来调整状态，这在处理粘包拆包时极易引发错误。ByteBuf 则引入了 readerIndex 和 writerIndex 两个指针，分别标记已读和已写的位置，使得数据流的追踪更加直观。此外，ByteBuf 支持复合缓冲区（CompositeByteBuf），可以将多个缓冲区逻辑上合并为一个，避免内存拷贝。它还提供了引用计数机制，允许开发者显式控制内存释放，既可以使用堆内内存也可以使用堆外内存（Direct Memory），从而减少 GC 压力。
