进程间通信之管道（匿名管道 + 命名管道）详解

作为进程间通信IPC的基础方式管道是 Linux/Unix 系统中最经典的 IPC 实现本文从原理、接口、特性、应用场景等维度讲讲匿名管道和命名管道。一、管道的核心本质先明确一个核心结论管道的本质是内核提供的一块内存级伪文件只存在于内存不刷盘让不同进程能访问同一块内存空间从而实现数据交互。和普通文件相比管道有两个关键差异管道文件的 inode、数据都只存在于内核缓冲区磁盘上无持久化存储文件大小始终为 0。管道的读写端分离读光标和写光标相互独立避免了普通文件读写光标重叠导致的错误。二、匿名管道Pipes2.1 核心定义匿名管道是基于血缘关系父子 / 兄弟进程的单向通信方式依赖父进程文件描述符表的继承特性实现无磁盘文件名匿名生命周期随进程。2.2 实现原理父进程调用pipe()创建管道得到两个文件描述符pipefd[0]读端、pipefd[1]写端。父进程调用fork()创建子进程子进程完全继承父进程的文件描述符表包括管道的读写端。为实现单向通信需要关闭一端的冗余描述符若父进程写、子进程读父进程关闭pipefd[0]子进程关闭pipefd[1]。若父进程读、子进程写父进程关闭pipefd[1]子进程关闭pipefd[0]。父子进程通过剩余的读写端完成数据交互内核保证管道的同步与互斥。2.3 核心接口#include unistd.h // 创建匿名管道 // pipefd输出型参数返回读写端文件描述符 // 返回值成功0失败-1设置errno int pipe(int pipefd[2]);2.4 完整示例代码父写子读#include stdio.h #include unistd.h #include string.h #include stdlib.h #include sys/wait.h int main() { int pipefd[2]; // 1. 创建管道 if (pipe(pipefd) -1) { perror(pipe error); exit(1); } // 2. 创建子进程 pid_t pid fork(); if (pid -1) { perror(fork error); exit(1); } // 3. 子进程读数据 if (pid 0) { // 关闭写端冗余 close(pipefd[1]); char buf[1024] {0}; // 读管道管道为空时会阻塞 ssize_t n read(pipefd[0], buf, sizeof(buf) - 1); if (n 0) { printf(子进程读到数据%s\n, buf); } else if (n 0) { printf(子进程管道写端已关闭\n); } close(pipefd[0]); // 关闭读端 exit(0); } // 4. 父进程写数据 close(pipefd[0]); // 关闭读端冗余 const char *msg Hello, 子进程这是父进程通过管道发送的消息; write(pipefd[1], msg, strlen(msg)); close(pipefd[1]); // 关闭写端触发子进程读端返回0 // 5. 等待子进程退出 waitpid(pid, NULL, 0); return 0; }编译运行gcc pipe_demo.c -o pipe_demo ./pipe_demo # 输出子进程读到数据Hello, 子进程这是父进程通过管道发送的消息2.5 管道的四种核心场景场景行为本质读写端正常管道为空读端阻塞内核保证同步等待写端写入数据读写端正常管道写满写端阻塞管道有固定缓冲区大小不同系统约 4K~64K避免数据溢出读端正常写端关闭读端读到 0文件结尾不阻塞内核告知读端无更多数据可读写端正常读端关闭写端进程被内核发送 13 号信号SIGPIPE终止内核避免无效写入回收资源2.6 匿名管道的核心特性血缘限制仅支持父子 / 兄弟进程通信。单向通信默认单方向双向通信需创建两个管道。同步互斥内核保证同一时间只有一个进程操作管道避免数据错乱。面向字节流数据无边界按字节传输需上层约定解析规则。随进程生命周期进程退出管道内核缓冲区被释放。原子性读写PIPE_BUF默认 4096 字节以内的数据保证原子性不会被打断。三、命名管道FIFO3.1 核心定义命名管道突破了血缘关系限制支持无关进程间通信通过磁盘上的管道文件有文件名、inode标识数据仍存储在内核缓冲区即不刷盘。3.2 核心原理进程 A 调用mkfifo()创建命名管道文件如/tmp/myfifo进程 A 以读 / 写方式打开该管道文件进程 B 以对应方式打开同一个管道文件内核为该管道文件维护唯一的缓冲区两个进程通过缓冲区完成数据交互管道文件仅作为标识数据始终在内存文件大小始终为 0。3.3 核心接口#include sys/stat.h #include sys/types.h // 创建命名管道 // pathname管道文件路径如/tmp/myfifo // mode文件权限如0664 // 返回值成功0失败-1设置errno int mkfifo(const char *pathname, mode_t mode);3.4 完整示例两个无关进程通信进程 1写管道fifo_write.c#include stdio.h #include unistd.h #include fcntl.h #include sys/stat.h #include string.h #include stdlib.h #define FIFO_PATH /tmp/myfifo int main() { // 1. 创建命名管道已存在则忽略 if (mkfifo(FIFO_PATH, 0664) -1) { perror(mkfifo error); // 若管道已存在继续执行 if (errno ! EEXIST) exit(1); } // 2. 以写方式打开管道阻塞直到有读端打开 int fd open(FIFO_PATH, O_WRONLY); if (fd -1) { perror(open error); exit(1); } // 3. 写入数据 const char *msg Hello, 无关进程这是命名管道发送的消息; write(fd, msg, strlen(msg)); printf(写进程已发送数据%s\n, msg); // 4. 关闭文件描述符 close(fd); return 0; }进程 2读管道fifo_read.c#include stdio.h #include unistd.h #include fcntl.h #include sys/stat.h #include string.h #include stdlib.h #define FIFO_PATH /tmp/myfifo int main() { // 1. 以读方式打开管道阻塞直到有写端打开 int fd open(FIFO_PATH, O_RDONLY); if (fd -1) { perror(open error); exit(1); } // 2. 读取数据 char buf[1024] {0}; ssize_t n read(fd, buf, sizeof(buf) - 1); if (n 0) { printf(读进程读到数据%s\n, buf); } // 3. 关闭文件描述符 close(fd); // 删除管道文件可选 unlink(FIFO_PATH); return 0; }编译运行# 终端1启动读进程阻塞等待写端 gcc fifo_read.c -o fifo_read ./fifo_read # 终端2启动写进程 gcc fifo_write.c -o fifo_write ./fifo_write # 终端1输出读进程读到数据Hello, 无关进程这是命名管道发送的消息 # 终端2输出写进程已发送数据Hello, 无关进程这是命名管道发送的消息3.5 命名管道的核心特性无血缘限制支持任意进程通信只要能访问同一个管道文件。阻塞打开读端 / 写端单独打开时会阻塞直到另一端也打开。文件标识磁盘上有管道文件ls -l显示类型为 p但无数据存储。其他特性同步互斥、面向字节流、原子性等与匿名管道一致。四、管道的典型应用场景4.1 Shell 管道符|日常使用的cat test.txt | head -10 | grep error本质是 Shell 创建了 3 个进程并为每两个进程创建匿名管道实现数据逐级传递Shell 解析到|先创建匿名管道。创建cat进程将其标准输出重定向到管道写端。创建head进程将其标准输入重定向到管道读端标准输出重定向到下一个管道写端。以此类推最终实现数据流水线处理。4.2 自定义 Shell 实现管道功能核心步骤解析命令行按|分割出 n1 个命令n 个|创建 n 个匿名管道每个管道连接两个相邻命令循环创建 n1 个子进程每个子进程第一个命令关闭标准输出将管道写端重定向为标准输出。中间命令关闭标准输入重定向为上一个管道读端关闭标准输出重定向为下一个管道写端。最后一个命令关闭标准输入将管道读端重定向为标准输入。父进程关闭所有管道描述符等待子进程退出。4.3 简易进程池进程池的核心是父进程提前创建一批子进程通过管道分配任务父进程创建一个命名管道用于发送任务。父进程循环创建 N 个子进程所有子进程打开该管道的读端。当有任务时父进程向管道写入任务数据。子进程从管道读取任务执行完成后通过另一个管道向父进程返回结果。父进程回收结果实现任务的异步处理。五、管道使用的注意事项避免管道阻塞写端写入数据后及时关闭或读端持续读取防止写端因管道满阻塞。处理 SIGPIPE 信号写端进程需捕获 13 号信号避免读端关闭导致写进程异常退出。数据边界处理面向字节流的特性需在数据中增加分隔符如\n或长度字段避免粘包。命名管道权限创建时需设置合理的 mode如 0664避免无关进程访问。资源释放通信完成后关闭管道描述符命名管道需手动unlink删除。总结管道的本质是内核提供的内存级伪文件匿名管道依赖血缘关系命名管道通过文件标识突破血缘限制。匿名管道核心接口是pipe()命名管道核心接口是mkfifo()open()两者均遵循同步互斥、面向字节流的特性。管道的核心场景包括 Shell 管道符、自定义 Shell、进程池等是进程间通信的基础方式。下一篇文章会接着分享我对于其它IPC共享内存消息队列等的理解感谢支持~