Netty服务器启动源码剖析

• Netty服务器启动源码剖析
• • • 1、Netty服务器启动源码剖析
    • • 1.1、执行new NioEventLoopGroup()时发生了什么
      • • 1.1.1、NioEventLoopGroup 成分
        • 1.1.2、追踪 new NioEventLoopGroup()
        • 1.1.3、总结
      • 1.2、引导类ServerBootstrap的创建与配置
      • • 1.2.1、ServerBootstrap 的成分
        • 1.2.2、ServerBootstrap 的配置
        • 1.2.3、总结
      • 1.3、执行ServerBootstrap.bind(PORT)时发生了什么
      • • 1.3.1、doBind 源码
        • 1.3.2、run 死循环
        • 1.3.3、总结

本次分析创建workerGroup的过程（创建 bossGroup 的过程同理）：

EventLoopGroup workGroup = new NioEventLoopGroup();

• Debug查看 workerGroup 的“成分”，可以看到它包含 8（cpu核数*2） 个 NioEventLoop，每个 NioEventLoop 里面有选择器、任务队列、执行器等等：

• NioEventLoop继承关系图：

• 追踪 new NioEventLoopGroup() 的底层调用：

  • （1）new NioEventLoopGroup()

    • 红色框圈住的构造方法的源码为：

          
          protected MultithreadEventExecutorGroup(int nThreads, Executor executor,
                                                  EventExecutorChooserFactory chooserFactory, Object... args) {
              if (nThreads <= 0) {
                  throw new IllegalArgumentException(String.format("nThreads: %d (expected: > 0)", nThreads));
              }
      
              // 这里的 ThreadPerTaskExecutor 实例是下文用于创建 EventExecutor 实例的参数
              if (executor == null) {
                  executor = new ThreadPerTaskExecutor(newDefaultThreadFactory());
                  // ThreadPerTaskExecutor 的源代码如下，它的功能是从线程工厂中获取线程来执行 command
                  
                  //public final class ThreadPerTaskExecutor implements Executor {
                  //    private final ThreadFactory threadFactory;
                  //
                  //    public ThreadPerTaskExecutor(ThreadFactory threadFactory) {
                  //        if (threadFactory == null) {
                  //            throw new NullPointerException("threadFactory");
                  //        }
                  //        this.threadFactory = threadFactory;
                  //    }
                  //
                  //    @Override
                  //    public void execute(Runnable command) {
                  //        threadFactory.newThread(command).start();
                  //    }
                  //}
              }
      
              // 这里定义了一个容量为 nThreads 的 EventExecutor 的数组
              children = new EventExecutor[nThreads];
      
              for (int i = 0; i < nThreads; i ++) {
                  boolean success = false;
                  try {
                      // 往 EventExecutor 数组中添加元素
                      children[i] = newChild(executor, args);
                      success = true;
                  } catch (Exception e) {
                      // TODO: Think about if this is a good exception type
                      throw new IllegalStateException("failed to create a child event loop", e);
                  } finally {
                      if (!success) {
                          // 添加元素失败，则 shutdown 每一个 EventExecutor
                          for (int j = 0; j < i; j ++) {
                              children[j].shutdownGracefully();
                          }
      
                          for (int j = 0; j < i; j ++) {
                              EventExecutor e = children[j];
                              try {
                                  while (!e.isTerminated()) {
                                      e.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS);
                                  }
                              } catch (InterruptedException interrupted) {
                                  // Let the caller handle the interruption.
                                  Thread.currentThread().interrupt();
                                  break;
                              }
                          }
                      }
                  }
              }
      
              // chooser 的作用是为了实现 next()方法，即从 group 中挑选一个 NioEventLoop 来处理连接上 IO 事件的方法
              chooser = chooserFactory.newChooser(children);
      
              final FutureListener