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