Netty网络编程第五卷

NioEventLoop 剖析
- 1.Selector何时创建
- 2.eventLoop为何有两个selector成员变量
- 3. eventloop的nio线程在何时启动
- 4. 提交普通任务会不会结束select阻塞
- 5.wakeup方法中代码如何理解
- 6.每次循环的时候，什么时候会进入SelectStrategy.SELECT分支
- 7.何时会select阻塞，会阻塞多久
- 8.nio空轮询bug在哪里体现，如何解决
- 9.ioRatio控制什么,设置100有什么作用
- 10.selectedKeys优化是怎么回事
Accept流程
- accept源码跟进
Read流程
总结

原本只打算写四卷,结果第四卷结尾只分析到了netty启动初始化部分的源码，特开第五卷将netty剩余重点部分源码分析完毕

NioEventLoop 剖析

学习NioEventLoop之前，先要搞清楚NioEventLoop的重要组成是:Selector,线程，任务队列; 以及NioEventLoop既会处理io事件，也会处理普通任务和定时任务

NioEventLoop 线程不仅要处理 IO 事件，还要处理 Task（包括普通任务和定时任务），

NioEventLoop的探究过程从下面几个问题展开

1.Selector何时创建

先来看NioEventLoop这个类

找到了selector,下面找一下thread对象,thread对象要去其父类里面找

下面是继承图

在NioEventLoop的爷爷类SingleThreadEventExecutor中定义了线程对象和普通任务队列

找其曾祖父类AbstractScheduledEventExecutor

到此我们可以看出NioEventLoop具备处理io,普通任务和定时任务的能力

下面追踪一下Selector的初始化过程，首先就需要看NioEventLoop的构造方法了

对比下面nio源码:

到此，第一个问题回答完毕，selector是在NioEventLoop的构造方法中进行创建的

2.eventLoop为何有两个selector成员变量

下面分析为什么不用原生的selector,反而整出两个selector?

selector都有一个selectionKeys集合，该集合实现是set,set遍历性能不高，因为底层实现是哈希表
netty对此做了优化，将原生的selectionKeys底层的set集合换成了基于数组的实现

替换的源码展示如下:

为什么还要保留原始的seletor，而不直接使用包装后的selector?

包装后的selector只是用来遍历selectionKeys的
原生的selector的一些功能无法由包装后的selector实现，一些功能还是需要基于原生selector实现

答案:为了在遍历selectedKeys时提高性能

3. eventloop的nio线程在何时启动

提交任务代码 io.netty.util.concurrent.SingleThreadEventExecutor#execute

下面探究execute方法源码

首先我们主要execute方法所属的类---->SingleThreadEventExecutor从名字可以看出，这是一个单线程的任务执行器,这也很好理解，可以把NioEventLoopGroup看做一个线程池，线程池是懒加载的，并且线程池里面每一个线程执行器就是SingleThreadEventExecutor
还需要注意一点，我们上面在NioEventLoop的组成时分析的:,即SingleThreadEventExecutor有一个成员变量thread用来保存当前开启的线程，因为是懒加载的，初始为null

同理真正干活的是doStartThread方法

首先验证excutor中任务的调用时通过nio线程异步调用的

下面我们再继续验证

线程工厂创建出来的线程启动执行run方法，run方法中会将新创建的线程赋值给单线程执行器的thread对象， 并且该线程执行完run方法后不会销毁，会进入死循环不断寻找新的任务执行

答案:当首次调用execute方法的时，nio线程启动，并且通过一个state状态位来控制线程只会启动一次

4. 提交普通任务会不会结束select阻塞

书接上回，当nio线程创建完毕启动后，会进入一个死循环

新创建出来的nio线程不仅处理io事件，其他任务来了也需要处理，因此nio线程不能无限阻塞下去，需要在有任务的时候醒过来，因此我们可以推断出，当有新任务来的时候，会唤醒阻塞的nio线程，当超时时间到的时候，也会唤醒阻塞的nio线程

下面验证提交普通任务，是否会唤醒阻塞的nio线程

显然这里excute方法调用的就是子类SingleThreadEventExecutor的实现，为什么不是AbstractEventExecutor呢?，因为AbstractEventExecutor是SingleThreadEventExecutor的父类实现

这里由于继承链比较多，很多方法都是调用父类的方法，有时候有会调用子类的实现，看起来比较迷糊

提交普通任务会唤醒在select除阻塞住的nio线程，让他来处理我们提交的普通或者定时任务，而select阻塞监听的是io事件 总结:首先先从eventloopgroup中获取一个eventloop对象(本质是一个单线程执行器,内部维护一个thread对象)----》eventloop提交任务--->先将任务加入队列---->创建线程(通过线程工厂创建一个线程，赋值给成员变量thread)，并用标记位防止重复创建--->thread赋值完毕后，会去运行传入的任务，该任务就是一个死循环，负责不断寻找新的可执行任务