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

news2025/1/13 13:56:44

摘要

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.coloradmin.cn/o/2150224.html

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

相关文章

人力资源数据集分析(二)_随机森林与逻辑回归

数据入口:人力资源分析数据集 - Heywhale.com 数据说明 字段说明EmpID唯一的员工IDAge年龄AgeGroup年龄组Attrition是否离职BusinessTravel出差:很少、频繁、不出差DailyRate日薪Department任职部门:研发部门、销售部门、人力资源部门Dista…

Visual Studio Code( VS Code)倍速提高编程工作效率的免费的源代码编辑器

耕耘于编程二十多年,后端、前端、操作系统、数据库、脚本都做过,各种各样的编程工具,IDE开发环境都用过,但是让我感觉比较好用、容易上手、能够提高工作效率的开发工具还是VS Code,下面我就简单的介绍一下这个广泛使用…

MySQL--导入SQL文件(命令行导入)

MySQL--导入SQL文件 一、前言二、导入SQL文件 一、前言 用可视化编辑工具编写,并且在控制台输入命令行在MySQL中导入SQL文件。 在导入SQL文件之前查看了目前存在的数据库 **目标:**在可视化编辑工具(这里以word文档为例)中编写SQL语句&…

计算机毕业设计 美妆神域网站的设计与实现 Java实战项目 附源码+文档+视频讲解

博主介绍:✌从事软件开发10年之余,专注于Java技术领域、Python人工智能及数据挖掘、小程序项目开发和Android项目开发等。CSDN、掘金、华为云、InfoQ、阿里云等平台优质作者✌ 🍅文末获取源码联系🍅 👇🏻 精…

力扣53-最大子序和(Java详细题解)

题目链接:力扣53-最大子序和 前情提要: 因为本人最近都来刷dp类的题目所以该题就默认用dp方法来做。 dp五部曲。 1.确定dp数组和i下标的含义。 2.确定递推公式。 3.dp初始化。 4.确定dp的遍历顺序。 5.如果没有ac打印dp数组 利于debug。 每一个…

EM-seq:酶法甲基化测序,甲基化测序的新选择

DNA甲基化作为一种关键的表观遗传修饰,已被广泛认为在基因表达调控、细胞分化以及多种疾病的发生发展中扮演着重要角色。DNA甲基化:将甲基基团添加到DNA分子的胞嘧啶上,可以影响基因的活性而不改变DNA序列,这种改变的持久性和可逆…

【原创教程】电气电工20:一文弄透电气电工辅材

电气电工这些知识点,我们描述的比较细,虽然看起来比较简单,但是它是后面我们技能提升的基础,如果我们后面学电气工程师相关知识,这些都属于基本功。 接着我们来看一下电气辅材。 电气辅材定义: 电气辅材是指与电气设备固有的元器件配套使用的配件和器具。常见的电气辅…

基于FPGA+GPU异构平台的遥感图像切片解决方案

随着遥感和成像技术的不断进步和普及,获取大量高分辨率的遥感图像已成为可能。这些大规模的遥感图像数据需要进行有效的处理和分析,以提取有用的信息,进行进一步的应用。遥感图像切片技术应运而生,该技术可以将大型遥感图像分割成…

Sentinel组件学习

Sentinel组件学习 1. Sentinel是什么2. Sentinel的作用3. 为啥使用Sentinel4. SpringCloud整合Sentinel代码示例4.1. 搭建Sentinel Dashboard4.2. SpringCloud项目接入Sentinel4.3. 使用SentinelResource注解 5. Sentinel Dashboard使用5.1 流控规则流控模式流控效果 5.2 熔断规…

cmake--get_filename_component

作用 按照指定的方式获取文件或者目录的信息。 使用 get_filename_component(<variable> <filename> <component>) variable: 用于保存提取的信息。 filename: 指定路径的文件或者目录。 component: 链接1 component DIRECTORY: 提取文件或者目录的父…

西安国际数字影像产业园:什么让这里成为创新型数字园区的典范?

