NIO核心依赖多路复用小记

NIO允许一个线程同时处理多个连接,而不会因为一个连接的阻塞而导致其他连接被阻塞。核心是依赖操作系统的多路复用机制。

操作系统的多路复用机制

多路复用是一种操作系统的 I/O 处理机制,允许单个进程(或线程)同时监视多个输入或输出流的就绪状态。这样,一个进程就能够通过一个系统调用来等待多个事件,而不是为每个事件创建一个独立的进程或线程。

多路复用常见机制

  1. select: select 是一个系统调用,通过它可以同时监视多个文件描述符(通常是套接字)。当其中任何一个文件描述符准备好进行读取或写入时,select 就会返回,并告诉程序哪些文件描述符处于就绪状态。

  2. poll: poll 也是一个系统调用,它和 select 类似,但是对文件描述符的管理更加灵活,而且没有文件描述符数目的限制。

  3. epoll: epoll 是 Linux 中引入的一种多路复用机制,相对于 selectpoll 具有更好的性能。epoll 使用事件通知的方式,只关心那些发生了变化的文件描述符,减少了遍历全部文件描述符的开销。

网络请求的流程

当客户端请求到达服务器时,整个流程可以分为以下几个步骤,涉及用户态和内核态的协同工作:

  1. 服务器启动: 服务器程序在用户态中启动,并创建一个监听 socket。这个监听 socket 负责接收客户端的连接请求。

  2. 监听连接: 服务器使用 select 或其他多路复用的系统调用,将监听 socket 添加到文件描述符集合中,然后阻塞等待事件发生。这时用户程序告诉内核要监听哪些文件描述符,而这些文件描述符通常是由 accept 等系统调用返回的新连接。

  3. 客户端连接: 当有客户端发起连接请求时,内核接收到连接请求,然后将新的连接 socket(客户端连接的文件描述符)添加到文件描述符集合中。此时内核通知用户程序,有文件描述符就绪。

  4. 处理连接: 用户程序从 select 返回后,检查文件描述符集合,确定哪些连接处于就绪状态。然后,用户程序可以通过 accept 接受新的连接,获得新的文件描述符,并处理与客户端的通信。

下面是一个简化的伪代码示例:

// 服务器启动
int listen_fd = create_and_bind_socket(port);
listen(listen_fd, SOMAXCONN);// 设置监听 socket 到文件描述符集合
fd_set master_fds;
FD_ZERO(&master_fds);
FD_SET(listen_fd, &master_fds);
int max_fd = listen_fd;while (true) {fd_set read_fds = master_fds;// 使用 select 监听文件描述符int ready = select(max_fd + 1, &read_fds, NULL, NULL, NULL);if (ready == -1) {// 处理错误} else {// 检查文件描述符集合,确定哪些连接就绪for (int i = 0; i <= max_fd; ++i) {if (FD_ISSET(i, &read_fds)) {if (i == listen_fd) {// 有新连接int new_fd = accept(listen_fd, ...);FD_SET(new_fd, &master_fds);if (new_fd > max_fd) {max_fd = new_fd;}} else {// 有数据可读handle_data(i);}}}}
}

在这个示例中,listen_fd 是监听 socket 的文件描述符,当有新的连接到达时,会使用 accept 获得新的文件描述符,然后将其添加到文件描述符集合中。select 会在有文件描述符就绪时返回,用户程序通过检查文件描述符集合确定哪些连接可以进行处理。

这个监听 socket 并不是客户端的连接请求,而是用于接受客户端连接的准备工作。客户端连接请求是在客户端发起连接时生成的。

文件描述符

在类Unix/Linux系统中,一切皆文件,包括网络连接。

文件描述符(File Descriptor)是用于标识已打开文件或I/O资源的整数。对于网络连接,文件描述符是内核用于跟踪每个连接的标识符。当一个客户端连接到服务器时,内核为这个连接分配一个文件描述符,通过这个文件描述符,内核能够管理和操作与客户端之间的I/O操作。

连接的表示

在 Linux 系统下,客户端与服务器之间的连接通常被抽象为文件描述符。这是因为内核为每个连接分配了一个文件描述符,通过这个文件描述符可以进行对应连接的读、写等I/O操作。文件描述符是一种通用的抽象,通过它,可以使用相同的接口进行文件、网络连接等各种I/O操作。

文件描述符(File Descriptor)并不是一个真正的文件

