Netty源码解析-请求处理与多路复用

Netty基本介绍,参考 Netty与网络编程

摘要

Netty源码系列-NioEventLoop

1.1 Netty给Channel分配Nio Event Loop的规则

看下图,EventLoopGroup是线程组,每个EventLoop是一个线程,那么线程处理请求是怎么分配的呢?我们看一下源码
在这里插入图片描述

1.1.1 MultithreadEventLoopGroup.register方法

该方法是EventLoop注册Channel的方法,进入next()方法,就在下图最上面的一个方法。此方法负责选择一个NioEventLoop,进入super.next()方法。
在这里插入图片描述

1.1.2 super.next()方法

我们看到这里调用了MultithreadEventExecutorGroup的属性chooser的next()方法
在这里插入图片描述

点击chooser,我们找到它赋值的地方在构造方法里面,chooser的正是通过DefaultEventExecutorChooserFactory的newChooser获取的,
在这里插入图片描述

1.1.3 newChooser方法

进入newChooser方法,根据传入的executors长度是否2的指数返回不同的实现类,这里实现了一个策略模式。为什么要这么做呢?我们继续往下看
在这里插入图片描述

注意到这里isPowerOfTwo只有一行代码,为什么还有单独写一个方法呢,虽然只有一行代码但是不容易看懂,通过方法名我们一下就看懂了,这是一种可读性更好的实现方式

1.1.4 我们继续看chooser.next()方法

该方法来自于接口EventExecutorChooserFactory.EventExecutorChooser,有两个实现类GenericEventExecutorChooser和PowerOfTwoEventExecutorChooser,都是在DefaultEventExecutorChooserFactory中。
在这里插入图片描述

1.1.5 看两个实现类实现的有何不同

在这里插入图片描述

两者都是通过idx来获取索引值的,idx是递增的,这种模式类似轮询的方式。但是获取位置的方式不一样

  • GenericEventExecutorChooser,idx对executors.length取模,并取绝对值
  • PowerOfTwoEventExecutorChooser, idx对executors.length - 1做与运算确定位置,这种方式类似于HashMap中对桶位置运算的处理,与运算比数学运算快很多,但是只能在executors.length是2的指数的时候才可以发挥作用。

为什么不直接用idx呢
因为idx一直累加下去可能会越界,超出数组长度,所以需要取模或者做与运算的方式控制范围。

例如: executors.length = 2^4, 其二进制为10000,executors.length-1=01111。任何值与1111与运算都不会超过executors.length,同时任何小于executors.length的值和1111与运算都是其本身。这是这个特性才能实现这样的优化。

总结

在正常情况下我们还是使用GenericEventExecutorChooser来选择EventLoop,这里PowerOfTwoEventExecutorChooser对next方法做了优化,所以在EventLoop组长度是2的指数的时候我们可以更快的处理

1.2 多路复用怎么跨平台的

如下图,在不同的系统平台上,EventLoop如何跨平台呢?我们看一下Selector的源码(其他类似)
在这里插入图片描述

1.2.1 我们看一下new NioEventLoopGroup()

在这里插入图片描述

点进这个方法,继续进入,我们找到下面这个方法,看Selector来自SelectorProvider.provider
在这里插入图片描述

1.2.2 进入SelectorProvider.provider,这里的run方法里面有三个分支, 如下图。

  • 第一个是从配置的类加载provider
  • 第二个是从系统加载provider
  • 如果前两个都没有,看第三个sun.nio.ch.DefaultSelectorProvider.create,
    这个方法是jre虚拟机的方法,不同平台的jdk版本上,该方法不一样,Selector通过这种方式来实现跨平台
    在这里插入图片描述

下图是openjdk不同平台是Selector实现:
在这里插入图片描述

总结

跨平台通过java虚拟机实现,调用java虚拟机的方法,在不同的平台,该方法由不同的java虚拟机实现,这样实现跨平台,这蒸是java通过虚拟机实现跨平台的方式。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.xdnf.cn/news/145394.html

