第一部分:通信的本质 —— “第三者”
既然进程 A 和 进程 B 的内存是隔离的,那它们怎么交换数据?答案:找一个它们都能看到的“第三者”。
这个“第三者”通常是操作系统内核。
- 进程 A 把数据从用户空间拷贝到内核缓冲区。
- 进程 B 从内核缓冲区把数据拷贝到自己的用户空间。
- 这个内核缓冲区,就是 IPC 的核心载体。
第二部分:匿名管道 (Anonymous Pipe)
这是 Linux 中最常见的 IPC 形式,就是我们在命令行里用的竖线|。
1. 原理:内核中的“水管”
管道在内核中本质上是一块内存缓冲区。 但 Linux 把它抽象成了文件。这意味着你可以用read和write系统调用来操作它,就像操作普通文件一样。
- 单向流动 (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 种“脾气”,这体现了进程同步的思想。
- 写慢读快:
- 如果管道空了,读端(子进程)会阻塞等待(进入 S 状态),直到有数据写入。
- 意义:管道自带同步机制,不需要我们自己写代码去轮询。
- 写快读慢:
- 如果管道满了(Linux 默认 64KB),写端会阻塞等待,直到读端读走一部分数据腾出空间。
- 写端关闭:
- 如果所有写端都关闭了,读端
read完剩余数据后,会返回0(表示 End Of File)。这是子进程知道“父进程写完了”的信号。
- 如果所有写端都关闭了,读端
- 读端关闭:
- 这是一个严重的问题。如果读端关闭了,写端还在拼命写,操作系统会认为这是在做无用功(没人读,写了干嘛?)。
- OS 会向写端进程发送
SIGPIPE(13号信号),直接杀死写端进程。 - 应用:你在 Shell 输
cat huge_file.txt | head -n 5,head读了 5 行就退出了(关闭读端),此时cat进程会被操作系统发信号干掉,避免它继续读取巨大的文件浪费资源。