使用dup2()和pipe()实现Linux管道遇问题：单管道不终止、多管道失效

核心问题原因 #

1. 单管道无法终止：进程未关闭管道的未使用端，导致后续进程（比如cat）一直监听管道输入，无法检测到EOF，从而持续阻塞。
2. 多管道失效：管道描述符管理混乱，未正确链式连接前后命令的输入输出，或者残留未关闭的管道端导致阻塞。

关键修复点 #

• 子进程必须关闭所有未用管道描述符：每个子进程只保留需要的管道端（比如前一个命令保留管道写端，后一个保留读端），其余所有管道的读写端都要关闭。
• 父进程需关闭所有管道描述符：fork完所有子进程后，父进程要关闭所有管道的读写端，避免子进程因管道未关闭而无法检测到EOF。
• 多管道链式处理：每两个相邻命令之间创建一个独立管道，前一个命令的stdout重定向到管道写端，后一个命令的stdin重定向到管道读端，依次处理。
• 父进程等待所有子进程退出：使用waitpid或wait等待所有子进程执行完毕，避免僵尸进程，同时确保命令流完整执行。

示例代码框架（处理多管道场景） #

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

#define MAX_CMDS 10

int main(int argc, char *argv[]) {
    // 示例命令：cmd1 | cmd2 | cmd3
    char *cmds[MAX_CMDS][MAX_CMDS] = {
        {"ls", "-l", NULL},
        {"grep", ".c", NULL},
        {"wc", "-l", NULL}
    };
    int cmd_count = 3;
    int pipes[cmd_count-1][2];
    pid_t pids[cmd_count];

    // 创建所有管道
    for (int i = 0; i < cmd_count-1; i++) {
        if (pipe(pipes[i]) == -1) {
            perror("pipe failed");
            exit(EXIT_FAILURE);
        }
    }

    // 逐个创建子进程处理命令
    for (int i = 0; i < cmd_count; i++) {
        pids[i] = fork();
        if (pids[i] == -1) {
            perror("fork failed");
            exit(EXIT_FAILURE);
        } else if (pids[i] == 0) {
            // 子进程：处理输入输出重定向
            if (i > 0) {
                // 不是第一个命令，将stdin重定向到前一个管道的读端
                dup2(pipes[i-1][0], STDIN_FILENO);
                close(pipes[i-1][0]);
                close(pipes[i-1][1]); // 关闭前一个管道的写端（未使用）
            }
            if (i < cmd_count-1) {
                // 不是最后一个命令，将stdout重定向到当前管道的写端
                dup2(pipes[i][1], STDOUT_FILENO);
                close(pipes[i][0]); // 关闭当前管道的读端（未使用）
                close(pipes[i][1]);
            }

            // 关闭所有其他未使用的管道
            for (int j = 0; j < cmd_count-1; j++) {
                if (j != i-1 && j != i) {
                    close(pipes[j][0]);
                    close(pipes[j][1]);
                }
            }

            // 执行命令
            execvp(cmds[i][0], cmds[i]);
            perror("execvp failed");
            exit(EXIT_FAILURE);
        }
    }

    // 父进程：关闭所有管道描述符
    for (int i = 0; i < cmd_count-1; i++) {
        close(pipes[i][0]);
        close(pipes[i][1]);
    }

    // 等待所有子进程退出
    for (int i = 0; i < cmd_count; i++) {
        waitpid(pids[i], NULL, 0);
    }

    return 0;
}

代码说明 #

• 先创建所有需要的管道，再逐个fork子进程处理命令
• 每个子进程只保留自己需要的管道端，其余全部关闭
• 父进程在fork完成后立即关闭所有管道，确保子进程能检测到EOF
• 最后等待所有子进程结束，保证命令执行完成

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