Netty源码剖析模型图

runAllTasks(ioTime * (100 - ioRatio) / ioRatio);

#NioEventLoop.run();

#AbstractNioMessageChannel.NioMessageUnsafe.read()

register0(promise);

doReadMessages(readBuf);

初始化NioServerSocketChannel

 pipeline.fireChannelRead(byteBuf);

调用pipeline里每个handler的handlerAdded方法

从head开始调用serverChannel的pipeline里的所有inboundHanddler

并配置channle为非阻塞

Selector

unsafe.read();#NioByteUnsafe

假设有客户端链接，则会发生OP_ACCEP事件

执行并删除调用完的haddler，并加入ServerBootstrapAcceptor

pipeline.invokeHandlerAddedIfNeeded()

childHandler就是netty服务端开初始代码，即我们自己写ChannelInitializer的

TaskQueue

client

把task线程放入TaskQueue异步执行

super(parent);

HeadContext

执行task

sockerchannel Pipeline

javaChannel().register(eventLoop().unwrappedSelector()

doBind(localAddress);

当timeoutMillis超时或者有事件发生会break处理

pipeline.fireChannelRead(readBuf.get(i));

serverChannelPipeline

SelectionKey.OP_READ | SelectionKey.OP_ACCEPT

获取socketChannel（可以看NIO代码做为参考）

eventLoop.execute(new Runnable() { @Override public void run() { register0(promise); } });

taskQueue.offer(task);

ServerBootstrap.init(channel)

TailContext

当channle注册时会调用

ch.configureBlocking(false);

selector.select(timeoutMillis);

主要通过0拷贝技术来实现

调用pipeline里每个handler的ChannelRegistered方法

死循环执行监听IO事件

ServerBootstrap(NettyServer)

for死循环执行SelectedKeys里的所有key

因为是双向链表，这里边实现责任链的模式调用。

把channelinitializer加入也就是我们自己的haddler

bootstrap.bind(9900)

addTask(task);

channel.pipeline()

#NioEventLoop.run()

客户端链接server端会触发

serverSockerChannel Pipeline

processSelectedKeys();

Boss Group

SingleThreadEventExecutor.this.run();

select(wakenUp.getAndSet(false));

task.run（）

SocketUtils.accept(javaChannel());

初始化channel，并将channel感兴趣的事件设置为OP_ACCEPET

把serverChannel绑定到到网络端口

readBuf里放的是op_accept事件连接过来来的所有socketChannel

#NioServerSocketChannel.doReadMessages(List<Object> buf)

NioEventGroup

监听端口

next().register(channel);

ChannelInitializer

不同线程组里的线程的selector监听处理

ServerBootstrapAcceptor

NioServerSocketChannel()

初始化并加入到pipeline中

initAndRegister();

直接调用socketChannel的pipeline里的所有handdler的channelRead方法

假设当前另一个客户端往服务端发送数据，socketChannel则会发生op_read事件

constructor.newInstance();

initChannel(ctx)

自定义的Handler

doStartThread();

worker Group

运行TaskQueue异步队列里的任务

初始化socketChannel的pipeline

初始化serverChannel的pipeline

channle注册时调用，调用完会删除该handler（此处逻辑比较深需要借助DeBUG）

newChannelPipeline();

p.addLast(new ChannelInitializer<Channel>() {...}

processSelectedKeysOptimized();

pipeline.fireChannelRegistered();

channelFactory.newChannel();

doRegister();

将socketChannel进行包装

客户端建立链接，此时进入workerGroup进行干活

 childGroup.register(child)

child.pipeline().addLast(childHandler);

config().group().register(channel);

从bossGroup里面拿一个线程来处理channel的注册，将其注册到线程自己的selector上

注册channle到selector（包装了NIO代码，可以参考NIO代码来看）

Pipeline

processSelectedKeysOptimized()

并将channel感兴趣的事件设置为OP_READ

SelectionKey.OP_READ

 sockerchannel注册逻辑跟serversocketchannel注册逻辑一样，注册完会调用socketchannel里的ChannelInitializer把里面我们自己写的Handler全部放入pipeline

for循环处理selectionkeys的里的所有key

将连接过来的socketchannel注册到workgroup里的一个线程的selector上

死循环执行

startThread();

......