【Linux C | I/O模型】IO复用 | select、pselect函数详解(看完就会用了)

😁博客主页😁：🚀https://blog.csdn.net/wkd_007🚀
🤑博客内容🤑：🍭嵌入式开发、Linux、C语言、C++、数据结构、音视频🍭
🤣本文内容🤣：🍭介绍select函数 🍭
😎金句分享😎：🍭你不能选择最好的，但最好的会来选择你——泰戈尔🍭
⏰发布时间⏰：2024-02-01 17:19:49

本文未经允许，不得转发！！！

目录

  • 🎄一、概述
  • 🎄二、select 函数介绍
  • 🎄三、select 函数使用步骤
  • 🎄四、select 函数使用例子
  • 🎄五、pselect 函数及例子
  • 🎄六、总结

在这里插入图片描述

🎄一、概述

在Unix / Linux系统中，有五种IO模型：阻塞I/O模型、非阻塞I/O模型、复用式I/O模型、信号驱动式I/O模型、异步I/O模型。其中，复用式I/O模型的实现方式之一就是使用select函数来阻塞等待内核准备好数据，等数据准备好了之后，再通知应用层的进程调用IO操作函数来获取数据。

在这里插入图片描述
下面将介绍select函数以及select函数的使用方法。

在这里插入图片描述

🎄二、select 函数介绍

select 函数原型：

#include <sys/select.h>
#include <sys/time.h>
int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);

select允许调用进程监视多个文件描述符，等待一个或多个文件描述符的I/O操作(读、写、异常)准备就绪。准备就绪是指该描述符执行相应的I/O操作(读、写、异常)不会等待(阻塞)了，可以直接返回。

参数说明：

  • nfds：填一个描述符数值，该数值等于三个集合(readfds、writefds、exceptfds)中最大文件描述符加1。
    例如：readfds、writefds、exceptfds中最大的描述符是58，则nfsd就填59。
  • readfds：传入传出参数，要监视的进行读取操作的描述符集合；
  • writefds：传入传出参数，要监视的进行写取操作的描述符集合；
  • exceptfds：传入传出参数，要监视的可能出现异常的描述符集合；
  • timeout：该参数指定select函数应阻止等待文件描述符准备就绪的时间间隔。这个参数有三种可能：
    • 1、timeout设置为NULL：一直阻塞等待，直到有描述符准备就绪；
    • 2、timeout设置一定的时间：阻塞等待timeout设置的时间，期间有描述符准备就绪就返回，没有就等到时间结束返回。
    • 3、timeout设置的时间为0：不等待，检查描述符后直接返回。

返回值：成功返回已准备就绪的描述符数，且对应的描述符集会返回已准备就绪的描述符；超时返回0；失败返回-1。

在这里插入图片描述

🎄三、select 函数使用步骤

select函数的使用步骤主要分成4步，前3步是为了调用函数，第4步是检查我们刚兴趣的描述符是否准备就绪：

  • 1、添加感兴趣的描述符到对应的描述符集；
    这个主要针对select函数中间的三个参数，它们都是fd_set类型的，可以使用下面4个宏来操作该类型：

    void FD_CLR(int fd, fd_set *set);	// 从描述符集删除 fd
int  FD_ISSET(int fd, fd_set *set);	// 检查描述符集是否包含了 fd
void FD_SET(int fd, fd_set *set);	// 设置 fd 到描述符集
void FD_ZERO(fd_set *set);			// 清空描述符集

  • 2、计算出所添加的所有描述符中最大的描述符，把该描述符加1，设置到select函数的第一个参数；

  • 3、根据需求设置等待时长。

    struct timeval {time_t      tv_sec;     // secondssuseconds_t tv_usec;    // microseconds-微秒
};

  • 4、函数成功返回后，如果有准备就像的描述符，会从设置的描述符集中返回。可以调用宏FD_ISSET来检查哪个描述符准备就像。

在这里插入图片描述

🎄四、select 函数使用例子

