ICode9

精准搜索请尝试: 精确搜索
首页 > 系统相关> 文章详细

将两个进程的stdout重定向到Linux C中的另一个进程的stdin

2019-05-29 21:48:08  阅读:415  来源: 互联网

标签:redirect c-3 linux stdin stdout


我遇到了关于多进程重定向stdout的问题.

假设我有进程A,我在A中使用fork(),然后我得到进程A和B.我在B中使用fork(),最后我得到进程A,B和C.B和C都在实现其他程序EXEC().

现在,我尝试用两个管道将A和B的stdout重定向到C的stdin.

#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的stdin最终重定向到BtoC [0],这是进程B的stdout.进程A的stdout没有传递给进程C的stdin.

我的问题是,是否有任何解决方案可以让我同时将进程A和B的stdout重定向到进程C的stdin.

另一个问题是,如果我还想在屏幕上打印进程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()(微睡眠,以微秒表示的睡眠时间)可用;如果没有,尝试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

标签:redirect,c-3,linux,stdin,stdout
来源: https://codeday.me/bug/20190529/1181093.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有