阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

2 Netty版socket网络编程

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

下面分别介绍图中对应组件。

3 Netty核心组件

3.1 NioEventLoop

3.1.1 简介

EventLoop

一个 eventloop 就是一个 eventexecutor

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

NioEventLoopGroup 是一个处理 I/O 操作的多线程事件循环。Netty 为不同类型传输提供各种 EventLoopGroup 实现。


在示例代码中,我们实现服务器端应用程序,因此将使用两个 NioEventLoopGroup:


第一个,通常称为’boss’,接受传入的连接


第二个(通常称为’work’)在上司接受连接并登记到工作人员后处理接受连接的流量。使用多少线程以及如何映射到创建的通道取决于 EventLoopGroup 实现,甚至可能通过构造函数进行配置。


Netty的发动机

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

Server端

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

Client端

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

while(true)就对应一个 run 方法

  • NioEventLoop#run
  • 阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)
  • netty有不同的io编程模型实现。
  • 以NIO为例,对IO事件的处理是在NioEventLoop里做的,事件的注册在下面的方法
  • 阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)
  • 阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)
  • 不同事件调用unsafe的不同方法,netty对底层socket的操作都是通过unsafe来做的

unsafe主要由两种不同的实现:


NioMessageUnsafe

NioServerSocketChannel使用的是NioMessageUnsafe来做socket操作

NioByteUnsafe

NioSocketChannel使用NioByteUnsafe来做socket操作

处理每一个连接

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

EventExecutorGroup

EventExecutorGroup 负责经由其使用next()方法提供EventExecutor。 除此之外,还负责处理自己的生命周期,并允许在全局模式中关闭它们。

EventExecutor

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

EventExecutor是个特殊的EventExecutorGroup,附带一些快捷方法,看是否有Thread在事件循环执行。

除此之外,它还继承了EventExecutorGroup以允许通用的方法来访问。

eventloopGroup

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

特殊的 EventExecutorGroup,它允许注册 Channel,即事件循环期间可以执行 channel 操作,得到处理,供以后选用

3.2 Channel

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

以服务端的NioMessageUnsafe为例来看下read()方法的实现,对应是否有新连接进来的情况

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

直接把底层的 channel 封装成 NioSocketChannel

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件(中)

上一篇:如何购买阿里云服务器ECS更便宜实惠?


下一篇:阿里云怎么购买云速成美站: 虚拟主机+建站模板