Linux 进程间通信（IPC）：管道与信号量完全指南

引言在 Linux 系统编程中进程间通信IPCInter-Process Communication是一个核心课题。进程是独立运行的单位默认情况下彼此隔离。但很多时候我们需要让进程之间交换数据或同步执行顺序——这就是进程间通信要解决的问题。Linux 提供了多种 IPC 机制管道Pipe最简单的 IPC 机制分为有名管道和无名管道信号量Semaphore用于进程同步协调资源访问顺序共享内存Shared Memory最高效的数据交换方式消息队列Message Queue结构化数据传递套接字Socket网络通信今天我将重点讲解管道和信号量这两种 IPC 机制涵盖它们的工作原理、使用方法和典型应用场景。第一部分管道Pipe一、管道的基本概念管道是 Linux 中最早的进程间通信方式它的本质是内核内存中的一个环形缓冲区不占用磁盘空间。管道的特点数据存储在内存中读写速度快半双工通信同一时刻只能单向传输自带同步机制读写自动阻塞/唤醒无持久性进程结束管道消失二、管道的分类类型通信范围创建方式文件标识无名管道仅限父子进程间通信pipe()系统调用无文件路径有名管道任意两个进程间通信mkfifo命令或mkfifo()函数管道文件类型为 p三、管道的工作原理管道在内核中通过环形缓冲区实现包含两个关键指针指针功能移动规则头指针指向下一个待写入的位置写入数据后向后移动尾指针指向下一个待读取的位置读取数据后向后移动读写规则写入数据头指针后移若缓冲区满则阻塞读取数据尾指针后移若缓冲区空则阻塞循环覆盖指针到达缓冲区末尾后重置到起始位置四、有名管道FIFO1. 创建有名管道# 命令行创建mkfifo myfifo# 查看文件类型p 表示管道文件ls -l myfifo# prw-r--r-- 1 user user 0 Apr 27 10:00 myfifo// 程序中创建 #include sys/types.h #include sys/stat.h int main() { mkfifo(myfifo, 0666); return 0; }2. 有名管道通信示例写端程序write.c#include stdio.h #include stdlib.h #include unistd.h #include fcntl.h #include string.h int main() { int fd open(myfifo, O_WRONLY); if (fd -1) { perror(open error); exit(1); } char buffer[128]; while (1) { printf(请输入消息: ); fgets(buffer, sizeof(buffer), stdin); buffer[strlen(buffer) - 1] \0; write(fd, buffer, strlen(buffer) 1); if (strcmp(buffer, exit) 0) break; } close(fd); return 0; }读端程序read.c#include stdio.h #include stdlib.h #include unistd.h #include fcntl.h int main() { int fd open(myfifo, O_RDONLY); if (fd -1) { perror(open error); exit(1); } char buffer[128]; while (1) { int n read(fd, buffer, sizeof(buffer)); if (n 0) break; // 写端关闭 printf(收到消息: %s\n, buffer); if (strcmp(buffer, exit) 0) break; } close(fd); return 0; }五、管道的阻塞特性场景阻塞情况说明open 调用阻塞直到另一端以对应模式打开只读打开时等待写端只写打开时等待读端read 调用管道为空且写端未关闭时阻塞写端关闭后 read 立即返回 0write 调用管道满时阻塞读端读取后解除阻塞// 演示管道的阻塞特性 // 单独运行写端会阻塞在 open int main() { int fd open(myfifo, O_WRONLY); // 阻塞等待读端 // 只有读端也打开后才继续执行 write(fd, hello, 5); close(fd); return 0; }六、管道关闭的特殊情况情况结果说明读端关闭写端写入进程收到 SIGPIPE 信号13默认终止进程内核检测到无效操作写端关闭读端读取read 立即返回 0EOF类似文件末尾两端都关闭管道被内核销毁所有文件描述符关闭后释放// 忽略 SIGPIPE 信号 #include signal.h int main() { signal(SIGPIPE, SIG_IGN); // 忽略 SIGPIPE int fd open(myfifo, O_WRONLY); // 即使读端关闭write 也不会导致进程终止 write(fd, hello, 5); return 0; }七、无名管道pipe1. pipe 函数#include unistd.h int pipe(int fd[2]); // 成功返回 0失败返回 -1 // fd[0]读端文件描述符 // fd[1]写端文件描述符2. 单进程使用无名管道#include stdio.h #include unistd.h #include string.h int main() { int fd[2]; pipe(fd); write(fd[1], hello, 5); sleep(3); char buffer[128]; read(fd[0], buffer, 127); printf(buffer%s\n, buffer); // 输出bufferhello close(fd[0]); close(fd[1]); return 0; }3. 父子进程通过无名管道通信#include stdio.h #include stdlib.h #include unistd.h #include string.h #include sys/wait.h int main() { int fd[2]; pipe(fd); pid_t pid fork(); if (pid 0) { // 子进程读取数据 close(fd[1]); // 关闭写端 char buffer[128]; read(fd[0], buffer, 127); printf(子进程收到: %s\n, buffer); close(fd[0]); exit(0); } else { // 父进程写入数据 close(fd[0]); // 关闭读端 char buffer[128]; printf(请输入消息: ); fgets(buffer, sizeof(buffer), stdin); buffer[strlen(buffer) - 1] \0; write(fd[1], buffer, strlen(buffer) 1); close(fd[1]); wait(NULL); } return 0; }无名管道的核心特点仅限父子进程间通信通过 fork 继承文件描述符半双工通信需关闭不需要的描述符自带同步机制读写自动阻塞/唤醒八、管道总结特性无名管道有名管道通信范围父子进程间任意进程间创建方式pipe()mkfifo文件路径无有持久性进程结束消失文件存在数据随进程数据存储内存内存第二部分信号量Semaphore一、什么是信号量信号量是操作系统提供的进程同步机制用于协调多个进程对共享资源的访问顺序避免竞态条件。典型应用场景打印机等共享设备的互斥访问生产者-消费者问题读者-写者问题多个进程协调执行顺序二、核心概念概念定义示例临界资源同一时刻仅允许单个进程访问的资源打印机、试衣间临界区访问临界资源的代码段打印数据的代码P操作申请资源原子减一进入试衣间前V操作释放资源原子加一离开试衣间后互斥防止多个进程同时访问临界资源信号量初值设为 1同步协调进程执行顺序生产后才能消费三、信号量的工作原理四、信号量接口使用信号量需要包含头文件sys/sem.h。1. semget——创建/获取信号量#include sys/sem.h int semget(key_t key, int nsems, int semflg); // 参数 // key: 键值多个进程通过相同的 key 获取同一个信号量 // nsems: 信号量个数 // semflg: 标志位IPC_CREAT 创建IPC_EXCL 排他 // 返回值成功返回信号量 ID失败返回 -12. semctl——控制信号量初始化/删除// 自定义联合体某些系统需要定义 union semun { int val; // 用于 SETVAL struct semid_ds *buf; unsigned short *array; }; int semctl(int semid, int semnum, int cmd, ...); // 参数 // semid: 信号量 ID // semnum: 信号量编号多个信号量时使用 // cmd: 命令SETVAL 初始化IPC_RMID 删除3. semop——执行 P/V 操作struct sembuf { unsigned short sem_num; // 信号量编号 short sem_op; // -1P操作或 1V操作 short sem_flg; // 标志位通常为 0 }; int semop(int semid, struct sembuf *sops, size_t nsops);五、信号量封装示例sem.h头文件#ifndef SEM_H #define SEM_H int sem_init(int key); void sem_p(int semid); void sem_v(int semid); void sem_destroy(int semid); #endifsem.c实现文件#include stdio.h #include stdlib.h #include sys/sem.h union semun { int val; struct semid_ds *buf; unsigned short *array; }; int sem_init(int key) { int semid; // 尝试创建信号量 semid semget(key, 1, IPC_CREAT | IPC_EXCL | 0600); if (semid -1) { // 已存在直接获取 semid semget(key, 1, 0600); } else { // 创建成功初始化值为 1 union semun a; a.val 1; semctl(semid, 0, SETVAL, a); } return semid; } void sem_p(int semid) { struct sembuf buf {0, -1, 0}; semop(semid, buf, 1); } void sem_v(int semid) { struct sembuf buf {0, 1, 0}; semop(semid, buf, 1); } void sem_destroy(int semid) { semctl(semid, 0, IPC_RMID); }六、使用信号量实现进程互斥进程Aa.c#include stdio.h #include unistd.h #include sem.h #define KEY 0x1234 int main() { int semid sem_init(KEY); for (int i 0; i 5; i) { sem_p(semid); // 进入临界区 printf(A); // 临界区 fflush(stdout); sleep(1); printf(A\n); // 临界区 fflush(stdout); sem_v(semid); // 退出临界区 sleep(1); } // 注意应由最后一个进程销毁信号量 // 此处简化实际需要协作 return 0; }进程Bb.c#include stdio.h #include unistd.h #include sem.h #define KEY 0x1234 int main() { int semid sem_init(KEY); for (int i 0; i 5; i) { sem_p(semid); // 进入临界区 printf(B); // 临界区 fflush(stdout); sleep(1); printf(B\n); // 临界区 fflush(stdout); sem_v(semid); // 退出临界区 sleep(1); } return 0; }编译与运行# 编译gcc -c sem.cgcc a.c sem.o -o agcc b.c sem.o -o b# 运行在两个终端分别执行./a./b# 输出结果严格交替# A# A# B# B# A# A# ...七、信号量的注意事项要点说明初始化时机由第一个进程创建并初始化其他进程只获取销毁时机由最后一个进程销毁需进程间协调SEM_UNDO 标志进程异常终止时自动恢复信号量状态避免死锁原子性P/V 操作是原子的不会被中断总结一、管道核心要点特性说明存储位置内存环形缓冲区通信模式半双工同步机制读写自动阻塞/唤醒无名管道仅父子进程有名管道任意进程二、信号量核心要点概念说明P操作申请资源值-1为0时阻塞V操作释放资源值1唤醒等待进程互斥信号量初值为 1保证互斥访问同步信号量初值为 0协调执行顺序临界区被 P/V 包围的代码段三、对比总结IPC 机制数据存储通信模式同步机制适用场景管道内存单向自动阻塞简单数据流信号量计数器信号P/V 操作资源同步共享内存内存双向需配合信号量大数据量消息队列内核双向自动排队结构化消息管道和信号量是 Linux 进程间通信的基础机制。管道解决了数据传输问题信号量解决了同步问题。理解它们的原理和使用方法是掌握多进程编程的关键。学习建议理解管道的阻塞特性注意读写端的正确管理区分无名管道和有名管道的使用场景掌握信号量的 P/V 操作逻辑区分互斥保护临界资源和同步协调执行顺序