如若内容造成侵权/违法违规/事实不符,请联系一条长河网进行投诉反馈,一经查实,立即删除!

相关文章

Docker 以外置数据库方式部署禅道

2.安装步骤 2.1.参考资料 禅道官网文档: https://www.zentao.net/book/zentaopms/docker-1111.html https://www.zentao.net/book/zentaopms/405.html 2.2.详细步骤 ssh 登录服务器创建目录 /opt/zentao /opt/zentao/data /opt/zentao/db cd /opt mkdir zentao mkdir zentao…

回归预测 | Matlab实现SSA-HKELM麻雀算法优化混合核极限学习机多变量回归预测

回归预测 | Matlab实现SSA-HKELM麻雀算法优化混合核极限学习机多变量回归预测 目录 回归预测 | Matlab实现SSA-HKELM麻雀算法优化混合核极限学习机多变量回归预测效果一览基本介绍程序设计参考资料 效果一览 基本介绍 1.Matlab实现SSA-HKELM麻雀算法优化混合核极限学习机多变量…

java -versionbash:/usr/lib/jvm/jdk1.8.0_162/bin/java:无法执行二进制文件:可执行文件格式错误

实验环境:Apple M1在VMwareFusion使用Utubun Jdk文件错误  尝试: 1、重新在网盘下载java1.8 2、在终端通过命令下载 3、确保 JDK 正确安装在系统中,可以通过 echo $JAVA_HOME 检查 JAVA_HOME 环境变量是否设置正确。 &#xfff…

十种果冻的做法

菠萝果冻 1.在菠萝的1/5处切开,切去顶做盖子用,用水果刀在四周划一圈使皮和果肉分离 2.注意底部切透了,用水果刀把菠萝肉挖出,菠萝肉切丁用盐水浸泡备用 3.把菠萝丁放入料理机中加入少许纯净水,打成菠萝汁备用 4.打好…

【学习笔记】数据结构(六 ②)

树和二叉树(二) 文章目录 树和二叉树(二)6.3.2 线索二叉树 6.4 树和森林6.4.1 树的存储结构6.4.2 森林与二叉树的转换6.4.3 树和森林的遍历 6.5 树与等价问题6.5.1 等价定义6.5.2 划分等价类的方法6.5.3 划分等价类的具体操作 - 并…

【IoTDB 线上小课 07】多类写入接口,快速易懂的“说明书”!

【IoTDB 视频小课】稳定更新中!第七期来啦~ 关于 IoTDB,关于物联网,关于时序数据库,关于开源... 一个问题重点,3-5 分钟,我们讲给你听: 一条视频了解写入接口 了解我们的友友们,应该…

[Linux]Vi和Vim编辑器

Vi和Vim编辑器 Linux系统会内置vi文本编辑器, 类似于windows中的记事本 Vim具有程序编辑的能力, 可以看作是Vi的增强版本, 可以进行语法检查, 代码补全,代码编译和错误调整等功能 Vi和Vim的模式 快速入门 使用vim开发一个Hello.java程序 通过Xshell连接Linux系统命令行输入…

XML:DOM4j解析XML

XML简介: 什么是XML:XML 是独立于软件和硬件的信息传输工具。 XML 的设计宗旨是传输数据,而不是显示数据。XML 标签没有被预定义。您需要自行定义标签。XML不会做任何事情,XML被设计用来结构化、存储以及传输信息。 XML可以发明…

企业内网安全

企业内网安全 1.安全域2.终端安全3.网络安全网络入侵检测系统异常访问检测系统隐蔽信道检测系统 4.服务器安全基础安全配置入侵防护检测 5.重点应用安全活动目录邮件系统VPN堡垒机 6.蜜罐体系建设蜜域名蜜网站蜜端口蜜服务蜜库蜜表蜜文件全民皆兵 1.安全域 企业出于不同安全防…

[备忘]测算.net中对象所占用的内存

.net 基础库中应该是没有直接提供计算某个对象所占内存的方法。简单查了下,找到几种方式: 1、运行态用工具进行内存分析 比如,微软这篇教程中有介绍。《使用 .NET 对象分配工具分析内存使用情况》https://learn.microsoft.com/zh-cn/visuals…

