【Netty】NioEventLoop的构建(四):chooserFactory.newChooser

【Netty】NioEventLoop的构建(四):chooserFactory.newChooser

Scroll Down

回顾

上一节,我跟进了NioEventLoop大致的构造过程(newChild方法),并且知道创建出的NioEventLoop实例最终会保存成属性名为children的EventExecutor数组,而这个children到后面又被用于构造一个chooser,本节就来探究下这个chooser的构建过程。

另外,chooser的作用就是给新连接绑定NioEventLoop,这个在第一节也提到过。

原谅我又拿前面的MultithreadEventExecutorGroup构造函数图出来,因为方便定位起点,忘记的可以看第一节
MultithreadEventExecutorGroup.png

此处【坐标1】
MultithreadEventExecutorGroup构造函数.png

Netty Version:4.1.6


追踪chooserFactory.newChooser(children);

可能有人会问为什么不先理一理整个流程?因为这个流程是真的简单,以致于我原本都没想过要记录这个过程,直到我遇到一个能与HashMap起到一点共鸣的东西。

好了,废话不多说,视角回到【坐标1】,找到以下代码:

chooser = chooserFactory.newChooser(children);

进入newChooser方法,此处【坐标2】:
io.netty.util.concurrent.DefaultEventExecutorChooserFactory#newChooser

    public EventExecutorChooser newChooser(EventExecutor[] executors) {
        if (isPowerOfTwo(executors.length)) {
            return new PowerOfTowEventExecutorChooser(executors);
        } else {
            return new GenericEventExecutorChooser(executors);
        }
    }

先进入isPowerOfTwo方法看看:

    private static boolean isPowerOfTwo(int val) {
        return (val & -val) == val;
    }
  • 这个方法就如同它的名字,就是判断数字是否是2的幂次方,相信你只要了解过一点jdk8的HashMap优化,应该就能猜出【坐标2】的中的代码到底是干嘛了。

我们将视角切回【坐标2】,然后将视角放大到类的所有函数,发现PowerOfTowEventExecutorChooser和GenericEventExecutorChooser的构造函数都是做同一件事,就是将NioEventLoop数组(属性名:executors)保存到自己的属性中。

注意,上面我特意强调了是NioEventLoop,就是怕被executors这个属性名以及EventExecutor这个类名给骗了,在上一节中也讲了为什么是这样,如果还不信,我贴个断点图:

在这个类中,我们应该重点关注的是两个内部类的next()方法:
io.netty.util.concurrent.DefaultEventExecutorChooserFactory.GenericEventExecutorChooser#next

public EventExecutor next() {
            return executors[Math.abs(idx.getAndIncrement() % executors.length)];
        }

io.netty.util.concurrent.DefaultEventExecutorChooserFactory.PowerOfTowEventExecutorChooser#next

        public EventExecutor next() {
            return executors[idx.getAndIncrement() & executors.length - 1];
        }

先解释下,next方法就是负责给新连接分配NioEventLoop的。

我在前面说过的一个类HashMap优化的思想,就体现在PowerOfTowEventExecutorChooser的next方法,即如果executors的数组长度是2的幂次方,调用next方法时,就会使用位运算做取模运算,从而提升性能。


小结:

  • chooserFactory.newChooser(children);的主要逻辑就是创建一个选择器,并将先前创建NioEventLoop保存到自己的属性中,用于分发给新连接。
  • 分发的策略会根据NioEventLoop的个数,即根据我们设置的线程数优化,如果设置的数值是2的幂次方,可能会获得更好的性能。