当前位置: 首页 > news >正文

进程间通信--匿名管道

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

既然进程 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进程会被操作系统发信号干掉,避免它继续读取巨大的文件浪费资源。
http://www.cnnetsun.cn/news/97438.html

相关文章:

  • 基于微信小程序的校园工会体育报名系统计算机毕业设计(源码+lw+部署文档+讲解等)
  • AppleRa1n:iOS激活锁绕过的终极解决方案指南
  • RTL8852BE驱动:Linux无线网络兼容性问题的完整解决方案指南
  • 如何彻底解决Windows 11安装蓝屏:MediaCreationTool.bat驱动兼容性完全指南
  • 最新软件测试面试题,常见面试题及答案汇总,不怕拿不到offer
  • Obsidian样式定制完全指南:从入门到精通的主题个性化技巧
  • LobeChat私域流量转化文案
  • Leakcanary检测内存泄漏汇总
  • LobeChat主持人串场词生成
  • 解锁全球付费内容:Bypass Paywalls Clean完全指南
  • 14、Linux 文件搜索:grep 与 find 命令全解析
  • 18、Linux系统:磁盘使用查询与软件安装管理指南
  • WebPlotDigitizer图表数据提取:3步实现科研图像到精准数据的完整指南
  • 【毕业设计】SpringBoot+Vue+MySQL 高校宣讲会管理系统平台源码+数据库+论文+部署文档
  • 如何彻底解决AutoCAD字体问题:终极字体管理插件使用指南
  • 3、量子世界的奥秘:从狄拉克到多世界诠释
  • 17、量子随机数、超密编码与量子隐形传态
  • 构建虚拟偶像配音系统?试试这款多情感TTS引擎EmotiVoice
  • LobeChat主题皮肤更换教程:打造个性化的AI聊天界面
  • 企业级工资信息管理系统管理系统源码|SpringBoot+Vue+MyBatis架构+MySQL数据库【完整版】
  • 悼词缅怀亲人:LobeChat传递真挚情感
  • LobeChat PCI-DSS支付安全建议
  • Obsidian Style Settings:终极自定义指南,轻松打造个性化笔记界面
  • 解锁 AI 潜力:9 大核心提示技巧,让交互更精准高效
  • zotero-style终极指南:5分钟打造智能文献管理神器
  • BetterNCM安装工具:3分钟快速上手网易云音乐插件终极指南
  • 思科DHCP服务1
  • 解锁Ryzen处理器性能的5大核心调试技术
  • LobeChat限时促销活动文案生成
  • LobeChat指标监控告警设置