在 Linux 下,文件描述符(File Descriptor)并不是一个真正的文件,而是一个整数,用于标识已打开文件或 I/O 资源。每个客户端连接到服务器时,内核会为该连接分配一个文件描述符。这个文件描述符在内核中用于跟踪和管理该连接的相关信息,包括读写数据等 I/O 操作。
Linux 内核并不会创建一个真正的文件来存放客户端的请求内容、客户端的 IP 和端口等信息。相反,它在内核中维护了一个数据结构来表示每个连接的状态,这个数据结构包含了与连接相关的信息。这个信息通常被称为 socket(套接字),是用于在网络上进行通信的抽象。
当客户端发起连接时,内核会分配一个 socket,并分配一个文件描述符用于标识这个 socket。该文件描述符被传递给用户程序,用户程序可以通过这个文件描述符进行对应连接的读写操作。客户端的 IP 地址和端口等信息通常可以通过相应的系统调用获取,而不是通过创建一个文件。
总之,Linux 中的文件描述符不是一个实际的文件,而是用于标识和操作已打开的 I/O 资源,其中包括网络连接。相关的信息则在内核中以 socket 的形式存在,而不是在文件中。

用户态和内核态

在操作系统中,用户态(User Mode)和内核态(Kernel Mode)是指操作系统与应用程序之间的两个不同的运行级别或权限级别。这两个模式之间的切换是由操作系统内核控制的,而且涉及到处理器的特权级别。

  1. 用户态(User Mode):

    • 在用户态运行的是应用程序代码。在这个级别下,应用程序只能访问自己的内存空间,不能直接访问操作系统的内核空间。
    • 用户态的应用程序不能执行一些特权指令,例如直接访问硬件设备或执行特定的系统管理任务。
  2. 内核态(Kernel Mode):

    • 内核态是操作系统内核运行的级别。在这个级别下,操作系统具有较高的特权,可以执行所有指令,包括直接访问硬件设备、修改系统控制寄存器等。
    • 操作系统内核负责管理系统的资源,处理中断、异常和系统调用,以及执行一些特权操作。
  3. 切换:

    • 当应用程序需要执行一些特权操作(例如打开一个文件、发送网络数据等)时,就需要从用户态切换到内核态。这个切换是通过系统调用(System Call)来触发的。
    • 当发生中断、异常或系统调用时,处理器会从用户态切换到内核态,执行相应的内核代码。完成后,再切换回用户态继续执行应用程序代码。
  4. 切换的目的:

    • 切换到内核态的目的是为了执行一些需要较高权限或操作系统特权的任务,例如管理系统资源、执行设备驱动程序等。
    • 切换回用户态后,应用程序可以继续执行。这种切换的目的是为了保护系统的安全性和稳定性,防止应用程序直接访问敏感的系统资源。

总的来说,用户态和内核态的划分是为了保障系统的安全性和稳定性,确保应用程序不能随意访问和修改系统的关键资源。用户态和内核态之间的切换是由操作系统内核控制的,它会根据需要在两者之间进行切换。

文件描述符集合

在用户态,通过 select 系统调用的参数中的文件描述符集合(通常是 fd_set)来告诉内核要监听哪些文件描述符。fd_set 是一个数据结构,它使用一个位图来表示文件描述符的状态,每个位表示一个文件描述符。

在调用 select 时,用户程序会将自己关心的文件描述符添加到 fd_set 中。在 select 返回后,用户程序可以检查 fd_set 来确定哪些文件描述符处于就绪状态。就绪状态通常表示有数据可读、有数据可写或者发生了错误。

下面是一个简化的示例:

#include <sys/select.h>int main() {fd_set read_fds;FD_ZERO(&read_fds);int sockfd = /* 创建并设置socket描述符 */;FD_SET(sockfd, &read_fds);// 设置超时时间为5秒struct timeval timeout;timeout.tv_sec = 5;timeout.tv_usec = 0;// 调用select,监听文件描述符int ready = select(sockfd + 1, &read_fds, NULL, NULL, &timeout);if (ready == -1) {// 处理错误} else if (ready == 0) {// 超时} else {// 检查read_fds,确定哪些文件描述符就绪if (FD_ISSET(sockfd, &read_fds)) {// sockfd 就绪,可以进行读操作}}return 0;
}

