网络编程4-epoll

article/2025/8/7 7:50:25

select底层原理

fd_set底层使用位图标记每个文件标识符有没有被使用，位图在c语言里靠数组实现。

 

 

select 流程

  1. 在用户态空间里（栈、堆、数据段）申请一个fd_set
  2. 将fd_set从用户态拷贝到内核态（在后面操作系统轮询会使用到）
  3. select调用时候：内核轮询 0~nfds-1；内核在轮询，进程阻塞；
  4. 在轮询中发现有监听的fd就绪，就放入fd_set，并返回
  5. 将fd_set从内核态拷贝到用户态
  6. 用户随后执行FD_ISSET，判断fd是否在就绪态

select的缺陷

  1. 存在多次数据在用户态和内核态空间的来回拷贝
  2. fd_set是一个位图，靠数组实现的，其长度编译时确定（一个进程的文件数量上限ulimit可以直接改，但是 fd_set 的长度需要重新编译系统库）
  3. 监听和就绪集合耦合在一起
  4. （最严重的问题）在就绪之后，用户要根据监听的数量去执行若干次FD_ISSET海量连接，少量就绪。

epoll 高性能 IO多路复用

epoll 和 select 功能是一样的，但是经过 libevent 测试后，epoll 性能更好。

 kqueue只能Unix，epoll只能Linux。

epoll 底层模型

  1.  epoll 将数据结构分配在内核区（文件对象）
  2.  在文件对象内部有两个独立的数据结构：
  • 监听集合是一颗红红黑树（没有上限）
  • 就绪集合是一个线性表

     3.  当轮询结束以后，epoll 会把收集到就绪集合拷贝到用户态，用户遍历就绪结合次数和就绪数量相关（而不是监听集合，性能比select提升）

红黑树

红黑树是一颗相对平衡的二叉搜索树，在内存里涉及到树的操作大量使用到红黑树。

  • 任何节点是红色或者黑色两种之一。
  • 根节点是黑色。
  • 空叶子记为黑色（实际不存在）。
  • 红色节点父亲和孩子都是黑色。
  • 从根出发到每个空节点的简单路径黑色节点数量是一样的。

相关函数

使用 man  7  epoll查看

epoll_creat

创建文件对象

曾经 int epoll_creat(int size)里面的size用来表示监听大小，现在无意义，为了兼容，size填写一个正数，返回一个epoll类型。

 

epoll_ctl

管理监听集合

  • epfd: 监听的文件描述符
  • op: 有下面三种类型分别对应增加、修改、删除
  • *event: 监听的属性

op 对应的选项：分别为增加、修改、删除

event 结构体如下：

events基本数据类型（读就绪或写就绪，水平出发或边缘触发）

data数据是一个共用体，可以在ptr、fd、u32、u64里面选择一个，用来记录将来就绪之后，往就绪集合里面放的东西。

在监听不同的文件描述符时，要将相应的event调整，并再使用一个epoll_ctl。

union

联合体、共用体

union 的用法和 struct 很像。

但是union 在某一时刻，只能存在一个成员，所有成员共用内存。

设置监听

代码实现

 struct epoll_event event;event.data.fd = STDIN_FILENO;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&event);event.data.fd = netfd;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,netfd,&event);

两个别监听的fd和data务必要不一样 

epoll_wait

内核轮询，用户阻塞

  • epfd 是epoll 的文件描述符。
  • *events 是 maxevents 是合在一起的。event 是一个数组，maxevents 是数组长度，里面存得到是epoll_event类型。这里只看 data 成员。
  • timeout 是最长等待时间，以毫秒为单位，-1 代表永久等待。

使用方法：

  • 主调方先申请一个 struct epoll_event 结构体数组，把数组首地址和长度传递给 epoll_wait
  • epoll_wait 在轮询结束后返回，把每个就绪的fd 的 data 拷贝到数据体数组中
  • 返回值为就绪集合的实际长度。

使用步骤：

struct epoll_event readyset[1024];while(1){int readynum = epoll_wait(epfd,readyset,1024,-1);for(int i=0;i<readynum;i++){if(readyset[i].data.fd = STDIN_FILENO){……}else if(readyset[i].data.fd = netfd){……}
}

