Linux 下 poll 详解

ops/2024/10/9 15:25:36/

在Linux系统编程中,poll 是一个强大的多路复用(I/O 多路复用)函数,用于同时监控多个文件描述符的事件,特别是在处理网络套接字或其他I/O设备时。相比于selectpoll 支持监控更多的文件描述符,并且没有像select那样的文件描述符数量限制。

一、poll函数介绍

poll 函数用于在指定的超时时间内监视一组文件描述符,并返回文件描述符上是否有指定的I/O事件发生。

函数原型

#include <poll.h>

int poll(struct pollfd *fds, nfds_t nfds, int timeout);

  • fds:是一个数组,每个元素是一个pollfd结构,描述一个文件描述符及其要监视的事件。
  • nfds:要监视的文件描述符个数。
  • timeout:等待的超时时间(以毫秒为单位)。-1表示无限等待,0表示立即返回(非阻塞模式)。
pollfd 结构体

struct pollfd { int fd; // 要监视的文件描述符

                short events; // 等待的事件

                short revents; // 实际发生的事件

};

  • fd:要监视的文件描述符,例如套接字或管道。
  • events:感兴趣的事件,可以是以下的值的组合:
    • POLLIN:有数据可读。
    • POLLOUT:可以写数据(不会阻塞)。
    • POLLERR:发生错误。
    • POLLHUP:挂起事件(对方关闭连接)。
    • POLLNVAL:非法的文件描述符。
  • reventspoll返回时,实际发生的事件。
返回值
  • 成功时,返回大于0的值,表示有多少文件描述符有事件发生。
  • 如果超时且无事件发生,返回0。
  • 失败时,返回-1,并设置errno

二、poll 的使用步骤

  1. 创建并初始化pollfd数组:为需要监控的文件描述符设置监视事件。
  2. 调用poll函数:传入pollfd数组、数组大小和超时时间。
  3. 处理事件:根据返回的revents判断哪个文件描述符有事件发生,并做出相应处理。

三、poll 示例

下面是一个使用 poll 监视两个套接字的简单例子:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <poll.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>#define PORT 8080
#define MAX_EVENTS 2int main() {int listenfd, connfd;struct sockaddr_in serv_addr;struct pollfd fds[MAX_EVENTS];int nfds = 1;// 创建监听套接字if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {perror("socket failed");exit(EXIT_FAILURE);}serv_addr.sin_family = AF_INET;serv_addr.sin_addr.s_addr = INADDR_ANY;serv_addr.sin_port = htons(PORT);// 绑定并监听端口if (bind(listenfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) < 0) {perror("bind failed");close(listenfd);exit(EXIT_FAILURE);}if (listen(listenfd, 3) < 0) {perror("listen failed");close(listenfd);exit(EXIT_FAILURE);}// 初始化pollfd数组fds[0].fd = listenfd;fds[0].events = POLLIN;printf("Waiting for connections...\n");while (1) {int ret = poll(fds, nfds, -1);  // 无限等待事件if (ret < 0) {perror("poll failed");exit(EXIT_FAILURE);}// 检查监听套接字是否有新连接if (fds[0].revents & POLLIN) {struct sockaddr_in client_addr;socklen_t addr_len = sizeof(client_addr);if ((connfd = accept(listenfd, (struct sockaddr*)&client_addr, &addr_len)) < 0) {perror("accept failed");exit(EXIT_FAILURE);}printf("New connection accepted\n");}}close(listenfd);return 0;
}

这个例子中,程序首先创建了一个监听套接字,然后使用 poll 函数监视这个套接字的 POLLIN 事件(有新的连接到来)。当有新连接时,程序通过 accept 函数接收连接。

四、常用API介绍

在使用poll和其他多路复用函数时,通常会涉及以下API:

  1. socket:创建一个套接字,用于网络通信。

    int socket(int domain, int type, int protocol);

  2. bind:将一个套接字绑定到一个特定的地址和端口。

    int bind(int sockfd, const struct sockaddr *addr,

    socklen_t addrlen);

  3. listen:将一个套接字设置为监听模式,等待客户端的连接。

    int listen(int sockfd, int backlog);

  4. accept:从监听套接字接受一个新的连接。

    int accept(int sockfd, struct sockaddr *addr,

    socklen_t *addrlen);

  5. connect:客户端用于连接到服务端的套接字。

    int connect(int sockfd, const struct sockaddr *addr,

    socklen_t addrlen);

  6. recvsend:分别用于接收和发送数据。

    ssize_t recv(int sockfd, void *buf, size_t len, int flags); ssize_t send(int sockfd, const void *buf, size_t len,

    int flags);

  7. close:关闭文件描述符。

    int close(int fd);