下面使用TCP套接字来演示select的使用例子，如果要执行的话，分别保存服务端、客户端代码为select_tcpSer.c、select_tcpCli.c，然后执行下面代码编译：

gcc select_tcpSer.c -o ser 
gcc select_tcpCli.c -o cli

然后先在一个命令行窗口运行服务端./ser，再重新打开一个命令行窗口运行客户端./cli。下面是服务端的运行结果：
在这里插入图片描述

TCP服务端代码如下：使用select阻塞等待可读描述符返回。


#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>#include <sys/select.h>
#include <sys/time.h>int select_wait(int listenFd, int connFd[10], int connNum)
{// 1、添加感兴趣的描述符到可读描述符集fd_set read_set;FD_ZERO(&read_set);FD_SET(listenFd, &read_set);int i = 0;for(i=0; i<connNum; i++){FD_SET(connFd[i], &read_set);}// 2、计算出最大描述符int maxFd = listenFd;for(i=0; i<connNum; i++){if(connFd[i]>maxFd)maxFd = connFd[i];}maxFd++;// 3、设置等待时长2分钟struct timeval timeout;timeout.tv_sec = 2*60;timeout.tv_usec= 0;int ret = select(maxFd, &read_set, NULL, NULL, &timeout);// 阻塞等待if(ret > 0)// 即使有多个fd可读，我们也只返回一个描述符，其他的下次处理{printf("success, Number of descriptors returned is %d\n", ret);if(FD_ISSET(listenFd, &read_set)){return listenFd;}for(i=0; i<connNum; i++){if(FD_ISSET(connFd[i], &read_set)){return connFd[i];}}}else if(ret == 0){printf("select timeout\n");}return -1;
}int del_connfd(int connFds[10], int connNum, int delFd) // 从connFds数组中删除delFd
{int tmpFds[10]={0,};int i = 0, index = 0;;memcpy(tmpFds, connFds, connNum*sizeof(connFds[0]));for(i=0; i<connNum; i++){if(tmpFds[i] != delFd){connFds[index++] = tmpFds[i];}}return index;
}int main()
{// 1、创建TCP套接字socketint sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd<0){perror("socket error" );return -1;}// 2、准备服务端ip和端口struct sockaddr_in servaddr;bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons (10086);servaddr.sin_addr.s_addr = INADDR_ANY; // 指定ip地址为 INADDR_ANY，这样要是服务器主机有多个网络接口，服务器进程就可以在任一网络接口上接受客户端的连接// 3、绑定 bindif (bind(sockfd,(struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){perror("bind error" );return -1;}// 4、监听 listenif(listen(sockfd, 10) != 0){perror("listen error");return -1;}printf("TcpSer sockfd=%d, start listening\n",sockfd);char recvline[256];int connFds[10];int connNum = 0;while(1){int readableFd = select_wait(sockfd, connFds, connNum);if(readableFd == sockfd)// 监听描述符可读，使用accept获取客户端套接字{printf("listenFd %d is alread to read, calling accept\n", sockfd);int connfd = accept(sockfd, NULL, NULL);if(connfd < 0){perror("accept error" );return -1;}connFds[connNum] = connfd;connNum++;}else // 客户端发数据过来，读取打印{int connfd = readableFd;printf("connfd %d is alread to read\n", connfd);int n = read(connfd, recvline, sizeof(recvline));if(n>0){recvline[n] = 0 ;/*null terminate */printf("recv connfd=%d [%s]\n",connfd,recvline);write(connfd, "Hello,I am tcp server", strlen("Hello,I am tcp server"));}printf("close connfd=%d\n",connfd);close(connfd);connNum = del_connfd(connFds, connNum, connfd);}}// 7、关闭close(sockfd);return 0;
}

TCP客户端代码如下，连接服务端后发送数据、读取数据：

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>int main()
{// 1、创建TCP套接字socketint sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd<0){perror("socket error" );return -1;}// 2、准备服务端ip和端口struct sockaddr_in servaddr;bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons (10086);if (inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr) <= 0) // 设置本机IP为服务端IPperror("inet_pton error");// 3、连接 connectif (connect(sockfd,(struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){perror("connect error");return -1;}// 4、交换数据printf("TcpCli sockfd=%d, send msg\n",sockfd);write(sockfd, "Hello,I am tcp client", strlen("Hello,I am tcp client"));char recvline[256];int n = 0;while ( (n = read (sockfd, recvline, sizeof(recvline))) > 0){recvline[n] = 0 ;/*null terminate */printf("recv[%s]\n",recvline);}if (n < 0)perror("read error" );// 5、关闭printf("close fd %d\n",sockfd);close(sockfd);return 0;
}

在这里插入图片描述

🎄五、pselect 函数及例子

在Linux系统中还有个pselect函数，其函数原型如下：

#include <sys/select.h>
int pselect(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, const struct timespec *timeout,const sigset_t *sigmask);

可以看到，和select基本差不多，但有下面三个区别：

  • 1、select函数使用的timeout参数是struct timeval(以秒和微秒表示)类型的，而pselect函数使用struct timespec(以秒或纳秒表示)。
  • 2、select可以更新timeout参数以指示剩余的时间。pselect的timeout参数声明为const确保其不会更改此参数。
  • 3、pselect可以选择使用的信号屏蔽字。若sigmask为空，那么在与信号有关的方面，pselect的运行状况和select相同。否则，sigmask指向一信号屏蔽字，在调用pselect时，以原子操作的方式安装该信号屏蔽字。在返回时恢复以前的信号屏蔽字。

下面将select函数例子的服务端修改为pselect函数，且屏蔽掉ctrl+c产生的信号，修改后代码如下，客户端还是用前面的客户端即可：

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>#include <sys/select.h>
#include <sys/time.h>#include <signal.h>int select_wait(int listenFd, int connFd[10], int connNum)
{// 1、添加感兴趣的描述符到可读描述符集fd_set read_set;FD_ZERO(&read_set);FD_SET(listenFd, &read_set);int i = 0;for(i=0; i<connNum; i++){FD_SET(connFd[i], &read_set);}// 2、计算出最大描述符int maxFd = listenFd;for(i=0; i<connNum; i++){if(connFd[i]>maxFd)maxFd = connFd[i];}maxFd++;// 3、设置等待时长2分钟struct timespec timeout;timeout.tv_sec = 2*60;timeout.tv_nsec= 0;sigset_t sigmask;sigemptyset(&sigmask);sigaddset(&sigmask, SIGINT);  // ctrl + cint ret = pselect(maxFd, &read_set, NULL, NULL, &timeout, &sigmask);// 阻塞等待if(ret > 0)// 即使有多个fd可读，我们也只返回一个描述符，其他的下次处理{printf("success, Number of descriptors returned is %d\n", ret);if(FD_ISSET(listenFd, &read_set)){return listenFd;}for(i=0; i<connNum; i++){if(FD_ISSET(connFd[i], &read_set)){return connFd[i];}}}else if(ret == 0){printf("select timeout\n");}return -1;
}int del_connfd(int connFds[10], int connNum, int delFd) // 从connFds数组中删除delFd
{int tmpFds[10]={0,};int i = 0, index = 0;;memcpy(tmpFds, connFds, connNum*sizeof(connFds[0]));for(i=0; i<connNum; i++){if(tmpFds[i] != delFd){connFds[index++] = tmpFds[i];}}return index;
}int main()
{// 1、创建TCP套接字socketint sockfd = socket(AF_INET, SOCK_STREAM, 0);if(sockfd<0){perror("socket error" );return -1;}// 2、准备服务端ip和端口struct sockaddr_in servaddr;bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons (10086);servaddr.sin_addr.s_addr = INADDR_ANY; // 指定ip地址为 INADDR_ANY，这样要是服务器主机有多个网络接口，服务器进程就可以在任一网络接口上接受客户端的连接// 3、绑定 bindif (bind(sockfd,(struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){perror("bind error" );return -1;}// 4、监听 listenif(listen(sockfd, 10) != 0){perror("listen error");return -1;}printf("TcpSer sockfd=%d, start listening\n",sockfd);char recvline[256];int connFds[10];int connNum = 0;while(1){int readableFd = select_wait(sockfd, connFds, connNum);if(readableFd == sockfd)// 监听描述符可读，使用accept获取客户端套接字{printf("listenFd %d is alread to read, calling accept\n", sockfd);int connfd = accept(sockfd, NULL, NULL);if(connfd < 0){perror("accept error" );return -1;}connFds[connNum] = connfd;connNum++;}else // 客户端发数据过来，读取打印{int connfd = readableFd;printf("connfd %d is alread to read\n", connfd);int n = read(connfd, recvline, sizeof(recvline));if(n>0){recvline[n] = 0 ;/*null terminate */printf("recv connfd=%d [%s]\n",connfd,recvline);write(connfd, "Hello,I am tcp server", strlen("Hello,I am tcp server"));}printf("close connfd=%d\n",connfd);close(connfd);connNum = del_connfd(connFds, connNum, connfd);}}// 7、关闭close(sockfd);return 0;
}

保存为pselect_tcpSer.c，编译运行后，结果如下，

执行完按ctrl+c无法结束进程，可以用kill -9 pid进程号终止该进程，操作如下：

$ ps aux | grep ser
wkd        51448  0.0  0.0   4212  1436 pts/12   S+   17:09   0:00 ./ser
wkd        51451  0.0  0.1  15960  2092 pts/17   S+   17:10   0:00 grep --color=auto ser
$ kill -9 51448

或者等待pselect超时后，会处理ctrl+c的信号的，也就退出了

在这里插入图片描述

🎄六、总结

👉本文先是介绍select函数，然后介绍使用select的步骤，并给出了使用select的C语言例子，最后介绍了pselect函数并给出C语言使用例子。看完有不懂的，可以留意。

在这里插入图片描述
如果文章有帮助的话，点赞👍、收藏⭐，支持一波，谢谢 😁😁😁

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

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

相关文章

天梯算法Day1整理

天梯算法Day1整理

Nanami and Arithmetic Sequence 题面 思路 炸鱼题 只有n1的时候&#xff0c;只有一个等差数列&#xff1b; 其余时候&#xff0c;都是都有无数个等差数列。 代码 #include <iostream> using namespace std;int main() {int t, n;cin >> t;while (t--) {cin…
阅读更多...
【计算机网络】深入掌握计算机网络的核心要点

【计算机网络】深入掌握计算机网络的核心要点

写在前面 前言四层模型网络地址管理Linux下设置ipARP请求包总结 前言 计算机网络是指将分散的计算机设备通过通信线路连接起来&#xff0c;形成一个统一的网络。为了使得各个计算机之间能够相互通信&#xff0c;需要遵循一定的协议和规范。OSI参考模型和TCP/IP参考模型是计算机…
阅读更多...
JavaScript高级：异常和debugger调试

JavaScript高级：异常和debugger调试

