我遇到了关于多进程重定向标准输出的问题。

假设我有进程 A,我在 A 中使用 fork(),然后我得到进程 A 和 B。我在 B 中使用 fork(),最后我得到进程 A、B 和 C。B 和 C 都通过以下方式实现其他程序执行()。

现在,我尝试使用两个管道将 A 和 B 的标准输出重定向到 C 的标准输入。

#include<unistd.h>
#include<stdio.h>
#include<sty/types.h>
int main()
{
    int AtoC [2];
    pipe(AtoC);

    int fd1,fd2;
    fd1=fork();
    if(fd1>0)
    {
        /***In process A, I do the following steps: ***/
        close(AtoC[0]);
        dup2(AtoC[1], STDOUT_FILENO);
        /* program running in process A */
    }
    else
    {
        int BtoC [2];
        pipe(BtoC);
        fd2=fork();
        if(fd2>0)
        {
            /***In process B, I do the following steps: ***/
            close(AtoC[1]);
            close(BtoC[0]);
            dup2(BtoC[1], STDOUT_FILENO);
            /*** execute another program in process B using execl(); ***/
        }
        else
        {
            /*** In process C, I do the following steps: ***/
            close(AtoC[1]);
            close(BtoC[1]);
            dup2(AtoC[0],STDIN_FILENO);
            dup2(BtoC[0],STDIN_FILENO);
            /*** execute another different program in process C using execl(); ***/
        }
    }
}

现在,在这两个声明之后:
dup2(AtoC[0],STDIN_FILENO);
dup2(BtoC[0],STDIN_FILENO);

进程 C 的标准输入最终被重定向到 BtoC[0] ,这是进程 B 的标准输出。 进程 A 的标准输出没有传递到进程 C 的标准输入中。

我的问题是是否有任何解决方案可以让我同时将进程 A 和 B 的标准输出重定向到进程 C 的标准输入。

另一个问题是如果我还想在屏幕中打印进程A的标准输出,我该怎么办?我知道命令行中的命令 tee 。我尝试在进程A中使用相应的函数tee(int fd_in, int fd_out, size_t len, unsigned int flags),但是我没有打印进程A的任何stdout。

任何建议表示赞赏,谢谢。

最佳答案

我不确定这是个好主意,但它完全可行。关键的观察是你只需要一根管子。多个进程(具有共同的父进程)可以写入单个管道。但是,只有一个文件描述符可以用作标准输入。在原始代码中,只有一个管道连接到 C 作为其标准输入(其他管道仍然连接,但主要是因为您没有关闭足够的描述符)。

  • 经验法则:如果通过 dup2() (或 dup() )将管道的一端连接到标准输入或标准输出,则应关闭 pipe() 返回的两个文件描述符。

  • 试试这个代码的大小。我减少了树的灌木丛,删除了未使用的变量(没有使用 fork() 返回的进程 ID),重命名管道,确保它在每个进程中正确关闭,并在进程 A 和 B 中提供了一些写入事件,还有一些读取进程 C 中的事件代替运行命令。我假设 usleep()(微 sleep ,以微秒表示的 sleep 时间)可用;如果没有,请尝试 nanosleep() ,但它具有更复杂的界面)。
    #include <unistd.h>
    
    int main(void)
    {
        int ABtoC[2];
        pipe(ABtoC);
    
        if (fork() > 0)
        {
            // Process A
            close(ABtoC[0]);
            dup2(ABtoC[1], STDOUT_FILENO);
            close(ABtoC[1]);     // Close this too!
            // Process A writing to C
            for (int i = 0; i < 100; i++)
            {
                write(STDOUT_FILENO, "Hi\n", sizeof("Hi\n")-1);
                usleep(5000);
            }
        }
        else if (fork() > 0)
        {
            // Process B
            close(ABtoC[0]);
            dup2(ABtoC[1], STDOUT_FILENO);
            close(ABtoC[1]);
            // Process B writing to C
            for (int i = 0; i < 100; i++)
            {
                write(STDOUT_FILENO, "Lo\n", sizeof("Lo\n")-1);
                usleep(5000);
            }
        }
        else
        {
            char buffer[100];
            ssize_t nbytes;
            close(ABtoC[1]);
            dup2(ABtoC[0], STDIN_FILENO);
            close(ABtoC[0]);
            // Process C reading from both A and B
            while ((nbytes = read(STDIN_FILENO, buffer, sizeof(buffer))) > 0)
                write(STDOUT_FILENO, buffer, nbytes);
        }
        return(0);
    }
    

    在我的 Mac(Mac OS X 10.7.5,GCC 4.7.1)上运行的最后产生:
    Lo
    Hi
    Lo
    Hi
    Lo
    Hi
    Lo
    Hi
    Lo
    Hi
    Hi
    Lo
    Lo
    Hi
    Hi
    Lo
    Hi
    Lo
    Hi
    Lo
    Hi
    Lo
    Hi
    Lo
    Lo
    Hi
    

    关于c - 在 Linux C 中将两个进程的 stdout 重定向到另一个进程的 stdin,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/13041416/

    10-11 22:38
    查看更多