Unix Pipes - 三个进程之间的管道答案

【问题标题】：Unix Pipes - Pipeline between three processesUnix Pipes - 三个进程之间的管道
【发布时间】：2013-11-18 19:25:43
【问题描述】：

我正在创建一个包含三个进程的小程序；源进程、过滤进程和汇进程。 source进程的stdout重定向到filter进程的stdin，filter进程的stdout重定向到sink进程的stdin。

我的问题是接收器进程没有将输出打印到标准输出。你们中的任何人都可以在下面的小sn-p 代码中看到问题吗？

#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>


int main(int argc, char** argv)
{
     // Pipes
     // pipe1 is from source to filter, pipe2 is from filter to sink
     int pipe1[2], pipe2[2];

     // Create pipes
     if (pipe(pipe1) < 0 || pipe(pipe2) < 0)
     {
          perror("Creating pipes failed!");
     }

     if (fork() == 0)
     {
          close(1);
          dup(pipe1[1]);
          close(pipe1[0]);

          close(pipe2[0]);
          close(pipe2[1]);

          execlp("ls", "ls", NULL);
          exit(0);
     }
     else
     {
          if (fork() == 0)
          {
               close(0);
               dup(pipe1[0]);
               close(pipe1[1]);

               close(1);
               dup(pipe2[1]);
               close(pipe2[0]);

               execlp("sort", "sort", NULL);
               exit(0);
          }
          else
          {
               if (fork() == 0)
               {

                    close(0);
                    dup(pipe2[0]);

                    execlp("more", "more", NULL);
                    exit(0);
               }
          }
     }


     wait(NULL);
     printf("Done.\n");

     return 0;
}

雅各布

【问题讨论】：

见Connecting n commands with pipes in a shell?。以及基于它的代码：pipeline-three-processes.c

标签： c unix pipe

【解决方案1】：

我认为问题可能是，wait 只会等待一个进程。当第一个孩子返回后父母退出时，我怀疑more 命令也决定终止，因为它可能会得到 SIGHUP（推测，不确定）。

但是，请检查所有系统调用的错误！同样对于成功的wait 调用，打印孩子退出的原因（是信号退出还是正常退出，如果是正常退出，退出代码是什么）。

另请注意，perror 不会退出，它只会打印。

如果其中没有错误处理，试图查看为什么某些代码会失败是毫无意义的......

【讨论】：

【解决方案2】：

为您的场景做管道的一些简单方法：

char cmd[MAX_LEN];
sprintf(cmd, "%s | %s | %s", app1, app2, app3); //app123 holds app name + args
system(cmd);

如果要捕获最后一个应用的输出，请使用 popen：

FILE pPipe = popen(cmd, "rt"); /* same access flag as fopen()*/
while (NULL != fget(buf, buf_len, pPipe)) {
    // do something with the read line in 'buf'
}

【讨论】：