五、pollselect的对比

  • 灵活性poll 可以处理更多的文件描述符,不受select的硬性限制。
  • 事件通知pollpollfd数组更加直观,每个文件描述符有自己的事件和返回事件。
  • 效率poll的实现较select高效,特别是在需要监控大量文件描述符的场景中。

六、结语

poll 提供了一种高效且灵活的方式来监控多个文件描述符的事件,特别适用于网络编程和I/O密集型应用。在实际应用中,poll 被广泛应用于高并发服务器、事件驱动框架等场景中。

如果对文件描述符数量和性能要求更高,还可以考虑使用 epoll,它是 Linux 下的增强版 poll,在处理大规模并发连接时更加高效。


http://www.ppmy.cn/ops/121380.html

相关文章

【EO-1(Earth Observing-1)卫星】

EO-1&#xff08;Earth Observing-1&#xff09;卫星是美国国家航空航天局&#xff08;NASA&#xff09;新千年计划&#xff08;New Millennium Program&#xff0c;NMP&#xff09;地球探测部分中的第一颗对地观测卫星。以下是对EO-1卫星的详细介绍&#xff1a; 一、发射与服…

【华为HCIP实战课程四】OSPF邻居关系排错时间和区域问题,网络工程师

一、OSPF邻居关系排错 1、MA网络(默认的以太网、FR和ATM)要求掩码一致 2、相邻OSPF设备RID相同不能建立邻居-----上节已经详细演示说明 3、同一链路必须相同区域 4、Hello和死亡时间匹配 5、MTU检测 6、认证 7、Flag位的一致性 8、华为设备上网络类型不一致 二、同一…

【深度学习】05-RNN循环神经网络-02- RNN循环神经网络的发展历史与演化趋势/LSTM/GRU/Transformer

RNN网络的发展历史与演化趋势 RNN&#xff08;Recurrent Neural Network&#xff0c;循环神经网络&#xff09;是一类用于处理序列数据的神经网络&#xff0c;特别擅长捕捉数据的时间或上下文依赖性。在其发展的过程中&#xff0c;不断出现各种改进和变体&#xff0c;以解决不…

链表面试编程题

1. 删除链表中等于给定值 val 的所有节点。 203. 移除链表元素 - 力扣&#xff08;LeetCode&#xff09; 2. 反转一个单链表。206. 反转链表 - 力扣&#xff08;LeetCode&#xff09; 3. 给定一个带有头结点 head 的非空单链表&#xff0c;返回链表的中间结点。如果有两个中间…

五.海量数据实时分析-FlinkCDC+DorisConnector实现数据的全量增量同步

前言 前面四篇文字都在学习Doris的理论知识&#xff0c;也是比较枯燥&#xff0c;当然Doris的理论知识还很多&#xff0c;我们后面慢慢学&#xff0c;本篇文章我们尝试使用SpringBoot来整合Doris完成基本的CRUD。 由于 Doris 高度兼容 Mysql 协议&#xff0c;两者在 SQL 语法…

JAVA智慧社区系统跑腿家政本地生活商城系统小程序源码

智慧社区系统集成跑腿家政与本地生活商城 —— 打造便捷高效的社区生活圈 &#x1f3e0; 智慧社区新时代&#xff1a;一站式服务新体验 在快节奏的都市生活中&#xff0c;智慧社区系统正悄然改变着我们的生活方式。它不再只是一个居住的空间&#xff0c;而是集成了跑腿家政、本…

Web 服务器与动态脚本语言通信的接口协议有哪些

Web 服务器与动态脚本语言通信的接口协议主要有以下几种&#xff1a; 一、FastCGI&#xff08;Fast Common Gateway Interface&#xff09; 特点&#xff1a;使用持久进程处理请求&#xff0c;减少了进程启动和关闭的开销&#xff0c;提高了性能和可扩展性。多个请求可由同一个…

【C++复习】C++11经典语法

文章目录 {}列表初始化1. 初始化内置类型变量2. 初始化数组3. 初始化标准容器4. 初始化自定义类型5. 构造函数初始化列表6. 初始化列表&#xff08;initializer_list&#xff09;7. 返回值初始化8. 静态成员变量和全局变量的就地初始化9. 防止类型收窄总结 decltype右值引用完美…