将两个进程的stdout重定向到Linux C中的另一个进程的stdin
发布时间：2020-12-14 00:52:34 所属栏目：Linux 来源：网络整理
导读：我遇到了关于多进程重定向stdout的问题. 假设我有进程A,我在A中使用fork(),然后我得到进程A和B.我在B中使用fork(),最后我得到进程A,B和C.B和C都在实现其他程序EXEC(). 现在,我尝试用两个管道将A和B的stdout重定向到C的stdin. #includeunistd.h#includestdio.
|
我遇到了关于多进程重定向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,"Hin",sizeof("Hin")-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,"Lon",sizeof("Lon")-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,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 （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |