手把手教你调试Netty创建连接流程源码

执行过程

boss thread

• NioEventLoop 中的 selector轮询创建连接事件 (ОР_АССЕРT)
• 创建 socket channel
• 初始化 socket channel 并从 worker group 中选择一个 NioEventLoop

worker thread

• 将socket channel注册到选择的NioEventLoop的selector
• 注册读事件(OP_ READ)到selector 上

接收连接请求的处理本质是对 OP_ACCEPT 的处理，即在 NioEventLoop 中，因为注册到了NioEventLoop的 selector。 分别调试启动 EchoServer 和 EchoClient

• 跳至对应 handler

• • 当前为 bosseventloop，不是 workereventloop

  

• 所以这里 false，又来到注册

• 创建完连接后了，已经可以开始接收数据了，即准备读数据了

最后观察下 server 的日志信息

• 前5行都是服务启动，后面的就是为了创建连接
• 服务启动过程多了个 bind 过程，且只绑定了一个接口，而对于下面的创建连接过程它有两个端口：客户端端口+server 监听的端口，这就是 socketChannel

接收连接的核心代码

// 阻塞轮询。非阻塞轮询。超时等待轮询
selector.select()/ selectNow()/select(timeoutMillis) 发现 OP_ACCEPT 事件,处理:
SocketChannel socketChannel = serverSocketChannel.accept()
selectionKey = javaChannel().register(eventLoop().unwrappedSelector(), 0, this);
selectionKey.interestOps(OP_READ);

创建连接的初始化和注册是通过pipeline.fireChannelRead在ServerBootstrapAcceptor中完成

第一次Register并非监听OP_READ，而是0

selectionKey = javaChannel().register(eventLoop().unwrappedSelector(), 0, this)

最终监听OP_READ是通过"Register"完成后的fireChannelActive (io.netty.channel.AbstractChannel.AbstractUnsafe#register0)触发

Worker’s NioEventLoop是通过Register操作执行来启动。

接受连接的读操作，不会尝试读取更多次(16次)。 因为无法知道后续是否还有连接，不可能一直尝试。