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

【C/C++】select、poll、epoll 实战对比:从 fd_set 到就绪事件列表

【C/C++】select、poll、epoll 实战对比:从 fd_set 到就绪事件列表

1. 为什么需要 IO 多路复用

上一篇多线程 TCP 服务端的模型是:每来一个连接,就创建一个线程阻塞在recv()上。这个模型好理解,但连接数一多,线程数、内存、上下文切换都会成为瓶颈。

IO 多路复用解决的是另一个问题:让一个线程同时管理多个 fd。线程不再盯着某一个连接阻塞,而是把一批 fd 交给内核,等内核告诉我们“哪些 fd 有事件”。

本项目分别实现了三个版本:

  • tcp_server_select.c:用fd_set管理连接。
  • tcp_server_poll.c:用struct pollfd数组管理连接。
  • tcp_server_epoll.c:用epoll_ctl注册事件,用epoll_wait获取就绪事件。

2. select:每一轮都要准备 fd_set

select的核心 API 是:

intactivity=select(maxfd+1,&tempfds,NULL,NULL,NULL);

项目中的关键写法是先保存一份总集合readfds,每次调用前复制到临时集合:

fd_set readfds;FD_ZERO(&readfds);FD_SET(serverfd,&readfds);intmaxfd=serverfd;while(1){fd_set tempfds=readfds;intactivity=select(maxfd+1,&tempfds,NULL,NULL,NULL);if(activity<0){perror("select");continue;}

为什么要复制?因为select()返回后会修改传进去的 fd 集合,只保留就绪 fd。如果下一轮继续拿同一个集合调用,就会丢失没有就绪的连接。

监听 socket 就绪表示有新连接:

if(FD_ISSET(serverfd,&tempfds)){structsockaddr_inclient_addr;socklen_tclient_len=sizeof(client_addr);intclientfd=accept(serverfd,(structsockaddr*)&client_addr,&client_len);FD_SET(clientfd,&readfds);if(clientfd>maxfd)maxfd=clientfd;}

普通客户端 fd 就绪表示可读:

for(inti=serverfd+1;i<=maxfd;i++){if(FD_ISSET(i,&tempfds)){charbuffer[1024];ssize_tn=recv(i,buffer,sizeof(buffer)-1,0);if(n<=0){close(i);FD_CLR(i,&readfds);}else{buffer[n]='\0';send(i,buffer,n,0);}}}

select的缺点也在这段代码里体现出来了:应用层需要从小到大扫描 fd,fd 很多时会浪费大量遍历成本。

3. poll:用数组管理 fd,事件更清楚

poll把 fd、关注事件、返回事件放在一个结构体里:

structpollfdfds[1024];fds[0].fd=sockfd;fds[0].events=POLLIN;intnfds=1;

调用方式比select更直接:

intret=poll(fds,nfds,-1);if(ret<0){perror("poll");continue;}

新连接到来时,把客户端 fd 追加到数组:

if(fds[0].revents&POLLIN){intclientfd=accept(sockfd,(structsockaddr*)&client_addr,&client_len);fds[nfds].fd=clientfd;fds[nfds].events=POLLIN;nfds++;}

客户端断开时,项目里用了一个很实用的技巧:用最后一个元素覆盖当前元素,然后nfds--

if(n<=0){close(fds[i].fd);fds[i]=fds[nfds-1];nfds--;i--;}

这样删除数组中间元素时不需要整体搬移。i--是为了重新检查被覆盖过来的新元素。

poll相比select的进步:

  • 不依赖FD_SETSIZE默认大小。
  • eventsrevents分开,关注事件和实际事件更清晰。
  • 不需要每轮重新构造fd_set

但它仍然需要把整个数组传给内核,也仍然要扫描数组。

4. epoll:注册一次,等待就绪事件

epoll的使用流程更像“先注册,再等待”:

intepollfd=epoll_create1(0);structepoll_eventev,events[1024];ev.events=EPOLLIN;ev.data.fd=sockfd;epoll_ctl(epollfd,EPOLL_CTL_ADD,sockfd,&ev);

事件循环里直接等待就绪事件:

intnfds=epoll_wait(epollfd,events,1024,-1);if(nfds<0){perror("epoll_wait");continue;}for(inti=0;i<nfds;i++){if(events[i].data.fd==sockfd){intclientfd=accept(sockfd,(structsockaddr*)&client_addr,&client_len);ev.events=EPOLLIN;ev.data.fd=clientfd;epoll_ctl(epollfd,EPOLL_CTL_ADD,clientfd,&ev);}else{ssize_tn=recv(events[i].data.fd,buffer,sizeof(buffer)-1,0);if(n<=0){close(events[i].data.fd);epoll_ctl(epollfd,EPOLL_CTL_DEL,events[i].data.fd,NULL);}}}

epoll_wait()返回的是就绪事件数组,不需要像select/poll那样扫描完整连接表。这也是它适合大量连接的关键原因。

5. 三者对比表

模型fd 管理方式每轮是否重建集合是否扫描全部 fd适合场景
selectfd_set位图需要需要入门理解、小规模 fd
pollpollfd数组不需要重建,但数组要传入内核需要中小规模连接
epoll内核维护兴趣集合不需要不需要扫描全部,只返回就绪项大量长连接

6. 编译运行

gcc tcp_server_select.c-oselectgcc tcp_server_poll.c-opoll gcc tcp_server_epoll.c-oepoll

分别启动:

./select ./poll ./epoll

nc测试:

nc127.0.0.18080hello

需要注意的是,本项目的 select 和 poll 版本会 echo 回客户端;epoll 基础版本主要演示读事件注册和删除,收到数据后打印到服务端终端。如果希望它也 echo,在recv()成功分支中补一行send(events[i].data.fd, buffer, n, 0);即可。

7. 小结

select -> poll -> epoll的演进,本质是 fd 管理方式的演进:

  • select:应用每轮准备集合,内核返回后还要应用扫描。
  • poll:数组结构更清楚,但仍要传递和扫描整张表。
  • epoll:内核保存兴趣集合,应用只处理就绪事件。

理解这三者之后,再看 Reactor 模式就不会突兀。Reactor 其实就是在epoll事件循环上继续抽象:把不同 fd、不同事件分发给对应的回调函数。

学习链接: https://github.com/0voice

http://www.cnnetsun.cn/news/3013094.html

相关文章:

  • 视频 API 接口是什么?给小白的一篇入门指南
  • 分布式爬虫中的任务调度策略深度剖析
  • Sunshine开源游戏串流服务器:跨平台自托管流媒体技术深度解析
  • 提“效”利器!桥田修磨机全系列重磅升级,高寿命刀具惊艳亮相!
  • 优学宝知识付费与在线刷题系统全新上线,兼容 Word、Excel 题库一键导入,内置 AI 大模型实现试题智能识别分类。系统对注册用户免费开放,涵盖上传与分享、协同刷题、全真模拟测验、多题型分类练。
  • Ubuntu 无线网络链接
  • Python量化交易数据获取的终极解决方案:efinance免费金融数据库完全指南 [特殊字符]
  • PyTorch KernelAgent 源码解读 ---(1)--- 原理
  • 【LLM系列】FlashAttention V3 深度解析:把H100算力利用率从35%拉到75%的秘密
  • Cahn-Hilliard与Keller-Segel耦合模型的弱解存在性与唯一性分析
  • 新型公共文化空间智能化设备深度解析:4个核心维度,选对靠谱升级方案
  • 别再只会问 Claude 了:搞懂工具调用,才算真正用明白 Claude 3
  • 大模型聚合 API 全网测速实测:延迟瓶颈拆解与商用平台落地对比
  • 如何高效使用智能屏幕翻译工具:终极操作指南
  • Windows FRP 内网穿透完整教程:从零搭建到实战应用
  • 2026新版PMP:技术岗值得考吗?涨薪攻略+避坑指南
  • Spring Boot + MyBatis 多模块项目中,如何优雅完成一个增量需求
  • 基于51单片机的智能香薰灯:从PID温控到WS2812B灯效的嵌入式开发实践
  • Spring Boot 跨服务事务实现
  • 云计算生态产品经理面试攻略:从系统思维到商业实战
  • 自动化测试平台开发
  • 推送原理:从APNs到厂商通道
  • SPC统计过程控制:从入门到实战的完整技术路线
  • Redis高级笔记:Java程序员短期面试突击必备!
  • 安达发|保健品行业aps生产排程:提升效率的关键密钥
  • 干草颗粒机公司
  • WAVES 2026大会聚焦具身智能:泡沫之下,何时真正走进现实?
  • 问题解决策略动态规划训练3
  • 不到8个月完成三轮融资!云际航电全栈自研航电系统,欲打破国际垄断
  • 3分钟配置完成:基于YOLOv5的智能中国象棋AI辅助系统