在这个示例中,通过 FD_SETsockfd 添加到 read_fds 中,然后调用 select 来监听这个文件描述符。当 select 返回后,通过检查 FD_ISSET 可以确定 sockfd 是否处于就绪状态,进而进行相应的操作。

用户程序在调用 select 之前,需要设置好相应的文件描述符集合,并在 select 返回后,根据就绪状态进行处理。这种方式允许用户程序选择性地监听和处理多个文件描述符。

学习打卡:Java学习笔记-day04-NIO核心依赖多路复用小记

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

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

相关文章

第二百六十一回

文章目录 1. 概念介绍2. 使用方法2.1 简单用法2.2 自定义用法 3. 示例代码4. 内容总结 我们在上一章回中介绍了"三方包open_settings"相关的内容&#xff0c;本章回中将介绍另外一个三方包&#xff1a;bluetooth_enable_fork.闲话休提&#xff0c;让我们一起Talk Flu…

【漏洞复现】锐捷EG易网关cli.php后台命令执行漏洞

Nx01 产品简介 锐捷EG易网关是一款综合网关&#xff0c;由锐捷网络完全自主研发。它集成了先进的软硬件体系架构&#xff0c;配备了DPI深入分析引擎、行为分析/管理引擎&#xff0c;可以在保证网络出口高效转发的条件下&#xff0c;提供专业的流控功能、出色的URL过滤以及本地化…

MySQL批量插入技巧

关于MySQL批量插入的一些问题 MySQL一直是我们互联网行业比较常用的数据&#xff0c;当我们使用半ORM框架进行MySQL大批量插入操作时&#xff0c;你是否考虑过这些问题: 进行大数据量插入时&#xff0c;是否需要进行分批次插入&#xff0c;一次插入多少合适&#xff1f;有什么…

Elasticsearch:Search tutorial - 使用 Python 进行搜索 (三)

这个是继上一篇文章 “Elasticsearch&#xff1a;Serarch tutorial - 使用 Python 进行搜索 &#xff08;二&#xff09;” 的续篇。在今天的文章中&#xff0c;本节将向你介绍一种不同的搜索方式&#xff0c;利用机器学习 (ML) 技术来解释含义和上下文。 向量搜索 嵌入 (embed…

【Python机器学习】深度学习——调参

先用MLPClassifier应用到two_moons数据集上&#xff1a; from sklearn.neural_network import MLPClassifier from sklearn.datasets import make_moons from sklearn.model_selection import train_test_split import mglearn import matplotlib.pyplot as pltplt.rcParams[f…

训练营第四十二天 | 01背包问题,你该了解这些! ● 01背包问题,你该了解这些! 滚动数组 ● 416. 分割等和子集

01背包问题 二维 代码随想录 dp二维数组 优化 01背包问题 一维 代码随想录 dp一维数组 416. 分割等和子集 把数组分成总和相等的两份&#xff0c;如果数组总和为奇数&#xff0c;不能分割&#xff0c;若有符合的数组子集&#xff0c;返回true 代码随想录 class Solution {p…

RK3568驱动指南|第十一篇 pinctrl 子系统-第127章 猜想验证

瑞芯微RK3568芯片是一款定位中高端的通用型SOC&#xff0c;采用22nm制程工艺&#xff0c;搭载一颗四核Cortex-A55处理器和Mali G52 2EE 图形处理器。RK3568 支持4K 解码和 1080P 编码&#xff0c;支持SATA/PCIE/USB3.0 外围接口。RK3568内置独立NPU&#xff0c;可用于轻量级人工…

LocalDateTime与时间戳转换的全局配置

问题 在开发中&#xff0c;我们使用LocalDateTime为时间类型作为返回给前端&#xff0c;或者接收给前端的值&#xff0c;经常遇到返回变成了这种形式。 {"timestamp": [2024,1,12,16,36,29,592604100] }所以我们需要规定一种统一格式来进行接收与返回&#xff0c;我…

数据中心建设之——理解基于财务三大报表的BI指标体系搭建

目录 1.1 三张报表的作用 1.2 三张报表长的样子 1.2.1 资产负债表 1.2.2 利润表 1.2.3 现金流 1.3 BI指标构建 1.3.1 盈利能力指标构建 1.3.2 营运能力指标构建 1.3.3 偿债能力指标构建 转眼间&#xff0c;一年又悄然而逝&#xff0c;时光荏苒&#xff0c;岁月如梭 &a…

