进程间通信之匿名管道阐述

摘要：通信机制示例代码解释父进程调用开辟管道，得到两个文件描述符指向管道的两端。父进程关闭管道写端，子进程关闭管道读端。管道的读写端通过打开的文件描述符来传递，因此要通信的两个进程必须从它们的公共祖先那里继承管道文件描述符。

每个进程各自有不同的用户地址空间，任何一个进程的全局变量在另一个进程中都看不到，所以进程之间要交换数据必须通过内核，在内核中开辟一块缓冲区，进程1把数据从用户空间拷到内核缓冲区，进程2再从内核缓冲区把数据读走，内核提供的这种机制称为进程间通信（IPC，InterProcess Communication）。如下图所示。

如果用过Linux命令，那么我们对这个名词不会陌生，我们经常通过“|”来使用管道，比如ls -l|grep string.
管道是一个进程连接数据流到另一个进程的通道，通常一个进程的输出通过管道连接到另一个进程的输入。

#include 
FILE* popen (const char *command, const char *open_mode);
int pclose(FILE *stream_to_close);

popen会启动另一个新进程，然后传递数据给它或从它接收数据。
command是要运行的程序名和相应的参数， open_mode只能是"r"或"w"
popen返回一个FILE类型指针， 然后就可以使用I/O文件函数对其操作。
当open_mode为“r”时, 表示主程序可以从被调用程序读取数据
当open_mode为“w”时， 表示主程序可以写数据到被调用程序
pclose用于关闭由popen创建出的关联文件流。pclose只在popen启动的进程结束后才返回，如果调用pclose时被调用进程仍在运行，pclose会等其结束。它返回关闭的文件流所在进程的退出码。

代码

//
// Created by         : Harris Zhu
// Filename           : test.c
// Author             : Harris Zhu
// Created On         : 2017-08-20 01:18
// Last Modified      :
// Update Count       : 2017-08-20 01:18
// Tags               :
// Description        :
// Conclusion         :
//
//=======================================================================

#include 
#include 
#include 
#include 

#define ERR_EXIT(m) 
    do { 
        perror(m); 
        exit(EXIT_FAILURE); 
    } while(0)

int main(int argc, char** argv)
{
    FILE *rdFP = NULL;
    FILE *writeFP = NULL;
    char buf[BUFSIZ + 1];
    int num_of_chars = 0;

    memset(buf, "", sizeof(buf));

    //打开ls作为读接口
    rdFP = popen("ls -l", "r");
    if(!rdFP)
    {
        ERR_EXIT("failed to open read pipe");
    }
    //打开grep作为写接口
  wrFP = popen("grep -rw-rw-r--", "w");
    if(!wrFP)
    {
        ERR_EXIT("failed to open write pipe");
    }
    if(rdFP && wrFP)
    {
        //从ls读取BUFSIZ字符
        num_of_chars = fread(buf, sizeof(char), BUFSIZ, rdFP);
        while(num_of_chars > 0)
        {
            buf[num_of_chars] = "";
            //把数据写入grep
            fwrite(buf, sizeof(char), num_of_chars, wrFP);
            //循环读取数据直到读完所有数据
            num_of_chars = fread(buf, sizeof(char), BUFSIZ, rdFP);
        }
        //关闭文件流
        pclose(rdFP);
        pclose(wrFP);
    }
    exit(EXIT_SUCCESS);
}

输出

-rw-rw-r--. 1 harriszh harriszh   126 Aug 20 01:28 makefile
-rw-rw-r--. 1 harriszh harriszh  1560 Aug 20 01:32 test.c

因为grep原因，在例子中需要使用4个 来escape -， 否则grep 被把它当成选项
另一种写法是

wrFP = popen("grep "-rw-rw-r--"", "w");

当popen运行一个程序时，它先启动shell, 然后当command字符串作为参数传递给它。
优点是参数扩展是由shell完成，所以可以使用各种通配符
缺点是每次打开一个程序，还要启动一个shell, 也就是说一次popen调用，启动了两个进程，从效率和资源看，popen都不太理想。

