news 2026/3/1 9:13:54

进程间通信--匿名管道

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
进程间通信--匿名管道

第一部分:通信的本质 —— “第三者”

既然进程 A 和 进程 B 的内存是隔离的,那它们怎么交换数据?答案:找一个它们都能看到的“第三者”。

这个“第三者”通常是操作系统内核

  1. 进程 A 把数据从用户空间拷贝到内核缓冲区
  2. 进程 B 从内核缓冲区把数据拷贝到自己的用户空间。
  3. 这个内核缓冲区,就是 IPC 的核心载体。

第二部分:匿名管道 (Anonymous Pipe)

这是 Linux 中最常见的 IPC 形式,就是我们在命令行里用的竖线|

1. 原理:内核中的“水管”

管道在内核中本质上是一块内存缓冲区。 但 Linux 把它抽象成了文件。这意味着你可以用readwrite系统调用来操作它,就像操作普通文件一样。

  • 单向流动 (Half-duplex):数据只能从一端流向另一端。就像水管,不能同时双向注水。
  • 面向字节流:没有固定的报文格式,读写次数不一定需要匹配(写100字节,可以分10次读,每次10字节)。
  • 血缘限制:匿名管道只能用于有亲缘关系的进程之间(父子、兄弟)。为什么?因为只有通过fork,子进程才能继承父进程打开的文件描述符。
2. 系统调用:pipe()

C

#include <unistd.h> int pipe(int pipefd[2]);
  • 参数:这是一个输出型参数数组。
    • pipefd[0]读端(Reader)。
    • pipefd[1]写端(Writer)。
    • 记忆技巧:0 像嘴巴(读),1 像笔(写)。
  • 返回值:成功返回 0,失败返回 -1。
3. 关键步骤:Fork 构建通道

创建管道本身并不难,难的是如何让父子进程各执一端。

第一步:父进程创建管道父进程调用pipe,此时父进程同时拥有读端和写端。

  • fd[0] -> 内核缓冲区
  • fd[1] -> 内核缓冲区

第二步:父进程 Fork 子进程fork之后,子进程拷贝了父进程的文件描述符表 (File Descriptor Table)。重点:虽然 PCB 拷贝了,但它们指向的struct file(文件结构体)是同一个。所以子进程也有fd[0]fd[1],指向同一个内核缓冲区。

第三步:关闭不需要的端口(构建单向信道)管道设计为单向。

  • 如果父写子读
    • 父进程:关闭fd[0](读端),保留fd[1]
    • 子进程:关闭fd[1](写端),保留fd[0]
  • 如果不关会怎样?虽然也能用,但会干扰 EOF(文件结束)的判断,稍后细讲。

第三部分:代码实战 —— 父子对话

我们写一个简单的程序:父进程往管道里写字符串,子进程读取并打印。

#include <iostream> #include <unistd.h> #include <string.h> #include <sys/wait.h> #include <sys/types.h> using namespace std; int main() { // 1. 创建管道 int pipefd[2] = {0}; if (pipe(pipefd) < 0) { perror("pipe"); return 1; } // 2. 创建子进程 pid_t id = fork(); if (id < 0) { perror("fork"); return 2; } if (id == 0) { // --- 子进程 (Reader) --- // 3. 子进程关闭写端 close(pipefd[1]); char buffer[1024]; while (true) { // 4. 从管道读取 // 如果管道没数据,read 会自动阻塞等待!(类似 wait 的状态) ssize_t s = read(pipefd[0], buffer, sizeof(buffer) - 1); if (s > 0) { buffer[s] = 0; cout << "Child got message: " << buffer << endl; } else if (s == 0) { // 写端关闭了,读端就会读到 0 (EOF) cout << "Writer quit, Child quit." << endl; break; } else { perror("read"); break; } } close(pipefd[0]); exit(0); } // --- 父进程 (Writer) --- // 3. 父进程关闭读端 close(pipefd[0]); const char *msg = "Hello Child, I am Father."; int count = 0; while (count < 5) { char out_buffer[1024]; snprintf(out_buffer, sizeof(out_buffer), "%s [%d]", msg, count++); // 4. 写入管道 write(pipefd[1], out_buffer, strlen(out_buffer)); sleep(1); // 故意慢一点,看看子进程会不会等 } // 5. 任务结束,关闭写端 // 这一步非常重要!关闭写端后,子进程的 read 才会返回 0 (EOF) close(pipefd[1]); waitpid(id, nullptr, 0); cout << "Father wait success." << endl; return 0; }

第四部分:管道的 4 种特殊情况(面试重点)

通过上面的代码,我们可以总结出管道的 4 种“脾气”,这体现了进程同步的思想。

  1. 写慢读快
    • 如果管道空了,读端(子进程)会阻塞等待(进入 S 状态),直到有数据写入。
    • 意义:管道自带同步机制,不需要我们自己写代码去轮询。
  1. 写快读慢
    • 如果管道满了(Linux 默认 64KB),写端会阻塞等待,直到读端读走一部分数据腾出空间。
  1. 写端关闭
    • 如果所有写端都关闭了,读端read完剩余数据后,会返回0(表示 End Of File)。这是子进程知道“父进程写完了”的信号。
  1. 读端关闭
    • 这是一个严重的问题。如果读端关闭了,写端还在拼命写,操作系统会认为这是在做无用功(没人读,写了干嘛?)。
    • OS 会向写端进程发送SIGPIPE(13号信号),直接杀死写端进程。
    • 应用:你在 Shell 输cat huge_file.txt | head -n 5head读了 5 行就退出了(关闭读端),此时cat进程会被操作系统发信号干掉,避免它继续读取巨大的文件浪费资源。
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/2/24 11:38:28

BetterNCM完全配置指南:如何快速打造个性化音乐体验

BetterNCM完全配置指南&#xff1a;如何快速打造个性化音乐体验 【免费下载链接】BetterNCM-Installer 一键安装 Better 系软件 项目地址: https://gitcode.com/gh_mirrors/be/BetterNCM-Installer 还在使用功能受限的网易云音乐客户端吗&#xff1f;想要获得更丰富的音…

作者头像 李华
网站建设 2026/2/26 12:13:48

BetterNCM插件配置指南:全面提升网易云音乐体验

BetterNCM插件配置指南&#xff1a;全面提升网易云音乐体验 【免费下载链接】BetterNCM-Installer 一键安装 Better 系软件 项目地址: https://gitcode.com/gh_mirrors/be/BetterNCM-Installer 还在为网易云音乐功能单一而困扰吗&#xff1f;BetterNCM插件管理器正是您需…

作者头像 李华
网站建设 2026/2/24 11:49:48

WorkshopDL:让非Steam平台玩家也能畅享创意工坊模组

WorkshopDL&#xff1a;让非Steam平台玩家也能畅享创意工坊模组 【免费下载链接】WorkshopDL WorkshopDL - The Best Steam Workshop Downloader 项目地址: https://gitcode.com/gh_mirrors/wo/WorkshopDL 还在为Epic、GOG等平台购买的Steam独占模组而烦恼吗&#xff1f…

作者头像 李华