如何实现事件循环NioEventLoop如何处理多路复用Netty如何管理Channel和Selector管理Channel管理Selector注意事项

Netty通过事件循环机制(EventLoop)处理IO事件和异步任务简单来说就是通过一个死循环不断处理当前已发生的IO事件和待处理的异步任务。

NIO的异步事件循环类它负责处理一个Channel的所有事件在这个Channel的生命周期期间。

NioEventLoop的整个生命周期只会依赖于一个单一的线程来完成。

一个NioEventLoop可以分配给多个ChannelNioEventLoop通过JDK

Selector来实现I/O多路复用以对多个Channel进行管理。

如果调用Channel操作的线程是EventLoop所关联的线程那么该操作会被立即执行。

否则会将该操作封装成任务放入EventLoop的任务队列中。

所有提交到NioEventLoop的任务都会先放入队列中然后在线程中以有序(FIFO)/连续的方式执行所有提交的任务。

已经注册到Selector的Channel的监控并在感兴趣的事件可执行时对其进行处理完成任务队列(taskQueue)中的任务以及对可执行的定时任务和周期性任务的处理(scheduledTaskQueue中的可执行的任务都会先放入taskQueue中后再从taskQueue中依次取出执行)。

主要功能

还负责执行定时任务和普通任务。

这些任务可以是用户自定义的也可以是

Netty

NioEventLoop在Netty中实现事件循环的过程是Netty网络框架的核心机制之一它结合了Java

NIO的非阻塞特性和事件驱动模型以高效地处理网络事件。

以下是NioEventLoop如何实现事件循环的详细过程

轮询就绪事件

在事件循环中NioEventLoop调用Selector的select()方法来等待Channel上就绪的事件。

select()方法会阻塞直到至少有一个Channel的事件就绪或者超时。

处理就绪事件

一旦select()方法返回NioEventLoop会获取就绪的Channel集合并遍历这些Channel。

对于每个就绪的ChannelNioEventLoop会根据其感兴趣的事件类型调用相应的处理器通常是ChannelPipeline中的ChannelInboundHandler来处理这些事件。

这可能包括读取数据、写入数据、处理连接等。

执行非I/O任务

除了处理I/O事件外NioEventLoop还负责执行提交给它的非I/O任务。

这些任务可能包括用户自定义的业务逻辑、回调方法等。

NioEventLoop通常有一个任务队列用于存储待执行的任务。

在事件循环中它会检查任务队列并依次执行其中的任务。

定时任务调度

NioEventLoop还支持定时任务的调度。

用户可以将定时任务提交给NioEventLoop并指定任务的执行时间或执行间隔。

NioEventLoop内部会维护一个定时任务列表并根据任务的调度信息在合适的时间点执行这些任务。

通过这个事件循环机制NioEventLoop能够高效地处理大量的网络连接和I/O事件同时保持单线程的事件处理模型简化了并发控制和线程安全的处理。

此外Netty还通过多线程模型和多个NioEventLoop实例的配合使用实现了真正的并发处理从而能够处理更大规模的并发连接和事件。

Overrideprotected

selectStrategy.calculateStrategy(selectNowSupplier,

hasTasks());switch

SelectStrategy.CONTINUE:continue;case

fall-through

nextScheduledTaskDeadlineNanos();if

(curDeadlineNanos

超时等待时间nextWakeupNanos.set(curDeadlineNanos);try

{if

所以使用lazySet是可以的(没有竞争条件)nextWakeupNanos.lazySet(AWAKE);}//

fall

如果我们在这里接收到IOException那是因为Selector搞错了。

//

https://github.com/netty/netty/issues/8566rebuildSelector0();selectCnt

0;handleLoopException(e);continue;}/***

代码走到这里*

确保运行了所有待执行任务包括当前时间已经过期的计划任务ranTasks

runAllTasks();}}

超时时间到了即使还有任务没有运行也直接返回了等下一个周期在运行这些任务ranTasks

runAllTasks(ioTime

{logger.debug(Selector.select()

returned

(unexpectedSelectorWakeup(selectCnt))

{//

unexpectedSelectorWakeup(selectCnt)

SelectselectCnt

{logger.debug(CancelledKeyException.class.getSimpleName()

raised

{handleLoopException(t);}}}}NioEventLoop如何处理多路复用

NioEventLoop

的非阻塞特性和选择器Selector机制。

多路复用允许单个线程同时处理多个通道Channel的

I/O

操作不能立即完成时例如等待数据从网络读取线程不会被阻塞而是可以继续处理其他任务或事件。

任务调度与执行

还负责执行提交给它的任务如定时任务、用户自定义任务等。

这些任务与

I/O

当一个新的连接建立时Netty会创建一个新的Channel实例例如NioSocketChannel或NioServerSocketChannel并将其注册到NioEventLoop中的Selector上。

注册过程包括将Channel添加到Selector的监控列表中并设置其感兴趣的事件类型如读、写、连接等。

事件处理

一旦Selector检测到某个Channel上有事件就绪例如数据可读或可写它会通知NioEventLoop。

然后NioEventLoop会调用相应的ChannelPipeline和ChannelHandler来处理这些事件。

关闭Channel

当连接关闭时Netty会注销Channel并从Selector的监控列表中移除它。

同时相关的资源也会被释放。

管理Selector

在NioEventLoop初始化时它会创建一个Selector实例。

这个Selector用于监控所有注册到该NioEventLoop的Channel。

轮询就绪事件

NioEventLoop在事件循环中不断调用Selector的select()方法来等待Channel上的事件就绪。

一旦有事件就绪Selector会返回这些事件的集合。

处理就绪事件

NioEventLoop遍历Selector返回的就绪事件集合并为每个事件调用相应的处理器。

这通常涉及到调用ChannelPipeline中的ChannelHandler来处理这些事件。

Netty可能会使用多个Selector和NioEventLoop实例来优化性能特别是在处理大量并发连接时。

通过分散负载到多个线程和Selector上Netty能够充分利用多核CPU的资源提高吞吐量。

注意事项

通常情况下你不需要直接管理Selector。

Netty的NioEventLoop和Channel抽象为你提供了高级的API来处理I/O事件和连接。

在编写自定义的ChannelHandler时你需要关注如何处理事件而不是如何管理Channel或Selector。

如果你需要执行定时任务或自定义的后台任务可以使用NioEventLoop的任务队列来提交这些任务。

这些任务会在事件循环的适当时候得到执行。