Linux 进程间通信：共享内存与消息队列完全指南

引言在Linux系统编程中进程间通信IPC是多进程协作的核心技术。前面我们学习了管道今天我们将深入讲解另外三种重要的IPC机制共享内存、信号量和消息队列。这三种机制各有特点共享内存最高效的数据交换方式无需数据拷贝信号量进程同步机制协调资源访问顺序消息队列结构化数据传递按类型接收消息它们与管道一起构成了Linux IPC的核第一部分共享内存Shared Memory一、共享内存的基本概念共享内存是最快的IPC机制。它的原理是将同一块物理内存映射到多个进程的逻辑地址空间中进程可以直接读写这块内存无需数据拷贝。心体系。通过ipcs命令可以查看系统中的所有IPC资源。二、共享内存的操作流程步骤操作函数说明1创建/获取shmget()创建共享内存或获取已存在的2映射shmat()将共享内存映射到进程地址空间3使用指针读写直接通过指针访问共享内存4断开映射shmdt()解除当前进程的映射非删除5删除shmctl()彻底删除共享内存三、共享内存接口详解1. shmget——创建/获取共享内存#include sys/ipc.h #include sys/shm.h int shmget(key_t key, size_t size, int shmflg); // 返回值成功返回共享内存ID失败返回-1参数说明key唯一标识符多个进程通过相同的key获取同一块共享内存size共享内存大小字节shmflg标志位IPC_CREAT创建、0600权限2. shmat——映射共享内存void *shmat(int shmid, const void *shmaddr, int shmflg); // 返回值成功返回映射地址失败返回(void*)-1参数说明shmidshmget返回的共享内存IDshmaddr指定映射地址通常设为NULL让系统自动选择shmflg标志位通常设为03. shmdt——断开映射int shmdt(const void *shmaddr); // 返回值成功返回0失败返回-14. shmctl——控制共享内存int shmctl(int shmid, int cmd, struct shmid_ds *buf); // 返回值成功返回0失败返回-1参数说明cmdIPC_RMID删除、IPC_STAT获取状态buf状态结构体删除时可设为NULL四、共享内存代码示例写入端程序write.c#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/ipc.h #include sys/shm.h #define SHM_SIZE 128 #define KEY 1234 int main() { // 1. 创建共享内存 int shmid shmget(KEY, SHM_SIZE, IPC_CREAT | 0600); if (shmid -1) { perror(shmget error); exit(1); } // 2. 映射共享内存 char *shmaddr (char *)shmat(shmid, NULL, 0); if (shmaddr (void *)-1) { perror(shmat error); exit(1); } // 3. 写入数据 printf(请输入消息: ); fgets(shmaddr, SHM_SIZE, stdin); shmaddr[strlen(shmaddr) - 1] \0; // 去除换行符 printf(写入完成: %s\n, shmaddr); // 4. 断开映射 shmdt(shmaddr); return 0; }读取端程序read.c#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/ipc.h #include sys/shm.h #define SHM_SIZE 128 #define KEY 1234 int main() { // 1. 获取共享内存已存在 int shmid shmget(KEY, SHM_SIZE, 0600); if (shmid -1) { perror(shmget error); exit(1); } // 2. 映射共享内存 char *shmaddr (char *)shmat(shmid, NULL, 0); if (shmaddr (void *)-1) { perror(shmat error); exit(1); } // 3. 读取数据 printf(读取到: %s\n, shmaddr); // 4. 断开映射 shmdt(shmaddr); return 0; }运行结果# 先运行写入端./write请输入消息: hello world写入完成: hello world# 再运行读取端./read读取到: hello world五、查看与管理共享内存# 查看所有IPC资源ipcs# 查看共享内存ipcs -m# 输出示例# ------ Shared Memory Segments --------# key shmid owner perms bytes nattch status# 0x000004d2 0 user 600 128 0# 删除共享内存ipcrm -m [shmid]第二部分共享内存与信号量的综合应用一、为什么需要信号量共享内存本身不提供同步机制。当多个进程同时读写共享内存时可能会出现竞态条件。例如读取端在写入端还未写入数据时就读取会读到无效数据。解决方案使用信号量实现进程同步控制读写顺序。二、同步逻辑设计信号量初始值控制目标操作逻辑SEM_WRITE1写端写入权限写入前P写入后VSEM_READ0读端读取权限读取前P读取后V三、完整代码实现sem.h头文件#ifndef SEM_H #define SEM_H int sem_init(int key, int nsems, int *init_vals); void sem_p(int semid, int sem_num); void sem_v(int semid, int sem_num); void sem_destroy(int semid); #endifsem.c实现文件#include stdio.h #include stdlib.h #include sys/ipc.h #include sys/sem.h union semun { int val; struct semid_ds *buf; unsigned short *array; }; int sem_init(int key, int nsems, int *init_vals) { int semid; // 尝试创建信号量集 semid semget(key, nsems, IPC_CREAT | IPC_EXCL | 0600); if (semid -1) { // 已存在直接获取 semid semget(key, nsems, 0600); } else { // 创建成功初始化信号量值 union semun a; for (int i 0; i nsems; i) { a.val init_vals[i]; semctl(semid, i, SETVAL, a); } } return semid; } void sem_p(int semid, int sem_num) { struct sembuf buf {sem_num, -1, SEM_UNDO}; if (semop(semid, buf, 1) -1) { perror(P操作失败); } } void sem_v(int semid, int sem_num) { struct sembuf buf {sem_num, 1, SEM_UNDO}; if (semop(semid, buf, 1) -1) { perror(V操作失败); } } void sem_destroy(int semid) { semctl(semid, 0, IPC_RMID); }写入端write_sync.c#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/ipc.h #include sys/shm.h #include sem.h #define SHM_SIZE 128 #define SHM_KEY 1234 #define SEM_KEY 5678 #define SEM_NUMS 2 int main() { // 初始化信号量SEM_WRITE1写权限SEM_READ0读权限 int init_vals[2] {1, 0}; int semid sem_init(SEM_KEY, SEM_NUMS, init_vals); // 创建共享内存 int shmid shmget(SHM_KEY, SHM_SIZE, IPC_CREAT | 0600); char *shmaddr (char *)shmat(shmid, NULL, 0); while (1) { sem_p(semid, 0); // P(写权限) - 申请写入 printf(请输入消息: ); fgets(shmaddr, SHM_SIZE, stdin); shmaddr[strlen(shmaddr) - 1] \0; if (strcmp(shmaddr, end) 0) { sem_v(semid, 1); // 通知读端结束 break; } printf(写入: %s\n, shmaddr); sem_v(semid, 1); // V(读权限) - 通知读取端 } shmdt(shmaddr); return 0; }读取端read_sync.c#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/ipc.h #include sys/shm.h #include sem.h #define SHM_SIZE 128 #define SHM_KEY 1234 #define SEM_KEY 5678 #define SEM_NUMS 2 int main() { // 获取信号量 int init_vals[2] {0, 0}; int semid sem_init(SEM_KEY, SEM_NUMS, init_vals); // 获取共享内存 int shmid shmget(SHM_KEY, SHM_SIZE, 0600); char *shmaddr (char *)shmat(shmid, NULL, 0); while (1) { sem_p(semid, 1); // P(读权限) - 等待写入 if (strcmp(shmaddr, end) 0) break; printf(读取到: %s\n, shmaddr); sem_v(semid, 0); // V(写权限) - 释放写入权限 } // 断开映射并删除信号量 shmdt(shmaddr); sem_destroy(semid); return 0; }编译与运行# 编译gcc sem.c write_sync.c -o writegcc sem.c read_sync.c -o read# 先启动读取端会阻塞等待数据./read # 再启动写入端./write第三部分消息队列Message Queue一、消息队列的基本概念消息队列是内核维护的消息链表每个消息有独立的类型标识符接收方可以按类型选择性读取。数据会一直驻留在队列中直到被读取或系统重启。二、消息队列接口操作函数说明创建/获取msgget()创建或获取消息队列发送消息msgsnd()向队列发送消息接收消息msgrcv()从队列接收消息可按类型过滤控制msgctl()删除消息队列三、消息队列代码示例消息结构体定义// 消息结构体首成员必须是long类型 struct msgbuf { long mtype; // 消息类型必须 ≥ 1 char mtext[128]; // 消息内容 };发送端程序send.c#include stdio.h #include stdlib.h #include string.h #include sys/ipc.h #include sys/msg.h #define KEY 1234 struct msgbuf { long mtype; char mtext[128]; }; int main() { // 1. 创建消息队列 int msgid msgget(KEY, IPC_CREAT | 0600); if (msgid -1) { perror(msgget error); exit(1); } struct msgbuf msg; // 2. 发送多条不同类型的消息 msg.mtype 1; strcpy(msg.mtext, Hello, type 1); msgsnd(msgid, msg, sizeof(msg.mtext), 0); msg.mtype 2; strcpy(msg.mtext, Hello, type 2); msgsnd(msgid, msg, sizeof(msg.mtext), 0); msg.mtype 1; strcpy(msg.mtext, Another type 1); msgsnd(msgid, msg, sizeof(msg.mtext), 0); printf(消息发送完成\n); return 0; }接收端程序recv.c#include stdio.h #include stdlib.h #include string.h #include sys/ipc.h #include sys/msg.h #define KEY 1234 struct msgbuf { long mtype; char mtext[128]; }; int main() { // 1. 获取消息队列 int msgid msgget(KEY, 0600); if (msgid -1) { perror(msgget error); exit(1); } struct msgbuf msg; // 2. 只接收类型为1的消息类型2的消息会保留在队列中 printf( 接收类型1的消息 \n); for (int i 0; i 2; i) { msgrcv(msgid, msg, sizeof(msg.mtext), 1, 0); printf(收到: %s\n, msg.mtext); } // 3. 再接收类型2的消息 printf( 接收类型2的消息 \n); msgrcv(msgid, msg, sizeof(msg.mtext), 2, 0); printf(收到: %s\n, msg.mtext); // 4. 删除消息队列 msgctl(msgid, IPC_RMID, NULL); return 0; }运行结果# 运行发送端./send消息发送完成# 运行接收端 接收类型1的消息 收到: Hello, type 1收到: Another type 1 接收类型2的消息 收到: Hello, type 2四、消息类型匹配规则msgtyp值行为 0只接收该类型消息如msgtyp1只接收类型1 0接收队列中第一个消息FIFO不区分类型 0接收小于等于|msgtyp|的最小类型消息五、查看与管理消息队列# 查看消息队列ipcs -q# 输出示例# ------ Message Queues --------# key msqid owner perms used-bytes messages# 0x000004d2 0 user 600 256 2# 删除消息队列ipcrm -q [msqid]总结一、共享内存核心要点操作函数说明创建shmget()指定key和大小映射shmat()返回内存指针断开shmdt()解除映射删除shmctl(IPC_RMID)彻底删除二、消息队列核心要点操作函数说明创建msgget()指定key发送msgsnd()消息必须有类型≥1接收msgrcv()可按类型过滤删除msgctl(IPC_RMID)删除队列三、共享内存 vs 消息队列特性共享内存消息队列数据存储物理内存内核链表通信模式双向双向同步机制需要信号量配合自带类型过滤数据持久性直到删除直到删除效率最高无数据拷贝中等适用场景大数据量快速交换结构化消息传递四、完整的IPC体系IPC机制主要功能参考文章管道/有名管道简单数据流传输IPC专题一信号量进程同步IPC专题二共享内存高效数据交换本文消息队列结构化消息传递本文共享内存和消息队列是Linux IPC的重要组成部分。共享内存解决了数据交换效率问题消息队列解决了结构化消息传递问题。理解它们的工作原理和使用方法是掌握多进程编程的关键。学习建议理解共享内存的映射原理物理内存映射到逻辑地址注意共享内存需要配合信号量实现同步掌握消息队列的类型匹配规则学会使用ipcs查看和管理IPC资源