【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;     // seconds
       suseconds_t tv_usec;    // microseconds-微秒
    };
    
  • 4、函数成功返回后,如果有准备就像的描述符,会从设置的描述符集中返回。可以调用宏FD_ISSET来检查哪个描述符准备就像。


在这里插入图片描述

🎄四、select 函数使用例子

下面使用TCP套接字来演示select的使用例子,如果要执行的话,分别保存服务端、客户端代码为select_tcpSer.cselect_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套接字socket
	int 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、绑定 bind
	if (bind(sockfd,(struct sockaddr*)&servaddr, sizeof(servaddr)) < 0)
	{
		perror("bind error" );
		return -1;
	}
	
	// 4、监听 listen
	if(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套接字socket
	int 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为服务端IP
		perror("inet_pton error");
	
	// 3、连接 connect
	if (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 + c
	
	int 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套接字socket
	int 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、绑定 bind
	if (bind(sockfd,(struct sockaddr*)&servaddr, sizeof(servaddr)) < 0)
	{
		perror("bind error" );
		return -1;
	}
	
	// 4、监听 listen
	if(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语言使用例子。看完有不懂的,可以留意。

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

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【Eclipse平台】2 Eclipse Workbench工作台介绍

Eclipse Workbench工作台介绍 本文介绍Eclipse工作台Workbench。 当工作台启动时&#xff0c;首先看到的是一个对话框&#xff0c;该对话框允许我们选择工作区的位置。工作区是存储工作的目录。现在&#xff0c;只需单击“确定”即可选择默认位置。 选择工作区位置后&#x…

LVGL部件4

一.列表部件 1.知识概览 2.函数接口 1.lv_list_add_btn lv_list_add_btn 是 LittlevGL&#xff08;LVGL&#xff09;图形库中的一个函数&#xff0c;用于向列表&#xff08;list&#xff09;对象中添加一个按钮&#xff08;button&#xff09;。 函数原型为&#xff1a;lv_ob…

数据库复试-SQL数据定义与数据查询语句

数据库复试-SQL数据定义与数据查询语句 使用mysql数据库代替之前的sqlserver (完全使用命令行进行操作) 一&#xff1a;登录数据库登录与创建 mysql -uroot -p 123456 CREATE TABLE Student(Sno CHAR(9) PRIMARY KEY, /*主键约束*/Sname CHAR(20) UNIQUE, /*唯一值*/Ssex …

关于标准那些事——第十篇 符号标准

“符号”几乎是无处不在的&#xff0c;无论是生活、学习还是工作中&#xff0c;每个人每天都会碰到&#xff0c;只是我们没有意识到她的存在。正因如此&#xff0c;符号标准在不同场景、不同领域都发挥着统一认知&#xff0c;规范行为的作用&#xff0c;其简约、易用和一致性的…

分布式事务(四)——TCC补偿模式解决方案

系列目录&#xff1a; 《分布式事务&#xff08;一&#xff09;—— 事务的基本概念》 《分布式事务&#xff08;二&#xff09;—— CAP和Base理论》 《分布式事务&#xff08;三&#xff09;—— 两阶段提交解决方案&#xff08;2PC&#xff09;》 一、常见分布式事务解决…

轻型民用无人机驾驶航空器安全操控——理论考试多旋翼部分笔记

今天已经可以在线考取轻型民用无人机驾驶航空器执照了&#xff0c;所以我也在在线观看完视频之后整理了如下的知识点&#xff0c;所有知识点全部来自UOM平台。 目录 航空器知识 &#xff08;1&#xff09;多旋翼民用无人驾驶航空器螺旋桨的作用 &#xff08;2&#x…

仰暮计划|“从米票、肉票、糖果票到肥皂票、煤票、棉花票等,生活里头的方方面面都能用粮票买到”

口述人&#xff1a;牛翠英(女) 整理人&#xff1a;霍芝冉 口述人基本信息&#xff1a;现68岁&#xff0c;河南省安阳市北关区霍家村人&#xff0c;现居河南安阳市区。 奶奶一生辛劳&#xff0c;操持家务&#xff1b;亲眼见证了时代变迁&#xff0c;社会发展&#xff0c;…

小米商城服务治理之客户端熔断器(Google SRE客户端熔断器)

目录 前言 一、什么是Google SRE熔断器 二、Google SRE 熔断器的工作流程&#xff1a; 三、客户端熔断器 (google SRE 熔断器) golang GRPC 实现 四、客户端熔断器 (google SRE 熔断器) golang GRPC单元测试 大家可以关注个人博客&#xff1a;xingxing – Web Developer …

【笔试常见易错选择题01】else、表达式、二维数组、%m.ns、%m.nf、常量指针和指针常量、宏定义、传参、数组越界、位段

1. 下列main()函数执行后的结果为&#xff08;&#xff09; int func(){ int i, j, k 0; for(i 0, j -1;j 0;i, j){ k; } return k; } int main(){cout << (func());return 0; }A. -1 B. 0 C. 1 D. 2 判断为赋值语句&#xff0c;j等于0 0为假不进循环 选B. 2. 下面程…

【日常总结】宝塔中 Gitlab服务器 forbidden

一、场景 二、问题 三、原因 四、解决方案 五、实战 Stage 1&#xff1a;打开 /etc/gitlab/gitlab.rb&#xff0c;并编辑 Stage 2&#xff1a;重启gitlab服务 Stage 3&#xff1a;测试&#xff08;打开girlab网页&#xff09; 六、后续 一、场景 公司更换新电脑 服务…

引用与常引用

1.定义 下面写法定义了一个引用&#xff0c;并将它进行初始化为引用某个变量。 类型名 & 引用名 某变量名&#xff1b; int n 4; int & r n; // r引用了n&#xff0c;r的类型是int & 某个变量的引用&#xff0c;等价于这个变量&#xff0c;相当于该变量…

共用体与枚举法,链表的学习

结构体注意事项&#xff1a; 1.结构体类型可以定义在main函数里面&#xff0c;但是此时的作用域就被限定在该函数中 2.结构体的的的定义的形式&#xff1a;a.先定义类型&#xff0c;后定义变量-----struct stu s b.定义类型的同时&#xff0c;定义了变量&#xff1a;struct…

C语言系列-联合

&#x1f308;个人主页: 会编程的果子君 ​&#x1f4ab;个人格言:“成为自己未来的主人~” 目录 联合体 联合体类型的声明 联合体的特点 相同成员的结构体和联合体对比 联合体大小的计算 联合的一个练习 联合体 联合体类型的声明 像结构体一样&#xff0c;联合体也是由…

幻兽帕鲁专用服务器搭建教程分享(手把手教学)

想要快速搭建幻兽帕鲁服务器&#xff0c;我们只需要参考以下教程即可轻易完成幻兽帕鲁服务器的搭建部署&#xff0c;与其他专用服务器游戏一样&#xff0c;可以让您和朋友在一个相对独立、稳定且私密的云端跨境中进行游戏&#xff0c;以获得更好、更流畅的游戏体验。 幻兽帕鲁游…

CYUSB3065配置CMOS

目录 目标Eclipse使用流程1.首先安装开发环境2.在SDK目录下找到开发工具Eclipse&#xff0c;并打开3.编译固件4.进入烧录模式5.烧录6.如何调试&#xff1f;串口调试GDB调试 配置CMOSCMOS转接电路两个参数新建CX3工程 当前问题 目标 这是Cypress的一个支持MIPI和UVC的模块&…

SAP同步异常5:继续处理获利能力异常WW291

Short text of error message: 派生过程中系统错误: CE01000-WW291 在ABAP辞典中不存在 Long text of error message: 诊断 带 CE01000-WW291 名字段派生参考的定制设置。这个字段在 ABAP 字典中不 存在。 系统响应 因为在定制中有矛盾&#xff0c;所以系统的程序崩溃。 步骤 …

类和对象-下篇

文章目录 一、再谈构造函数1. 构造函数体赋值2. 初始化列表3. explicit关键字 二、static成员1. 概念2. 特性 三、友元1. 友元函数2. 友元类 四、 内部类1. 概念2. 特性 五、再次理解封装 一、再谈构造函数 1. 构造函数体赋值 在创建对象时&#xff0c;编译器通过调用构造函数…

BFS的基本应用——flood fill 最短路

bfs的核心就是一层一层往外扩展&#xff0c;在bfs中会用到一个队列&#xff0c;又由于是一层一层往外扩展的&#xff0c;故而可以用来求连通的问题&#xff0c;同时相当于每次往外扩展的边权都是1&#xff0c;所以这个队列是有序的&#xff0c;相当于dijkstra算法中的优先队列&…

vue3学习——初始化项目及配置

初始化项目 环境 node 16pnpm 8.0.0 命令 pnpm create vite进行以下选择 &#x1f447; – 项目名 – VUe – Ts – cd/目录 – pnpm run dev 浏览器自动打开 package.json 配置eslint 安装依赖包 pnpm i eslint -D npx eslint --init // 生成配置文件进行以下选择 &a…

SpringBoot 使用WebSocket功能

实现步骤&#xff1a; 1.导入WebSocket坐标。 在pom.xml中增加依赖项&#xff1a; <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId> </dependency>2.编写WebSocket配…