Netty源码学习2——NioEventLoop的执行

转载 作者：我是一只小鸟 更新时间：2023-08-19 21:56:41 28 4

系列文章目录和关于我 。

零丶引入

在《 Netty源码学习1——NioEventLoopGroup的初始化 》中，我们学习了NioEventLoopGroup和NioEventLoop的初始化，在下面netty服务端启动的demo中 。

会在ServerBootStrap中指定Channel为Nio类型的Channel，然后启动的时候绑定端口，之前我们解释道NioEventLoop是事件循环，这里的事件是指客户端连接，数据准备就绪等IO事件，循环是指会有一个线程不断的处理任务。so 这篇我们一起看下NioEventLoop是如何产生IO事件并执行各种任务的.

一丶NioEventLoop的初始化

这部分在[Netty源码学习1——NioEventLoopGroup的初始化#第四节]( Netty源码学习1——NioEventLoopGroup的初始化 - Cuzzz - 博客园 (cnblogs.com) )中进行了说明，其中比较有趣的是Netty对JDK原生Selector的优化，将原本基于HashSet的SelectionKey集合，修改为基于数组的SelectionKey集合，优化了迭代和修改的效率，再次就不在过多赘述了.

二丶NioEventLoop的启动

NioEventLoop中存在一个run方法，该方法是一个死循环，这便是事件循环中的循环，它由一个线程专门去执行，我们先分析下NioEventLoop#run方法是什么时候开始执行的.

如上分别是客户端和服务端启动部分的源码，在bind 和 connect中都会触发——Channel的初始化+Channel的注册.

1. Channel的初始化：由对应的Factory进行创建（默认使用反射） 。

2. Channel的注册：这里的注册将调用NioEventLoopGroup#register方法， 。

   

   这里自然是通过EventExecutorChooser#next方法选择一个NioEventLoop进行注册 。

   

   

   在excute方法中会将EventLoop#run方法包装成一个Runnable提交到线程池中，这里的线程池是被包装后的ThreadPerTaskExecutor，每一个任务的提交都会新建一个线程去执行 。

   

   因此可以任务NioEventLoop#run方法由一个线程单独去执行 。

三丶NioEventLoop#run

1.SelectStrategy控制循环

和Tomcat的Poller类似，NioEventLoop需要使用Selector去进行IO多路复用，Netty抽象出SelectStrategy使用其calculateStrategy来控制循环 。

其中selectNow即使用JDK Selector#selectNow方法进行非阻塞select 。

DefaultSelectStrategy#calculateStrategy的逻辑是，如果当前EventLoop中存在任务那么直接返回就绪的就绪SelectionKey数目，如果不存哎任务，那么返回常量SELECT(-1)，根据返回的数字会进入不同的分支.

2.执行阻塞select

NioEventLoop支持调度任务，因此内部使用了优先队列保存调度任务，并且调度任务具备一个deadlineNanos属性 。

3.执行任务

NioEventLoop支持ioRatio指定IO事件的处理事件，和其他任务执行时间的比例 。

其中处理IO时间的部分涉及到Netty的ChannelPipeline的执行，这部分在后续的博客中进行讲解 。

3.1 runAllTasks

无参的runAllTask会在IO事件处理结束后执行，首先会将scheduledTaskQueue中的任务（未到执行时间的任务，or deadlineNanos早于当前时间的任务 不会转移到taskQueue）转移到taskQueue，然后执行taskQueue中的任务，执行完taskQueue的任务后，执行tailTasks中的任务 。

3.2 runAllTasks(超时时间)

大流程和上面runAllTasks类似，依旧是将调度任务从scheduledTaskQueue转移到taskQueue，然后执行taskQueue任务，然后执行tailTasks中的任务 。

感觉比较有趣的是，对调度任务的处理，移动到taskQueue后并不会再次判断其deadlineNanos和当前时间的关系，不会再关注其是否过期.

3.3 处理NIO空轮询的bug

Java NIO在linux下基于epoll，但是因为poll和epoll对于突然中断的连接socket会对返回的eventSet事件集合置为EPOLLHUP或者EPOLLERR， eventSet事件集合发生了变化 ，这会导致Selector会被唤醒，唤醒之后却没有感兴趣的事件，导致IO事件处理的循环不会执行，陷入到循环中. 。

下面我们看看netty是如何处理此bug的 。

可以看到 Netty通过重新构建Selector的方式去规避空轮询的bug ，其中rebuildSelector最终调用rebuildSelector0，会将原本selector中的SelectionKey拷贝到新的selector，然后关闭旧的Selector 。

四丶总结

此节我们学习了NioEventLoop的执行原理，本质上还是通过Selector进行IO多路复用，理解了什么是事件循环，其中的事件指通过IO多路复用监听多路IO事件，循环是指循环的监听IO事件，并处理IO事件和其他任务，但是对于IO事件的处理我们并未做更多的学习，这部分将在下一篇中进行学习.

最后此篇关于Netty源码学习2——NioEventLoop的执行的文章就讲到这里了,如果你想了解更多关于Netty源码学习2——NioEventLoop的执行的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

28 4 0

• macos - 执行 wine != 执行 `which wine`

  我有一个“有趣”的问题，即以两种不同的方式运行 wine 会导致: $> wine --version /Applications/Wine.app/Contents/Resources/bin/wi

• javascript - CRONTAB 执行 Python，使用 puppeteer 执行 Node 来进行网页抓取不起作用

  我制作了这个网络抓取工具来获取网页中的表格。我使用 puppeteer (不知道 crontab 有问题)、Python 进行清理并处理数据库的输出 但令我惊讶的是，当我执行它时 */50 * * *

• javascript - 对 javascript 函数的 Objective-C 调用何时被调用/执行，何时不被调用/执行？

  JavaScript 是否被调用或执行取决于什么？准确地说，我有两个函数，它们都以相同的方式调用: [self.mapView stringByEvaluatingJavaScriptFromStri

• python - 为什么使用 statsmodels 执行 OLS 和使用 scikit 执行 PooledOLS 时会得到相同的结果？

  我目前正在使用 python 做一个机器学习项目(这里是初学者，从头开始学习一切)。 只是想知道 statsmodels 的 OLS 和 scikit 的 PooledOlS 使用我拥有的相同面板数据

• c# - 通过 Enterprise Guide 执行 SAS 和从 .Net 执行 IOM 之间的区别

  在使用集成对象模型 (IOM) 后，我可以执行 SAS 代码并将 SAS 数据集读入 .Net/C# 数据集 here . 只是好奇，使用 .Net 作为 SAS 服务器的客户端与使用 Enterpr

• javascript - jQuery 不会使用 animate : top 200px function. 执行，但它会使用 animate: height 执行

  有一些直接的 jQuery 在单击时隐藏打开的 div 未显示，但仍将高度添加到导航中以使其看起来好像要掉下来了。 这个脚本工作正常: $(document).ready(funct

• java - 为什么我的代码使用 'IF' 执行 'ELSE' 和 '==' ，但不使用 '.equals' 执行？

  这个问题已经有答案了: How do I compare strings in Java? (23 个回答) 已关闭 4 年前。 这里是 Java 新手，我正在使用 NetBeans 尝试一些简单的代

• python - Keras 2.0.8 仅使用 Python 3.x 执行 1 个 epoch，使用 2.x 执行 10 个

  如果我将它切换到 Python 2.x，它执行 10。这是为什么？ 训练逻辑回归模型 import keras.backend as

• JavaScript 执行

  我有两个脚本，它们包含在 HTML 正文中。在第一个脚本中，我初始化一个 JS 对象，该对象在第二个脚本标记中引用。 ... obj.a = 1000; obj.

• 执行@number时的Java链接列表错误消息

  每当我运行该方法时，我都会收到一个带有数字的错误 以下是我的代码。 public String getAccount() { String s = "Listing the accounts";

• java - 执行 while 循环以显示菜单

  我已经用 do~while(true) 创建了我的菜单；但是每次用户输入一个数字时，它不会运行程序，而是再次显示菜单!你怎么看？ //我的主要方法 public static void main(St

• ipython - 执行/命令完成时通知

  执行命令后，如何让IPython通知我？我可以使用铃声/警报还是通过弹出窗口获取它？我正在OS X 10.8.5的iTerm上运行Anaconda。 最佳答案 使用最新版本的iTerm，您可以在she

• java - Swing 执行

  您好，我刚刚使用菜单栏为 Swing 编写了代码。但是问题出现在运行中。我输入: javac Menu.java java Menu 它没有给出任何错误，但 GUI 没有显示。这是我的源代码以供引用:

• .net - 执行.NET应用程序时验证Authenticode签名

  我觉得这里缺少明显的东西，但是我看不到它写在任何地方。 我使用Authenticode证书对可执行文件进行签名，但是当我开始学习有关它的更多信息时，我对原样的值(value)提出了质疑。 签名的exe

• 按钮单击事件上的 JavaScript 执行

  我正在设计一个应用程序，它使用 DataTables 中的预定义库来创建数据表。我想对数据表执行删除操作，为此应在按钮单击事件上执行 java 脚本。 $(document).ready(functi

• Haskell - 执行 while 循环

  我是 Haskell 新手，如果有人愿意帮助我，我会很高兴!我试图让这个程序与 do while 循环一起工作。 第二个 getLine 命令的结果被放入变量 goGlenn 中，如果 goGlenn

• java - 执行 while 循环时出现问题

  我有一个用 swing 实现迷你游戏的程序，在主类中我有一个循环，用于监听游戏 map 中的 boolean 值。使用 while 实现的循环不会执行一条指令，如果它是唯一的一条指令，我不知道为什么。

• java - 执行.jar时将OJBDC添加到类路径

  我正在尝试开发一个连接到 Oracle 数据库并执行函数的 Java 应用程序。如果我在 Eclipse 中运行该应用程序，它可以工作，但是当我尝试在 Windows 命令提示符中运行 .jar 时，

• java future 执行

  我正在阅读有关 Java 中的 Future 和 javascript 中的 Promises 的内容。下面是我作为示例编写的代码。我的问题是分配给 future 的任务什么时候开始执行？ 当如下行创

• java - 执行 && 最有效的方法？

  我有一个常见的情况，您有两个变量(xSpeed 和 ySpeed)，当它们低于 minSpeed 时，我想将它们独立设置为零，并在它们都为零时退出。 最有效的方法是什么？目前我有两种方法(方法2更干净