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

【linux学习】深入理解 Linux 进程间通信：管道的艺术与实现

news 2026/6/13 20:20:30

大家好，我是程序员小青蛙，今天来介绍进程间通信的技术。

在 Linux 系统中，进程是独立的执行单元，拥有各自的地址空间和资源。但当多个进程需要协同工作时，它们之间的信息交换就变得至关重要。** 进程间通信（IPC, Inter-Process Communication）** 正是解决这一问题的核心机制。

在众多 IPC 方式中，** 管道（Pipe）** 是 Unix/Linux 系统中最古老、也最基础的通信形式。本文将带你从零开始，深入理解管道的原理、分类与实现，并通过代码实例和内核视角，彻底掌握这一经典的进程间通信技术。

一、什么是管道？

管道的本质，就是一个连接两个进程的数据流通道。它像一根水管，一端进水，一端出水，数据只能单向流动。

在 Shell 命令中，我们早已见过管道的身影：

who | wc -l

这个命令中，who进程的标准输出，通过管道被直接连接到了wc -l进程的标准输入。who输出当前登录用户列表，wc -l则接收这些数据并统计行数，实现了进程间的无缝协作。

二、匿名管道（Anonymous Pipe）

匿名管道是最基础的管道形式，它的特点是只能用于具有亲缘关系（父子进程）的进程间通信。

1. 核心 API：`pipe()`函数

创建匿名管道需要调用pipe()系统调用，它定义在<unistd.h>头文件中：

#include <unistd.h> int pipe(int fd[2]);

参数：fd是一个输出型参数，它会被填充两个文件描述符：
- fd[0]：管道的读端，用于从管道读取数据。
- fd[1]：管道的写端，用于向管道写入数据。
返回值：成功返回0，失败返回-1并设置errno。

管道的核心是内核中的一块缓冲区，读端和写端分别指向这块缓冲区。

2. 父子进程如何共享管道？

匿名管道创建后，只能被当前进程访问。要让子进程也能使用，必须通过fork()创建子进程。

父进程创建管道：调用pipe()得到fd[0]和fd[1]。
父进程fork()出子进程：子进程会继承父进程的文件描述符表，因此它也拥有指向同一管道的fd[0]和fd[1]。
关闭无用的描述符：为了实现单向通信，父进程和子进程需要各自关闭不需要的一端。例如，如果父进程写、子进程读：
- 父进程关闭读端fd[0]，只保留写端fd[1]。
- 子进程关闭写端fd[1]，只保留读端fd[0]。

这样，就建立了一条从父进程流向子进程的单向通道。

3. 代码示例：父子进程通信

下面是一个典型的匿名管道通信示例，父进程向管道写入数据，子进程读取并打印：

#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #include <sys/wait.h> #define ERR_EXIT(m) \ do { perror(m); exit(EXIT_FAILURE); } while(0) int main() { int pipefd[2]; if (pipe(pipefd) == -1) { ERR_EXIT("pipe error"); } pid_t pid = fork(); if (pid == -1) { ERR_EXIT("fork error"); } if (pid == 0) { // 子进程：读数据 close(pipefd[1]); // 关闭写端 char buf[1024]; ssize_t len = read(pipefd[0], buf, sizeof(buf)-1); if (len > 0) { buf[len] = '\0'; printf("子进程收到：%s\n", buf); } close(pipefd[0]); exit(EXIT_SUCCESS); } else { // 父进程：写数据 close(pipefd[0]); // 关闭读端 const char* msg = "Hello, Pipe!"; write(pipefd[1], msg, strlen(msg)); close(pipefd[1]); waitpid(pid, NULL, 0); // 等待子进程结束 } return 0; }

三、管道的读写规则与特性

管道并非简单的缓冲区，它在内核中实现了一套完整的同步机制。

1. 读写行为

场景	读端行为	写端行为
管道为空，读操作	默认阻塞，直到有数据写入。	-
管道为满，写操作	-	默认阻塞，直到有数据被读出。
所有写端已关闭	`read()`返回`0`，表示读到文件末尾。	-
所有读端已关闭	-	`write()`会触发`SIGPIPE`信号，进程默认会被杀死。

2. 核心特性总结

半双工通信：数据只能在一个方向上流动。如果需要双向通信，必须创建两个管道。
面向字节流：数据以字节流的形式传递，没有消息边界。
生命周期随进程：管道随进程创建，当所有引用它的文件描述符都被关闭后，内核会自动销毁管道。
自带同步机制：内核保证读写操作的原子性，无需用户额外加锁。

四、命名管道（FIFO）：无亲缘进程的桥梁

匿名管道的限制在于只能在父子进程间使用。如果想让两个不相关的进程通信，就需要使用命名管道（Named Pipe），也叫 FIFO。

1. 什么是命名管道？

命名管道是一种特殊类型的文件，它在文件系统中有一个路径名。进程可以像打开普通文件一样打开它，从而实现通信。

2. 创建命名管道

可以通过命令行创建：

mkfifo myfifo

也可以在代码中创建：

#include <sys/stat.h> int mkfifo(const char *pathname, mode_t mode);

pathname：管道文件的路径。
mode：文件权限，如0664。

3. 代码示例：用命名管道实现文件拷贝

我们用两个进程来实现文件拷贝：一个进程读取源文件并写入管道，另一个进程从管道读取数据并写入目标文件。

写端（writer.c）：

#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <fcntl.h> #include <sys/stat.h> #define ERR_EXIT(m) \ do { perror(m); exit(EXIT_FAILURE); } while(0) int main() { // 创建命名管道 if (mkfifo("myfifo", 0664) == -1) { ERR_EXIT("mkfifo error"); } // 打开源文件 int infd = open("source.txt", O_RDONLY); if (infd == -1) ERR_EXIT("open source.txt error"); // 打开管道（写端） int outfd = open("myfifo", O_WRONLY); if (outfd == -1) ERR_EXIT("open myfifo error"); char buf[1024]; ssize_t n; while ((n = read(infd, buf, sizeof(buf))) > 0) { write(outfd, buf, n); } close(infd); close(outfd); return 0; }

读端（reader.c）：

#include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <fcntl.h> #include <sys/stat.h> #define ERR_EXIT(m) \ do { perror(m); exit(EXIT_FAILURE); } while(0) int main() { // 打开目标文件 int outfd = open("target.txt", O_WRONLY | O_CREAT | O_TRUNC, 0664); if (outfd == -1) ERR_EXIT("open target.txt error"); // 打开管道（读端） int infd = open("myfifo", O_RDONLY); if (infd == -1) ERR_EXIT("open myfifo error"); char buf[1024]; ssize_t n; while ((n = read(infd, buf, sizeof(buf))) > 0) { write(outfd, buf, n); } close(infd); close(outfd); unlink("myfifo"); // 删除管道文件 return 0; }