当前位置: 首页 > news >正文

Netty的基本架构详解

EventLoopGroup基本认识

我们需要了解的 EventLoopGroup, Netty对EventLoopGroup做了很多的扩展实现,下图是他的家族图谱:

我们上一节课使用的案例,使用的是NioEventLoopGroup,他是NIO的实现,可以看出来他是MultithreadEventLoopGroup的子类,从名字上可以看出来,NioEventLoopGroup是一个多线程事件循环组,这里你可以把它看作是一个线程池,内部存在多个线程(NioEventLoop),每一个客户端连接的SocketChannel都对应一个线程(NioEventLoop)!

我们上面一直再说NioEventLoop, 我们基于上图可以看出来,他是SingleThreadEventLoop的子类,从名字上也能看出来,他是一个单线程的执行器!我们可以看到,他的父接口事实上也是继承与EventLoopGroup, 也就是说,虽然NIoEventLoop是一个单线程事件循环,但是我们基于接口,也可以把他看作为一个线程池,只不过这个线程池内部只有一个线程!

\## Netty的通讯通道

我们需要了解的Netty中的管道种类,这里我们重点分析NIO的实现方式:

我们可以看到,Netty的Socket通讯管道的主要实现方式有两种,NioServerSocketChannelNioSocketChannel, 这两种实现是Netty对于服务端通道,与客户端通道的不同实现,我们在开发Netty的服务端与客户端的时候,会指定使用管道的类型! 这里面有一个比较重要的点,即NioServerSocketChannel的父类实现是 AbstractNioMessageChannel, NioSocketChannel的父类实现是AbstractNioByteChannel ,这两个实现是后续NIO事件循环的时候判断是处理连接还是处理数据的重要手段,这里留个印象,我们后续会详细说!

Netty的管道流

我们需要了解的Netty的业务执行链,又叫管道流 ChannelPipeline

我们的Netty代码中都会由类似这种逻辑的代码:

他是Netty能够让我们专注于业务的主要实现方式,他的主要实现是一个双向链表,这里是在链表末尾追加一个Handler业务处理器,Handler的种类大致分为两种:

如上图所示,他有两种实现方式,一个是ChannelInboundHandlerAdapter一个是ChannelOutboundHandlerAdapter, 他们的调用在一个业务流中的执行顺序如下,我们借用一个图示来说明:

当我们调用Socket的读数据的API时,即从Socket管道读取数据时,Pipeline会按照你的添加顺序依次执行 Inbound Handler,当我们读取事件完毕,调用write方法向通道内写入数据的时候,管道流开始调用 Outbound Handler方法,倒序调用!这个倒序调用可能不好理解,我们还是用图来说明:

当调用read方法的时候,顺序调用Inbound节点! 当调用write方法的时候,倒序调用outbount方法!

Netty的Handler事件回调种类

1. ChannelInboundHandler

方法名称方法作用
handlerAdded通道被添加 1
channelRegisteredJDK注册成功后回调所有Handler的方法 2
channelActivejdkChannel被激活后回调 3
channelRead通道内有数据可读 4
channelReadComplete数据读取完毕 5
channelInactive通道被关闭后回调该方法 6
channelUnregistered通道被取消注册回调用该方法 7
handlerRemoved通道被删除 8
userEventTriggered如果触发了用户事件,则调用该方法。
channelWritabilityChanged可写的状态改变
exceptionCaught发生了异常

2. ChannelOutboundHandler

方法名称方法作用
bind进行绑定操作后调用。
connect进行连接操作后调用。
disconnect进行断开连接操作后调用。
close进行关闭操作后调用。
deregister从当前已注册的EventLoop进行注销操作后调用。
read读数据
write写数据
flush刷新到管道

总结

通过本篇文章,我们可以了解到Netty中比较重要的几个概念,EventLoopGroup的基本概念、Netty中的通道概念、Netty中的管道流的概念!

相关文章:

  • Next.js 15【实用教程】2025最新版
  • BGP配置华为——路由汇总
  • 计算机网络原理习题一
  • 《网络编程卷2:进程间通信》第七章:同步机制深度解析与多场景实践
  • #渗透测试#批量漏洞挖掘#AJ-Report开源数据大屏存在远程命令执行漏洞
  • 数据结构中的邻接矩阵
  • Wireshark TS | 再谈虚假的 TCP Spurious Retransmission
  • QT笔记——QRadioButton
  • VRPTW 问题与新兴技术结合的创新方向及具体案例
  • 借3D视觉定位东风,汽车零部件生产线实现无人化的精准飞跃
  • Ubuntu设置docker代理报网络错误
  • 【Python】条件循环
  • tcp/ip网络模型
  • C# Dictionary的实现原理
  • 傅里叶变换推导
  • 清理docker/podman的存储空间
  • Effective Objective-C 2.0 读书笔记——内存管理(上)
  • 在vuejs项目中使用momentjs获取今日、昨日、本周、下周、本月、上月、本季度、上季度、本年、去年等日期
  • ADC 的音频实验,无线收发模块( nRF24L01)
  • 【Python深入浅出㊸】解锁Python3中的TensorFlow:开启深度学习之旅
  • 《风林火山》千呼万唤始出来,戛纳首映后口碑崩盘?
  • 被围观的“英之园”,谁建了潮汕天价违建?
  • 舞者王佳俊谈“与AI共舞”:像多了一个舞伴,要考虑它的“感受”
  • 《歌手》回归,人均技术流,00后整顿职场
  • 马上评|家长抱婴儿值护学岗,如何避免“被自愿”?
  • 普京调整俄陆军高层人事任命