linux 进程间通讯之管道

１．概述

1.1 一个管道是一个字节流：

• 使用管道时是不存在消息或消息边界，即读取进程能够读取任意大小的数据块，而无论写入进程写入管道的数据块大小是什么。
• 管道传递的数据是顺序的，即从管道中读取出来的字节的顺序与被写入管道的顺序一致。

1.2 从管道中读取数据：

• 读取数据为空的管道将会堵塞直到至少有一个字节被写入到管道为止。
• 管道的写入端没有关闭，那么读取数据将会堵塞直到全部管道的写入端关闭。
• 管道的写入端关闭，那么进程能够读取任意大小的数据块，直至读完了管道中的全部数据即read()返回0 。

1.3 管道是单向的：

• 管道中数据的传递方向是单向的，管道的一端用于写入，另外一端用于读取。

1.4 管道的容量是有限的：

• 管道实际上是一个在内核内存中维护的缓冲器，这个缓冲器的存储能力是有限的。
• 管道被填满以后，后续向管道写入操做都会被堵塞直到有读取进程读取管道中的数据。

1.5 能够确保写入不超过PIPE_BUF字节的操做是原子的：

• 若是多个进程写入同一个管道，那么若是他们在一个时刻写入的数据量不超过PIPE_BUF字节，那么就能够确保写入的数据不会混淆。
• 写入的数据块大小超过了PIPE_BUF字节，那么内核会将数据分割成几个较小的片断传输，在读者从管道中消耗数据时再附加上后续的数据。(write()调用会阻塞直到全部数据被写入到管道为止)，因此当多个写入进程写入大数据块的时候，可能会出现数据交叉的现象。

2.建立和使用管道

#include<unistd.h>
int pipe(int filedes[2]);//return 0 on success,or -1 on error
复制代码

• filedes[0]表示管道的读取端;

• filedes[1]表示管道的写入端;

• 使用read()和write()系统调用来在管道上执行I/O。

建立完管道以后处理文件描述符

3.关闭未使用管道文件描述符

3.1 读取进程需关闭其持有的管道写入描述符的缘由：

read()会堵塞直到全部管道的写入描述符关闭为止。

3.2 写入进程需关闭其持有的管道读取描述符的缘由：

当一个进程试图向管道中写入数据但没有任何进程拥有该管道的打开着的读取描述符的时候，内核会向写入进程发送一个SIGPIPE信号(默认会杀死进程)，进程能够捕获或忽略该信号，这样write操做将会返回EPIPE的错误。收到SIGPIPE信号或获得EPIPE错误能够获知管道的状态，能够避免写入被堵塞的风险，由于一直写入数据没有读取，将会充满管道，那么后续的写入请求都将会被堵塞。

3.3 关闭未使用管道文件描述符的缘由：

当全部进程中的管道文件描述符都关闭以后才会销毁该管道以及释放该管道占用的资源以供其余进程复用。同时，管道中的数据都会丢失。

4.管道能够做为一种进程同步的方法

父进程在建立子进程以前构建了一个管道。每一个子进程会继承管道的写入端的文件描述符并完成动做以后关闭这些描述符。当全部子进程都关闭了管道的写入端的文件描述符以后，父进程在管道上的read()就会结束并返回文件结束(0)。这时，父进程就可以作其余工做了。（父进程要关闭管道的写入端，不然将永远阻塞。）

switch (fork()) {
        case -1:
                ERR_EXIT("fork");
        case 0:
                if (close(pfd[0]) == -1)
                    ERR_EXIT("close");
                
                //Child does some work,and lets parent know It‘s done
                
                if(close(pfd[1])==-1)
                    ERR_EXIT("close");

                //child now carries on to do other things...
               
                _exit(EXIT_SUCCESS);
        default:
                break;
    }

    if(close(pfd[1])==-1)
        ERR_EXIT("close");
    //parent may do other work,then synchronizes with children

    if(read(pfd[0],&dummy,1)!=0)//block
        ERR_EXIT("read");
 
复制代码

5.经过管道与shell命令进行通讯：popen()

#include<stdio.h>
FIFE *popen(const char *command,const char *mode);
    //return file stream,or NULL on error
int pclose(FILE *stream);
    //return termination status of child process,or -1 on error
复制代码

popen() 函数建立了一个管道，而后建立了一个子进程来执行shell，而shell又建立了一个子进程来执行command字符串。mode参数是一个字符串，它确调用进程是从管道中读取数据（mode是r）仍是将数据写入到管道中（mode是w）。

mode的取值肯定了所执行的命令的标准输出是链接到管道的写入端仍是将其标准输入链接到管道的读取端。

调用进程fp--(fork(),exec())-->/bin/sh--(fork(),exec())-->命令(stdout)--（管道）-->调用进程fp

a)mode is r

调用进程fp--(fork(),exec())-->/bin/sh--(fork(),exec())-->命令(stdin)

调用进程fp--(管道)-->命令stdin

b) mode is w