：架构整体全貌 —— 模块划分与核心组件关系)
文章目录一、模块全景六大核心模块的分层组织1.1 模块分层架构1.2 六大核心模块职责界定二、核心组件关系五大组件如何协作完成一次请求2.1 五大核心组件一览2.2 组件协作流程2.3 Reactor 主从多线程模型映射三、IoHandler/IoHandle 分离架构3.1 传统 EventLoop 模型的局限性3.2 IoHandler/IoHandle 三层分离3.3 架构优势四、设计原则总结4.1 六大设计哲学4.2 核心价值全文小结Netty 是一个异步事件驱动的网络应用框架用于快速开发高性能、高可靠性的网络服务端与客户端。它并非又一个网络框架而是对 Java NIO 的深度封装与增强将 Reactor 模型、零拷贝、内存池化、责任链等经典设计模式工程化落地被广泛应用于 gRPC、Dubbo、RocketMQ、Elasticsearch 等主流中间件。本系列文章选择 Netty 4.2.16.Final 作为分析版本。4.2.x 是 2025 年发布的新一代架构引入了IoHandler/IoHandle分离、AdaptiveByteBufAllocator自适应分配器、io_uring 传输、HTTP/3基于 QUIC 等核心能力代表了 Netty 框架的最新演进方向。阅读本系列建议具备以下前提理解 Java NIO 核心组件Selector、Channel、ByteBuffer了解 Reactor 线程模型单线程、多线程、主从多线程的基本概念最好有 Netty 基本使用经验能搭建简单的 Server/Client。本篇作为系列开篇将从宏观视角回答以下四个核心问题六大核心模块common、buffer、transport、handler、codec-base、resolver各自承担什么职责它们之间有什么依赖关系Bootstrap、EventLoop、Channel、Pipeline、ByteBuf这五大核心组件如何协作完成一次网络请求Reactor 主从多线程模型在 Netty 中是如何映射的Boss Group 和 Worker Group 的职责边界在哪里IoHandler/IoHandle分离架构相比传统EventLoop模型带来了什么设计优势一、模块全景六大核心模块的分层组织1.1 模块分层架构Netty 的源码工程按层次划分为八大层级从底层的公共工具到顶层的应用示例每一层职责清晰、边界明确各模块遵循严格自底向上的依赖关系common作为最底层基础设施不依赖任何其他 Netty 模块buffer仅依赖commontransport依赖buffer和commonhandler和codec-base依赖transport协议编解码层则依赖codec-base和handler。每一层只向下依赖绝不允许反向引用这种设计保证了模块的内聚和可替换性。在横向维度上每个层级支持可插拔替换。以传输层为例transport-native-epoll、transport-native-kqueue和transport-native-io_uring是三个独立的原生传输模块分别对应 Linux Epoll、macOS/BSD KQueue 和 Linux io_uring 三种底层 IO 多路复用机制。它们通过IoHandlerFactory工厂模式与transport核心解耦用户可通过选择不同的EventLoopGroup实现NioEventLoopGroup/EpollEventLoopGroup/KQueueEventLoopGroup/IoUringEventLoopGroup来切换底层传输。协议编解码层是模块最丰富的一层覆盖了 HTTP/1.1、HTTP/2、HTTP/3(QUIC)、MQTT、Redis、SOCKS、STOMP、Memcache、SMTP、Protobuf 等十余种协议几乎囊括了主流网络通信协议的全部场景。1.2 六大核心模块职责界定从模块全景中我们提炼出六大核心模块它们是理解 Netty 架构的起点模块artifactId源码路径核心职责commonnetty-commoncommon/src/main/java/io/netty/util/FastThreadLocal 高性能线程本地变量、Recycler 对象池、HashedWheelTimer 时间轮、AttributeMap 属性映射、ReferenceCounted 引用计数、ResourceLeakDetector 内存泄漏检测buffernetty-bufferbuffer/src/main/java/io/netty/buffer/ByteBuf 双索引读写分离缓冲区、PooledByteBufAllocator 池化分配器、CompositeByteBuf 零拷贝聚合、AdaptiveByteBufAllocator 自适应分配transportnetty-transporttransport/src/main/java/io/netty/Bootstrap/ServerBootstrap 启动引导、Channel 连接抽象、ChannelPipeline 责任链、IoEventLoop 事件循环、IoHandler/IoHandle IO 抽象handlernetty-handlerhandler/src/main/java/io/netty/handler/SslHandler TLS 加密、IdleStateHandler 空闲检测、ChunkedWriteHandler 流式传输、TrafficShapingHandler 流量整形、LoggingHandler 日志codec-basenetty-codeccodec-base/src/main/java/io/netty/handler/codec/ByteToMessageDecoder 解码框架、MessageToByteEncoder 编码框架、LengthFieldBasedFrameDecoder 帧解码器、DelimiterBasedFrameDecoder 分隔符解码器resolvernetty-resolverresolver/src/main/java/io/netty/resolver/AddressResolver 地址解析抽象、DnsNameResolver DNS 解析、HostsFileEntriesResolver hosts 文件解析common模块是整个框架的基石。它提供了FastThreadLocal基于数组索引的线程本地变量比 JDK 的ThreadLocal性能更高、Recycler基于WeakOrderQueue的轻量级对象池避免频繁 GC、HashedWheelTimer基于哈希时间轮的延迟任务调度器等基础设施这些工具类被上层所有模块共享。buffer模块定义了ByteBuf——Netty 的数据容器它具有读写双索引readerIndex/writerIndex分离、引用计数自动回收、池化复用等特性是对 JDKByteBuffer的根本性改进。transport模块是整个架构的核心枢纽。它定义了Channel、EventLoop、Pipeline等核心抽象所有上层模块handler、codec、resolver都依赖它提供的编程模型。transport不关心具体用什么 IO 模型NIO/Epoll/KQueue/io_uring这由IoHandler/IoHandle抽象层在运行时动态绑定。二、核心组件关系五大组件如何协作完成一次请求2.1 五大核心组件一览理解 Netty 架构的关键在于理解以下五个核心组件及其协作关系组件核心接口/类职责生命周期BootstrapBootstrap / ServerBootstrap启动引导配置 EventLoopGroup、Channel 类型、Handler一次性启动完成后不再需要EventLoopIoEventLoop / SingleThreadIoEventLoop事件循环引擎每个线程绑定一个 EventLoop处理 IO 事件和任务随 EventLoopGroup 创建应用关闭时销毁ChannelChannel / NioSocketChannel网络连接抽象每个连接对应一个 Channel连接建立时创建连接关闭时销毁PipelineChannelPipeline责任链有序组织 ChannelHandler处理入站/出站事件与 Channel 绑定随 Channel 创建/销毁ByteBufByteBuf数据容器双索引读写分离引用计数管理每次请求分配处理完成后 releaseBootstrap是组装的起点。它将EventLoopGroup、Channel类型、Handler等配置项聚合在一起最终通过bind()或connect()触发整个启动流程。ServerBootstrap继承AbstractBootstrap额外引入了childGroupWorker 线程组、childHandler子 Channel 处理器和childOptions子 Channel 配置项三个维度io.netty.bootstrap.ServerBootstrappublicclassServerBootstrapextendsAbstractBootstrapServerBootstrap,ServerChannel{privatefinalMapChannelOption?,ObjectchildOptionsnewLinkedHashMapChannelOption?,Object();privatefinalMapAttributeKey?,ObjectchildAttrsnewConcurrentHashMapAttributeKey?,Object();privatevolatileEventLoopGroupchildGroup;privatevolatileChannelHandlerchildHandler;Channel是连接抽象的核心。在 Netty 4.2.x 中Channel接口继承了三个关键接口——AttributeMap属性存储、ChannelOutboundInvoker出站操作入口和Comparable有序性体现了数据附属、出站驱动和有序管理的设计理念io.netty.channel.ChannelpublicinterfaceChannelextendsAttributeMap,ChannelOutboundInvoker,ComparableChannel{ChannelIdid();EventLoopeventLoop();Channelparent();ChannelConfigconfig();booleanisOpen();booleanisRegistered();booleanisActive();ChannelMetadatametadata();SocketAddresslocalAddress();SocketAddressremoteAddress();ChannelFuturecloseFuture();Unsafeunsafe();ChannelPipelinepipeline();EventLoop是执行引擎。4.2.x 中核心的SingleThreadIoEventLoop持有一个IoHandler实例负责在事件循环中驱动 IO 调度。SingleThreadIoEventLoop的run()方法展示了事件循环的核心节奏初始化IoHandler→ 循环执行runIo()IO 处理→runAllTasks()任务处理→ 检查关闭状态io.netty.channel.SingleThreadIoEventLoop#run// 事件循环主循环IO 处理 任务处理交替进行protectedvoidrun(){assertinEventLoop();ioHandler.initialize();do{runIo();if(isShuttingDown()){ioHandler.prepareToDestroy();}// 在最大时间配额内运行所有待处理任务然后回到 IO 轮询runAllTasks(maxTaskProcessingQuantumNs);}while(!confirmShutdown()!canSuspend());}2.2 组件协作流程五大组件如何协作完成一次网络请求下面以服务端为例用一张时序图展示从启动到响应返回的完整链路上面的时序图清晰地展示了六个阶段的协作链路启动阶段用户通过ServerBootstrap的流式 API 配置BossGroup、WorkerGroup、Channel类型和childHandler然后调用bind(port)触发启动。初始化阶段AbstractBootstrap.initAndRegister()是启动的核心。它首先通过ChannelFactory.newChannel()创建ServerSocketChannel实例然后调用init(channel)初始化其Pipeline。在ServerBootstrap.init()中最关键的一步是向Pipeline添加ServerBootstrapAcceptor——这是一个特殊的ChannelInboundHandler负责将新接入的连接分发给 Worker Groupio.netty.bootstrap.ServerBootstrap#initvoidinit(Channelchannel)throwsThrowable{setChannelOptions(channel,newOptionsArray(),logger);setAttributes(channel,newAttributesArray());ChannelPipelinepchannel.pipeline();finalEventLoopGroupcurrentChildGroupchildGroup;finalChannelHandlercurrentChildHandlerchildHandler;finalEntryChannelOption?,Object[]currentChildOptionsnewOptionsArray(childOptions);finalEntryAttributeKey?,Object[]currentChildAttrsnewAttributesArray(childAttrs);p.addLast(newChannelInitializerChannel(){OverridepublicvoidinitChannel(finalChannelch){finalChannelPipelinepipelinech.pipeline();ChannelHandlerhandlerconfig.handler();if(handler!null){pipeline.addLast(handler);}ch.eventLoop().execute(newRunnable(){Overridepublicvoidrun(){pipeline.addLast(newServerBootstrapAcceptor(ch,currentChildGroup,currentChildHandler,currentChildOptions,currentChildAttrs,extensions));}});}});}注册阶段initAndRegister()调用config().group().register(channel)将ServerSocketChannel注册到 Boss EventLoop。注册完成后doBind0()通过channel.bind(localAddress)触发底层 JDKServerSocketChannel.bind()并将OP_ACCEPT注册到Selector。新连接接入阶段Boss EventLoop 的IoHandler检测到OP_ACCEPT事件后ServerSocketChannel的accept()方法创建NioSocketChannel。随后ServerBootstrapAcceptor.channelRead()被触发它将childHandler添加到新连接的Pipeline然后通过childGroup.register(child)将连接注册到 Worker EventLoopio.netty.bootstrap.ServerBootstrap.ServerBootstrapAcceptor#channelReadpublicvoidchannelRead(ChannelHandlerContextctx,Objectmsg){finalChannelchild(Channel)msg;// 将用户配置的 childHandler 添加到新连接的 Pipelinechild.pipeline().addLast(childHandler);setChannelOptions(child,childOptions,logger);setAttributes(child,childAttrs);// 注册到 Worker EventLoop实现连接负载均衡childGroup.register(child).addListener(future-{if(!future.isSuccess()){forceClose(child,future.cause());}});}数据读写阶段Worker EventLoop 的IoHandler检测到OP_READ事件后NioSocketChannel将数据读取到ByteBuf然后通过ChannelPipeline.fireChannelRead()沿 Pipeline 的 Inbound 方向传播给业务 Handler。响应写入阶段业务 Handler 处理完数据后调用ctx.writeAndFlush(response)响应沿 Pipeline 的 Outbound 方向传播最终由HeadContext调用unsafe.write()将数据入队到ChannelOutboundBufferflush()触发底层 Socket 发送。2.3 Reactor 主从多线程模型映射Netty 的 Reactor 模型映射非常直观Boss GroupMainReactor通常包含一个或多个NioEventLoop每个持有一个NioIoHandler。它只负责ServerSocketChannel的OP_ACCEPT事件——接受新连接然后通过ServerBootstrapAcceptor将新连接分发给 Worker Group。Boss 线程不处理任何读写操作职责单一保证新连接接入的低延迟。Worker GroupSubReactor包含多个NioEventLoop每个持有一个NioIoHandler。它负责已建立连接的OP_READ/OP_WRITE事件以及 Pipeline 中所有 Handler 的业务逻辑执行。每个 Worker 线程可以管理成千上万个连接。连接分发策略ServerBootstrapAcceptor通过childGroup.next()轮询选择 Worker EventLoop。next()方法通过MultithreadEventExecutorGroup的chooser机制实现轮询底层使用AtomicInteger递增取模保证连接均匀分布到所有 Worker 线程。三、IoHandler/IoHandle 分离架构3.1 传统 EventLoop 模型的局限性在 Netty 4.1.x 中NioEventLoop同时承担了 IO 调度Selector.select()、SelectionKey管理和事件循环节奏控制select → processSelectedKeys → runAllTasks两项职责。这种耦合带来了两个问题传输层扩展困难如果要新增 Epoll 或 io_uring 传输需要重写整个EventLoop及其上层集成代码因为 IO 调度逻辑与事件循环逻辑紧密耦合在一起。职责边界模糊NioEventLoop既要知道何时做 IO事件循环节奏也要知道怎么做 IOSelector 操作违反了单一职责原则。3.2 IoHandler/IoHandle 三层分离Netty 4.2.x 通过引入IoHandler/IoHandle/IoEvent三层抽象将 IO 处理从EventLoop中彻底分离三个层次的职责泾渭分明IoEventLoop只负责事件循环节奏——runIo()委托给IoHandler.run()→runAllTasks()处理任务队列。它不关心底层是 Selector 还是 Epoll只关心何时做 IO和何时做任务。IoHandler负责 IO 调度。NioIoHandler内部持有Selector和SelectionKey集合提供run(IoHandlerContext)方法执行 select/poll 操作将就绪事件封装为IoEvent分发给对应的IoHandle。IoHandler是IoHandle的注册中心通过register(IoHandle)方法管理所有 IO 资源。以下是IoHandler接口的核心定义io.netty.channel.IoHandlerpublicinterfaceIoHandler{defaultvoidinitialize(){}intrun(IoHandlerContextcontext);defaultvoidprepareToDestroy(){}defaultvoiddestroy(){}IoRegistrationregister(IoHandlehandle)throwsException;voidwakeup();booleanisCompatible(Class?extendsIoHandlehandleType);}IoHandle封装底层 IO 资源SelectableChannel/fd/epoll_event通过IoRegistration向IoHandler注册感兴趣的事件。当IoHandler检测到就绪事件时回调IoHandle.handle(IoRegistration, IoEvent)执行实际的数据读写io.netty.channel.IoHandlepublicinterfaceIoHandleextendsAutoCloseable{voidhandle(IoRegistrationregistration,IoEventioEvent);defaultvoidregistered(){}defaultvoidunregistered(){}voidclose()throwsException;}IoEventIoEvent是 IO 事件的标记接口IoOps是 IO 操作的标记接口两者均为空接口。具体实现类如NioIoEvent和NioIoOps扩展了这两个标记接口NioIoEvent封装了就绪的NioIoOps信息READ/WRITE/CONNECT/ACCEPT由NioIoHandler检测到就绪事件后分发给NioIoHandle.handle()。不同传输实现有各自的IoEvent/IoOps扩展方式保证了事件传递的标准化。3.3 架构优势三层分离带来了三个显著优势可插拔传输层新增 io_uring 传输只需实现IoHandlerIoHandleIoEvent三个接口无需修改IoEventLoop或任何上层代码。IoHandlerFactory工厂模式在创建EventLoopGroup时注入对应的IoHandler实现。职责清晰每个接口只做一件事。IoEventLoop管理事件循环节奏IoHandler管理 IO 调度IoHandle管理 IO 资源。这使得代码的阅读、测试和维护都更加直观。测试友好可以单独 MockIoHandler或IoHandle在单元测试中模拟 IO 事件而不依赖真实网络环境。IoHandler的run()方法接受IoHandlerContext参数允许测试代码精确控制 select 行为和超时时间。四、设计原则总结4.1 六大设计哲学贯穿 Netty 整个架构的是以下六大设计原则原则体现位置说明异步非阻塞IoEventLoop Future/Promise所有 IO 操作异步返回 Future不阻塞调用线程。Channel 接口的 write()、connect()、bind() 等所有出站操作均返回 ChannelFuture事件驱动ChannelPipeline ChannelHandler入站事件channelRead、channelActive和出站事件write、flush沿 Pipeline 双向传播Handler 按需处理责任链模式ChannelPipeline 双向链表每个 Handler 独立处理一个关注点编解码、SSL、业务逻辑可插拔、可复用、可动态增删零拷贝CompositeByteBuf FileRegion Epoll writev 零拷贝发送减少数据在堆内/堆外/内核之间的拷贝次数。CompositeByteBuf 将多个 ByteBuf 虚拟聚合为零拷贝视图内存池化PooledByteBufAllocator Recycler复用 ByteBuf 和内部对象减少 GC 压力和内存分配开销。AdaptiveByteBufAllocator 根据历史分配大小动态调整池化策略可插拔传输IoHandler/IoHandle IoHandlerFactory 工厂模式同一套 Channel/EventLoop/Pipeline API底层自动适配 NIO/Epoll/KQueue/io_uring运行时按平台选择最优实现4.2 核心价值六大设计原则的工程化落地造就了 Netty 的核心竞争力高性能零拷贝减少 CPU 开销内存池化降低 GC 频率无锁设计减少线程竞争原生传输消除 JNI 调用开销。高扩展Pipeline 责任链支持任意 Handler 组合IoHandler传输层抽象支持新增传输实现codec 协议层支持按需引入协议模块。易用性Bootstrap流式 API 降低启动门槛ChannelFuture异步通知简化编程模型丰富的内置协议支持减少重复开发。稳定性内置 Epoll 空轮询 bug 修复、内存泄漏检测ResourceLeakDetector、优雅关闭机制、流量整形保障生产环境的长期稳定运行。全文小结本文聚焦 Netty 4.2.x 源码工程的架构整体全貌从模块组织和核心组件协作两个维度建立了 Netty 源码阅读的全局认知。在模块组织方面Netty 的六大核心模块按common → buffer → transport → handler/codec → 协议层的层次自底向上依赖各司其职common提供基础设施FastThreadLocal、Recycler、HashedWheelTimerbuffer提供数据容器ByteBuf双索引 池化transport提供网络抽象Bootstrap、Channel、EventLoop、Pipelinehandler提供通用处理SSL、空闲检测、流量整形codec-base提供编解码框架resolver提供地址解析。原生传输模块通过IoHandlerFactory工厂模式与transport解耦用户通过选择不同的EventLoopGroup实现来切换底层传输。在核心组件协作方面Bootstrap作为启动入口EventLoop作为执行引擎Channel作为连接抽象Pipeline作为事件处理链ByteBuf作为数据容器五者通过IoHandler/IoHandle三层分离架构协作完成一次网络请求。Reactor 主从多线程模型通过 Boss Group 处理OP_ACCEPT、Worker Group 处理OP_READ/OP_WRITE的方式映射到 Netty 中。IoHandler/IoHandle分离架构是 4.2.x 最核心的架构演进它将 IO 调度从EventLoop中解耦实现了传输层的完全可插拔。原创不易如果本文对您有帮助带来了些许灵感或启发烦请动动小手点赞、关注、转发、收藏。这是作者持续更新的动力源泉衷心感谢您的支持。我会尽量在工作之余为大家带来更高品质的内容努力保持周更。
Netty 4.2.x 源码深度解析 (一)：架构整体全貌 —— 模块划分与核心组件关系
发布时间：2026/7/23 3:07:03
文章目录一、模块全景六大核心模块的分层组织1.1 模块分层架构1.2 六大核心模块职责界定二、核心组件关系五大组件如何协作完成一次请求2.1 五大核心组件一览2.2 组件协作流程2.3 Reactor 主从多线程模型映射三、IoHandler/IoHandle 分离架构3.1 传统 EventLoop 模型的局限性3.2 IoHandler/IoHandle 三层分离3.3 架构优势四、设计原则总结4.1 六大设计哲学4.2 核心价值全文小结Netty 是一个异步事件驱动的网络应用框架用于快速开发高性能、高可靠性的网络服务端与客户端。它并非又一个网络框架而是对 Java NIO 的深度封装与增强将 Reactor 模型、零拷贝、内存池化、责任链等经典设计模式工程化落地被广泛应用于 gRPC、Dubbo、RocketMQ、Elasticsearch 等主流中间件。本系列文章选择 Netty 4.2.16.Final 作为分析版本。4.2.x 是 2025 年发布的新一代架构引入了IoHandler/IoHandle分离、AdaptiveByteBufAllocator自适应分配器、io_uring 传输、HTTP/3基于 QUIC 等核心能力代表了 Netty 框架的最新演进方向。阅读本系列建议具备以下前提理解 Java NIO 核心组件Selector、Channel、ByteBuffer了解 Reactor 线程模型单线程、多线程、主从多线程的基本概念最好有 Netty 基本使用经验能搭建简单的 Server/Client。本篇作为系列开篇将从宏观视角回答以下四个核心问题六大核心模块common、buffer、transport、handler、codec-base、resolver各自承担什么职责它们之间有什么依赖关系Bootstrap、EventLoop、Channel、Pipeline、ByteBuf这五大核心组件如何协作完成一次网络请求Reactor 主从多线程模型在 Netty 中是如何映射的Boss Group 和 Worker Group 的职责边界在哪里IoHandler/IoHandle分离架构相比传统EventLoop模型带来了什么设计优势一、模块全景六大核心模块的分层组织1.1 模块分层架构Netty 的源码工程按层次划分为八大层级从底层的公共工具到顶层的应用示例每一层职责清晰、边界明确各模块遵循严格自底向上的依赖关系common作为最底层基础设施不依赖任何其他 Netty 模块buffer仅依赖commontransport依赖buffer和commonhandler和codec-base依赖transport协议编解码层则依赖codec-base和handler。每一层只向下依赖绝不允许反向引用这种设计保证了模块的内聚和可替换性。在横向维度上每个层级支持可插拔替换。以传输层为例transport-native-epoll、transport-native-kqueue和transport-native-io_uring是三个独立的原生传输模块分别对应 Linux Epoll、macOS/BSD KQueue 和 Linux io_uring 三种底层 IO 多路复用机制。它们通过IoHandlerFactory工厂模式与transport核心解耦用户可通过选择不同的EventLoopGroup实现NioEventLoopGroup/EpollEventLoopGroup/KQueueEventLoopGroup/IoUringEventLoopGroup来切换底层传输。协议编解码层是模块最丰富的一层覆盖了 HTTP/1.1、HTTP/2、HTTP/3(QUIC)、MQTT、Redis、SOCKS、STOMP、Memcache、SMTP、Protobuf 等十余种协议几乎囊括了主流网络通信协议的全部场景。1.2 六大核心模块职责界定从模块全景中我们提炼出六大核心模块它们是理解 Netty 架构的起点模块artifactId源码路径核心职责commonnetty-commoncommon/src/main/java/io/netty/util/FastThreadLocal 高性能线程本地变量、Recycler 对象池、HashedWheelTimer 时间轮、AttributeMap 属性映射、ReferenceCounted 引用计数、ResourceLeakDetector 内存泄漏检测buffernetty-bufferbuffer/src/main/java/io/netty/buffer/ByteBuf 双索引读写分离缓冲区、PooledByteBufAllocator 池化分配器、CompositeByteBuf 零拷贝聚合、AdaptiveByteBufAllocator 自适应分配transportnetty-transporttransport/src/main/java/io/netty/Bootstrap/ServerBootstrap 启动引导、Channel 连接抽象、ChannelPipeline 责任链、IoEventLoop 事件循环、IoHandler/IoHandle IO 抽象handlernetty-handlerhandler/src/main/java/io/netty/handler/SslHandler TLS 加密、IdleStateHandler 空闲检测、ChunkedWriteHandler 流式传输、TrafficShapingHandler 流量整形、LoggingHandler 日志codec-basenetty-codeccodec-base/src/main/java/io/netty/handler/codec/ByteToMessageDecoder 解码框架、MessageToByteEncoder 编码框架、LengthFieldBasedFrameDecoder 帧解码器、DelimiterBasedFrameDecoder 分隔符解码器resolvernetty-resolverresolver/src/main/java/io/netty/resolver/AddressResolver 地址解析抽象、DnsNameResolver DNS 解析、HostsFileEntriesResolver hosts 文件解析common模块是整个框架的基石。它提供了FastThreadLocal基于数组索引的线程本地变量比 JDK 的ThreadLocal性能更高、Recycler基于WeakOrderQueue的轻量级对象池避免频繁 GC、HashedWheelTimer基于哈希时间轮的延迟任务调度器等基础设施这些工具类被上层所有模块共享。buffer模块定义了ByteBuf——Netty 的数据容器它具有读写双索引readerIndex/writerIndex分离、引用计数自动回收、池化复用等特性是对 JDKByteBuffer的根本性改进。transport模块是整个架构的核心枢纽。它定义了Channel、EventLoop、Pipeline等核心抽象所有上层模块handler、codec、resolver都依赖它提供的编程模型。transport不关心具体用什么 IO 模型NIO/Epoll/KQueue/io_uring这由IoHandler/IoHandle抽象层在运行时动态绑定。二、核心组件关系五大组件如何协作完成一次请求2.1 五大核心组件一览理解 Netty 架构的关键在于理解以下五个核心组件及其协作关系组件核心接口/类职责生命周期BootstrapBootstrap / ServerBootstrap启动引导配置 EventLoopGroup、Channel 类型、Handler一次性启动完成后不再需要EventLoopIoEventLoop / SingleThreadIoEventLoop事件循环引擎每个线程绑定一个 EventLoop处理 IO 事件和任务随 EventLoopGroup 创建应用关闭时销毁ChannelChannel / NioSocketChannel网络连接抽象每个连接对应一个 Channel连接建立时创建连接关闭时销毁PipelineChannelPipeline责任链有序组织 ChannelHandler处理入站/出站事件与 Channel 绑定随 Channel 创建/销毁ByteBufByteBuf数据容器双索引读写分离引用计数管理每次请求分配处理完成后 releaseBootstrap是组装的起点。它将EventLoopGroup、Channel类型、Handler等配置项聚合在一起最终通过bind()或connect()触发整个启动流程。ServerBootstrap继承AbstractBootstrap额外引入了childGroupWorker 线程组、childHandler子 Channel 处理器和childOptions子 Channel 配置项三个维度io.netty.bootstrap.ServerBootstrappublicclassServerBootstrapextendsAbstractBootstrapServerBootstrap,ServerChannel{privatefinalMapChannelOption?,ObjectchildOptionsnewLinkedHashMapChannelOption?,Object();privatefinalMapAttributeKey?,ObjectchildAttrsnewConcurrentHashMapAttributeKey?,Object();privatevolatileEventLoopGroupchildGroup;privatevolatileChannelHandlerchildHandler;Channel是连接抽象的核心。在 Netty 4.2.x 中Channel接口继承了三个关键接口——AttributeMap属性存储、ChannelOutboundInvoker出站操作入口和Comparable有序性体现了数据附属、出站驱动和有序管理的设计理念io.netty.channel.ChannelpublicinterfaceChannelextendsAttributeMap,ChannelOutboundInvoker,ComparableChannel{ChannelIdid();EventLoopeventLoop();Channelparent();ChannelConfigconfig();booleanisOpen();booleanisRegistered();booleanisActive();ChannelMetadatametadata();SocketAddresslocalAddress();SocketAddressremoteAddress();ChannelFuturecloseFuture();Unsafeunsafe();ChannelPipelinepipeline();EventLoop是执行引擎。4.2.x 中核心的SingleThreadIoEventLoop持有一个IoHandler实例负责在事件循环中驱动 IO 调度。SingleThreadIoEventLoop的run()方法展示了事件循环的核心节奏初始化IoHandler→ 循环执行runIo()IO 处理→runAllTasks()任务处理→ 检查关闭状态io.netty.channel.SingleThreadIoEventLoop#run// 事件循环主循环IO 处理 任务处理交替进行protectedvoidrun(){assertinEventLoop();ioHandler.initialize();do{runIo();if(isShuttingDown()){ioHandler.prepareToDestroy();}// 在最大时间配额内运行所有待处理任务然后回到 IO 轮询runAllTasks(maxTaskProcessingQuantumNs);}while(!confirmShutdown()!canSuspend());}2.2 组件协作流程五大组件如何协作完成一次网络请求下面以服务端为例用一张时序图展示从启动到响应返回的完整链路上面的时序图清晰地展示了六个阶段的协作链路启动阶段用户通过ServerBootstrap的流式 API 配置BossGroup、WorkerGroup、Channel类型和childHandler然后调用bind(port)触发启动。初始化阶段AbstractBootstrap.initAndRegister()是启动的核心。它首先通过ChannelFactory.newChannel()创建ServerSocketChannel实例然后调用init(channel)初始化其Pipeline。在ServerBootstrap.init()中最关键的一步是向Pipeline添加ServerBootstrapAcceptor——这是一个特殊的ChannelInboundHandler负责将新接入的连接分发给 Worker Groupio.netty.bootstrap.ServerBootstrap#initvoidinit(Channelchannel)throwsThrowable{setChannelOptions(channel,newOptionsArray(),logger);setAttributes(channel,newAttributesArray());ChannelPipelinepchannel.pipeline();finalEventLoopGroupcurrentChildGroupchildGroup;finalChannelHandlercurrentChildHandlerchildHandler;finalEntryChannelOption?,Object[]currentChildOptionsnewOptionsArray(childOptions);finalEntryAttributeKey?,Object[]currentChildAttrsnewAttributesArray(childAttrs);p.addLast(newChannelInitializerChannel(){OverridepublicvoidinitChannel(finalChannelch){finalChannelPipelinepipelinech.pipeline();ChannelHandlerhandlerconfig.handler();if(handler!null){pipeline.addLast(handler);}ch.eventLoop().execute(newRunnable(){Overridepublicvoidrun(){pipeline.addLast(newServerBootstrapAcceptor(ch,currentChildGroup,currentChildHandler,currentChildOptions,currentChildAttrs,extensions));}});}});}注册阶段initAndRegister()调用config().group().register(channel)将ServerSocketChannel注册到 Boss EventLoop。注册完成后doBind0()通过channel.bind(localAddress)触发底层 JDKServerSocketChannel.bind()并将OP_ACCEPT注册到Selector。新连接接入阶段Boss EventLoop 的IoHandler检测到OP_ACCEPT事件后ServerSocketChannel的accept()方法创建NioSocketChannel。随后ServerBootstrapAcceptor.channelRead()被触发它将childHandler添加到新连接的Pipeline然后通过childGroup.register(child)将连接注册到 Worker EventLoopio.netty.bootstrap.ServerBootstrap.ServerBootstrapAcceptor#channelReadpublicvoidchannelRead(ChannelHandlerContextctx,Objectmsg){finalChannelchild(Channel)msg;// 将用户配置的 childHandler 添加到新连接的 Pipelinechild.pipeline().addLast(childHandler);setChannelOptions(child,childOptions,logger);setAttributes(child,childAttrs);// 注册到 Worker EventLoop实现连接负载均衡childGroup.register(child).addListener(future-{if(!future.isSuccess()){forceClose(child,future.cause());}});}数据读写阶段Worker EventLoop 的IoHandler检测到OP_READ事件后NioSocketChannel将数据读取到ByteBuf然后通过ChannelPipeline.fireChannelRead()沿 Pipeline 的 Inbound 方向传播给业务 Handler。响应写入阶段业务 Handler 处理完数据后调用ctx.writeAndFlush(response)响应沿 Pipeline 的 Outbound 方向传播最终由HeadContext调用unsafe.write()将数据入队到ChannelOutboundBufferflush()触发底层 Socket 发送。2.3 Reactor 主从多线程模型映射Netty 的 Reactor 模型映射非常直观Boss GroupMainReactor通常包含一个或多个NioEventLoop每个持有一个NioIoHandler。它只负责ServerSocketChannel的OP_ACCEPT事件——接受新连接然后通过ServerBootstrapAcceptor将新连接分发给 Worker Group。Boss 线程不处理任何读写操作职责单一保证新连接接入的低延迟。Worker GroupSubReactor包含多个NioEventLoop每个持有一个NioIoHandler。它负责已建立连接的OP_READ/OP_WRITE事件以及 Pipeline 中所有 Handler 的业务逻辑执行。每个 Worker 线程可以管理成千上万个连接。连接分发策略ServerBootstrapAcceptor通过childGroup.next()轮询选择 Worker EventLoop。next()方法通过MultithreadEventExecutorGroup的chooser机制实现轮询底层使用AtomicInteger递增取模保证连接均匀分布到所有 Worker 线程。三、IoHandler/IoHandle 分离架构3.1 传统 EventLoop 模型的局限性在 Netty 4.1.x 中NioEventLoop同时承担了 IO 调度Selector.select()、SelectionKey管理和事件循环节奏控制select → processSelectedKeys → runAllTasks两项职责。这种耦合带来了两个问题传输层扩展困难如果要新增 Epoll 或 io_uring 传输需要重写整个EventLoop及其上层集成代码因为 IO 调度逻辑与事件循环逻辑紧密耦合在一起。职责边界模糊NioEventLoop既要知道何时做 IO事件循环节奏也要知道怎么做 IOSelector 操作违反了单一职责原则。3.2 IoHandler/IoHandle 三层分离Netty 4.2.x 通过引入IoHandler/IoHandle/IoEvent三层抽象将 IO 处理从EventLoop中彻底分离三个层次的职责泾渭分明IoEventLoop只负责事件循环节奏——runIo()委托给IoHandler.run()→runAllTasks()处理任务队列。它不关心底层是 Selector 还是 Epoll只关心何时做 IO和何时做任务。IoHandler负责 IO 调度。NioIoHandler内部持有Selector和SelectionKey集合提供run(IoHandlerContext)方法执行 select/poll 操作将就绪事件封装为IoEvent分发给对应的IoHandle。IoHandler是IoHandle的注册中心通过register(IoHandle)方法管理所有 IO 资源。以下是IoHandler接口的核心定义io.netty.channel.IoHandlerpublicinterfaceIoHandler{defaultvoidinitialize(){}intrun(IoHandlerContextcontext);defaultvoidprepareToDestroy(){}defaultvoiddestroy(){}IoRegistrationregister(IoHandlehandle)throwsException;voidwakeup();booleanisCompatible(Class?extendsIoHandlehandleType);}IoHandle封装底层 IO 资源SelectableChannel/fd/epoll_event通过IoRegistration向IoHandler注册感兴趣的事件。当IoHandler检测到就绪事件时回调IoHandle.handle(IoRegistration, IoEvent)执行实际的数据读写io.netty.channel.IoHandlepublicinterfaceIoHandleextendsAutoCloseable{voidhandle(IoRegistrationregistration,IoEventioEvent);defaultvoidregistered(){}defaultvoidunregistered(){}voidclose()throwsException;}IoEventIoEvent是 IO 事件的标记接口IoOps是 IO 操作的标记接口两者均为空接口。具体实现类如NioIoEvent和NioIoOps扩展了这两个标记接口NioIoEvent封装了就绪的NioIoOps信息READ/WRITE/CONNECT/ACCEPT由NioIoHandler检测到就绪事件后分发给NioIoHandle.handle()。不同传输实现有各自的IoEvent/IoOps扩展方式保证了事件传递的标准化。3.3 架构优势三层分离带来了三个显著优势可插拔传输层新增 io_uring 传输只需实现IoHandlerIoHandleIoEvent三个接口无需修改IoEventLoop或任何上层代码。IoHandlerFactory工厂模式在创建EventLoopGroup时注入对应的IoHandler实现。职责清晰每个接口只做一件事。IoEventLoop管理事件循环节奏IoHandler管理 IO 调度IoHandle管理 IO 资源。这使得代码的阅读、测试和维护都更加直观。测试友好可以单独 MockIoHandler或IoHandle在单元测试中模拟 IO 事件而不依赖真实网络环境。IoHandler的run()方法接受IoHandlerContext参数允许测试代码精确控制 select 行为和超时时间。四、设计原则总结4.1 六大设计哲学贯穿 Netty 整个架构的是以下六大设计原则原则体现位置说明异步非阻塞IoEventLoop Future/Promise所有 IO 操作异步返回 Future不阻塞调用线程。Channel 接口的 write()、connect()、bind() 等所有出站操作均返回 ChannelFuture事件驱动ChannelPipeline ChannelHandler入站事件channelRead、channelActive和出站事件write、flush沿 Pipeline 双向传播Handler 按需处理责任链模式ChannelPipeline 双向链表每个 Handler 独立处理一个关注点编解码、SSL、业务逻辑可插拔、可复用、可动态增删零拷贝CompositeByteBuf FileRegion Epoll writev 零拷贝发送减少数据在堆内/堆外/内核之间的拷贝次数。CompositeByteBuf 将多个 ByteBuf 虚拟聚合为零拷贝视图内存池化PooledByteBufAllocator Recycler复用 ByteBuf 和内部对象减少 GC 压力和内存分配开销。AdaptiveByteBufAllocator 根据历史分配大小动态调整池化策略可插拔传输IoHandler/IoHandle IoHandlerFactory 工厂模式同一套 Channel/EventLoop/Pipeline API底层自动适配 NIO/Epoll/KQueue/io_uring运行时按平台选择最优实现4.2 核心价值六大设计原则的工程化落地造就了 Netty 的核心竞争力高性能零拷贝减少 CPU 开销内存池化降低 GC 频率无锁设计减少线程竞争原生传输消除 JNI 调用开销。高扩展Pipeline 责任链支持任意 Handler 组合IoHandler传输层抽象支持新增传输实现codec 协议层支持按需引入协议模块。易用性Bootstrap流式 API 降低启动门槛ChannelFuture异步通知简化编程模型丰富的内置协议支持减少重复开发。稳定性内置 Epoll 空轮询 bug 修复、内存泄漏检测ResourceLeakDetector、优雅关闭机制、流量整形保障生产环境的长期稳定运行。全文小结本文聚焦 Netty 4.2.x 源码工程的架构整体全貌从模块组织和核心组件协作两个维度建立了 Netty 源码阅读的全局认知。在模块组织方面Netty 的六大核心模块按common → buffer → transport → handler/codec → 协议层的层次自底向上依赖各司其职common提供基础设施FastThreadLocal、Recycler、HashedWheelTimerbuffer提供数据容器ByteBuf双索引 池化transport提供网络抽象Bootstrap、Channel、EventLoop、Pipelinehandler提供通用处理SSL、空闲检测、流量整形codec-base提供编解码框架resolver提供地址解析。原生传输模块通过IoHandlerFactory工厂模式与transport解耦用户通过选择不同的EventLoopGroup实现来切换底层传输。在核心组件协作方面Bootstrap作为启动入口EventLoop作为执行引擎Channel作为连接抽象Pipeline作为事件处理链ByteBuf作为数据容器五者通过IoHandler/IoHandle三层分离架构协作完成一次网络请求。Reactor 主从多线程模型通过 Boss Group 处理OP_ACCEPT、Worker Group 处理OP_READ/OP_WRITE的方式映射到 Netty 中。IoHandler/IoHandle分离架构是 4.2.x 最核心的架构演进它将 IO 调度从EventLoop中解耦实现了传输层的完全可插拔。原创不易如果本文对您有帮助带来了些许灵感或启发烦请动动小手点赞、关注、转发、收藏。这是作者持续更新的动力源泉衷心感谢您的支持。我会尽量在工作之余为大家带来更高品质的内容努力保持周更。
![[Android] 可视化音乐制作 -短视频超火的音乐视频制作工具](http://pic.xiahunao.cn/yaotu/[Android] 可视化音乐制作 -短视频超火的音乐视频制作工具)
