【Netty 从成神到升仙系列 二】你真的懂 NIOEventLoop 嘛？

• 作者简介：大家好，我是爱敲代码的小黄，独角兽企业的Java开发工程师，Java领域新星创作者。
• 个人公众号：爱敲代码的小黄（回复 “技术书籍” 可获千本电子书籍）
• 系列专栏：Java设计模式、数据结构和算法、Kafka从入门到成神、Kafka从成神到升仙、操作系统从入门到成神
• 如果文章知识点有错误的地方，请指正！和大家一起学习，一起进步
• 如果感觉博主的文章还不错的话，请三连支持一下博主哦
• 博主正在努力完成2022计划中：以梦为马，扬帆起航，2022追梦人

• Netty 源码
• • 二、NIOEventLoop
  • • 1. Selector 何时创建？
    • • 1.1 EventLoop 里面为什么有两个 selector 成员变量？
    • 2. EventLoop 何时启动？
    • 3.提交普通任务会不会结束 select 阻塞？
    • 4. 什么时候会进入 SelectStrategy.SELECT 分支？
    • • 4.1 何时会 select 阻塞，阻塞多久
    • 5. 空轮询 bug
    • 6. ioRatio 控制什么，设置成 100 有何作用？
    • 8. 在哪里进行事件类型的处理
  • 三、Accept
  • • 1. SocketChannel的创建与注册

从全局来看，我们的 NioEventLoop 主要包括一下几方面：

• Selector

  public final class NioEventLoop extends SingleThreadEventLoop {
      private Selector selector;
      private Selector unwrappedSelector;
  }
  

• 线程

  public abstract class SingleThreadEventExecutor extends AbstractScheduledEventExecutor implements OrderedEventExecutor {
      // 一个 NioEventLoop 只包括一个线程
      private volatile Thread thread;
      // 使用的是一个线程，不过这里可以提交一些任务
      private final Executor executor;
  }
  

• 任务队列

  public abstract class SingleThreadEventExecutor extends AbstractScheduledEventExecutor implements OrderedEventExecutor {
      // 缓存的任务队列
      // 当任务执行过多时，会将多余的任务缓存至该队列中
      private final Queue taskQueue;
     
      // 在其父类中，还存在着定时队列，执行定时任务
      PriorityQueue> scheduledTaskQueue;
  }
  

先给结论：当我们调用 NIOEventLoop 的构造方法时，进行创建

源码：

NioEventLoop(NioEventLoopGroup parent, Executor executor, SelectorProvider selectorProvider,
                 SelectStrategy strategy, RejectedExecutionHandler rejectedExecutionHandler,
                 EventLoopTaskQueueFactory queueFactory) {
    	  // 执行 openSelector 方法
        final SelectorTuple selectorTuple = openSelector();
        this.selector = selectorTuple.selector;
        this.unwrappedSelector = selectorTuple.unwrappedSelector;
}
 private SelectorTuple openSelector() {
     final Selector unwrappedSelector;
     // 通过 provider.openSelector 进行创建
     unwrappedSelector = provider.openSelector();
 }

从上述我们可以得知，NioEventLoop 中的 Selector 是通过 provider.openSelector() 进行的创建

所以，我们只要验证 provider.openSelector() == Selector.open()

从上述代码逻辑可看出，我们的 provider.openSelector() == Selector.open() 结论成立，故 Selector 的创建时机成立。

我们上面讲到了，真正调用 provider.openSelector() 的是 unwrappedSelector 该成员变量

正常来说，我们只有一个 Selector 就足够了，为什么还需要另外的呢？

这里主要和 SelectionKey 优化有关，我们 Java 自己封装的 SelectionKey 是一个 Set 的类型，如下：public abstract Set selectedKeys();

这样当我们去遍历的时候，其实效率是比较低的，而 Netty 在此基础进行改良，将 Set 类型修改为 数组 类型，查询效率大大提升

整体源码如下所示：

private SelectorTuple openSelector() {
    	  //  unwrappedSelector：原始的 selector 创建
        final Selector unwrappedSelector;
        unwrappedSelector = provider.openSelector();
			
        // Netty 利用数组魔改的 selectedKey 集合
        final SelectedSelectionKeySet selectedKeySet = new SelectedSelectionKeySet();

        Object maybeException = AccessController.doPrivileged(new PrivilegedAction