当前位置: 首页 > news >正文

IO复用详解——C/C++

IO复用

在Linux网络编程中,I/O复用是处理高并发连接的核心技术。它允许单个线程/进程同时监控多个文件描述符(如Socket)的可读/可写状态,避免为每个连接创建独立线程的资源浪费。以下是 selectpollepoll 的详细对比与实现方法:


1. I/O复用核心概念

  • 阻塞I/O:线程等待数据就绪,期间无法执行其他操作。
  • 非阻塞I/O:轮询检查数据是否就绪,浪费CPU资源。
  • I/O复用:通过系统调用统一监控多个I/O事件,仅处理就绪的I/O。

2. select

原理

  • 使用**位图(fd_set)**表示监控的文件描述符集合。

    typedef struct {unsigned long fds_bits[FD_SETSIZE / (8 * sizeof(unsigned long))];
    } fd_set;
    
    • FD_SETSIZE
      是一个宏,定义了 fd_set 可容纳的最大文件描述符数量,默认值通常为 1024

    • fds_bits

    • 每个文件描述符对应一个位。

    • 位为 1:表示文件描述符在集合中。

    • 位为 0:表示文件描述符不在集合中。

    功能描述
    FD_ZERO(fd_set *set)清空集合,将所有位设为 0。
    FD_SET(int fd, fd_set *set)将文件描述符 fd 添加到集合中(对应位设为 1)。
    FD_CLR(int fd, fd_set *set)从集合中移除文件描述符 fd(对应位设为 0)。
    FD_ISSET(int fd, fd_set *set)检查 fd 是否在集合中,返回值为 1(存在)或 0(不存在)。
  • 每次调用时需将所有fd集合从用户态拷贝到内核态,内核通过线性扫描判断就绪状态。

  • 支持跨平台(Windows/Linux)。

代码示例

#include <sys/select.h>int main() {fd_set read_fds;FD_ZERO(&read_fds);     // 清空集合FD_SET(sock_fd, &read_fds); // 添加sock_fd到监控集合struct timeval timeout;timeout.tv_sec = 5;     // 超时时间5秒timeout.tv_usec = 0;// 调用select,监控可读事件int ret = select(sock_fd + 1, &read_fds, NULL, NULL, &timeout);if (ret > 0) {if (FD_ISSET(sock_fd, &read_fds)) {// 处理数据读取}}
}

优缺点

  • 优点:跨平台兼容。
  • 缺点
    • 最大支持 FD_SETSIZE(通常1024)个文件描述符。
    • 每次调用需重置fd集合,存在内存拷贝开销。
    • 线性扫描效率低(时间复杂度O(n))。

3. poll

原理

  • 使用**结构体数组(pollfd)**替代select的位图,突破文件描述符数量限制。
  • 仍需要遍历所有fd检查就绪状态。

代码示例

#include <poll.h>int main() {struct pollfd fds[1];fds[0].fd = sock_fd;      // 监控的fdfds[0].events = POLLIN;   // 监控可读事件// 调用poll,超时时间5秒int ret = poll(fds, 1, 5000);if (ret > 0) {if (fds[0].revents & POLLIN) {// 处理数据读取}}
}

优缺点

  • 优点:无文件描述符数量限制。
  • 缺点
    • 仍需遍历所有fd,效率随连接数线性下降。
    • 每次调用需传递完整的fd数组。

4. epoll(Linux特有)

原理

  • 使用红黑树管理待监控的fd,事件驱动机制。
  • **边缘触发(ET)水平触发(LT)**两种模式。
    • LT模式(默认):只要fd处于就绪状态,每次epoll_wait都会通知。
    • ET模式:仅当fd状态变化时通知一次,需一次性处理完数据。

代码示例

#include <sys/epoll.h>int main() {int epoll_fd = epoll_create1(0); // 创建epoll实例struct epoll_event event;event.events = EPOLLIN;         // 监控可读事件event.data.fd = sock_fd;// 添加sock_fd到epoll监控epoll_ctl(epoll_fd, EPOLL_CTL_ADD, sock_fd, &event);struct epoll_event events[10];// 等待事件,超时时间5秒int ret = epoll_wait(epoll_fd, events, 10, 5000);if (ret > 0) {for (int i = 0; i < ret; i++) {if (events[i].data.fd == sock_fd) {// 处理数据读取}}}
}

优缺点

  • 优点
    • 支持海量连接(时间复杂度O(1))。
    • 无需每次传递全部fd,通过事件回调机制高效通知。
  • 缺点:仅适用于Linux系统。

5. 对比总结

特性selectpollepoll
最大连接数1024无限制无限制
效率O(n) 线性扫描O(n) 线性扫描O(1) 事件驱动
内存拷贝每次拷贝全部fd集合每次拷贝全部fd数组仅注册时拷贝一次
触发模式水平触发(LT)水平触发(LT)支持LT/ET模式
跨平台是(多数系统)仅Linux

6. 应用场景建议

  • select/poll:低并发场景或需要跨平台时使用。
  • epoll:Linux高并发服务器(如Web服务器、即时通讯)。
  • Windows替代方案:IOCP(I/O Completion Ports)。

7. 注意事项

  1. ET模式需一次性读取所有数据(循环读取直到EAGAIN错误)。
  2. fd管理:epoll需手动管理fd的增删(EPOLL_CTL_ADD/DEL/MOD)。
  3. 多线程:epoll实例本身非线程安全,需加锁或每个线程独立实例。

I/O复用技术是构建高性能服务器的关键!

相关文章:

  • ubuntu清除缓存
  • svg图片转base64 -- svg转png -- png转base64
  • [数据结构]5. 栈-Stack
  • ​Android学习总结之handler中源码解析和场景回答
  • 计算机操作系统(七)详细讲解进程的组成与特性,状态与转换
  • 可视化数据图表怎么做?如何实现三维数据可视化?
  • 技术中台-核心技术介绍(微服务、云原生、DevOps等)
  • Prometheus+Grafana+AlertManager完整安装过程
  • YOLO v2:目标检测领域的全面性进化
  • 网络防空总结 各种攻击
  • 光流 | Matlab工具中的光流算法
  • acwing 4275. Dijkstra序列
  • JVM学习专题(二)内存模型深度剖析
  • 尚硅谷阳哥JVM
  • upload-labs通关笔记-第5关 文件上传之.ini绕过
  • CSS Grid布局:从入门到实战
  • 【windows server脚本每天从网络盘复制到本地】
  • AI世界的崩塌:当人类思考枯竭引发数据生态链断裂
  • 数据安全与权限管控,如何实现双重保障?
  • Vue3学习(组合式API——计算属性computed详解)
  • 苏轼“胡为适南海”?
  • 缅甸内观冥想的历史漂流:从“人民鸦片”到东方灵修
  • 微软宣布全球裁员约3%:涉及约6000人,侧重经理层
  • 云南威信麟凤镇通报“有人穿‘警察’字样雨衣参与丧事”:已立案查处
  • 中国人民抗日战争暨世界反法西斯战争胜利80周年纪念活动标识发布
  • 生态环境保护督察工作条例对督察对象和内容作了哪些规定?有关负责人答问