1、pipe函数实现有血缘关系进程通信

管道原理：内核使用环形机制，借助缓冲区实现
不可重复读取，数据填满就会覆盖
不可自己读自己写
双向半双工
数据只能单向流通

pipe函数介绍

int pipe(int pipefd[2]);
参数：fd[0]: 读端fd[1]: 写端
返回值:成功 0失败 -1

通过管道实现父子进程通信

#include <unistd.h>
#include <sys/wait.h>
#include <stdio.h>
#include <stdlib.h>void sys_perror(const char* str)
{perror(str);exit(1);
}int main()
{int ret;int fd[2];ret = pipe(fd);if(ret == -1){sys_perror("pipe error");}pid_t pid = fork();if(pid == -1){sys_perror("fork error");}if(pid > 0)	// 父进程{close(fd[0]);	// 关闭读端write(fd[1],"hello",5);	//向管道中写数据wait(NULL);	// 回收子进程}else if(pid == 0)	// 子进程{close(fd[1]);	// 关闭写端char buf[5];read(fd[0],buf,sizeof(buf));	// 从管道中读数据printf("%s\n",buf);}return 0;
}

兄弟进程间通信

#include <unistd.h>
#include <sys/wait.h>
#include <stdio.h>
#include <stdlib.h>void sys_perror(const char* str)
{perror(str);exit(1);
}int main()
{int ret;int fd[2];ret = pipe(fd);if(ret == -1){sys_perror("pipe error");}int i;for(i=0;i<2;i++){pid_t pid = fork();if(pid==0)  // 子进程退出循环break;if(pid == -1){sys_perror("fork error");}}if(i == 2)  // 父进程{close(fd[0]);close(fd[1]);for(i=0;i<2;i++)wait(NULL);}else if(i == 0) // 第二个子进程{close(fd[1]);char buf[5];read(fd[0],buf,sizeof(buf));printf("%s\n",buf);}else if(i == 1) // 第一个子进程{close(fd[0]);write(fd[1],"hello",5);}return 0;
}

2、mkfifo函数实现无血缘关系进程通信

int mkfifo(const char* pathname,mode_t mode);
参数：pathname 通道名字mode 	权限
返回值：成功 0失败 -1

和文件操作很类似，打开管道文件，一边写数据，一边读数据

写端：

#include <unistd.h>
#include <sys/wait.h>
#include <string.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>void sys_perror(const char* str)
{perror(str);exit(1);
}int main()
{// int ret = mkfifo("./fifo",0664);int fd = open("./fifo",O_RDWR);if(fd < 0){sys_perror("open error");}char buf[1024];int i = 0;while (1){sleep(1);sprintf(buf,"我是%d次写入\n",i++);write(fd,buf,strlen(buf));}close(fd);return 0;   
}

无血缘进行间通信：读端

#include <unistd.h>
#include <sys/wait.h>
#include <string.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>void sys_perror(const char* str)
{perror(str);exit(1);
}int main()
{// int ret = mkfifo("./fifo",0664);int fd = open("./fifo",O_RDWR);if(fd < 0){sys_perror("open error");}char buf[1024];int i = 0;while (1){sleep(1);int n = read(fd,buf,sizeof(buf));write(STDOUT_FILENO,buf,n);}close(fd);return 0;   
}