仓储|仓库管理水墨屏RFID电子标签2.4G基站CK-RTLS0501G功能说明与安装方式

随着全球智能制造进度的推进以及物流智能化管理水平的升级&#xff0c;行业亟需一种既能实现RFID批量读取、又能替代纸质标签在循环作业、供应链管理以及实现动态条码标签显示的产品。在此种行业需求背景下&#xff0c;我是适时推出了基于墨水屏显示技术的VT系列可视化超高频标…

JVM-JVM支持高并发底层原理精讲

一、透彻掌握高并发-从理解JVM开始 二、从线程的开闭看JVM的作用 1.run方法 启动start方法&#xff0c;会调用底层C方法&#xff0c;告诉操作系统当前线程处于可运行状态&#xff0c;而如果直接调用run方法&#xff0c;则就不是以线程的方式来运行了&#xff0c;只是当做一个普…

一套成熟的Spring Cloud智慧工地平台源码,自主版权,支持二次开发!

智慧工地源码&#xff0c;java语言开发的智慧工地源码 智慧工地利用移动互联、物联网、云计算、大数据等新一代信息技术&#xff0c;彻底改变传统施工现场各参建方的交互方式、工作方式和管理模式&#xff0c;为建设集团、施工企业、监理单位、设计单位、政府监管部门等提供一揽…

【Databend】基础函数应用

文章目录 数值函数字符串函数逻辑函数JSON 函数聚合函数总结 数值函数 使用频率较高的数值函数如下&#xff1a; abs(x)&#xff1a;参数x的绝对值。ceil(x)&#xff1a;参数x向上取整。floor(x)&#xff1a;参数x向下取整。rand([n])&#xff1a;生成 [0,1&#xff09;的浮点…

RabbitMQ(十)队列的声明方式

目录 1.编程式声明补充&#xff1a;RabbitTemplate 和 AmqpAdmin 的区别 2.声明式声明补充&#xff1a;new Queue() 和 QueueBuilder.durable(queueName).build() 的区别 背景&#xff1a; 在学习 RabbitMQ 的使用时&#xff0c; 经常会遇到不同的队列声明方式&#xff0c;有的…

酚醛胶面建筑模板 — 广西厂家直销,质保可靠

在现代建筑行业中&#xff0c;选择高质量的建筑板材对于确保施工质量和工程安全至关重要。广西厂家直销的酚醛胶面建筑板&#xff0c;以其卓越的质量和可靠的质保&#xff0c;成为了建筑行业的优选材料。 产品特性 卓越的耐候性&#xff1a;我们的酚醛胶面建筑板采用高品质酚醛…

图文看懂Android的Matrix原理

Matrix结构 在Android开发中&#xff0c;矩阵是一个非常强大且有趣的工具。位于图形库中&#xff0c;android.graphics.Matrix 是一个 33 的 float 矩阵&#xff0c;其主要作用是坐标变换。 它的结构大概是这样的&#xff1a; 其中每个位置的数值作用和其名称所代表的的含义是…

【写作】短篇《相遇与相守》

文章目录 前言背景角色故事梗概 第一章 缘分的邂逅第二章 心动的瞬间第三章 甜蜜的日子第四章 误会与和解第五章 共度风雨 前言 背景 时代背景 现代&#xff0c;一个充满忙碌和喧嚣的都市。这个都市是许多年轻人追求梦想和奋斗的地方&#xff0c;但也是许多人渴望寻找真挚感情…

Vue-18、Vue人员列表排序

<!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>列表排序</title><script type"text/javascript" src"https://cdn.jsdelivr.net/npm/vue2/dist/vue.js"></script…

Linux中DCHP与时间同步

目录 一、DHCP &#xff08;一&#xff09;工作原理 1.获取 2.续约 &#xff08;二&#xff09;分配方式 &#xff08;三&#xff09;服务器配置 1.随机地址分配 2.固定地址分配 二、时间同步 &#xff08;一&#xff09;ntpdate &#xff08;二&#xff09;chrony …

window-nginx注册服务(nginx-1.24.0.zip)

window-nginx注册服务(nginx-1.24.0.zip) 1、下载当前windows版nginx的稳定版本。 https://nginx.org/en/download.html 2、解压到指定目录中&#xff0c;这里解压到D盘根目录&#xff0c;D:\nginx-1.24.0 3、管理员打开命令行&#xff0c;可先进行相关操作&#xff0c;看一下n…