Netty接收请求过程

Netty接收请求过程

由于Netty用来进行接收请求和处理请求的是两个线程组，那么两个线程组是如何进行交互来处理请求的呢

// bossGroup用于接收Client端连接,会将请求交给workerGroup
// bossGroup的线程数建议设置为1，因为仅负责接收客户端的连接，不做复杂的逻辑处理，可以尽少的占用资源
// NioEventLoopGroup中的子线程数默认是cpu核数*2
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
// workerGroup会获取到真正的连接，然后和连接进行通信，workerGroup用于实际业务处理的
EventLoopGroup workerGroup = new NioEventLoopGroup();

EventLoop的作用就是一个死循环，在循环中

• 有条件的等待Nio事件
• 处理Nio事件
• 处理消息队列中的任务

protected void run() {
    for (;;) {
        boolean oldWakenUp = wakenUp.getAndSet(false);
        try {
            if (hasTasks()) {
                selectNow();
            } else {
                select(oldWakenUp);

                if (wakenUp.get()) {
                    selector.wakeup();
                }
            }

            cancelledKeys = 0;
            needsToSelectAgain = false;
            final int ioRatio = this.ioRatio;
            if (ioRatio == 100) {
                processSelectedKeys();
                runAllTasks();
            } else {
                final long ioStartTime = System.nanoTime();
                                // 处理事件
                processSelectedKeys();

                final long ioTime = System.nanoTime() - ioStartTime;
              // 执行队列中的任务
                runAllTasks(ioTime * (100 - ioRatio) / ioRatio);
            }

            if (isShuttingDown()) {
                closeAll();
                if (confirmShutdown()) {
                    break;
                }
            }
        } catch (Throwable t) {
            logger.warn("Unexpected exception in the selector loop.", t);

            // Prevent possible consecutive immediate failures that lead to
            // excessive CPU consumption.
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // Ignore.
            }
        }
    }
}