(文章目录)
前言
本篇文章将给大家讲解进程间通信中的管道使用方法和概念。
一、管道的概念
管道的概念来源于Unix操作系统，在Unix-like系统（如Linux）中被广泛使用。它也存在于其他操作系统中，如Windows。
管道可以将一个进程的输出直接连接到另一个进程的输入，从而实现数据的流动和传输。通过管道，一个进程产生的输出可以无需写入临时文件，而是直接传递给另一个进程进行处理，这样可以提高系统的效率和响应时间。
二、管道的原理和创建方法
1.管道的原理
管道是一种在内核中实现的进程间通信机制，通过共享内存缓冲区来传递数据。默认情况下，管道的缓冲区大小为4KB，它提供了一种读写进程之间的同步机制，读取进程会阻塞直到有数据可读，写入进程会阻塞直到有足够的空间可写。通过调整缓冲区大小，可以提高管道的读写效率。 
2.管道的创建方法
创建管道的方法可以使用系统调用pipe()函数。这个函数会在内核中创建一个管道，并返回两个文件描述符，一个用于读取数据，另一个用于写入数据。
下面是使用pipe()函数创建管道的基本步骤：
1.包含头文件：首先需要包含头文件<unistd.h>，该头文件中声明了pipe()函数的原型。
2.调用pipe()函数：使用pipe()函数创建管道，并将返回的文件描述符存储在一个整型数组中。通常，数组的第一个元素用于读取数据，第二个元素用于写入数据。
#include <unistd.h>
int pipe(int fd[2]);
参数fd是一个整型数组，长度为2。调用成功时，fd[0]表示管道的读取端，fd[1]表示管道的写入端。如果调用失败，返回值为-1。
3.使用管道进行进程间通信：通过文件描述符进行数据的读取和写入操作。一般来说，调用fork()函数创建子进程后，可以将父子进程分别关闭不需要的文件描述符，然后使用剩下的文件描述符进行进程间的数据交换。
#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <string.h>
int main(int argc, char** argv)
{
pid_t pid;
int fd[2];
char buf[1024];
pipe(fd);//创建管道
if((pid = fork()) == 0)
{
/*子进程*/
close(fd[0]);//关闭读端
write(fd[1], "Hello", strlen("Hello") + 1);
close(fd[1]);
}
else
{
/*父进程*/
close(fd[1]);//关闭写端
read(fd[0], buf, 1024);
printf("parent read buf : %s\n", buf);
close(fd[0]);
}
return 0;
}
3.管道的局限性
1.单向传输：管道是单向的，数据只能在一个方向上流动。在创建管道时，需要确定一个进程负责写入数据，另一个进程负责读取数据。如果需要双向通信，需要创建两个管道。
2.半双工通信：管道是半双工的，即同一时间只能有一个进程进行读取或写入操作。当一个进程在读取数据时，另一个进程必须等待，反之亦然。这种限制可以通过使用多线程或者使用多个管道来解决。
3.父子进程限制：管道通常用于父子进程之间的通信。如果需要实现其他进程间通信，如兄弟进程或无关进程之间的通信，使用管道就不够灵活。在这种情况下，可以考虑使用其他进程间通信机制，如命名管道、共享内存或消息队列等。
4.有限的缓冲区：管道在内核中具有有限的缓冲区。当写入数据超过缓冲区大小时，写入进程将被阻塞，直到有足够的空间来容纳数据。同样，当读取进程尝试读取数据时，如果缓冲区为空，读取进程也会被阻塞。这可能导致进程阻塞或数据丢失的问题。
5.匿名管道限制：管道是匿名的，只能在具有共同祖先的进程之间使用。如果需要在没有共同祖先的进程之间进行通信，就不能使用匿名管道，而需要使用其他适合的进程间通信机制。
三、创建两个管道进行双向通信
由于管道特性的原因只能够支持半双工通信，那么想要支持全双工通信该怎么做呢？那么这里就可以创建两个管道出来进行全双工通信：
#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <string.h>
int main(int argc, char** argv)
{
pid_t pid;
int fd1[2];
int fd2[2];
char buf1[1024];
char buf2[1024];
pipe(fd1);//创建管道1
pipe(fd2);//创建管道2
if((pid = fork()) == 0)
{
/*子进程*/
close(fd1[0]);//关闭读端
write(fd1[1], "Hello Parent", strlen("Hello Parent") + 1);
close(fd1[1]);
close(fd2[1]);//关闭写端
read(fd2[0], buf2, 1024);
printf("child read buf : %s\n", buf2);
close(fd2[0]);
}
else
{
/*父进程*/
close(fd1[1]);//关闭写端
read(fd1[0], buf1, 1024);
printf("parent read buf : %s\n", buf1);
close(fd1[0]);
close(fd2[0]);//关闭读端
write(fd2[1], "Hello Child", strlen("Hello Child") + 1);
close(fd2[1]);
}
return 0;
}
四、兄弟进程间的通信
管道除了可以进行父子之间的通信还可以进行兄弟之间的通信。
#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <string.h>
#include <sys/wait.h>
int main(int argc, char** argv)
{
pid_t pid;
int fd[2];
char buf[1024];
int i = 0;
pipe(fd);//创建管道
for(i = 0; i < 2; i++)
{
if((pid = fork()) == 0)
{
break;
}
}
if(pid > 0)
{
/*父进程*/
printf("Parent pid : %d\n", getpid());
close(fd[0]);
close(fd[1]);
wait(NULL);
wait(NULL);
}
if(i == 0)
{
/*兄进程*/
printf("old brother pid : %d\n", getpid());
close(fd[0]);//关闭读端
write(fd[1], "Hello brother", strlen("Hello brother") + 1);
close(fd[1]);
}
else if(i == 1)
{
/*弟进程*/
printf("brother pid : %d\n", getpid());
close(fd[1]);//关闭写端
read(fd[0], buf, 1024);
printf("brother read buf : %s\n", buf);
close(fd[0]);
}
return 0;
}
注意点： 父进程需要将读端和写端都关闭，将使用权限给兄弟进程，这样才能保证数据的正常传输。
五、管道的读写行为
当读端不存在时 管道的表现取决于操作系统的实现。一般情况下，当读端不存在时，写入进程会收到一个错误信号（SIGPIPE）。这是因为写入进程试图往一个没有读取端的管道写入数据，操作系统会认为这是一个非法操作，因此向写入进程发送SIGPIPE信号，通知其管道的读取端已经不存在。如果写入进程没有处理这个信号，它可能会被终止。因此，在使用管道进行通信时，写入进程应该处理SIGPIPE信号，以避免意外终止。
当写端不存在时 读取进程会从管道中读取数据，直到读取完所有的数据。读取进程不会收到错误信号，因为写入端不存在不会影响读取端的操作。读取进程会读取到写入进程已经写入的数据，并在读取完数据后返回一个特殊的值，通常是0，表示已经读取到了管道的末尾。
总结
本篇文章就讲解到这里，下篇文章讲解fifo有名管道。