使用C语言poll()实现子进程向服务器发送数据的问题排查

咱们先拆解下你遇到的核心问题：服务器端poll的revents始终没触发，说明你监听的文件描述符根本没产生可读事件，大概率是管道的使用逻辑或者文件描述符对应关系出了问题，我来一步步给你梳理：

1. 管道方向搞反了？先检查监听的是读端还是写端 #

管道是单向的：fd[0]是读端（只能读），fd[1]是写端（只能写）。如果你的fdh[i][0]是管道的写端，那监听POLLIN事件完全没用——写端不会产生可读事件。

你得先确认：

• 调用pipe()创建管道时，是不是把fdh[i][0]设为了读端；
• 服务器只应该监听管道的读端，子进程往写端写数据。

2. 子进程的stdout没连到管道写端！ #

你在子进程里用write(1, &Mess, sizeof(Mess))，这里的1是默认的stdout（一般是终端），如果没把它重定向到管道的写端，数据根本不会流到服务器监听的管道里。

怎么修复？ #

fork子进程后，在子进程里把stdout替换成管道写端：

// 假设当前管道的读写端是pipefd[0]（读）、pipefd[1]（写）
dup2(pipefd[1], 1); // 把stdout重定向到管道写端
close(pipefd[0]);   // 子进程不需要读端，赶紧关掉
close(pipefd[1]);   // 原写端可以关了，因为dup2已经复制了一份

这样子进程调用write(1, ...)甚至直接printf的内容，都会写到管道里，服务器的读端就能收到数据了。

3. poll超时设为0，导致没等事件就返回了 #

你的代码里poll(fds, hts, 0)，第三个参数是超时时间（毫秒），设为0表示立即返回，不等待任何事件。如果调用poll的时候子进程还没写完数据，poll直接返回0，自然不会触发revents。

调整方式： #

• 如果想一直等事件，把超时设为-1（永久阻塞）；
• 如果需要周期性检查，给个合理的超时值（比如1000毫秒），并把poll放进循环里：

while (1) {
    int h = poll(fds, hts, 1000); // 等1秒，超时了再轮询
    if (h == -1) {
        perror("poll出错了");
        break;
    }
    for (int i = 0; i < hts; i++) {
        if (fds[i].revents & POLLIN) {
            ssize_t ret = read(fdh[i][0], &Mess, sizeof(Mess));
            if (ret == -1) {
                perror("read失败");
            } else if (ret == 0) {
                // 管道写端被关了（子进程退出了），可以清理这个fd
                close(fds[i].fd);
                fds[i].fd = -1; // 标记成无效，后续poll会忽略它
            } else {
                // 这里处理收到的Mess数据
            }
        }
    }
}

4. 没关闭管道的冗余端，导致引用计数异常 #

fork之后，父进程和子进程都会持有管道的读写端。如果父进程没关管道的写端，或者子进程没关读端，管道的引用计数就不会降到0，父进程的读端永远收不到EOF事件，甚至会干扰poll对可读事件的判断。

给你个正确的管道+fork流程示例： #

int pipefd[2];
if (pipe(pipefd) == -1) {
    perror("创建管道失败");
    exit(EXIT_FAILURE);
}

pid_t pid = fork();
if (pid == -1) {
    perror("fork失败");
    exit(EXIT_FAILURE);
}

if (pid == 0) {
    // 子进程：写数据到管道
    close(pipefd[0]); // 子进程不需要读端，关掉
    dup2(pipefd[1], 1); // 把stdout定向到管道写端
    close(pipefd[1]); // 原写端可以关了

    // 这里用write(1,...)发送数据
    write(1, &Mess, sizeof(Mess));
    exit(EXIT_SUCCESS);
} else {
    // 父进程（服务器）：读管道数据
    close(pipefd[1]); // 父进程不需要写端，关掉
    struct pollfd fds[1];
    fds[0].fd = pipefd[0];
    fds[0].events = POLLIN;

    int h = poll(fds, 1, -1); // 永久等事件
    if (h > 0 && (fds[0].revents & POLLIN)) {
        read(pipefd[0], &Mess, sizeof(Mess));
        // 处理收到的数据
    }
    close(pipefd[0]);
    waitpid(pid, NULL, 0); // 等子进程退出
}

最后提几个小细节 #

• 确保Mess是POD类型（比如结构体里没有指针、虚函数这些），不然跨进程传输会有内存布局问题；
• read()可能不会一次性读完sizeof(Mess)字节，最好循环读取直到拿到全部数据；
• 如果有多个子进程，每个子进程要对应独立的管道，别共用一个，不然数据会混在一起。

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