Linux通过匿名管道进行进程间通信

本文研究的主要是linux通过匿名管道进行进程间通信的相关内容，具体介绍如下。

在前面，介绍了一种进程间的通信方式：使用信号，我们创建通知事件，并通过它引起响应，但传递的信息只是一个信号值。这里将介绍另一种进程间通信的方式——匿名管道，通过它进程间可以交换更多有用的数据。

一、什么是管道

如果你使用过linux的命令，那么对于管道这个名词你一定不会感觉到陌生，因为我们通常通过符号“|"来使用管道，但是管理的真正定义是什么呢？管道是一个进程连接数据流到另一个进程的通道，它通常是用作把一个进程的输出通过管道连接到另一个进程的输入。

举个例子，在shell中输入命令：ls -l | grep string，我们知道ls命令（其实也是一个进程）会把当前目录中的文件都列出来，但是它不会直接输出，而是把本来要输出到屏幕上的数据通过管道输出到grep这个进程中，作为grep这个进程的输入，然后这个进程对输入的信息进行筛选，把存在string的信息的字符串（以行为单位）打印在屏幕上。

二、使用popen函数

1、popen函数和pclose函数介绍

有静就有动，有开就有关，与此相同，与popen函数相对应的函数是pclose函数，它们的原型如下：

				?

									#include <stdio.h> 

									file* popen (const char *command, const char *open_mode); 

									int pclose(file *stream_to_close);

poen函数允许一个程序将另一个程序作为新进程来启动，并可以传递数据给它或者通过它接收数据。command是要运行的程序名和相应的参数。open_mode只能是"r（只读）"和"w（只写）"的其中之一。注意，popen函数的返回值是一个file类型的指针，而linux把一切都视为文件，也就是说我们可以使用stdio i/o库中的文件处理函数来对其进行操作。

如果open_mode是"r"，主调用程序就可以使用被调用程序的输出，通过函数返回的file指针，就可以能过stdio函数（如fread）来读取程序的输出；如果open_mode是"w"，主调用程序就可以向被调用程序发送数据，即通过stdio函数（如fwrite）向被调用程序写数据，而被调用程序就可以在自己的标准输入中读取这些数据。

pclose函数用于关闭由popen创建出的关联文件流。pclose只在popen启动的进程结束后才返回，如果调用pclose时被调用进程仍在运行，pclose调用将等待该进程结束。它返回关闭的文件流所在进程的退出码。

2、例子

很多时候，我们根本就不知道输出数据的长度，为了避免定义一个非常大的数组作为缓冲区，我们可以以块的方式来发送数据，一次读取一个块的数据并发送一个块的数据，直到把所有的数据都发送完。下面的例子就是采用这种方式的数据读取和发送方式。源文件名为popen.c，代码如下：

				?

									#include <unistd.h> 

									#include <stdlib.h> 

									#include <stdio.h> 

									#include <string.h> 

									int main() 

									{ 

									  file *read_fp = null; 

									  file *write_fp = null; 

									  char buffer[bufsiz + 1]; 

									  int chars_read = 0; 

									  //初始化缓冲区 

									  memset(buffer, '\0', sizeof(buffer)); 

									  //打开ls和grep进程 

									  read_fp = popen("ls -l", "r"); 

									  write_fp = popen("grep rwxrwxr-x", "w"); 

									  //两个进程都打开成功 

									  if(read_fp && write_fp) 

									  { 

									    //读取一个数据块 

									    chars_read = fread(buffer, sizeof(char), bufsiz, read_fp); 

									    while(chars_read > 0) 

									    { 

									      buffer[chars_read] = '\0'; 

									      //把数据写入grep进程 

									      fwrite(buffer, sizeof(char), chars_read, write_fp); 

									      //还有数据可读，循环读取数据，直到读完所有数据 

									      chars_read = fread(buffer, sizeof(char), bufsiz, read_fp); 

									    } 

									    //关闭文件流 

									    pclose(read_fp); 

									    pclose(write_fp); 

									    exit(exit_success); 

									  } 

									  exit(exit_failure); 

									}

运行结果如下：

Linux通过匿名管道进行进程间通信

从运行结果来看，达到了信息筛选的目的。程序在进程ls中读取数据，再把数据发送到进程grep中进行筛选处理，相当于在shell中直接输入命令：ls -l | grep rwxrwxr-x。

3、popen的实现方式及优缺点

当请求popen调用运行一个程序时，它首先启动shell，即系统中的sh命令，然后将command字符串作为一个参数传递给它。

这样就带来了一个优点和一个缺点。优点是：在linux中所有的参数扩展都是由shell来完成的。所以在启动程序（command中的命令程序）之前先启动shell来分析命令字符串，也就可以使各种shell扩展（如通配符）在程序启动之前就全部完成，这样我们就可以通过popen启动非常复杂的shell命令。

而它的缺点就是：对于每个popen调用，不仅要启动一个被请求的程序，还要启动一个shell，即每一个popen调用将启动两个进程，从效率和资源的角度看，popen函数的调用比正常方式要慢一些。

三、pipe调用

如果说popen是一个高级的函数，pipe则是一个底层的调用。与popen函数不同的是，它在两个进程之间传递数据不需要启动一个shell来解释请求命令，同时它还提供对读写数据的更多的控制。

pipe函数的原型如下：

				?

									#include <unistd.h> 

									int pipe(int file_descriptor[2]);

我们可以看到pipe函数的定义非常特别，该函数在数组中墙上两个新的文件描述符后返回0，如果返回返回-1，并设置errno来说明失败原因。

