这篇文章详细解释进程间通信(IPC)的各种方式,包括早期的方法、System V的机制以及现代的套接字。早期的是无名管道、有名管道和信号。System V的包括消息队列、共享内存和信号量。现在主要使用套接字,特别是网络编程中的应用,套接字实现了不同主机之间的通信,是现在最常用的主流通信方式。
大纲:
- 无名管道(匿名管道):
-
用于有亲缘关系的进程间通信,比如父子进程。
-
半双工,单向通信。
-
使用pipe()系统调用创建。
-
需要记得关闭不需要的文件描述符。
-
示例代码可能包括创建管道,fork进程,然后父子进程分别读写。
- 有名管道(FIFO):
-
可以在无关进程之间使用,因为通过文件系统中的命名管道文件进行通信。
-
使用mkfifo()创建,然后像普通文件一样打开、读写。
-
需要处理阻塞问题,比如同时打开读写端。
- 信号(Signal):
-
用于通知进程发生了某个事件,比如中断或子进程终止。
-
使用kill()发送信号,signal()或sigaction()注册处理函数。
-
需要注意信号处理函数的可重入性和异步安全。
- System V IPC:
-
消息队列:允许进程发送格式化的数据块,每个消息有类型,可以非先进先出顺序读取。
-
共享内存:多个进程可以访问同一块内存区域,需要配合信号量进行同步。
-
信号量:用于进程间同步,控制对共享资源的访问。
- 套接字(Socket):
-
支持不同主机间的通信,可以是TCP或UDP。
-
本地套接字也可以用于同一台机器上的进程通信。
-
涉及bind(), listen(), accept(), connect(), send(), recv()等函数。
接下来,对于每个部分的细节进行详细解析,比如API函数的参数、使用步骤,以及示例代码的正确性。同时,要注意对比不同IPC机制的特点,比如速度、复杂度、适用场景等。
我提供的代码在我的Ubuntu上运行是可行的,您可以直接复制粘贴使用即可。为了确保示例代码的正确性和简洁性,特别是信号处理和共享内存同步部分,这些地方容易出错。你在使用我的代码的时候,还是需要检查每个系统调用的返回值,处理错误情况,比如管道或FIFO创建失败时的处理。在基于对编程流程的理解之上,进行代码复用(不要无脑抄,谢谢)。
我会确保文章的结构清晰,每个IPC方法分点说明,特点、API、示例分开展示,便于读者理解。
进程间通信(IPC)的详细分类和说明,涵盖早期、System V 和现代方法:
早期:无名管道有名管道信号通信System V:消息队列共享内存信号量现在:套接字 --- 网络编程 -- 实现了不同主机之间的通信无名管道: -- 管道在内核空间注意事项:1 - 无名管道只能作用域亲缘关系之间的进程通信2 - 无名管道有固定的读端以及写端3 - 如果管道中无数据,则读操作会阻塞4 - 无名管道不能用于存储数据5 - 如果没有读操作则写操作没有意义6 - 如果管道满了则写操作会阻塞 7 - 是一个半双工通信单工:数据只能单向传递 A ---> B双工:数据可以双向发送 A <---> B半双工通信:数据在同一时刻只能单向发送全双工通信:数据可以在任意时刻双向发送有名管道:特点:1- 有名字 -- 由文件的实体2- 有名管道可以作用于非亲缘进程间的通信3- 可以使用文件IO的相关函数进行操作4- 管道只是数据的传递,本身不存储任何数据,管道文件大小恒定为05- 管道文件不能光标的偏移和定位(fseek/ftell禁用)6- 如果管道中没有数据则读操作会阻塞7- 每次读数据能够读取到 size个大小8- 全双工通信信号通信 特点:1- 唯一的异步通信2- 信号属于内核的内容3- 信号不直接传输数据,只是给一个提醒4- 不能自定义信号5- 进程对信号的响应方式5.1> 默认处理(缺省操作) 9) SIGKILL 19) SIGSTOP 只能默认处理 ***5.2> 自定义处理(信号捕捉) 10) SIGUSR1 12) SIGUSR2 只能被捕捉 *****5.3> 忽略处理 SIGKILL及SIGSTOP 不能被忽略 ****6- 软件层次上对中断机制的模拟------------------------------------------------------------------------------------ IPC通信对象: Inter Process CommunicationSystem V:共享内存信号量消息队列1-共享内存1> 共享内存是内核实际存在的一块物理内存 2> 共享内存是通信效率最高的通信方式3> 共享内存的读操作主动不会阻塞(共享内存的数据不会主动消失,bzero清空后,读操作也会阻塞); -------------------------------------key shmid owner perms bytes nattch status 键值 id号 拥有者 权限 大小 当前使用的进程数 状态操作:1> 获得键值- 直接指定 -- 容易重复- 系统自带的宏 - IPC_PRIVAT - 只会创建不会打开- ftok() 自动获取 - 推荐2> 打开/创建 共享内存 共享内存的ID号 = shmget(key,大小,权限);3> 映射共享内存映射后的地址 = shmat(ID号,NULL,权限);0 : 可读可写SHM_RDONLY:只读映射成功后就可以进行读写操作了4> 取消映射shmdt(映射后的地址);5> 删除共享内存 -- 可选shmctl() -- 操作共享内存shmctl(ID号,指令选择,存放信息的结构体)cmd:IPC_STAT : 查看属性IPC_SET : 设置属性IPC_RMID : 删除共享内存------------------------------------------------------------------------------------ 2-信号量 - 信号灯注意: 和信号没有任何关系1> 信号灯是内核VAL资源2> PV操作 P操作:申请资源 V:释放资源3> IPC创建的是信号灯集4> 信号灯不进行任何数据的传输,作为实现进程同步的工具5> 信号灯的值不会主动归0key semid owner perms nsems 信号灯集中信号灯的个数操作:1-获得键值 - 同共享内存2-打开/创建 信号灯集信号灯集ID = semget(key,信号灯的个数,权限 -shmget一样)3- 执行PV操作semop(ID号, 指令选择,要操作信号灯的个数)指令选择:struct sembuf{unsigned short sem_num; /* semaphore number 信号灯的编号*/short sem_op; /* semaphore operation PV操作的选择 */// P: <0 V: >0short sem_flg; /* operation flags 权限选择 */0, 会阻塞进程 IPC_NOWAIT, 不会阻塞进程 } 4- 操作信号灯集semctl(ID号,信号灯的编号,指令选择,/* 相关信息的联合体 */)指令选择:SETVAL:设置信号灯的值 -- 此时需要第四个参数GETVAL:用于查看信号灯的值IPC_RMID:删除信号灯union semun {int val; /* Value for SETVAL 信号灯更改值 */struct semid_ds *buf; /* Buffer for IPC_STAT, IPC_SET */unsigned short *array; /* Array for GETALL, SETALL */struct seminfo *__buf; /* Buffer for IPC_INFO(Linux-specific) */}; 1-消息队列 1> 先进先出的队列2> 消息队列的格式: 消息类型 + 消息正文key msqid owner perms used-bytes messages 已经使用的字节数 当前消息队列中未读的消息数------------------------------------------------------------------------------------ Uinx 套接字. Unix 套接字可用于本地进程间通信。. 创建套接字时使用本地协议 PF_LOCAL / PF_UNIX / AF_LOCAL / AF_UINX。. 可以创建流式套接字(SOCK_STREAM),数据报套接字(SOCK_DGRAM),面向连接的套接字(SOCK_SEQPACKET)。数据报套接字是可靠的,既不会丢失消息,也不会传递出错。. Unix 套接字是套接字和管道之间的混合物。. 和其他进程间通信方式比,Unix 本地套接字使用方便,效率也高。因为它不需要经过网络协议栈、不需要打包拆包、不需要计算校验和、不需要维护序号和应答等,只是将应用层数据从一个进程复制到另一个进程。. 常用于前后台进程通信,比如 X Window。. 另外,Unix 本地套接字可用于传递文件描述符、传递用户凭证等场景。Unix 套接字地址类型:struct sockaddr_un {sa_family_t sun_family; /* AF_UNIX */char sun_path[108]; /* pathname */};Unix 套接字在 struct sockaddr_un 结构体的 sun_path 数组中有三种不同的地址类型:. pathname 文件系统文件名。服务器和客户端可各自指定文件系统中的文件名,这个文件名的类型是套接字类型(在 ls -l 的模式中含 s,如 srw-rw-r--),文件名必须是以空字符结束的字符串。文件名保存在 sun_path 数组中,因此长度不能超 107。此地址必须调用 bind() 进行绑定。该文件用仅于向客户进程告知套接字名称,既不能打开,也不能由应用程序用于通信。如果在 bind() 时该文件已存在则 bind() 失败,关闭套接字时它也不会自动删除。因此一般在应用程序结束前删除它。为可移植性考虑,绑定时的地址长度可以使用以下方法计算:offsetof(struct sockaddr_un, sun_path) + strlen(sun_path)offsetof() 是在 <stddef.h> 中定义的宏,它计算 sun_path 成员从结构开始处的偏移量。. 无名。未用 bind() 绑定的流套接字是无名的,同样地用 socketpair() 创建的两个套接字也是无名的。显然如果使用 bind() 的话则只有客户端可以使用无名套接字,而服务器不能使用无名套接字,因为那样客户端发送给谁?用 socketpair() 创建的两个套接字因为是无名的,因此只能用于有亲缘关系的进程。. 抽象文件名。使用抽象文件名的好处是不用在文件系统中创建文件,也不删除文件。在 sun_path[0] 中指定空字符 '\0',即可使用抽象文件名的套接字。又分两种情况,一是将抽象文件名保存在sun_path[1] 开始处,注意名称长度不能超过 106。绑定时地址长度可按以下计算:offsetof(struct sockaddr_un, sun_path) + strlen(sun_path + 1) + 1这种情况服务器和客户端都可以使用抽象文件名。二是自动生成抽象文件名。即清空 sun_path 数组,而绑定的地址长度为:offsetof(struct sockaddr_un, sun_path)自动生成的抽象文件名长度为 5 字节,字符范围是 [0-9a-f]。显然自动生成抽象文件名,也只能用于客户端。
一、早期 IPC 方法
1. 无名管道(匿名管道,Pipe)
详情请参见文章:【进程与线程】无名管道(匿名管道,Pipe)
- 特点:
- 仅适用于 父子进程或有亲缘关系的进程。
- 半双工(单向通信),数据只能单向流动。
- 基于文件描述符,通过内存缓冲区传输数据。
- API:
int pipe(int fd[2])
:创建管道,fd[0]
为读端,fd[1]
为写端。
- 示例:
#include <stdio.h>
#include <unistd.h>int main() {int fd[2];char buf[20];pipe(fd); // 创建管道if (fork() == 0) { // 子进程close(fd[0]); // 关闭读端write(fd[1], "Hello", 6);close(fd[1]);} else { // 父进程close(fd[1]); // 关闭写端read(fd[0], buf, sizeof(buf));printf("Received: %s\n", buf);close(fd[0]);}return 0;
}
2. 有名管道(FIFO)
详情请参见文章:【进程与线程】有名管道(FIFO)
- 特点:
- 通过 文件系统中的命名管道文件 实现,无关进程可通信。
- 支持 阻塞和非阻塞模式。
- API:
int mkfifo(const char *path, mode_t mode)
:创建命名管道文件。
示例:
// 进程 A(写端)
#include <stdio.h>
#include <fcntl.h>int main() {mkfifo("/tmp/myfifo", 0666);int fd = open("/tmp/myfifo", O_WRONLY);write(fd, "Hello FIFO", 11);close(fd);return 0;
}// 进程 B(读端)
#include <stdio.h>
#include <fcntl.h>int main() {int fd = open("/tmp/myfifo", O_RDONLY);char buf[20];read(fd, buf, sizeof(buf));printf("Received: %s\n", buf);close(fd);return 0;
}
3. 信号(Signal)
详情请参见文章:【进程与线程】信号(Signal)
- 特点:
- 用于 异步通知进程 某个事件的发生(如
SIGINT
、SIGTERM
)。 - 信号处理函数需简短且可重入。
- 用于 异步通知进程 某个事件的发生(如
- API:
void (*signal(int sig, void (*handler)(int)))(int)
:注册信号处理函数。int kill(pid_t pid, int sig)
:向指定进程发送信号。
示例:
#include <stdio.h>
#include <signal.h>
#include <unistd.h>void handler(int sig) {printf("Received signal: %d\n", sig);
}int main() {signal(SIGINT, handler); // 捕获 Ctrl+Cwhile (1) {sleep(1);}return 0;
}
二、System V IPC
1. 消息队列(Message Queue)
- 特点:
- 消息按类型存储,支持 优先级读取。
- 独立于进程存在(需显式删除)。
- API:
int msgget(key_t key, int msgflg)
:创建或获取消息队列。int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg)
:发送消息。ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg)
:接收消息。
示例:
// 发送端
#include <sys/msg.h>
struct msgbuf {long mtype;char mtext[100];
};int main() {int msqid = msgget(1234, IPC_CREAT | 0666);struct msgbuf msg = {1, "Hello Message Queue"};msgsnd(msqid, &msg, sizeof(msg.mtext), 0);return 0;
}// 接收端
int main() {int msqid = msgget(1234, 0666);struct msgbuf msg;msgrcv(msqid, &msg, sizeof(msg.mtext), 1, 0);printf("Received: %s\n", msg.mtext);msgctl(msqid, IPC_RMID, NULL); // 删除队列return 0;
}
2. 共享内存(Shared Memory)
- 特点:
- 速度最快 的 IPC 方式,进程直接读写同一内存区域。
- 需配合信号量同步。
- API:
int shmget(key_t key, size_t size, int shmflg)
:创建或获取共享内存。void *shmat(int shmid, const void *shmaddr, int shmflg)
:附加共享内存。int shmdt(const void *shmaddr)
:分离共享内存。
示例:
// 写入端
#include <sys/shm.h>
int main() {int shmid = shmget(1234, 1024, IPC_CREAT | 0666);char *shm = shmat(shmid, NULL, 0);sprintf(shm, "Hello Shared Memory");shmdt(shm);return 0;
}// 读取端
int main() {int shmid = shmget(1234, 1024, 0666);char *shm = shmat(shmid, NULL, 0);printf("Received: %s\n", shm);shmdt(shm);shmctl(shmid, IPC_RMID, NULL); // 删除共享内存return 0;
}
3. 信号量(Semaphore)
- 特点:
- 用于 进程间同步,控制对共享资源的访问。
- 支持原子操作(P/V 操作)。
- API:
int semget(key_t key, int nsems, int semflg)
:创建或获取信号量集。int semop(int semid, struct sembuf *sops, size_t nsops)
:执行信号量操作。
示例:
#include <sys/sem.h>int main() {int semid = semget(1234, 1, IPC_CREAT | 0666);semctl(semid, 0, SETVAL, 1); // 初始化信号量为1struct sembuf op = {0, -1, 0}; // P操作(获取资源)semop(semid, &op, 1);printf("Critical section start\n");sleep(2);printf("Critical section end\n");op.sem_op = 1; // V操作(释放资源)semop(semid, &op, 1);semctl(semid, 0, IPC_RMID); // 删除信号量return 0;
}
三、现代 IPC:套接字(Socket)
- 特点:
- 支持 跨网络通信(TCP/UDP)。
- 本地套接字(Unix Domain Socket)也可用于同一主机的进程通信。
- 全双工通信。
- API:
socket()
:创建套接字。bind()
、listen()
、accept()
(服务端)。connect()
、send()
、recv()
(客户端)。
示例(本地 TCP 通信):
// 服务端
#include <sys/socket.h>
#include <sys/un.h>int main() {int sockfd = socket(AF_UNIX, SOCK_STREAM, 0);struct sockaddr_un addr = {AF_UNIX, "/tmp/mysocket"};bind(sockfd, (struct sockaddr*)&addr, sizeof(addr));listen(sockfd, 5);int client = accept(sockfd, NULL, NULL);send(client, "Hello Socket", 12, 0);close(client);close(sockfd);unlink("/tmp/mysocket");return 0;
}// 客户端
int main() {int sockfd = socket(AF_UNIX, SOCK_STREAM, 0);struct sockaddr_un addr = {AF_UNIX, "/tmp/mysocket"};connect(sockfd, (struct sockaddr*)&addr, sizeof(addr));char buf[20];recv(sockfd, buf, sizeof(buf), 0);printf("Received: %s\n", buf);close(sockfd);return 0;
}
对比与适用场景
根据适合场景的需求选择合适的 IPC 机制:
- 简单通信:无名管道、信号。
- 高性能共享:共享内存 + 信号量。
- 跨网络通信:套接字。
IPC 方法 | 速度 | 复杂度 | 适用范围 | 同步需求 |
---|---|---|---|---|
无名管道 | 快 | 低 | 父子进程 | 无需显式同步 |
有名管道(FIFO) | 中 | 中 | 任意进程 | 无需显式同步 |
信号 | 快 | 低 | 异步通知 | 信号处理函数 |
消息队列 | 中 | 高 | 任意进程 | 内置消息类型管理 |
共享内存 | 最快 | 高 | 高性能数据共享 | 需信号量同步 |
信号量 | 快 | 高 | 进程同步 | 原子操作 |
套接字 | 中 | 高 | 跨网络或本地进程 | 协议层控制 |
以上。仅供学习与分享交流,请勿用于商业用途!转载需提前说明。
我是一个十分热爱技术的程序员,希望这篇文章能够对您有帮助,也希望认识更多热爱程序开发的小伙伴。
感谢!