  1. 准别一个就绪集合 readyset，大小无所谓
  2. 调用 epoll_wait epfd 就绪集合数组名，数组长度，-1
  3. 从 epoll_wait 当中返回，返回readynum时就绪集合的实际长度
  4. 写一个执行 readysetnum 次的 for 循环遍历就绪集合

支持断线重连的双人通信

基于TCP编程和epoll，实现一个客户端和一个服务端双人即时聊天，服务端需要处理stdin，并支持断线重连

server.c

#include <my_header.h>/* Usage:  */
int main(int argc, char *argv[]){                                  ARGS_CHECK(argc,3);int sockfd = socket(AF_INET,SOCK_STREAM,0);struct sockaddr_in serverAddr;serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = inet_addr(argv[1]);serverAddr.sin_port = htons(atoi(argv[2]));int flag = 1;setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&flag,sizeof(flag));int b_ret = bind(sockfd,(struct sockaddr *)&serverAddr,sizeof(serverAddr));ERROR_CHECK(b_ret,-1,"bind");listen(sockfd,50);    int epfd = epoll_create(1);struct epoll_event event;event.data.fd = STDIN_FILENO;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&event);event.data.fd = sockfd;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,sockfd,&event);char buf[4096];struct epoll_event readyset[1024];int netfd = -1;while(1){int readynum = epoll_wait(epfd,readyset,1024,-1);for(int i=0;i<readynum;i++){if(readyset[i].data.fd == sockfd){netfd = accept(sockfd,NULL,NULL);printf("netfd = %d, client connected\n",netfd);event.data.fd = netfd;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,netfd,&event);event.data.fd = STDIN_FILENO;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,NULL);epoll_ctl(epfd,EPOLL_CTL_DEL,sockfd,NULL);}else if(netfd != -1 && readyset[i].data.fd == STDIN_FILENO){bzero(buf,sizeof(buf));ssize_t sret = read(STDIN_FILENO,buf,sizeof(buf));if(sret == 0){printf("server close connection\n");epoll_ctl(epfd,EPOLL_CTL_DEL,STDIN_FILENO,NULL);epoll_ctl(epfd,EPOLL_CTL_DEL,netfd,NULL);netfd =-1;goto END;}send(netfd,buf,strlen(buf),0);} else if(netfd != -1 && readyset[i].data.fd == netfd){bzero(buf,sizeof(buf));ssize_t sret = recv(netfd,buf,sizeof(buf),0);if(sret == 0){printf("client disconnected\n");epoll_ctl(epfd,EPOLL_CTL_DEL,STDIN_FILENO,NULL);epoll_ctl(epfd,EPOLL_CTL_DEL,netfd,NULL);event.data.fd = sockfd;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,sockfd,&event);close(netfd);continue;}printf("[buf] %s\n",buf);}}}
END:close(epfd);close(sockfd);return 0;
}

client.c

#include <my_header.h>/* Usage:  */
int main(int argc, char *argv[]){                                  ARGS_CHECK(argc,3);int sockfd = socket(AF_INET,SOCK_STREAM,0);struct sockaddr_in serverAddr;serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = inet_addr(argv[1]);serverAddr.sin_port = htons(atoi(argv[2]));int c_ret = connect(sockfd,(struct sockaddr *)&serverAddr,sizeof(serverAddr));ERROR_CHECK(c_ret,-1,"connect");int epfd = epoll_create(1);struct epoll_event event;event.data.fd = STDIN_FILENO;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&event);event.data.fd = sockfd;event.events = EPOLLIN;epoll_ctl(epfd,EPOLL_CTL_ADD,sockfd,&event);char buf[4096];struct epoll_event readyset[1024];while(1){int readynum = epoll_wait(epfd,readyset,1024,-1);for(int i=0;i<readynum;i++){if(readyset[i].data.fd == STDIN_FILENO){bzero(buf,sizeof(buf));ssize_t sret = read(STDIN_FILENO,buf,sizeof(buf));if(sret == 0){printf("client close connection\n");epoll_ctl(epfd,EPOLL_CTL_DEL,sockfd,NULL);epoll_ctl(epfd,EPOLL_CTL_DEL,STDIN_FILENO,NULL);goto END;}send(sockfd,buf,strlen(buf),0);} if(readyset[i].data.fd == sockfd){bzero(buf,sizeof(buf));ssize_t sret = recv(sockfd,buf,sizeof(buf),0);if(sret == 0){printf("server disconnected\n");epoll_ctl(epfd,EPOLL_CTL_DEL,sockfd,NULL);epoll_ctl(epfd,EPOLL_CTL_DEL,STDIN_FILENO,NULL);goto END;}printf("[buf] %s\n",buf);}}}
END:close(sockfd);return 0;
}


http://www.hkcw.cn/article/UscrsOrZmd.shtml

相关文章

SOC-ESP32S3部分：19-ADC模数转换

SOC-ESP32S3部分：19-ADC模数转换

飞书文档https://x509p6c8to.feishu.cn/wiki/XycAwmO6Niitdtka1RAcclYfnvf ESP32-S3 集成了两个 12 位 SAR ADC&#xff0c;共支持 20 个模拟通道输入。 SAR ADC 管脚通过 IO MUX 与 GPIO1 ~ GPIO20、RTC_GPIO1 ~ RTC_GPIO20、触摸传感器接口、UART 接口、SPI 接口、以及 USB…
阅读更多...
默克微生物培养基选择指南