数组中的两个文件描述符以一种特殊的方式连接起来，数据基于先进先出的原则，写到file_descriptor[1]的所有数据都可以从file_descriptor[0]读回来。由于数据基于先进先出的原则，所以读取的数据和写入的数据是一致的。

特别提醒：

1、从函数的原型我们可以看到，它跟popen函数的一个重大区别是，popen函数是基于文件流（file）工作的，而pipe是基于文件描述符工作的，所以在使用pipe后，数据必须要用底层的read和write调用来读取和发送。

2、不要用file_descriptor[0]写数据，也不要用file_descriptor[1]读数据，其行为未定义的，但在有些系统上可能会返回-1表示调用失败。数据只能从file_descriptor[0]中读取，数据也只能写入到file_descriptor[1]，不能倒过来。

例子：

首先，我们在原先的进程中创建一个管道，然后再调用fork创建一个新的进程，最后通过管道在两个进程之间传递数据。源文件名为pipe.c，代码如下：

				?

									#include <unistd.h> 

									#include <stdlib.h> 

									#include <stdio.h> 

									#include <string.h> 

									int main() 

									{ 

									  int data_processed = 0; 

									  int filedes[2]; 

									  const char data[] = "hello pipe!"; 

									  char buffer[bufsiz + 1]; 

									  pid_t pid; 

									  //清空缓冲区 

									  memset(buffer, '\0', sizeof(buffer)); 

									  if(pipe(filedes) == 0) 

									  { 

									    //创建管道成功 

									    //通过调用fork创建子进程 

									    pid = fork(); 

									    if(pid == -1) 

									    { 

									      fprintf(stderr, "fork failure"); 

									      exit(exit_failure); 

									    } 

									    if(pid == 0) 

									    { 

									      //子进程中 

									      //读取数据 

									      data_processed = read(filedes[0], buffer, bufsiz); 

									      printf("read %d bytes: %s\n", data_processed, buffer); 

									      exit(exit_success); 

									    } 

									    else

									    { 

									      //父进程中 

									      //写数据 

									      data_processed = write(filedes[1], data, strlen(data)); 

									      printf("wrote %d bytes: %s\n", data_processed, data); 

									      //休眠2秒，主要是为了等子进程先结束，这样做也只是纯粹为了输出好看而已 

									      //父进程其实没有必要等等子进程结束 

									      sleep(2); 

									      exit(exit_success); 

									    } 

									  } 

									  exit(exit_failure); 

									}

运行结果为：

Linux通过匿名管道进行进程间通信

可见，子进程读取了父进程写到filedes[1]中的数据，如果在父进程中没有sleep语句，父进程可能在子进程结束前结束，这样你可能将看到两个输入之间有一个命令提示符分隔。

四、把管道用作标准输入和标准输出

下面来介绍一种用管道来连接两个进程的更简洁方法，我们可以把文件描述符设置为一个已知值，一般是标准输入0或标准输出1。这样做最大的好处是可以调用标准程序，即那些不需要以文件描述符为参数的程序。

为了完成这个工作，我们还需要两个函数的辅助，它们分别是dup函数或dup2函数，它们的原型如下

				?

									#include <unistd.h> 

									int dup(int file_descriptor); 

									int dup2(int file_descriptor_one, int file_descriptor_two);

dup调用创建一个新的文件描述符与作为它的参数的那个已有文件描述符指向同一个文件或管道。对于dup函数而言，新的文件描述总是取最小的可用值。而dup2所创建的新文件描述符或者与int file_descriptor_two相同，或者是第一个大于该参数的可用值。所以当我们首先关闭文件描述符0后调用dup，那么新的文件描述符将是数字0.

例子

在下面的例子中，首先打开管道，然后fork一个子进程，然后在子进程中，使标准输入指向读管道，然后关闭子进程中的读管道和写管道，只留下标准输入，最后调用execlp函数来启动一个新的进程od，但是od并不知道它的数据来源是管道还是终端。父进程则相对简单，它首先关闭读管道，然后在写管道中写入数据，再关闭写管道就完成了它的任务。源文件为pipe2.c，代码如下：

				?

									#include <unistd.h> 

									#include <stdlib.h> 

									#include <stdio.h> 

									#include <string.h> 

									int main() 

									{ 

									  int data_processed = 0; 

									  int pipes[2]; 

									  const char data[] = "123"; 

									  pid_t pid; 

									  if(pipe(pipes) == 0) 

									  { 

									    pid = fork(); 

									    if(pid == -1) 

									    { 

									      fprintf(stderr, "fork failure!\n"); 

									      exit(exit_failure); 

									    } 

									    if(pid == 0) 

									    { 

									      //子进程中 

									      //使标准输入指向fildes[0] 

									      close(0); 

									      dup(pipes[0]); 

									      //关闭pipes[0]和pipes[1]，只剩下标准输入 

									      close(pipes[0]); 

									      close(pipes[1]); 

									      //启动新进程od 

									      execlp("od", "od", "-c", 0); 

									      exit(exit_failure); 

									    } 

									    else

									    { 

									      //关闭pipes[0],因为父进程不用读取数据 

									      close(pipes[0]); 

									      data_processed = write(pipes[1], data, strlen(data)); 

									      //写完数据后，关闭pipes[1] 

									      close(pipes[1]); 

									      printf("%d - wrote %d bytes\n", getpid(), data_processed); 

									    } 

									  } 

									  exit(exit_success); 

									}