UpstreamChannelStateEvent(open state)
step1.add handlerto pipeline
step2.fireChannelOpen
step1.创建ChannelStatEvent
构造NioServerSocketChannel
loop proess task
push
NioServerSocketPipelineSink
NioServerBoss
NettyServerSocket的bind异步Future await
DownstreamChannelStateEventbound state
私有类Binder(SimpleChannelUpstreamHandler)
step2.调用handler处理事件
Channels
依赖
tailChannelHandlerContext
start Boss Runnable
NioWorkerPoolcore*2 NW
ChannelPipelineFactory(用户定义)
poll
ChannelFuture
ChannelFutureListener.notifyuListeners()
step1.open
ServerBootstrap.bind(用户定义)
setSuccess
Task QueueConcurrentLinkedQueue
NIO ServerSocketChannel.open()
ServerSocketChannel
ChannelPipeline.sendUpstream
Channels.bind
step2.使用factory创建channel
ChannelPipeline.sendDownstream
head ChannelHandlerContext
eventSunk处理bound事件
fireChannelBound
NioServerBoss.bind
NioServerBossPooldefault 1 NSB
创建pipeline并send
ServerSocketChannel.bind
newChannel
ChannelFuture
Interceptor chain(handles list)
selecor
NioServerSocketChannelFactory(用户定义)
UpstreamChannelStateEvent(bound state)
open selector
wakeup