默克微生物培养基选择指南

微生物学研究需要能在实验室提供各种不同种类的细菌、酵母或病毒。诸如发酵、蛋白质和疫苗生产的大规模过程需要大量处于生理活性状态的细菌。因此&#xff0c;针对各种应用需要有能提供适当的生化环境并保持微生物所有特征的合适的营养培养基。 任何微生物培养基都应包括营养…
阅读更多...
移动安全Android——解决APP抓包证书无效问题

移动安全Android——解决APP抓包证书无效问题

问题 通过Burpsuite和ProxyPin进行代理抓包Android APP的时候发现虽然已经正确添加了用户证书&#xff0c;但是还是会出现SSL握手错误&#xff0c;证书无效问题。这是因为Android 7 以上版本APP默认不信任用户证书&#xff0c;只信任系统证书&#xff0c;所以需要将用户证书移动…
阅读更多...
【数据库】数据库恢复技术

【数据库】数据库恢复技术

数据库恢复技术 实现恢复的核心是使用冗余&#xff0c;也就是根据冗余数据重建不正确数据。 事务 事务是一个数据库操作序列&#xff0c;是一个不可分割的工作单位&#xff0c;是恢复和并发的基本单位。 在关系数据库中&#xff0c;一个事务是一条或多条SQL语句&#xff0c…
阅读更多...
【学习笔记】深度学习-梯度概念

【学习笔记】深度学习-梯度概念

一、定义 梯度向量不仅表示函数变化的速度&#xff0c;还表示函数增长最快的方向 二、【问】为什么说它表示方向&#xff1f; 三、【问】那在深度学习梯度下降的时候&#xff0c;还要判断梯度是正是负来更新参数吗&#xff1f; 假设某个参数是 w&#xff0c;损失函数对它的…
阅读更多...
【ROS2实体机械臂驱动】rokae xCoreSDK Python测试使用

【ROS2实体机械臂驱动】rokae xCoreSDK Python测试使用

【ROS2实体机械臂驱动】rokae xCoreSDK Python测试使用 文章目录 前言正文配置环境下载源码配置环境变量测试运行修改点说明实际运行情况 参考 前言 本文用来记录 xCoreSDK-Python的调用使用1。 正文 配置环境 配置开发环境&#xff0c;这里使用conda做python环境管理&…
阅读更多...
深入浅出网络分析与故障检测工具

深入浅出网络分析与故障检测工具

目录 网络故障检测工具&#xff1a;别只靠“Ping 不通” 实战组合拳&#xff1a;分析 检测 问题闭环 四、选择工具的几个建议 五、总结&#xff1a;工具是手段&#xff0c;思维才是核心 在如今这个“数据就是生命线”的时代&#xff0c;网络的稳定性和性能直接决定着企业…
阅读更多...
使用Haproxy搭建Web群集

使用Haproxy搭建Web群集

目录 1&#xff0c;Haproxy简介 1&#xff0c;核心功能与特点 二&#xff0c;搭建haproxy群集 1&#xff0c;准备工作 2&#xff0c;修改haproxy的配置文件 3&#xff0c;准备网站 4&#xff0c;配置日志 5&#xff0c;验证 1&#xff0c;Haproxy简介 HAProxy 是一款高…
阅读更多...
Elasticsearch的写入流程介绍

Elasticsearch的写入流程介绍

Elasticsearch 的写入流程是一个涉及 分布式协调、分片路由、数据同步和副本更新 的复杂过程，其设计目标是确保数据一致性、可靠性和高性能。以下是写入流程的详细解析： 一、写入流程总览 二、详细步骤解析 1. 客户端请求路由 请求入口：客户端（如 Java 客户端、REST API）…
阅读更多...
记录一次apisix上cros配置跨域失败的问题

记录一次apisix上cros配置跨域失败的问题

安全要求不允许跨域请求&#xff0c;但是业务侧由于涉及多个域名&#xff0c;并且需要共享cookie&#xff0c;所以需要配置跨域。 在apisix上配置了cors如下。 结果安全漏扫还是识别到了跨域请求的漏洞。 调试了cors.lua的插件脚本&#xff0c;发现apisix上是如果不在allowOri…
阅读更多...
VSCode无法转到定义python源码（ctrl加单击不跳转）

VSCode无法转到定义python源码（ctrl加单击不跳转）

已经尝试的方案&#xff1a; 1.确保对应python环境正确激活 在 VSCode 中&#xff0c;打开命令面板&#xff08;CtrlShiftP&#xff09;&#xff0c;输入并选择 Python: Select Interpreter&#xff0c;然后从列表中选择正确的 Python 解释器。 2.重新卸载Python插件再重新安装…
阅读更多...
会议室钥匙总丢失？换预约功能的智能门锁更安全

会议室钥匙总丢失？换预约功能的智能门锁更安全

在企业日常运营中&#xff0c;会议室作为重要的沟通与协作场所&#xff0c;其管理效率与安全性直接影响着企业的运作顺畅度。然而&#xff0c;传统会议室管理方式中钥匙丢失、管理不便等问题频发&#xff0c;给企业带来了不少困扰。近期&#xff0c;某企业引入了启辰智慧预约系…
阅读更多...
漫画Android：事件分发的过程是怎样的？

漫画Android：事件分发的过程是怎样的？

当用户触摸屏幕时&#xff0c;硬件层会捕获触摸信号&#xff0c;并将其转化为内核事件。 Android系统会通过InputManagerService和WindowManagerService等服务将这些事件包装成MotionEvent对象&#xff0c;并将其传递给Activity的dispatchTouchEvent()方法中&#xff0c;Activi…
阅读更多...
【算法提升】分组 day_tow

【算法提升】分组 day_tow

1.分组 1.1 解析 个人认为这题最难的点在于如何想到使用二分的算法来解题。 正向求解&#xff1a;就是去看每一组中需要分多少个人&#xff0c;但是这样求解代码我根本写不出来。 所以根据正难则反的思想&#xff0c;我们可以从最终结果去倒推。 枚举最终的分配结果中&#xff…
阅读更多...
【笔记】Suna 部署之 Supabase 数据库 schema 暴露操作

【笔记】Suna 部署之 Supabase 数据库 schema 暴露操作

#工作记录 一、前置信息 在 Suna 部署过程中&#xff0c;Supabase 数据库设置已完成&#xff08;✅ Supabase database setup completed &#xff09;&#xff0c;但需要手动在 Supabase 平台暴露basejump模式&#xff08;schema&#xff09;。 Suna 部署过程中&#xff0c;S…
阅读更多...
【Linux 学习计划】-- 进程状态 | 进程运行、阻塞和挂起的本质 | 并行、并发与进程切换 | 进程优先级

【Linux 学习计划】-- 进程状态 | 进程运行、阻塞和挂起的本质 | 并行、并发与进程切换 | 进程优先级

目录 进程状态 五状态进程模型 运行、就绪状态的本质 阻塞状态的本质 挂起状态 并行与并发 进程切换 进程优先级 结语 进程状态 进程状态的本质是什么&#xff1f; 首先我们知道&#xff0c;在操作系统中&#xff0c;进程是需要被管理起来的&#xff0c;具体则是用一…
阅读更多...
自证式推理训练：大模型告别第三方打分的新纪元

自证式推理训练：大模型告别第三方打分的新纪元

1. 传统验证体系的困境与技术跃迁的必然性 1.1 传统验证器的局限性 现有强化学习框架依赖显式验证器对答案进行二值化判定&#xff0c;这种模式在数学、代码等可验证领域表现优异。某厂内部数据显示&#xff0c;传统R1-Zero方法在代码生成任务中准确率达92%&#xff0c;但切换…
阅读更多...
《操作系统真相还原》——加载器

《操作系统真相还原》——加载器

显存 将上一章的中断输出&#xff0c;变为显存输出 加载器 使用mbr引导程序从磁盘中加载loader程序。 MBR %include "boot.inc" SECTION MBR vstart0x7c00 mov ax,cs mov ds,axmov es,axmov ss,axmov fs,axmov sp,0x7c00mov ax,0xb800mov gs,ax;cl…
阅读更多...
Spring Boot 应用中实现配置文件敏感信息加密解密方案

Spring Boot 应用中实现配置文件敏感信息加密解密方案

Spring Boot 应用中实现配置文件敏感信息加密解密方案 背景与挑战 &#x1f6a9;一、设计目标 &#x1f3af;二、整体启动流程 &#x1f504;三、方案实现详解 ⚙️3.1 配置解密入口&#xff1a;EnvironmentPostProcessor3.2 通用解密工具类&#xff1a;EncryptionTool 四、快速…
阅读更多...
前端实现图片压缩：基于 HTML5 File API 与 Canvas 的完整方案

前端实现图片压缩：基于 HTML5 File API 与 Canvas 的完整方案

在 Web 开发中，处理用户上传的图片时，前端压缩可以有效减少服务器压力并提升上传效率。本文将详细讲解如何通过<input type="file">实现图片上传，结合 Canvas 实现图片压缩，并实时展示压缩前后的图片预览和文件大小对比。 一、核心功能架构 我们将实现以…
阅读更多...
推荐文章

Copyright @ 2022~2023