NioEventLoop 启动流程详解

1. 关于 NioEventLoop 的问题整理

NioEventLoop 是 Netty 项目中用于处理 I/O 事件的核心线程模型。它基于 Reactor 线程模型，专注于非阻塞 I/O 操作，能够高效处理大量连接。

Reactor 线程模型主要包括以下三个部分：

NioEventLoop 的创建过程如下：

调用 ServerBootstrap.bind() 方法。

执行 doBind() 方法，创建服务端 Channel。

初始化并注册服务端 Channel 到 Selector。

当服务端启动时，ServerBootstrap.bind() 方法会触发以下流程：

当新连接接入时，通过 Chooser 绑定一个 NioEventLoop。

调用 NioEventLoop.inEventLoop() 方法判断当前线程是否为 Reactor 线程。NioEventLoop 会将线程实体保存到自身的成员变量中。

如果当前线程不是 NioEventLoop 线程，会执行以下步骤：

调用 SingleThreadEventExecutor.startThread() 方法启动线程。

使用 ThreadPerTaskExecutor 创建一个 FastThreadLocalThread 线程。

线程执行 Runnable 任务，将线程实体保存到 NioEventLoop 中。

调用 NioEventLoop 的 run() 方法启动线程。

NioEventLoop 启动流程：

服务端启动时，主线程调用 AbstractUnsafe.register() 方法。

将 NioEventLoop 绑定到服务端 Channel。

执行 Runnable 任务，启动 NioEventLoop 线程。

NioEventLoop 的 run() 方法驱动 Netty 运转的核心逻辑。

通过以上流程，NioEventLoop 能够高效管理和处理 I/O 事件，确保服务端 Channel 正确注册到 Selector 上。

转载地址：http://fvcfk.baihongyu.com/

你可能感兴趣的文章