popen是高级函数，pipe则是底层调用，它不需要启动shell来解释命令，而且它能提供更多对数据的控制

#include 
int pipe(int filedes[2]);

调用pipe函数时在内核中开辟一块缓冲区（称为管道）用于通信，它有一个读端一个写端，然后通过filedes参数传出给用户程序两个文件描述符，filedes[0]指向管道的读端，filedes[1]指向管道的写端（很好记，就像0是标准输入1是标准输出一样）。所以管道在用户程序看起来就像一个打开的文件，通过read(filedes[0]);或者write(filedes[1]);向这个文件读写数据其实是在读写内核缓冲区。pipe函数调用成功返回0，调用失败返回-1。

代码

//
// Created by         : Harris Zhu
// Filename           : test.c
// Author             : Harris Zhu
// Created On         : 2017-08-19 13:28
// Last Modified      :
// Update Count       : 2017-08-19 13:28
// Tags               :
// Description        :
// Conclusion         :
//
//=======================================================================

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 

#define ERR_EXIT(m) 
    do { 
        perror(m); 
        exit(EXIT_FAILURE); 
    } while(0)


int main(int argc, char** argv)
{
    int pipefd[2];
    if (pipe(pipefd) == -1)
    {
        ERR_EXIT("open pipe error");
    }
    pid_t pid;
    pid = fork();
#ifdef SWITCH
    char r_buf[100]={0};
    char w_buf[100]="hello";
    switch(pid)
    {
    case -1:
        ERR_EXIT("fork error");
        break;
    case 0:
        close(pipefd[0]);
        printf("son: sending %s, size = %d
", w_buf, sizeof(w_buf));
        write(pipefd[1], w_buf, sizeof(w_buf));
        close(pipefd[1]);
        exit(EXIT_SUCCESS);
        break;
    default:
        close(pipefd[1]);
        read(pipefd[0], r_buf, 100);
        printf("paraent: receive %s, size=%d
", r_buf, sizeof(r_buf));
        close(pipefd[0]);
//        exit(EXIT_SUCCESS);
        break;
    }
#else
    if(pid < 0)
    {
        ERR_EXIT("fork error");
    } else {
        if(pid == 0)
        {
            close(pipefd[0]);
            char *w_buf="hello";
            printf("son: sending %s, size = %d
", w_buf, strlen(w_buf));
            write(pipefd[1], "hello", 5);
            close(pipefd[1]);
            exit(EXIT_SUCCESS);
        } else {
            char r_buf[100]={0};
            close(pipefd[1]);
            read(pipefd[0], r_buf, 5);
            printf("paraent: receive %s, size=%d
", r_buf, strlen(r_buf));
            close(pipefd[0]);
            exit(EXIT_SUCCESS);
        }
    }
#endif
    return 0;
}

解释

父进程调用pipe开辟管道，得到两个文件描述符指向管道的两端。

父进程调用fork创建子进程，那么子进程也有两个文件描述符指向同一管道。

父进程关闭管道写端，子进程关闭管道读端。子进程可以往管道里写，父进程可以从管道里读，管道是用环形队列实现的，数据从写端流入从读端流出，这样就实现了进程间通信。

两个进程通过一个管道只能实现单向通信，比如最上面的例子，父进程读子进程写，如果有时候也需要子进程读父进程写，就必须另开一个管道。
管道的读写端通过打开的文件描述符来传递，因此要通信的两个进程必须从它们的公共祖先那里继承管道文件描述符。上面的例子是父进程把文件描述符传给子进程之后父子进程之间通信，也可以父进程fork两次，把文件描述符传给两个子进程，然后两个子进程之间通信，总之需要通过fork传递文件描述符使两个进程都能访问同一管道，它们才能通信。
通信进程需要是父子进程关系，这使得它的应用受到了很大限制，这时我们可以用命名管道来解决

pipe的使用和原理非常简单，所以本文不过多解释展开，如有问题讲写邮件本人

参考：
linux系统编程之管道