2 Netty版socket网络编程
下面分别介绍图中对应组件。
3 Netty核心组件
3.1 NioEventLoop
3.1.1 简介
EventLoop
一个 eventloop 就是一个 eventexecutor
NioEventLoopGroup 是一个处理 I/O 操作的多线程事件循环。Netty 为不同类型传输提供各种 EventLoopGroup 实现。
在示例代码中,我们实现服务器端应用程序,因此将使用两个 NioEventLoopGroup:
第一个,通常称为’boss’,接受传入的连接
第二个(通常称为’work’)在上司接受连接并登记到工作人员后处理接受连接的流量。使用多少线程以及如何映射到创建的通道取决于 EventLoopGroup 实现,甚至可能通过构造函数进行配置。
Netty的发动机
Server端
Client端
while(true)
就对应一个 run 方法
- NioEventLoop#run
- netty有不同的io编程模型实现。
- 以NIO为例,对IO事件的处理是在NioEventLoop里做的,事件的注册在下面的方法
- 不同事件调用unsafe的不同方法,netty对底层socket的操作都是通过unsafe来做的
unsafe主要由两种不同的实现:
NioMessageUnsafe
NioServerSocketChannel使用的是NioMessageUnsafe来做socket操作
NioByteUnsafe
NioSocketChannel使用NioByteUnsafe来做socket操作
处理每一个连接
EventExecutorGroup
EventExecutorGroup
负责经由其使用next()
方法提供EventExecutor
。 除此之外,还负责处理自己的生命周期,并允许在全局模式中关闭它们。
EventExecutor
该EventExecutor
是个特殊的EventExecutorGroup
,附带一些快捷方法,看是否有Thread
在事件循环执行。
除此之外,它还继承了EventExecutorGroup
以允许通用的方法来访问。
eventloopGroup
特殊的 EventExecutorGroup
,它允许注册 Channel
,即事件循环期间可以执行 channel 操作,得到处理,供以后选用
3.2 Channel
以服务端的NioMessageUnsafe为例来看下read()方法的实现,对应是否有新连接进来的情况
直接把底层的 channel 封装成 NioSocketChannel