一、生活和计算机中的管道😜

生活中的管道特点

都是有出口和入口的

都是单向传输内容的(例如：纯净水管道和污水管道不可能同时传输纯净水和污水对吧)

管道中传输的都是资源(例如：运输天然气等等)

计算机中的管道：

和生活中的管道特点类似，同样都是有出口和入口的都是单向传输的，不过计算机中传输的资源是“数据”。

总结：管道是一种进程间单向通信的方式。

二、管道实现进程间通信的原理😏

先说核心概念：管道通信背后是通过进程之间的共享内存进行通信的，记住这句话好了，我们开始解说原理。

在说原理之前，我们需要明确一点 --- 进程之间是具有很强的独立性的；

我们需要知道在创建一个进程时，操作系统会为这个进程创建一个task_struct结构体和files_struct文件结构体，task_struct来记录这个进程的信息，files_struct文件结构体来记录这个进程打开的文件信息。这里我们需要知道的是：files_struct是用来记录一个进程打开文件的信息的，OK知道了这一点

在files_struct中有一个fd_array[]数组 -- 用来存放进程打开的文件fd(文件描述符的)，在这里我们可以举个实例：我们打开的每一个进程都会自动打开stdin/stdout/stderr -- 分别是标准输入/标准输出/标准错误，对应的在fd_array[0] = 0, fd_array[1] = 1, fd_array[2] = 2(注意：数组下标不一定就是对应的文件描述符，这里只是一个例子)

这里我们需要知道的是:files_struct中有一个fd_array[]数组 -- 用来存放进程打开的文件fd

有了以上的认识之后，我们就可以描述一下一个进程是如何去访问文件的了：

例如进程A想访问一个打开的文件B，A通过它自己的task_struct结构体找到指向files_struct结构体的成员指针，再通过files_struct找到其中的fd_array[]成员数组，访问这个数组从而就可以找到这个进程打开的文件B的文件描述符fd了，通过fd就可以访问这个文件B了。

好了现在又有了一个阶段性的认识，知道了进程是如何访问文件的了，这里很重要的一点，那些是进程相关的数据结构、那些是文件相关的数据结构？

为什么要做这个区分？因为进程之间是有很强的独立性的，有关进程的数据结构之间是基本不可能有什么交集的，就更不要说通过进程的相关数据结构进行进程间通信了。而文件相关的数据结构就不一样，文件要被访问是会被加载在内存中的，而这些被加载到内存中的文件是可以被任何进程访问的！！！这是一个十分关键的一点，管道通信的理解关键就在于此。也就是说我们可以通过两个进程访问一个文件来间接的实现进程间通信。

以上对管道通信的原理做出的相对清楚的解释，还有一点小小细节，为了保证管道的特点，需要多加以下一下规则：

一个进程只用写方式打开文件，另一个文件只用读方式打开文件(保证单向)

三、demo代码😍

如下写了一个使用管道通信的例子：

大致的流程是：

创建管道

创建子进程

做子进程的接收处理

做父进程的发送处理

这里使用管道通信涉及到了一个系统函数：int pipe(int pipefd[2])

用处是我们传入一个一维数组，他会分别以只w写和只r读的方式打开同一个文件，将只读的文件描述符放入pipefd[0]，将只写的文件描述符放入pipefd[1]

其实就是一个简化操作的函数，我们自己以两种方式打开也可以；

简单说一下我们做了什么事情：

（如果是小白）关于头文件的包含和函数我们使用了几个关键函数：fork()、pipe、waitpid()，snprintf()去查相关的man手册即可

这里的代码：

首先通过pipe创建一个管道用pipefd存放，子进程创建一个缓冲区来接收父进程发送的数据。

父进程创建一个缓冲区来存放发送的数据，最后结束等待子进程退出处理。

#include <iostream>
#include <string>
#include <cstring>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include <cassert>

using namespace std;

int main()
{
    // 创建管道
    int pipefd[2] = {0};
    int n = pipe(pipefd); // 创建的pipedfd[0]是读 pipedp[1]是写
    assert(n != -1);
    (void)n;

    // 创建子进程
    pid_t id = fork();
    assert(id >= 0);
    if (id == 0) // 子进程接收处理+关闭写
    {
        close(pipefd[1]);
        // 搞一个缓冲区来接收数据
        while (true)
        {
            char buffer[1024];
            ssize_t s = read(pipefd[0], buffer, sizeof(buffer) - 1);
            buffer[s] = 0;

            cout << getpid() << ":reserve a message from father:" << buffer << endl;
        }
    }
    // 父进程发送处理+关闭读
    close(pipefd[0]);

    char send_Buffer[1024];
    while (true)
    {
        string msg = "儿子我给你发了一个信息";

        snprintf(send_Buffer, sizeof(send_Buffer), "[%d]:%s", getpid(), msg.c_str());
        write(pipefd[1], send_Buffer, strlen(send_Buffer));

        sleep(1);
    }

    //等待子进程退出
    int ret = waitpid(id, nullptr, 0);
    assert(ret > 0);
    (void)ret;

    return 0;
}