目录
- doRegister()
- invokeHandlerAddedIfNeeded()
- PendingHandlerCallback
- fireChannelRegistered()
当channel创建成功后会先进行注册, Unsafe的 register
整体过程如下:
整体源码如下:
接下来详细分析第4/6/8这三步。
doRegister()
doRegister
是AbstractNioChannel的方法,其最终调用java底层的channel进行注册并返回SelectionKey,源码如下:
invokeHandlerAddedIfNeeded()
channel注册成功后会先调用方法invokeHandlerAddedIfNeeded
,该方法会执行pipeline中的pendingHandlerCallbackHead
任务。
接下来先分析下PendingHandlerCallback抽象类。
PendingHandlerCallback
PendingHandlerCallback实现了Runnable接口,它还有一个抽象方法execute
。
PendingHandlerCallback有两个实现类,我们以PendingHandlerAddedTask为例看下它的run
方法和execute
方法。
execute
方法的功能主要是将HandlerContext的handlerState
设置为ADD_COMPLETE状态,并触发channel的handlerAdded
方法,最终会调用ChannelInitializer类的handlerAdded
方法对channel进行一些初始化工作,后面再详细分析。
fireChannelRegistered()
pipeline的fireChannelRegistered()
方法将会把registered事件传导给整个链条中的channelHandler。
至此Unsafe的register方法分析到此结束。
版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: