接上篇
阻塞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： 要监视的最大文件描述符+1
readfds： 要监视的读文件描述符集合 不关心可以传NULL
writefds： 要监视的写文件描述符集合 不关心可以传NULL
exceptfds： 要监视的异常文件描述符集合 不关心可以传NULL
timeout： 超时时间 如果设置成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--是为了提高效率的
}
}
}
#endif
close(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 fiof3
char 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;
}