在数字化浪潮奔涌的时代&#xff0c;创新型数字园区如雨后春笋般涌现&#xff0c;而树莓集团倾力打造的西安国际数字影像产业园无疑是其中的佼佼者。究竟是什么让这里成为创新型数字产业园区的典范呢&#xff1f; 1、西安国际数字影像产业园拥有强大的产业集聚效应。树莓集团凭…

『功能项目』QFrameWork道具栏物品生成【64】

我们打开上一篇63QFrameWork框架重构OnGUI的项目&#xff0c; OnGUI优点&#xff1a; 简单易用&#xff1a;OnGUI是基于代码的UI系统&#xff0c;对于简单的调试界面或者小型项目来说&#xff0c;可以快速实现UI需求。即时更新&#xff1a;OnGUI的UI元素是即时更新的&#xff…

基于Benes网络的SIMD同态密文任意重排

摘要 RLWE的密文使用了SIMD后极大的增加的同态加密的效率。同态加密通过加密一个向量&#xff0c;实现对明文的快速加法和乘法。然而&#xff0c;加密为一个密文的向量的内部元素之间&#xff0c;无法高效的操作。 如一个密文加密了 [ a , b , c ] [a,b,c] [a,b,c]&#xff0c…

13 vue3之内置组件keep-alive

内置组件keep-alive 有时候我们不希望组件被重新渲染影响使用体验&#xff1b;或者处于性能考虑&#xff0c;避免多次重复渲染降低性能。而是希望组件可以缓存下来,维持当前的状态。这时候就需要用到keep-alive组件。 开启keep-alive 生命周期的变化 初次进入时&#xff1a;…

使用express或koa或nginx部署history路由模式的单页面应用

使用hash模式会有#&#xff0c;影响美观&#xff0c;所以使用history模式会是个更好的选择。 前端项目打包上线部署&#xff0c;可以使用下面的方式部署history模式的项目&#xff0c;下面以 jyH5 为例 expressjs部署 express脚手架搭建的app.js中添加如下代码&#xff1a; …

大模型团队招人(校招):阿里巴巴智能信息,2025届春招来了!

阿里巴巴智能信息&#xff0c;2025届春招开始啦&#xff0c;欢迎有意向的优秀同学扫码投递。实习的内容也是大语言模型的核心方向Alignment&#xff0c;在这里有丰富的实验资源、良好的数据支持、优秀的师兄师姐带领你进入大模型的全新领域。内推直达&#xff1a;https://talen…

【Python】探索 Blinker:Python 进程内信号/事件分发系统

没人疼就去健身 &#xff0c;练完浑身疼&#xff01; 在现代软件开发中&#xff0c;事件驱动编程是一种非常强大的模式&#xff0c;它允许系统组件之间进行松散耦合的通信。Blinker 是一个 Python 库&#xff0c;提供了一个快速的进程内信号/事件分发系统&#xff0c;使得事件…

Double-Fetch漏洞检测工具的部署、使用与原理分析

文章目录 前言1、概述1.1、简介1.2、工作原理1.2.1、内核空间与用户空间的信息传递1.2.2、Double-Fetch漏洞产生的原因1.2.3、产生Double-Fetch漏洞的情况1.2.4、一个Double-Fetch漏洞示例1.2.5、Double-Fetch漏洞检测工具原理 1.3、模式匹配原理分析1.3.1、Coccinelle介绍1.3.…

AN7563PT数据手册学习笔记1

AN7563PT AN7563PT1 Overview2 Feature3 Block Diagram AN7563PT 1 Overview AN7563PT是一款高度集成的单芯片解决方案&#xff0c;适用于以太网网关应用。集成4个千兆以太网物理层、1个DDR4/DDR3控制器、1个USB3.0主机接口、1个USB2.0主机接口、2个PCIe Gen2单通道、1个VoIP…

什么是损失函数?常见的损失函数有哪些?

损失函数 什么是损失函数&#xff1f;损失函数作用如何设计损失函数常见的损失函数有哪些&#xff1f; 什么是损失函数&#xff1f; 损失函数&#xff08;Loss Function&#xff09;&#xff0c;也称为误差函数&#xff0c;是机器学习和深度学习中的一个重要概念。它用于衡量模…