一文搞懂 Netty 的总体流程，还有谁不会？

做者：fredalxin\
地址：https://fredal.xin/netty-process

本文基于版本 4.1.46，同时只描述类而不展现具体源码。

Netty 的总体流程

Netty 的总体流程相对来讲仍是比较复杂的，初学者每每会被绕晕。

因此这里总结了一下总体的流程，从而对 Netty 的总体服务流程有一个大体的了解。从功能上，流程能够分为服务启动、创建链接、读取数据、业务处理、发送数据、关闭链接以及关闭服务。

总体流程以下所示(图中没有包含关闭的部分)：

服务启动

服务启动时，咱们以 example 代码中的 EchoServer 为例，启动的过程以及相应的源码类以下：

1. EchoServer#new NioEventLoopGroup(1)->NioEventLoop#provider.openSelector() : 建立 selector
2. EchoServer#b.bind(PORT).sync->AbstractBootStrap#doBind()->initAndRegister()-> channelFactory.newChannel() / init(channel) : 建立 serverSocketChannel 以及初始化
3. EchoServer#b.bind(PORT).sync->AbstractBootStrap#doBind()->initAndRegister()-> config().group().register(channel) ：从 boss group 中选择一个 NioEventLoop 开始注册 serverSocketChannel
4. EchoServer#b.bind(PORT).sync->AbstractBootStrap#doBind()->initAndRegister()->config().group().register(channel)->AbstractChannel#register0(promise)->AbstractNioChannel#javaChannel().register(eventLoop().unwrappedSelector(), 0, this) : 将 server socket channel 注册到选择的 NioEventLoop 的 selector
5. EchoServer#b.bind(PORT).sync()->AbstractBootStrap#doBind()->doBind0()->AbstractChannel#doBind(localAddress)->NioServerSocketChannel#javaChannel().bind(localAddress, config.getBacklog()) : 绑定地址端口开始启动
6. EchoServer#b.bind(PORT).sync()->AbstractBootStrap#doBind()->doBind0()->AbstractChannel#pipeline.fireChannelActive()->AbstractNioChannel#selectionKey.interestOps(interestOps|readInterestOp): 注册 OP_READ 事件

上述启动流程中，一、二、3 是由咱们本身的线程执行的，即 mainThread，四、五、6 是由 Boss Thread 执行。相应时序图以下：

创建链接

服务启动后即是创建链接的过程了，相应过程及源码类以下：

1. NioEventLoop#run()->processSelectedKey() NioEventLoop 中的 selector 轮询建立链接事件（OP_ACCEPT）
2. NioEventLoop#run()->processSelectedKey()->AbstractNioMessageChannel#read->NioServerSocketChannel#doReadMessages()->SocketUtil#accept(serverSocketChannel) 建立 socket channel
3. NioEventLoop#run()->processSelectedKey()->AbstractNioMessageChannel#fireChannelRead->ServerBootstrap#ServerBootstrapAcceptor#channelRead-> childGroup.register(child) 从worker group 中选择一个 NioEventLoop 开始注册 socket channel
4. NioEventLoop#run()->processSelectedKey()->AbstractNioMessageChannel#fireChannelRead->ServerBootstrap#ServerBootstrapAcceptor#channelRead-> childGroup.register(child)->AbstractChannel#register0(promise)-> AbstractNioChannel#javaChannel().register(eventLoop().unwrappedSelector(), 0, this) 将 socket channel 注册到选择的 NioEventLoop 的 selector
5. NioEventLoop#run()->processSelectedKey()->AbstractNioMessageChannel#fireChannelRead->ServerBootstrap#ServerBootstrapAcceptor#channelRead-> childGroup.register(child)->AbstractChannel#pipeline.fireChannelActive()-> AbstractNioChannel#selectionKey.interestOps(interestOps | readInterestOp) 注册 OP_ACCEPT 事件

一样，上述流程中 一、二、3 的执行仍由 Boss Thread 执行，直到 四、5 由具体的 Work Thread 执行。

读写与业务处理

链接创建完毕后是具体的读写，以及业务处理逻辑。以 EchoServerHandler 为例，读取数据后会将数据传播出去供业务逻辑处理，此时的 EchoServerHandler 表明咱们的业务逻辑，而它的实现也很是简单，就是直接将数据写回去。咱们将这块当作一个整条，流程以下：

1. NioEventLoop#run()->processSelectedKey() NioEventLoop 中的 selector 轮询建立读取事件（OP_READ）
2. NioEventLoop#run()->processSelectedKey()->AbstractNioByteChannel#read() nioSocketChannel 开始读取数据
3. NioEventLoop#run()->processSelectedKey()->AbstractNioByteChannel#read()->pipeline.fireChannelRead(byteBuf)把读取到的数据传播出去供业务处理
4. AbstractNioByteChannel#pipeline.fireChannelRead->EchoServerHandler#channelRead在这个例子中即 EchoServerHandler 的执行
5. EchoServerHandler#write->ChannelOutboundBuffer#addMessage 调用 write 方法
6. EchoServerHandler#flush->ChannelOutboundBuffer#addFlush 调用 flush 准备数据
7. EchoServerHandler#flush->NioSocketChannel#doWrite 调用 flush 发送数据

在这个过程当中读写数据都是由 Work Thread 执行的，可是业务处理能够由咱们自定义的线程池来处理，而且通常咱们也是这么作的，默认没有指定线程的状况下仍然由 Work Thread 代为处理。

关闭链接

服务处理完毕后，单个链接的关闭是什么样的呢？

1. NioEventLoop#run()->processSelectedKey() NioEventLoop 中的 selector 轮询建立读取事件（OP_READ)，这里关闭链接仍然是读取事件
2. NioEventLoop#run()->processSelectedKey()->AbstractNioByteChannel#read()->closeOnRead(pipeline)当字节<0 时开始执行关闭 nioSocketChannel
3. NioEventLoop#run()->processSelectedKey()->AbstractNioByteChannel#read()->closeOnRead(pipeline)->AbstractChannel#close->AbstractNioChannel#doClose() 关闭 socketChannel
4. NioEventLoop#run()->processSelectedKey()->AbstractNioByteChannel#read()->closeOnRead(pipeline)->AbstractChannel#close->outboundBuffer.failFlushed/close 清理消息：不接受新信息，fail 掉全部 queue 中消息
5. NioEventLoop#run()->processSelectedKey()->AbstractNioByteChannel#read()->closeOnRead(pipeline)->AbstractChannel#close->fireChannelInactiveAndDeregister->AbstractNioChannel#doDeregister eventLoop().cancel(selectionKey()) 关闭多路复用器的 key

时序图以下：

关闭服务

最后是关闭整个 Netty 服务：

1. NioEventLoop#run->closeAll()->selectionKey.cancel/channel.close 关闭 channel，取消 selectionKey
2. NioEventLoop#run->confirmShutdown->cancelScheduledTasks 取消定时任务
3. NioEventLoop#cleanup->selector.close() 关闭 selector

时序图以下，为了好画将 NioEventLoop 拆成了 2 块：

至此，整个 Netty 的服务流程就结束了。
近期热文推荐：

1.600+ 道 Java面试题及答案整理(2021最新版)

2.终于靠开源项目弄到 IntelliJ IDEA 激活码了，真香！

3.阿里 Mock 工具正式开源，干掉市面上全部 Mock 工具！

4.Spring Cloud 2020.0.0 正式发布，全新颠覆性版本！

5.《Java开发手册（嵩山版）》最新发布，速速下载！

以为不错，别忘了随手点赞+转发哦！