1 抛出异常 function fn(x, y) {if (!x || !y) {throw new Error(参数不能为空&#xff01;) // 会终止程序}return x y}console.log(fn()) 2 捕获异常 try...catch 捕获异常 try {// 可能抛出异常的代码const p document.querySelector(.p)p.style.color red} catch (err)…
阅读更多...
通用CI/CD软件平台TeamCity全新发布v2023.11——增强Git托管平台的集成

通用CI/CD软件平台TeamCity全新发布v2023.11——增强Git托管平台的集成

TeamCity是一个通用的 CI/CD 软件平台&#xff0c;可以实现灵活的工作流、协作和开发做法。我们的解决方案将帮助在您的 DevOps 流程中成功实现持续集成、持续交付和持续部署。 TeamCity 2023.11正式版下载 TeamCity 2023.11 带来了矩阵构建和构建缓存等多项备受期待的功能&a…
阅读更多...
DolphinScheduler数仓任务管理规范

DolphinScheduler数仓任务管理规范

目录 一、DolphinScheduler调度数仓任务现状分析 2.1 一个任务流构建数仓所有的逻辑节点 2.2 每个逻辑节点构建一个任务流 二、数仓任务管理调度需求分析 三、DolphinScheduler数仓开发任务管理规范 四、结语 前言&#xff1a;大数据领域对多种任务都有调度需求&#xff…
阅读更多...
Asp .Net Core 系列：Asp .Net Core 配置 System.Text.Json

Asp .Net Core 系列：Asp .Net Core 配置 System.Text.Json

文章目录 简介Asp .Net Core 如何配置 System.Text.Json所有配置全局配置 对比 Newtonsoft.Json无实体类型下操作 Json自定义转换器处理 Dynamic 类型封装常用配置封装 JsonHelper 帮助类 简介 System.Text.Json 命名空间提供用于序列化和反序列化 JavaScript 对象表示法 (JSO…
阅读更多...
JavaScript高级：深浅拷贝

JavaScript高级：深浅拷贝

目录 1 引言 2 浅拷贝 2.1 拷贝数组 1.2 拷贝对象 3 赋值操作和浅拷贝的比较 4 深拷贝 4.1 前置知识 --> 递归函数 4.2 使用递归实现深拷贝 4.3 js库中的lodash里面的cloneDeep内部实现深拷贝 4.4 利用JSON实现深拷贝 深浅拷贝只针对引用数据类型 1 引言 假如我们…
阅读更多...
如何在Windows系统使用Plex部署影音服务与公网访问本地资源【内网穿透】

如何在Windows系统使用Plex部署影音服务与公网访问本地资源【内网穿透】

文章目录 1.前言2. Plex网站搭建2.1 Plex下载和安装2.2 Plex网页测试2.3 cpolar的安装和注册 3. 本地网页发布3.1 Cpolar云端设置3.2 Cpolar本地设置 4. 公网访问测试5. 结语 正文开始前给大家推荐个网站&#xff0c;前些天发现了一个巨牛的 人工智能学习网站&#xff0c; 通…
阅读更多...
人工智能时代：AI提示工程的奥秘 —— 驾驭大语言模型的秘密武器

人工智能时代：AI提示工程的奥秘 —— 驾驭大语言模型的秘密武器

文章目录 一、引言二、提示工程与大语言模型三、大语言模型的应用实践四、策略与技巧五、结语《AI提示工程实战&#xff1a;从零开始利用提示工程学习应用大语言模型》亮点内容简介作者简介目录获取方式 一、引言 随着人工智能技术的飞速发展&#xff0c;大语言模型作为一种新…
阅读更多...
如何发布自己的npm包：

如何发布自己的npm包：

1.创建一个打包组件或者库&#xff1a; 安装weback&#xff1a; 打开项目&#xff1a; 创建webpack.config.js,创建src目录 打包好了后发现两个js文件都被压缩了&#xff0c;我们想开发使用未压缩&#xff0c;生产使用压缩文件。 erserPlugin&#xff1a;&#xff08;推荐使用…
阅读更多...
UAD155A0111 3BHE029110R0111

UAD155A0111 3BHE029110R0111

UAD155A0111 3BHE029110R0111 UAD155A0111 3BHE029110R0111 UAD155A0111 3BHE029110R0111如何通过CDMA模块实现车载终端数据通信 ... 包括单片机(rabbit2000)、GPS模块、CDMA 手机模块、GSM手机模块、铁电存储器、 ... 提取经纬度信息&#xff0c;通过GSM和 CDMA 模块分别采…
阅读更多...
YIA主题如何关闭新版本升级提示？WordPress主题怎么取消升级提醒？

YIA主题如何关闭新版本升级提示？WordPress主题怎么取消升级提醒？

前两天YIA主题发布了升级到2.8版本&#xff0c;新增了一些功能&#xff0c;优化调整修复了一些功能&#xff0c;但是这些功能调整幅度不大&#xff0c;加上boke112百科使用的YIA主题已经进行了很多方面的个性化修改&#xff0c;所以就懒得升级了&#xff0c;但是每次进入WordPr…
阅读更多...
Spring的事件监听机制

Spring的事件监听机制

这里写自定义目录标题 1. 概述&#xff08;重点&#xff09;2. ApplicationEventMulticaster2.1 SimpleApplicationEventMulticaster2.2 AbstractApplicationEventMulticaster 3. ApplicationListener3.1 注册监听器3.2 自定义 4. SpringApplicationRunListeners 1. 概述&#…
阅读更多...
Python接口自动化测试（接口状态）

Python接口自动化测试（接口状态）

本节开始&#xff0c;开始介绍python的接口自动化测试&#xff0c;首先需要搭建python开发环境&#xff0c;到https://www.python.org/下载python 版本直接安装就以了&#xff0c;建议 下载python2.7.11版本&#xff0c;当然&#xff0c;也是可以下载python最新版本的。 接口测…
阅读更多...
纯干货，3步轻松生成智慧乡村3D场景！

纯干货，3步轻松生成智慧乡村3D场景！

临近春节返乡&#xff0c;网上有个话题又重新上了热门&#xff0c;“以你的专业&#xff0c;回到家乡能做什么贡献&#xff1f;”虽然很多人调侃&#xff0c;对家乡最大的贡献就是“离开家乡”&#xff0c;但其实现在农村老家的发展也离不开打工人在远方的支持。 比如AMRT3D引…
阅读更多...
Docker基础（持续更新中）

Docker基础（持续更新中）

# 第1步&#xff0c;去DockerHub查看nginx镜像仓库及相关信息# 第2步&#xff0c;拉取Nginx镜像 docker pull nginx# 第3步&#xff0c;查看镜像 docker images # 结果如下&#xff1a; REPOSITORY TAG IMAGE ID CREATED SIZE nginx latest 60…
阅读更多...
【数学】【记忆化搜索 】【动态规划】964. 表示数字的最少运算符

【数学】【记忆化搜索 】【动态规划】964. 表示数字的最少运算符

作者推荐 【动态规划】【字符串】【表达式】2019. 解出数学表达式的学生分数 本文涉及知识点 动态规划汇总 数学 记忆化搜索 LeetCoce964表示数字的最少运算符 给定一个正整数 x&#xff0c;我们将会写出一个形如 x (op1) x (op2) x (op3) x … 的表达式&#xff0c;其中每…
阅读更多...
接口性能优化常见12式

接口性能优化常见12式

目录 1.批处理 2.异步处理 3.空间换时间 4.预处理 5.池化思想 6.串行改并行 7.索引 8.避免大事务 9.优化程序结构 10.深分页问题 11.SQL优化 12.锁粒度避免过粗 1.批处理 批量思想&#xff1a;批量操作数据库&#xff0c;这个很好理解&#xff0c;我们在循环插入场…
阅读更多...
微服务—Docker

微服务—Docker

目录 初识Docker Docker与虚拟机的区别 镜像与容器 Docker架构 常见Docker命令 镜像命令 容器命令 数据卷挂载 直接挂载 初识Docker 在项目部署的过程中&#xff0c;如果出现大型项目组件较多&#xff0c;运行环境也较为复杂的情况&#xff0c;部署时会碰到一些问题&…
阅读更多...
算法练习-逆波兰表达式求值（思路+流程图+代码）

算法练习-逆波兰表达式求值（思路+流程图+代码）

难度参考 难度&#xff1a;中等 分类&#xff1a;栈与队列 难度与分类由我所参与的培训课程提供&#xff0c;但需要注意的是&#xff0c;难度与分类仅供参考。且所在课程未提供测试平台&#xff0c;故实现代码主要为自行测试的那种&#xff0c;以下内容均为个人笔记&#xff0c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023