C语言编写的管道函数无法处理两个以上管道输入该如何修复？

核心问题排查 #

你代码的核心故障点如下：

• 管道描述符数组分配空间不足：每个管道需要占用2个文件描述符，executeCommand函数中仅分配了pipes个int大小的内存，实际需要2 * pipes个，内存越界会导致后面的管道fd值被篡改，这是多管道场景失效的直接原因。
• fork时机错误：在解析当前命令参数前就执行fork，父子进程会重复跑参数解析逻辑，容易出现不可预知的异常。
• 子进程异常分支未退出：execvp执行失败后，子进程没有退出，会继续执行父进程的递归逻辑，导致进程混乱。
• 父进程未及时关闭无用管道：父进程持有管道的读写端不释放，会导致下游命令永远等不到管道EOF，无法结束读取。
• 未回收子进程：没有调用wait系列函数回收子进程，会产生大量僵尸进程。

修复后的完整代码 #

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

// 假设你原有lengthOfArray的实现是正确的，此处补充实现供参考
int lengthOfArray(char **arr) {
    int len = 0;
    while (arr[len] != NULL) len++;
    return len;
}

// 关闭所有管道的通用函数
void closePipes(int *pipefd, int pipes) {
    for (int i = 0; i < 2 * pipes; i++) {
        close(pipefd[i]);
    }
}

// 去掉全局变量，改为参数传递，避免并发问题
void executeCommandFork(char **commands, int start, int loopNum, int *pipefd, int pipes) {
    // 第一步先解析当前命令的参数
    int end = start;
    for (; end < lengthOfArray(commands) && strcmp(commands[end], "|") != 0; end++);
    int cmd_len = end - start;
    char **args = malloc(sizeof(char *) * (cmd_len + 1));
    for (int i = 0; i < cmd_len; i++) {
        args[i] = commands[start + i];
    }
    args[cmd_len] = NULL;

    // 参数解析完成后再fork
    pid_t pid = fork();
    if (pid == 0) {
        // 子进程逻辑：绑定管道
        if (loopNum > 0) {
            // 不是第一个命令，绑定前一个管道的读端到stdin
            dup2(pipefd[2*(loopNum - 1)], STDIN_FILENO);
        }
        if (loopNum < pipes) {
            // 不是最后一个命令，绑定当前管道的写端到stdout
            dup2(pipefd[2*loopNum + 1], STDOUT_FILENO);
        }
        // 子进程关闭所有管道fd
        closePipes(pipefd, pipes);

        execvp(args[0], args);
        // exec失败直接退出，避免子进程继续执行
        perror("execvp failed");
        free(args);
        _exit(EXIT_FAILURE);
    } else if (pid > 0) {
        free(args);
        // 父进程关闭已经用不到的管道写端，让下游能收到EOF
        if (loopNum < pipes) {
            close(pipefd[2*loopNum + 1]);
        }
        // 递归执行下一个命令
        if (loopNum < pipes) {
            executeCommandFork(commands, end + 1, loopNum + 1, pipefd, pipes);
        }
        // 等待子进程执行完毕
        waitpid(pid, NULL, 0);
    } else {
        perror("fork failed");
        exit(EXIT_FAILURE);
    }
}

void executeCommand(char **commands, int pipes) {
    // 修正内存分配：每个管道2个fd，总大小为2*pipes*sizeof(int)
    int *pipefd = malloc(sizeof(int) * 2 * pipes);
    for (int i = 0; i < pipes; i++) {
        if (pipe(pipefd + 2*i) < 0) {
            perror("pipe create failed");
            exit(EXIT_FAILURE);
        }
    }

    executeCommandFork(commands, 0, 0, pipefd, pipes);
    
    // 父进程关闭所有剩余管道
    closePipes(pipefd, pipes);
    free(pipefd);
}

修复说明 #

1. 修正了管道数组的内存分配逻辑，现在足够存储所有管道的读写fd
2. 调整fork时机到参数解析完成后，避免重复执行解析逻辑
3. 移除了全局变量，改用参数传递管道相关信息，逻辑更清晰也更安全
4. 父进程会及时关闭用完的管道写端，保证下游命令能正常收到EOF
5. 补充了错误处理和子进程回收逻辑，避免僵尸进程和异常残留

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