admin 管理员组

文章数量: 1087747

管道pipe

<1>两个进程利用管道来进行读写，写一个write_fifo.c文件利用mkfifo创建管道，以只写的方式打开管道文件，然后创建while循环，向管道中输入数据，当输入的数据是”quit”的时候，当前进程结束。在写一个read_fifo.c文件利用mkfifo创建管道，以只读的方式打开read_filo.c文件中打开的管道文件。然后把数据输出来。当读取到”quit”数据的时候，进程结束)。两个进程结束。

读

​
#include<stdio.h>
#include<unistd.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<fcntl.h>
#include<string.h>
#include<stdlib.h>
#include<errno.h>int main(int argc, const char *argv[])
{int fd;int n;char buf[1024]={0};if(argc != 2){fprintf(stderr,"Usage:%s file\n",argv[0]);return -1;}//创建有名管道if((mkfifo(argv[1],0666)<0) && errno != EEXIST){perror("Fail to mkfifo");return -1;}printf("open %s is successful\n",argv[1]);fd = open(argv[1],O_RDWR);while(1){
//		memset(buf,0,sizeof(buf));n = read(fd,buf,sizeof(buf));if(n==0){perror("Fail to read");return -1;}if(!strncmp(buf,"quit",4))//exit(0);printf("读到的字节：%s\n",buf);}close(fd);return 0;
}​

写

#include<stdlib.h>
#include<errno.h>void write_file(int fd)
{char buf[1024]={0};int n = 0;while(1){memset(buf,0,sizeof(buf));fgets(buf,sizeof(buf),stdin);write(fd,buf,sizeof(buf));lseek(fd,-n,SEEK_CUR);if(!strncmp(buf,"quit",4))exit(0);}
}int main(int argc, const char *argv[])
{int fd;if(argc != 2){fprintf(stderr,"Usage:%s file\n",argv[0]);return -1;}//创建有名管道	if((mkfifo(argv[1],0666)<0) && errno != EEXIST){perror("Fail to mkfifo");return -1;}printf("open %s is successful\n",argv[1]);fd = open(argv[1],O_RDWR);write_file(fd);close(fd);return 0;
}

结果

 

本文标签： 管道pipe

版权声明：本文标题：管道pipe 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.roclinux.cn/b/1687418831a100407.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。