C语言中实现单进程向两个管道写入的技术问询

核心错误点 #

1. 参数定义错误：函数参数中第二个char **app1是笔误，应为char **app2，否则编译报错且无法正确传递app2的启动参数。
2. stdout重写错误：app1子进程中连续调用dup2(fd[1], 1)和dup2(fd[3], 1)，第二次dup2会完全覆盖第一次的结果——最终app1的stdout只会指向fd[3]（第二个管道的写端），第一个管道fd[0]（对应app2的读端）根本收不到数据。
3. 管道关闭时机错误：父进程在waitpid所有子进程后才关闭管道描述符，会导致管道写端一直处于打开状态，app2/app3的read操作会持续阻塞，无法正常输出或退出。

正确实现思路 #

单个进程的stdout无法直接绑定到两个管道写端（文件描述符是一对一映射），正确的做法是：让app1将输出写入一个管道，父进程读取该管道的数据后，再分别写入另外两个管道，分发给app2和app3。

修正后的代码 #

#include <unistd.h>
#include <sys/wait.h>
#include <stdlib.h>

int pipepipe(char **app1, char **app2, char**app3){
    // 管道1：app1 -> 父进程
    int fd_app1_to_parent[2];
    // 管道2：父进程 -> app2
    int fd_parent_to_app2[2];
    // 管道3：父进程 -> app3
    int fd_parent_to_app3[2];

    if (pipe(fd_app1_to_parent) == -1 || pipe(fd_parent_to_app2) == -1 || pipe(fd_parent_to_app3) == -1) {
        return 2;
    }

    // 启动app1进程
    pid_t pid1 = fork();
    if (pid1 < 0) {
        return 2;
    }
    if (pid1 == 0) {
        // 关闭不需要的管道端
        close(fd_app1_to_parent[0]);
        close(fd_parent_to_app2[0]);
        close(fd_parent_to_app2[1]);
        close(fd_parent_to_app3[0]);
        close(fd_parent_to_app3[1]);

        // 将stdout重定向到app1->父进程的管道写端
        dup2(fd_app1_to_parent[1], STDOUT_FILENO);
        close(fd_app1_to_parent[1]); // 重定向后关闭原描述符

        execvp(app1[0], app1);
        exit(1); // execvp失败才会执行到这里
    }

    // 启动app2进程
    pid_t pid2 = fork();
    if (pid2 < 0) {
        return 2;
    }
    if (pid2 == 0) {
        // 关闭不需要的管道端
        close(fd_app1_to_parent[0]);
        close(fd_app1_to_parent[1]);
        close(fd_parent_to_app2[1]);
        close(fd_parent_to_app3[0]);
        close(fd_parent_to_app3[1]);

        // 将stdin重定向到父进程->app2的管道读端
        dup2(fd_parent_to_app2[0], STDIN_FILENO);
        close(fd_parent_to_app2[0]);

        execvp(app2[0], app2);
        exit(1);
    }

    // 启动app3进程
    pid_t pid3 = fork();
    if (pid3 < 0) {
        return 2;
    }
    if (pid3 == 0) {
        // 关闭不需要的管道端
        close(fd_app1_to_parent[0]);
        close(fd_app1_to_parent[1]);
        close(fd_parent_to_app2[0]);
        close(fd_parent_to_app2[1]);
        close(fd_parent_to_app3[1]);

        // 将stdin重定向到父进程->app3的管道读端
        dup2(fd_parent_to_app3[0], STDIN_FILENO);
        close(fd_parent_to_app3[0]);

        execvp(app3[0], app3);
        exit(1);
    }

    // 父进程：关闭不需要的管道端，开始转发数据
    close(fd_app1_to_parent[1]); // 关闭app1->父进程的写端（父进程只读）
    close(fd_parent_to_app2[0]); // 关闭父进程->app2的读端（父进程只写）
    close(fd_parent_to_app3[0]); // 关闭父进程->app3的读端（父进程只写）

    char buf[1024];
    ssize_t bytes_read;
    // 读取app1的输出，同时写入给app2和app3
    while ((bytes_read = read(fd_app1_to_parent[0], buf, sizeof(buf))) > 0) {
        write(fd_parent_to_app2[1], buf, bytes_read);
        write(fd_parent_to_app3[1], buf, bytes_read);
    }

    // 转发完成，关闭所有管道写端，让app2/app3读到EOF
    close(fd_app1_to_parent[0]);
    close(fd_parent_to_app2[1]);
    close(fd_parent_to_app3[1]);

    // 等待所有子进程结束
    waitpid(pid1, NULL, 0);
    waitpid(pid2, NULL, 0);
    waitpid(pid3, NULL, 0);

    return 0;
}

关键说明 #

• 管道分工明确：三个管道分别负责不同方向的数据传输，避免原代码中管道复用导致的混乱。
• 及时关闭无用描述符：每个子进程都关闭不需要的管道端，防止因写端未关闭引发的阻塞问题。
• 父进程转发逻辑：父进程作为中间节点，将app1的输出复制后分发给app2和app3，实现了"一分二"的输出效果。

内容的提问来源于stack exchange，提问作者smallpop