我遇到了关于重定向多进程标准输出的问题。
假设我有进程 A,我在 A 中使用 fork(),然后我得到进程 A 和 B。我在 B 中使用 fork(),最后我得到进程 A、B 和 C。B 和 C 都在实现exec() 的其他程序。
现在,我尝试使用两个管道将 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的stdin最终重定向到BtoC[0]
,这是进程B的stdout。进程A的stdout没有传入进程C的stdin。
我的问题是有没有什么解决方案可以让我同时将进程A和B的stdout重定向到进程C的stdin。
另一个问题是如果我也想在screen中打印进程A的stdout,怎么办?我知道命令行中的命令 tee
。我尝试在进程 A 中使用相应的函数 tee(int fd_in, int fd_out, size_t len, unsigned int flags)
,但是我无法打印进程 A 的任何标准输出。
感谢任何建议,谢谢。
最佳答案
我不确定这是个好主意,但它完全可行。关键观察结果是您只需要一个 管道。多个进程(具有共同的父进程)可以写入单个管道。但是,只有一个文件描述符可以用作标准输入。在原始代码中,只有一个管道连接到 C 作为其标准输入(其他管道仍然连接,但主要是因为您没有关闭足够的描述符)。
- 经验法则:如果通过
dup2()
(或dup()
)将管道的一端连接到标准输入或标准输出,则应关闭两者pipe()
返回的文件描述符。
尝试使用此代码确定大小。我减少了树的繁琐,删除了未使用的变量(没有使用 fork()
返回的进程 ID),重命名了管道,确保它在每个进程中正确关闭,并提供了一些进程 A 和 B 中的写入事件以及进程 C 中的一些读取事件代替运行命令。我假设 usleep()
(微 sleep ,以微秒表示的 sleep 时间)可用;如果没有,试试 nanosleep()
,但它有一个更复杂的接口(interface))。
#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 中将两个进程的标准输出重定向到另一个进程的标准输入,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/13041416/