Netty 4源码解析：请求处理

Netty 4源码解析：请求处理

通过之前《Netty 4源码解析：服务端启动》的分析，我们知道在最前端“扛压力”的是NioEventLoop.run()方法。我们指定创建出的NioServerSocketChannel就是注册到了NioEventLoop中的Selector上。所以我们继续顺藤摸瓜，看看服务端启动完成后，Netty是如何处理每个请求的。

1.MainReactor

1.1 事件轮询

之前我们曾分析过到NioEventLoop.run()方法，但因为之前只关注启动流程所以“浅尝辄止”了，这次我们就以它为起点开始深入分析。NioEventLoop于Selector绑定，它是真正轮询Selector的地方。至于有哪一个或哪些Channel的事件绑定到Selector了，则是注册阶段决定的。对于MainReactor来说，只有一个NioEventLoop负责处理一个ServerSocketChannel的事件。

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

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

                if (ioRatio == 100) {
                    processSelectedKeys();
                    runAllTasks();
                }
            } catch (Throwable t) {
                logger.warn("Unexpected exception in the selector loop.", t);
            }
        }
    }

    private void processSelectedKeys() {
        if (selectedKeys != null) {
            processSelectedKeysOptimized(selectedKeys.flip());
        } else {
            processSelectedKeysPlain(selector.selectedKeys());
        }
    }

    private void processSelectedKeysPlain(Set<SelectionKey> selectedKeys) {
        if (selectedKeys.isEmpty()) {
            return;
        }

        Iterator<SelectionKey> i = selectedKeys.iterator();
        for (;;) {
            final SelectionKey k = i.next();
            final Object a = k.attachment();
            i.remove();

            if (a instanceof AbstractNioChannel) {
                processSelectedKey(k, (AbstractNioChannel) a);
            }

            if (!i.hasNext()) {
                break;
            }
        }
    }

1.2 事件触发

不知道大家是否还记得，NioServerSocketChannel注册时有一个小细节，就是它将自己作为了attachment。所以上面处理SelectionKey时就能通过attachement取到注册时的Channel。为什么一定要拿到当时的Channel呢？继续往下看。

    @Override
    protected void doRegister() throws Exception {
        for (;;) {
            try {
                selectionKey = javaChannel().register(eventLoop().selector, 0, this);
                return;
            } catch (CancelledKeyException e) {
                // ...
            }
        }
    }

原来跟之前介绍过的注册和绑定一样，最终都是通过Channel的unsafe工具类来完成的。

// NioEventLoop
private static void processSelectedKey(SelectionKey k, AbstractNioChannel ch) {
        final NioUnsafe unsafe = ch.unsafe();
        try {
            int readyOps = k.readyOps();
            // Also check for readOps of 0 to workaround possible JDK bug which may otherwise lead to a spin loop
            if ((readyOps & (SelectionKey.OP_READ | SelectionKe