30、Netty源码分析：ChannelPipeline的fireChannelRead

本文深入解析Netty中fireChannelRead方法的调用流程，重点剖析了ReferenceCounted引用计数机制的内存管理原理，以及pipeline头结点如何将数据传播给后续handlers，帮助开发者理解Netty高性能网络通信的核心数据处理机制。

fireChannelRead

当调用read方法将channel的信息读取到netty的缓冲区后就开始调用fireChannelRead方法将信息传播给pipeline中的handlers,当收到事件后handlers开始进行数据处理，pipeline中的fireChannelRead源码过程如下：

在这个过程第1步的引用计数与第2步头结点的处理需要分析下。

ReferenceCounted

在Netty中承载数据的ByteBuf增加了引用计数的实现，通过该引用计数可对直接内存和池化对象进行回收，能够更精准的控制访问以及提高内存分配与释放的性能。在pipeline中定义了touch参数，它的值在类初始化的时候就进行设置，通过该值判断是否要对msg信息进行引用计数。

ResourceLeakDetector.isEnabled()方法通过其类属性level的值返回值。枚举类Level的值有：DISABLED,SIMPLE, ADVANCED, PARANOID, 在ResourceLeakDetector中通过静态块代码设置level的值，level默认值SIMPLE，默认开启，可通过io.netty.noResourceLeakDetection关闭；level的值通过io.netty.leakDetectionLevel设置，也可以io.netty.leakDetection.level设置，后者优先级更高。

ReferenceCountUtil.touch对msg信息的引用+1。

头结点读取信息

头结点的作用就是把信息传播到pipeline中其他handlers，每个handler处理完后就传播到下一个handler。

至此，pipeline的fireChannelRead方法分析完毕。