接上篇

阻塞IO、非阻塞IO、IO多路复用和信号驱动IO简介-CSDN博客文章浏览阅读95次。阻塞IO、非阻塞IO、IO多路复用和信号驱动IO简介https://blog.csdn.net/CSDN_DU666666/article/details/139598410?csdn_share_tail=%7B%22type%22%3A%22blog%22%2C%22rType%22%3A%22article%22%2C%22rId%22%3A%22139598410%22%2C%22source%22%3A%22CSDN_DU666666%22%7D

基本思想：

        构造一个关于文件描述符的表，将所以要监视的文件描述符都放在这个表里

        将这个表传给一个函数 (select poll epoll)，这个函数默认也是阻塞的

        当监视的文件描述中有一个或多个文件描述符准备就绪的时候

        函数会立即返回，并告诉调用者哪些文件描述符已经就绪了

        我们已经知道哪些文件描述符就绪了，再去执行对应的io操作，就不会阻塞了

select函数

功能：实现多路IO复用
头文件：#include <sys/select.h>
函数原型：int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);
参数：nfds：		要监视的最大文件描述符+1readfds：	要监视的读文件描述符集合 不关心可以传NULLwritefds：	要监视的写文件描述符集合 不关心可以传NULLexceptfds：	要监视的异常文件描述符集合 不关心可以传NULLtimeout：	超时时间 如果设置成NULL 会一直阻塞 直到有文件描述符就绪
返回值：成功 就绪的文件描述符的个数超时 0失败 -1 重置错误码 注意事项：1.select只能监视小于FD_SETSIZE(1024)的文件描述符2.select返回时会将没有就绪的文件描述符在集合中擦除所以循环中使用select时 每次需要重置集合3.我们一般只关心读文件文件描述符集合 其他两个置NULL即可void FD_CLR(int fd, fd_set *set);	//将文件描述符在集合中删除int  FD_ISSET(int fd, fd_set *set);	//判断文件描述符是否还在集合中// 返回0 表示不在了 非0 表示在void FD_SET(int fd, fd_set *set);	//向集合中添加一个文件描述符void FD_ZERO(fd_set *set);			//清空集合

service.c

首先创建三个管道文件

指令：mkfifo fifo1  

          mkfifo fifo2

          mkfifo fifo3

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>int main(int argc, const char *argv[]){int fd1 = open("fifo1", O_RDONLY);int fd2 = open("fifo2", O_RDONLY);int fd3 = open("fifo3", O_RDONLY);char buff[128] = {0};//创建文件描述符集合fd_set readfds;//母本FD_ZERO(&readfds);fd_set readfds_temp;//副本 用来给select每次擦除用FD_ZERO(&readfds_temp);int max_fd = 0;//用来记录最大的文件描述符//将要监视的文件描述符添加到集合中FD_SET(fd1, &readfds);max_fd = max_fd>fd1 ? max_fd : fd1;FD_SET(fd2, &readfds);max_fd = max_fd>fd2 ? max_fd : fd2;FD_SET(fd3, &readfds);max_fd = max_fd>fd3 ? max_fd : fd3;
#if 0//基础版while(1){//select返回时会将没有就绪的文件描述符在集合中擦除//所以循环中使用select时 每次需要重置集合readfds_temp = readfds;if(-1 == select(max_fd+1, &readfds_temp, NULL, NULL, NULL)){perror("select error");}//程序执行到这儿 说明有文件描述符就绪了//我们需要判断谁就绪了if(FD_ISSET(fd1, &readfds_temp)){memset(buff, 0, 128);read(fd1, buff, 128);printf("fifo1:[%s]\n", buff);}if(FD_ISSET(fd2, &readfds_temp)){memset(buff, 0, 128);read(fd2, buff, 128);printf("fifo2:[%s]\n", buff);}if(FD_ISSET(fd3, &readfds_temp)){memset(buff, 0, 128);read(fd3, buff, 128);printf("fifo3:[%s]\n", buff);}}
#endif#if 1
//进阶版//基础版int ret = 0;int i = 0;while(1){readfds_temp = readfds;if(-1 == (ret = select(max_fd+1, &readfds_temp, NULL, NULL, NULL))){perror("select error");}//遍历文件描述符集合 谁还在里面说明谁就绪for(i = 3; i < max_fd+1 && ret != 0; i++){if(FD_ISSET(i, &readfds_temp)){memset(buff, 0, 128);read(i, buff, 128);printf("buff[%d-3]:[%s]\n",i, buff);ret--;//此处的ret--是为了提高效率的}}}
#endifclose(fd1);close(fd2);close(fd3);return 0;
}

client.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>int main(int argc, const char *argv[]){int fd = open("fifo1", O_WRONLY);//fifo2 fiof3char buff[128] = {0};while(1){memset(buff, 0, 128);printf("请输入:");fgets(buff, 128, stdin);buff[strlen(buff)-1] = '\0';write(fd, buff, 128);}close(fd);return 0;
}