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