在C中从管道中连续读取

#include <stdio.h>
#include <unistd.h>

#define BUFFER_SIZE 1024

int main() {
    int pipefd[2];
    char buffer[BUFFER_SIZE];

    // 创建管道
    if (pipe(pipefd) == -1) {
        perror("pipe");
        return 1;
    }

    // 创建子进程
    pid_t pid = fork();
    if (pid == -1) {
        perror("fork");
        return 1;
    }

    if (pid == 0) {
        // 子进程写入数据到管道
        close(pipefd[0]);  // 关闭读端
        dup2(pipefd[1], STDOUT_FILENO);  // 将标准输出重定向到写端

        // 执行写入操作，这里以输出字符串为例
        printf("Hello, World!\n");

        close(pipefd[1]);  // 关闭写端
    } else {
        // 父进程从管道中读取数据
        close(pipefd[1]);  // 关闭写端
        dup2(pipefd[0], STDIN_FILENO);  // 将标准输入重定向到读端

        // 连续读取数据，直到管道中没有数据可读
        ssize_t bytesRead;
        while ((bytesRead = read(STDIN_FILENO, buffer, BUFFER_SIZE)) > 0) {
            // 处理读取到的数据，这里以输出为例
            write(STDOUT_FILENO, buffer, bytesRead);
        }

        close(pipefd[0]);  // 关闭读端
    }

    return 0;
}