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

Netty对Channel事件的处理以及空轮询Bug的解决

继续上一篇Netty文章,这篇文章主要分析Netty对Channel事件的处理以及空轮询Bug的解决

当Netty中采用循环处理事件和提交的任务时

由于此时我在客户端建立连接,此时服务端没有提交任何任务

此时select方法让Selector进入无休止的阻塞等待

此时selectCnt++进行一次计数,ioRatio用来设置处理非事件任务所占总事件的比例

紧接着进入processSelectedKeys方法内部,处理连接事件

由于NioEventLoop中维护了一个Selector,这里的SelectedKeys是对原始Selector中的SelectedKeys的一种优化,后续文章会总结Netty做的优化

这段代码作用就是获得到对应事件,然后通过附件的方式拿到NioServerSocketChannel

紧接着利用NioServerSocketChannel中的unsafe类完成消息的写出的读入

调用unsafe的read方法后,通过read方法中的doReadMessages拿到Java ServerSocketChannel建立的SocketChannel

拿到SocketChannel后,创建一个NioSocketChannel,并创建对应的pipleline,config等等和NioServerSocketChannel一样。然后把它暂存在一个List集合buf中

紧接着调用NioServerSocketChannel的pipleline方法出发read事件,这里提醒一下pipleline的组成一次是head,logging,acceptor,tail组成

此方法内部其实就是不断的查找下一个Handler,调用Read方法

并且由于一些任务比较耗时为了不阻塞链接线程可以使用自己设置线程组

当轮到acceptor方法处理时

注意:这里的childHandler是我们在server端最开始的strap代码时填入childHandler属性中的Handler,同时下方的childGroup就是server端最开始的childNioEventLoopGroup

接下来register方法内部就是我们上一篇文章讲到的进行线程切换,把NioSocketChannel以附件的形式绑定到SocketChannel。由于每个NioEventLoop都维护了一个Selector,同时把SocketChannel注册到(child)NioEventLoopGroup中的NioEventLoop中的Selector接着继续循环监听事件处理提交的任务。分析到这里我们可以理解Netty的基本线程模型了

接下来连接事件处理完毕,BossGroup该处理普通任务了

可以看到ioRation是控制所占用时间的比例的

而selectCnt是为了避免在Linux中导致selector不阻塞从而进行计数,当超过512时就认为出现bug,Netty解决方法就是重新创建一个Selector,并把原始信息复制一份。

接下来我们研究数据的发送和读写

http://www.lryc.cn/news/327378.html

相关文章:

  • 【PostgreSQL】- 1.1 在 Debian 12 上安装 PostgreSQL 15
  • 第4章.精通标准提示,引领ChatGPT精准输出
  • HTTP状态 405 - 方法不允许
  • 题目 2898: 二维数组回形遍历
  • Git命令上传本地项目至github
  • 机器学习之决策树现成的模型使用
  • 【python分析实战】成本:揭示电商平台月度开支与成本结构占比 - 过于详细 【收藏】
  • 新网站收录时间是多久,新建网站多久被百度收录
  • 通过Caliper进行压力测试程序,且汇总压力测试问题解决
  • LabVIEW比例流量阀自动测试系统
  • 安卓U3D逆向从Assembly-CSharp到il2cpp
  • 计算机网络——30SDN控制平面
  • Obsidian插件-高亮块(Admonition)
  • jHipster 之 webflux-前端用EventSource处理sse变成了批量处理而非实时处理
  • 原型链-(前端面试 2024 版)
  • 网络套接字补充——UDP网络编程
  • 自动化测试 —— Pytest fixture及conftest详解
  • Scala第十四章节(隐式转换、隐式参数以及获取列表元素平均值的案例)
  • VsCode的json文件不允许注释的解决办法
  • 利用图像识别进行疾病诊断
  • 大数据学习-2024/3/28-excel文件的读写操作
  • k8s 如何获取加入节点命名
  • 黑群晖基于docker配置frp内网穿透
  • 多线程基础:线程通信内容补充
  • 使用Jenkins打包时执行失败,但手动执行没有问题如ERR_ELECTRON_BUILDER_CANNOT_EXECUTE
  • OpenCV图像滤波、边缘检测
  • 前端项目在本地localhost可以调取到拍照或麦克风等设备,但是在局域网内IP+端口号访问项目时访问不到设备
  • flutter生成二维码并截图保存到图库
  • EasyExcel Converter实现java对象和excel单元格转换
  • stamac Ethernet DTS配置