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方法分析完毕。
版权声明：本文不是「本站」原创文章，版权归原作者所有 | 原文地址: