epoll_event 事件类型详解

epoll_event 事件类型详解

epoll_event 是 Linux epoll I/O 多路复用机制的核心结构体，其中的事件类型决定了 epoll 监控的行为和触发条件。以下是各种事件类型的详细解析：

epoll_event 结构体

#include <sys/epoll.h>typedef union epoll_data {void    *ptr;int      fd;uint32_t u32;uint64_t u64;
} epoll_data_t;struct epoll_event {uint32_t     events;   // 事件类型标志位（位掩码）epoll_data_t data;     // 用户数据（通常存储文件描述符）
};

事件类型标志位 (events)

事件类型值 (十六进制)说明触发条件
EPOLLIN0x001可读事件接收缓冲区有数据可读 (≥1字节)
EPOLLOUT0x004可写事件发送缓冲区有空间可写
EPOLLRDHUP0x2000对端关闭连接 (需内核≥2.6.17)TCP连接对端关闭写端 (半关闭) 或完全关闭
EPOLLPRI0x002紧急数据事件收到带外数据 (OOB) 或 TCP 紧急数据
EPOLLERR0x008错误事件文件描述符发生错误 (自动监控，无需显式设置)
EPOLLHUP0x010挂起事件文件描述符被挂起 (如管道写端关闭后读端)
EPOLLET0x80000000边缘触发模式 (默认水平触发)设置后进入边缘触发模式
EPOLLONESHOT0x40000000单次触发模式事件触发后自动禁用监控，需重新EPOLL_CTL_MOD启用
EPOLLWAKEUP0x20000000防止系统休眠 (需内核≥3.5)事件处理期间阻止系统进入休眠状态
EPOLLEXCLUSIVE0x10000000独占唤醒 (需内核≥4.5)避免惊群效应，多个等待进程中只唤醒一个

核心事件详解

1. EPOLLIN (可读事件)

  • 触发条件：
    • 套接字接收缓冲区有数据可读
    • 监听套接字有新连接到达
    • TCP对端关闭连接 (触发EPOLLIN+读取返回0)
    • 管道/FIFO的写端关闭
  • 使用场景：
    // 监控套接字可读
event.events = EPOLLIN;
epoll_ctl(epfd, EPOLL_CTL_ADD, sockfd, &event);

2. EPOLLOUT (可写事件)

  • 触发条件：
    • 套接字发送缓冲区有空间可写入
    • 非阻塞connect()连接完成
  • 注意事项：
    • 水平触发模式下会持续触发直到缓冲区满
    • 通常只在需要时启用，避免CPU空转
  • 使用技巧：
    // 只在需要写入时启用EPOLLOUT
event.events = EPOLLIN;  // 默认只监控读
if (need_write) {event.events |= EPOLLOUT; // 动态添加写监控
}
epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd, &event);

3. EPOLLRDHUP (对端关闭)

  • 优势：
    • 替代EPOLLIN + read() == 0的检测方式
    • 更高效检测TCP半关闭状态
  • 使用示例：
    // 检测连接关闭
event.events = EPOLLIN | EPOLLRDHUP;
  • 触发条件：
    • 收到FIN包 (TCP对端调用shutdown(SHUT_WR)或close())

4. EPOLLET (边缘触发)

  • 工作模式对比：
    特性水平触发 (LT)边缘触发 (ET)
    触发条件状态满足即触发状态变化时触发
    事件通知频率高 (持续通知)低 (仅变化时通知)
    数据处理要求可分批处理必须一次处理完所有数据
    缓冲区处理无需完全清空必须完全清空缓冲区
    性能较低更高
  • ET模式注意事项：
    1. 必须使用非阻塞I/O
    2. 必须一次性读取/写入所有数据
    3. 需要手动跟踪未完成操作
    // 边缘触发设置
event.events = EPOLLIN | EPOLLET;

高级事件类型

5. EPOLLONESHOT (单次触发)

  • 设计目的：
    • 防止多线程同时操作同一文件描述符
    • 确保事件只被一个线程处理
  • 工作流程：
    是
    否
    注册EPOLLONESHOT
    事件触发
    工作线程处理
    需要继续监控?
    重新注册EPOLL_CTL_MOD
    关闭连接
  • 代码示例：
    // 设置单次触发
event.events = EPOLLIN | EPOLLONESHOT;
epoll_ctl(epfd, EPOLL_CTL_ADD, fd, &event);// 处理完成后重新启用
event.events = EPOLLIN | EPOLLONESHOT; // 保持设置
epoll_ctl(epfd, EPOLL_CTL_MOD, fd, &event);

6. EPOLLEXCLUSIVE (独占唤醒)

  • 解决惊群问题：
    • 多个进程监听同一端口时，只唤醒一个进程
    • 替代SO_REUSEPORT的解决方案
  • 使用限制：
    • 仅对EPOLL_CTL_ADD操作有效
    • 必须与EPOLLIN或EPOLLOUT同时使用
    // 多进程避免惊群
event.events = EPOLLIN | EPOLLEXCLUSIVE;

事件组合与典型场景

常见事件组合

应用场景推荐事件组合说明
TCP服务器监听套接字EPOLLIN接受新连接
TCP数据接收`EPOLLINEPOLLRDHUP [
TCP数据发送EPOLLOUT (动态启用)缓冲区可写时发送
非阻塞connectEPOLLOUT连接完成时可写
错误检测(自动包含)无需设置，总是监控
高并发服务器`EPOLLINEPOLLET
多线程安全处理`EPOLLINEPOLLONESHOT`

完整事件处理示例

#define MAX_EVENTS 10
struct epoll_event events[MAX_EVENTS];while (1) {int n = epoll_wait(epfd, events, MAX_EVENTS, -1);for (int i = 0; i < n; i++) {int fd = events[i].data.fd;uint32_t revents = events[i].events;// 1. 错误处理（优先检查）if (revents & EPOLLERR) {int error = 0;socklen_t errlen = sizeof(error);getsockopt(fd, SOL_SOCKET, SO_ERROR, &error, &errlen);close(fd);continue;}// 2. 连接关闭if (revents & EPOLLRDHUP) {close(fd); continue;}// 3. 可读事件if (revents & EPOLLIN) {if (fd == listen_fd) {// 接受新连接accept_new_connection(fd);} else {// 处理客户端数据handle_client_data(fd);}}// 4. 可写事件if (revents & EPOLLOUT) {send_pending_data(fd);// 数据发完后关闭写监控struct epoll_event ev;ev.events = EPOLLIN | EPOLLET; // 移除EPOLLOUTepoll_ctl(epfd, EPOLL_CTL_MOD, fd, &ev);}}
}

最佳实践与陷阱规避

  1. 必须处理的错误事件：

    // EPOLLERR 必须处理，否则可能导致死循环
if (events[i].events & EPOLLERR) {// 获取具体错误码int err;socklen_t len = sizeof(err);getsockopt(fd, SOL_SOCKET, SO_ERROR, &err, &len);printf("Error on fd %d: %s\n", fd, strerror(err));close(fd);
}

  2. ET模式下的读写要求：

    // ET模式必须循环读取直到EAGAIN
while (1) {ssize_t count = read(fd, buf, sizeof(buf));if (count == -1) {if (errno == EAGAIN) break; // 数据读完// 处理其他错误break;}if (count == 0) { // 连接关闭close(fd);break;}// 处理数据...
}

  3. 避免EPOLLOUT误用：

    • 不要长期启用EPOLLOUT，只在有数据要发送时启用
    • 发送完成后立即移除EPOLLOUT监控
    // 启用写监控
event.events = current_events | EPOLLOUT;
epoll_ctl(epfd, EPOLL_CTL_MOD, fd, &event);// 发送完成后禁用
event.events = current_events & ~EPOLLOUT;
epoll_ctl(epfd, EPOLL_CTL_MOD, fd, &event);

  4. 性能优化建议：

    • 高并发场景优先使用ET模式
    • 短连接服务使用LT更简单
    • 多核处理器结合SO_REUSEPORT+EPOLLEXCLUSIVE

💡 经验法则：理解每种事件类型的触发机制和适用场景是构建高性能网络程序的基础。EPOLLRDHUP和EPOLLET的组合是现代Linux高性能服务器的黄金标准。

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

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

相关文章

设计自己的小传输协议 导论与概念

设计自己的小传输协议 导论与概念

设计自己的小传输协议 导论与概念 1&#xff1a;聊一聊协议头设计 ​ 早在《TCP/IP详解》中的第一句话中&#xff0c;我们就知道协议的含义是这样的&#xff1a;协议是通信双方共同遵守的一套规则&#xff0c;提供格式定义、语义解释等&#xff0c;使不同设备或软件能够正确交…
阅读更多...
iOS —— 天气预报仿写总结

iOS —— 天气预报仿写总结

在iOS中&#xff0c;最常见的网络请求方式是NSURLSession&#xff0c;它是苹果推荐的现代API&#xff0c;简单安全且易于拓展。一次完整的网络请求流程&#xff1a;构造 NSURL 对象创建 NSURLSessionDataTask发起请求&#xff08;resume&#xff09;在回调中解析数据回到主线程…
阅读更多...
MySQL 8.4 Windows 版安装记录与步骤参考

MySQL 8.4 Windows 版安装记录与步骤参考

导语&#xff1a; MySQL 作为广泛使用的开源数据库管理系统&#xff0c;是许多开发者和学习者的必备工具。最近有朋友询问安装过程&#xff0c;正好整理了 MySQL 8.4 在 Windows 系统下的安装步骤和一些注意事项&#xff0c;分享给有需要的朋友做个参考。关于 MySQL&#xff1a…
阅读更多...
七、搭建springCloudAlibaba2021.1版本分布式微服务-skywalking9.0链路追踪

七、搭建springCloudAlibaba2021.1版本分布式微服务-skywalking9.0链路追踪

前言链路追踪介绍 对于一个大型的几十个&#xff0c;几百个微服务构成的微服务架构系统&#xff0c;通常会遇到下面的一系列问题。 如何串联整个调用链路&#xff0c;快速定位问题&#xff1f;如何澄清各个微服务之间的依赖关系&#xff1f;如何进行各个微服务接口的性能分析&a…
阅读更多...
深入理解大语言模型生成参数：temperature、top\_k、top\_p 等全解析

深入理解大语言模型生成参数：temperature、top\_k、top\_p 等全解析

在使用大语言模型&#xff08;如 GPT-4、LLaMA、ChatGLM 等&#xff09;进行文本生成任务时&#xff0c;很多开发者会面对各种“生成参数”&#xff0c;如 temperature、top_k、top_p、repetition_penalty 等。这些参数虽然看起来抽象&#xff0c;但掌握它们的意义和配置技巧&a…
阅读更多...
vulhub Web Machine(N7)靶场攻略

vulhub Web Machine(N7)靶场攻略

下载地址&#xff1a; https://download.vulnhub.com/webmachine/Web-Machine-N7.ova 使用方法&#xff1a; 靶场下载好以后不用解压&#xff0c;需要使用Oracle VirtualBox虚拟机打开&#xff0c;用VMware会报错。安装Oracle VirtualBox虚拟机时安装地址不能随便选择&#…
阅读更多...
【机器学习深度学习】模型微调：多久才算微调完成？——如何判断微调收敛，何时终止训练

【机器学习深度学习】模型微调：多久才算微调完成？——如何判断微调收敛，何时终止训练

目录 前言 一、微调过程的目标&#xff1a;优化模型表现 二、微调需要多久&#xff1f; 微调时间无法确定 三、如何判断微调何时收敛&#xff1f; 3.1 观察Loss的下降趋势 3.2 损失值趋于平稳&#xff0c;意味着收敛 如何识别收敛&#xff1f; 3.3 验证Loss的波动&…
阅读更多...
红队视角：实战渗透测试中漏洞利用的进阶技巧与防御

红队视角：实战渗透测试中漏洞利用的进阶技巧与防御

红队作为渗透测试的 “攻击方”&#xff0c;其核心价值不仅在于发现漏洞&#xff0c;更在于挖掘漏洞的深度利用方式 —— 通过绕过防护措施、组合低危漏洞形成攻击链&#xff0c;暴露企业真实安全风险。从红队视角解析漏洞利用的进阶技巧&#xff0c;既能帮助防御方理解攻击思路…
阅读更多...
OpenHarmony BUILD.gn中执行脚本

OpenHarmony BUILD.gn中执行脚本

在OpenHarmony编译构建中笔者经常遇到这样的场景——需要执行sh脚本完成某些操作。笔者将OpenHarmony BUILD.gn中执行脚本的方法分享如下&#xff1a; 前置知识点 1.能够把自定义的子系统加入OpenHarmony源码的编译构建&#xff0c;请参考&#xff1a;https://ost.51cto.com/…
阅读更多...
QUIC协议如何在UDP基础上解决网络切换问题

QUIC协议如何在UDP基础上解决网络切换问题

一、UDP 四元组的本质局限UDP 本身无连接状态&#xff0c;其数据包仅通过四元组寻址。但 QUIC 在 UDP 之上构建了完整的连接语义。二、QUIC 的连接迁移核心机制1. 连接标识符&#xff08;Connection ID&#xff09;关键设计&#xff1a;每个 QUIC 连接拥有全局唯一 64-bit Conn…
阅读更多...
力扣131:分割回文串

力扣131:分割回文串

力扣131:分割回文串题目思路代码题目 给你一个字符串 s&#xff0c;请你将 s 分割成一些 子串&#xff0c;使每个子串都是 回文串 。返回 s 所有可能的分割方案。 思路 从题目中我们可以总结出这道题的三个需要解决的问题&#xff1a; 如何判断回文串如何找到一种方案里的所…
阅读更多...
代驾小程序系统开发：引领出行行业数字化转型

代驾小程序系统开发：引领出行行业数字化转型

随着数字技术的飞速发展&#xff0c;出行行业正经历着深刻的数字化转型。代驾小程序系统作为这一转型的重要推手&#xff0c;以其高效、便捷、智能的特点&#xff0c;引领着出行行业向数字化、网络化、智能化方向发展。一、数字化管理&#xff0c;提升运营效率代驾小程序系统通…
阅读更多...
数独求解器与生成器（回溯算法实现）

数独求解器与生成器（回溯算法实现）

摘要本毕业设计旨在利用MATLAB技术实现一个基于回溯算法的数独求解器与生成器。通过深入分析数独游戏的规则和回溯算法的原理&#xff0c;设计并实现了数独求解的核心算法&#xff0c;同时开发了数独生成功能&#xff0c;能够生成符合规则的有效数独谜题。系统采用MATLAB图形用…
阅读更多...
[数据结构]#7 哈希表

[数据结构]#7 哈希表

哈希表&#xff08;Hash Table&#xff09;&#xff0c;有时也称为散列表&#xff0c;是一种数据结构&#xff0c;它提供了一种快速存取数据的方法。哈希表利用一个被称为哈希函数的机制将键映射到表中的一个位置来直接访问记录&#xff0c;以此加快查找的速度。哈希表通常支持…
阅读更多...
C++ 23种设计模式-工厂模式

C++ 23种设计模式-工厂模式

工厂模式是一种创建型的设计模式&#xff0c;他提供了一种创建对象的最佳方式&#xff0c;而无需指定将要创建对象的具体类。包括&#xff1a;简单工厂模式、工厂方法模式、抽象工厂模式。简单工厂模式组成成员&#xff1a;抽象产品类、具体产品类 A、B、C等、工厂类工作原理&a…
阅读更多...
vue3 el-table 行的某个特定值来决定某些列是否显示

vue3 el-table 行的某个特定值来决定某些列是否显示

在 Vue 3 中使用 Element Plus 的 <el-table> 组件时&#xff0c;如果你想要根据行的某个特定值来决定某些列是否显示&#xff0c;你可以通过自定义列渲染函数&#xff08;render 函数&#xff09;来实现这一需求。下面是一个如何实现该功能的步骤说明和示例代码。步骤 1…
阅读更多...
电商数据采集API与爬虫技术结合的全网比价方案

电商数据采集API与爬虫技术结合的全网比价方案

一、技术选型与工具准备API优先策略官方API接入&#xff1a;京东、淘宝、拼多多等平台提供商品详情API&#xff0c;需注册开发者账号获取API Key。例如&#xff1a;京东API支持实时获取商品价格、库存、评价数据。淘宝API通过RESTful接口返回JSON格式的商品信息&#xff0c;需O…
阅读更多...
Socket详解

Socket详解

一.定义Socket&#xff08;套接字&#xff09;是网络编程的核心&#xff0c;它允许不同主机或同一主机的不同进程之间进行通信&#xff0c;Socket API 提供了一套标准的接口&#xff0c;支持 TCP、UDP、IP 等协议分为以下三个类型&#xff1a;SOCK_STREAM: 用于tcp协议&#xf…
阅读更多...
如何实现打印功能

如何实现打印功能

一、AI赋能提供思路基本框架<!-- 隐藏的打印内容&#xff08;默认不显示&#xff09; --> <div id"print-container" style"display: none;"><h1>退货单打印内容</h1><table><!-- 打印专用的表格结构 --></table&g…
阅读更多...
Android 架构演进：从 MVC 到 MVVM 的设计之道

Android 架构演进：从 MVC 到 MVVM 的设计之道

在 Android 开发初期&#xff0c;很多开发者会把所有逻辑塞进 Activity—— 网络请求、数据处理、UI 更新全堆在一起&#xff0c;导致代码超过数千行&#xff0c;改一个按钮点击都要翻半天。这种 “面条式代码” 的根源是缺乏架构设计。随着应用复杂度提升&#xff0c;MVC、MVP…
阅读更多...
最新文章

Copyright @ 2022~2023