【Linux】进程见通信之匿名管道pipe
2023-12-13 20:47:15
1.匿名管道的特点
以下管道的统称仅代表匿名管道。
- 管道是一个只能单向通信的通信信道。为了实现进程间通信.
- 管道是面向字节流的。
- 仅限于父子通信或者具有血缘关系的进程进行进程见通信。
- 管道自带同步机制,原子性写入。
- 管道的生命周期是随进程的。
2.匿名管道通信的四种情况
- 读端不读或者读的慢,写端要等读端。
- 读端关闭,写端收到SIGPIPE信号直接终止。
- 写端不写或者写的慢,读端要等写端
- 写端关闭,读端读完pipe内部的数据然后再读,会读到0,表示读到文件结尾。
3.pipe函数介绍
在Linux中,pipe() 是一个底层系统调用,用于创建管道(pipe)。pipe函数的使用如下:
#include<unistd.h>//使用所需包含的头文件
int pipe(int pipefd[2]);
对于参数pipefd是一个两个元素的整型数组,它是一个传出参数,用于存放管道的读写文件描述符。其中pipefd[0]为管道读端,pipefd[1]为管道写端。这两个文件描述符可以像其他文件描述符一样进行读写操作。
4.pipe函数使用示例
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/wait.h>
#include <stdlib.h>
int main()
{
//定义pipe函数所需的pipe_fd,用来存放文件描述符。
int pipe_fd[2] = {0};
if(pipe(pipe_fd) < 0){
perror("pipe");
return 1;
}
printf("%d, %d\n", pipe_fd[0], pipe_fd[1]);
//创建子进程
pid_t id = fork();
if(id < 0){
perror("fork");
return 2;
}
else if(id == 0) { //write
//child
//在子进程中关闭读端
close(pipe_fd[0]);
char c = 'x';
int count = 0;
while(1){
write(pipe_fd[1], &c, 1);
count++;
printf("write: %d\n", count);
}
//使用完结束不要忘记关闭写端!!!
close(pipe_fd[1]);
exit(0);
}
else{ //read
//parent
//在父进程中关闭写端
close(pipe_fd[1]);
char buffer[64];
while(1){
buffer[0] = 0;
//从读端,读取sizeof(buffer)-1个字节到buffer中
ssize_t size = read(pipe_fd[0], buffer, sizeof(buffer)-1);
if(size > 0){//读取成功
buffer[size] = 0;
printf("parent get messge from child# %s\n", buffer);
}
else if(size == 0){
printf("pipe file close, child quit!\n");
break;
}
else{
//TODO
break;
}
}
//定义进程等待状态,并进行进程等待
int status = 0;
if(waitpid(id, &status,0) > 0){
printf("child quit, wait success!, sig: %d\n", status&0x7F);
}
close(pipe_fd[0]);
}
return 0;
}
5.从文件描述的角度深入理解匿名管道
文章来源:https://blog.csdn.net/weixin_51692487/article/details/134856937
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!