优数:助力更高效的边缘计算

在数字化时代的浪潮中,数据已成为企业最宝贵的资产之一。随着物联网(IoT)设备的激增和5G技术的兴起,我们正迅速步入一个新时代,在这个时代中,数据不仅在量上爆炸性增长,更在速度和实时性上提出了…

idea 恢复 pom 文件呈现灰色并带删除线

今天在 idea 中导入别人的项目时发现有几个 pom 文件是灰色的并带删除线。 可以用以下方式解决: 打开file - settings - build,execution,deployment - Build Tools - Maven - Ignored Files 把 pom.xml 前面的复选框去掉,去掉之后,点击 appl…

IMS 中private user id/public user id的格式

private user identity(IMPI)的格式为 "<IMSI>ims.mnc<MNC>.mcc<MCC>.3gppnetwork.org" public user identity SIP URI 格式为 sip:usernamedomain&#xff1b;而Tel URI 格式为 tel:<CC><NDC><SN> temporary public user ide…

linux安装nginx+前端部署vue项目(实际测试react项目也可以)

&#x1f9f8;本篇博客作者测试上线过不下5个项目&#xff0c;包括单纯的静态资源&#xff0c;vue项目和react项目&#xff0c;包好用&#xff0c;请放心使用 &#x1f4dc;作者首页&#xff1a;dream_ready-CSDN博客 &#x1f4dc;有任何问题都可以评论留言&#xff0c;作者将…

无人机飞手教员培训及就业分析

无人机飞手教员培训是一个综合性的教育体系&#xff0c;旨在培养具备专业飞行技能、扎实理论知识以及高效教学能力的无人机飞手导师。培训内容广泛覆盖从无人机基础知识到高级飞行技巧&#xff0c;再到教学方法与技巧&#xff0c;确保学员能够全面掌握无人机操作与教学的精髓。…

pcdn盒子连接方式

连接方式 大部分连接方式如下 光猫拨号 → 路由器 → 盒子 优点&#xff1a;光猫负责拨号&#xff0c;路由器只需做路由转发&#xff0c;性能要求不高缺点&#xff1a;光猫会有一层nat&#xff0c;路由器还有一层nat&#xff0c;两层nat需要在两个设备上都做nat优化注意&…

macOS 中搭建 Flutter 开发环境

如果你的 Mac 是 Apple silicon 处理器&#xff0c;那么有些 Flutter 组件就需要通过 Rosetta 2 来转换适配&#xff08;详情&#xff09;。要在 Apple silicon 处理器上运行所有 Flutter 组件&#xff0c;请运行以下指令来安装 Rosetta 2。 sudo softwareupdate --install-ro…

最新LinPay码支付 免签支付系统源码 免授权版本(含搭建教程)

最新LinPay码支付 免签支付系统源码 免授权版本 服务集成商兼容市面所有易支付&#xff0c;兼容所有商城LinPay是专为个人站长打造的聚合免签系统&#xff0c;拥有卓越的性能和丰富的功能。它采用全新轻量化的界面UI&#xff0c;让您能更方便快捷地解决知识付费和运营赞助的难…

ChatGPT搭上langchain的知识库RAG应用,效果超预期

最近利用LangchainChatGPT实现了上传文档实现个人知识库应用的能力&#xff0c;效果比想象得要好。文末大家可以体验一下效果~~ 给大家大致介绍下实现方式&#xff0c;参考了Langchain chatchat。 一、LangchainChatGPT 1、概述 LangChain 是一个强大的框架&#xff0c;可以…

CDA Level 1 业务数据分析

目录 理解业务数据分析方法、掌握业务数据分析流程、能够使用及设计创建业务指标、能够结合业务模型及业务分析方法正确理解业务问题&#xff0c;找到问题原因&#xff0c;并能够提出解决问题建议&#xff0c;这个章节的应用会考的比较多&#xff08;终于正经起来了呢&#xf…