netty nioeventloop,netty nioeventloopgroup
目录
NioEventLoop的运行()方法：processSelectedKeys()方法processSelectedKeysOptimized(选定的键。flip())方法processSelectedKey(k，(AbstractNioChannel) a)方法前文传送门：NioEventLoop执行挑选操作入口
之前我们了解了执行选择()操作的相关逻辑，这一小节我们继续学习轮询到超正析象管事件的相关逻辑：
NioEventLoop的run()方法：
受保护的void run(){ for(；){尝试{切换(选择策略。calculate strategy(select now supplier，hasTasks()){ case select strategy .继续：继续；案例选择策略。选择： //轮询超正析象管事件(1)选择(唤醒。getandset(false))；如果(醒来。get()){ selector。醒来()；}默认： }取消键=0；needsToSelectAgain=false//默认是50 final int io=this。io比率；if(io ratio==100){ try { processSelectedKeys()；}最后{ run all tasks()；} } else { //记录下开始时间最终长ioStartTime=system。纳米时间()；尝试{ //处理轮询到的key(2)processSelectedKeys()；}最后{ //计算耗时最终长io时间=系统。nano time()-ioStartTime；//执行task(3)runall tasks(io时间*(100-io比)/io比)；} } } catch(Throwable t){ handleLoopException(t)；} //代码省略}}我们首先看if(ioRatio==100)这个判断，比例主要是用来控制processSelectedKeys()方法执行时间和任务队列执行时间的比例，其中ioRatio默认是50, 所以会走到下一步其他
首先通过finalongiostartime=system。纳米时间()记录下开始时间，再通过processSelectedKeys()方法处理轮询到的键
processSelectedKeys()方法
private void processSelectedKeys(){ if(selected keys！=null) { //flip()方法会直接返回键的数组processSelectedKeysOptimized(选定的键。flip())；} else { processselectedkessplain(选择器。选定的键())；}}我们知道选择器通过网状的优化之后，会初
始化 selectedKeys这个属性, 所以这个属性不为空就会走到processSelectedKeysOptimized(selectedKeys.flip())方法, 这个方法就是对应优化过的selector进行操作的
如果是非优化的selector, 则会进入processSelectedKeysPlain(selector.selectedKeys())方法
selectedKeys.flip()为selectedKey中绑定的数组, 我们之前小节讲过selectedKeys其实是通过数组存储的, 所以经过select()操作如果监听到事件selectedKeys的数组就会有值
processSelectedKeysOptimized(selectedKeys.flip())方法
private void processSelectedKeysOptimized(SelectionKey[] selectedKeys) { //通过for循环遍历数组 for (int i = 0;; i ++) { //拿到当前的selectionKey final SelectionKey k = selectedKeys[i]; if (k == null) { break; } //将当前引用设置为null selectedKeys[i] = null; //获取channel(NioSeverSocketChannel) final Object a = k.attachment(); //如果是AbstractNioChannel, 则调用processSelectedKey()方法处理io事件 if (a instanceof AbstractNioChannel) { processSelectedKey(k, (AbstractNioChannel) a); } else { @SuppressWarnings("unchecked") NioTask<SelectableChannel> task = (NioTask<SelectableChannel>) a; processSelectedKey(k, task); } //代码省略 }}首先通过for循环遍历数组中的每一个key, 获得key之后首先将数组中对应的下标清空, 因为selector不会自动清空, 这与我们使用原生selector时候, 通过遍历selector.selectedKeys()的set的时候, 拿到key之后要执行remove()是一个意思
之后获取注册在key上的channel, 判断channel是不是AbstractNioChannel, 通常情况都是AbstractNioChannel, 所以这里会执行processSelectedKey(k, (AbstractNioChannel) a)
processSelectedKey(k, (AbstractNioChannel) a)方法
private void processSelectedKey(SelectionKey k, AbstractNioChannel ch) { //获取到channel中的unsafe final AbstractNioChannel.NioUnsafe unsafe = ch.unsafe(); //如果这个key不是合法的, 说明这个channel可能有问题 if (!k.isValid()) { //代码省略 } try { //如果是合法的, 拿到key的io事件 int readyOps = k.readyOps(); //链接事件 if ((readyOps & SelectionKey.OP_CONNECT) != 0) { int ops = k.interestOps(); ops &= ~SelectionKey.OP_CONNECT; k.interestOps(ops); unsafe.finishConnect(); } //写事件 if ((readyOps & SelectionKey.OP_WRITE) != 0) { ch.unsafe().forceFlush(); } //读事件和接受链接事件 //如果当前NioEventLoop是work线程的话, 这里就是op_read事件 //如果是当前NioEventLoop是boss线程的话, 这里就是op_accept事件 if ((readyOps & (SelectionKey.OP_READ SelectionKey.OP_ACCEPT)) != 0 readyOps == 0) { unsafe.read(); if (!ch.isOpen()) { return; } } } catch (CancelledKeyException ignored) { unsafe.close(unsafe.voidPromise()); }}我们首先获取和channel绑定的unsafe, 之后拿到channel注册的事件
我们关注
if((readyOps & (SelectionKey.OP_READ SelectionKey.OP_ACCEPT)) != 0 readyOps == 0)
这个判断, 这个判断相信注释上写的很明白, 如果当前NioEventLoop是work线程的话, 这里就是op_read事件, 如果是当前NioEventLoop是boss线程的话, 这里就是op_accept事件
然后会通过channel绑定的unsafe对象执行read()方法用于处理链接或者读写事件
以上就是NioEventLoop对io事件的处理过程, 有关read()方法执行逻辑, 会在以后的章节中详细剖析，更多关于Netty NioEventLoop处理IO事件逻辑的资料请关注盛行IT其它相关文章！
郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。