转载自：【Linux编程】进程间通信（IPC）

进程间通信 (IPC，InterProcess Communication) 是指在不同进程之间传播或交换信息。IPC的方式通常有管道（包括无名管道和命名管道）、消息队列、信号量、共享存储、Socket、Streams等。其中 Socket和Streams支持不同主机上的两个进程IPC。

一、管道

管道，通常指无名管道，是 UNIX 系统IPC最古老的形式。

1、特点：

它是半双工的（即数据只能在一个方向上流动），具有固定的读端和写端。

它只能用于具有亲缘关系的进程之间的通信（也是父子进程或者兄弟进程之间）。

它可以看成是一种特殊的文件，对于它的读写也可以使用普通的read、write 等函数。但是它不是普通的文件，并不属于其他任何文件系统，并且只存在于内存中。

2、原型：

#include <unistd.h>
int pipe(int fd[2]);    // 返回值：若成功返回0，失败返回-1

当一个管道建立时，它会创建两个文件描述符：fd[0] 为读而打开，fd[1] 为写而打开。

要关闭管道只需将这两个文件描述符关闭即可。

3、例子

单个进程中的管道几乎没有任何用处。所以，通常调用 pipe 的进程接着调用 fork，这样就创建了父进程与子进程之间的 IPC 通道。

若要数据流从父进程流向子进程，则关闭父进程的读端（fd[0]）与子进程的写端（fd[1]）；反之，则可以使数据流从子进程流向父进程。

#include<stdio.h>
#include<unistd.h>int main()
{int fd[2];  // 两个文件描述符pid_t pid;char buff[20];if(pipe(fd) < 0)  // 创建管道printf("Create Pipe Error!\n");if((pid = fork()) < 0)  // 创建子进程printf("Fork Error!\n");else if(pid > 0)  // 父进程{close(fd[0]); // 关闭读端write(fd[1], "hello world\n", 12);}else{close(fd[1]); // 关闭写端read(fd[0], buff, 20);printf("%s", buff);}return 0;
}

二、FIFO

FIFO，也称为命名管道，它是一种文件类型。

1、特点

FIFO可以在无关的进程之间交换数据，与无名管道不同。
FIFO有路径名与之相关联，它以一种特殊设备文件形式存在于文件系统中。

2、原型

#include <sys/stat.h>
// 返回值：成功返回0，出错返回-1
int mkfifo(const char *pathname, mode_t mode);

其中的 mode 参数与open函数中的 mode 相同。一旦创建了一个 FIFO，就可以用一般的文件I/O函数操作它。

当 open 一个FIFO时，是否设置非阻塞标志（O_NONBLOCK）的区别：

若没有指定O_NONBLOCK（默认），只读 open 要阻塞到某个其他进程为写而打开此 FIFO。类似的，只写 open 要阻塞到某个其他进程为读而打开它。

若指定了O_NONBLOCK，则只读 open 立即返回。而只写 open 将出错返回 -1 如果没有进程已经为读而打开该 FIFO，其errno置ENXIO。

3、例子

FIFO的通信方式类似于在进程中使用文件来传输数据，只不过FIFO类型文件同时具有管道的特性。

在数据读出时，FIFO管道中同时清除数据，并且“先进先出”。下面的例子演示了使用 FIFO 进行 IPC 的过程：

write_fifo.c

#include<stdio.h>
#include<stdlib.h>   // exit
#include<fcntl.h>    // O_WRONLY
#include<sys/stat.h>
#include<time.h>     // timeint main()
{int fd;int n, i;char buf[1024];time_t tp;printf("I am %d process.\n", getpid()); // 说明进程IDif((fd = open("fifo1", O_WRONLY)) < 0) // 以写打开一个FIFO {perror("Open FIFO Failed");exit(1);}for(i=0; i<10; ++i){time(&tp);  // 取系统当前时间n=sprintf(buf,"Process %d's time is %s",getpid(),ctime(&tp));printf("Send message: %s", buf); // 打印if(write(fd, buf, n+1) < 0)  // 写入到FIFO中{perror("Write FIFO Failed");close(fd);exit(1);}sleep(1);  // 休眠1秒}close(fd);  // 关闭FIFO文件return 0;
}

read_fifo.c

#include<stdio.h>
#include<stdlib.h>
#include<errno.h>
#include<fcntl.h>
#include<sys/stat.h>int main()
{int fd;int len;char buf[1024];if(mkfifo("fifo1", 0666) < 0 && errno!=EEXIST) // 创建FIFO管道perror("Create FIFO Failed");if((fd = open("fifo1", O_RDONLY)) < 0)  // 以读打开FIFO{perror("Open FIFO Failed");exit(1);}while((len = read(fd, buf, 1024)) > 0) // 读取FIFO管道printf("Read message: %s", buf);close(fd);  // 关闭FIFO文件return 0;
}

在两个终端里用 gcc 分别编译运行上面两个文件，可以看到输出结果如下：

[songlee@localhost]$ ./write_fifo
I am 5954 process.
Send message: Process 5954's time is Mon Apr 20 12:37:28 2015
Send message: Process 5954's time is Mon Apr 20 12:37:29 2015
Send message: Process 5954's time is Mon Apr 20 12:37:30 2015
Send message: Process 5954's time is Mon Apr 20 12:37:31 2015
Send message: Process 5954's time is Mon Apr 20 12:37:32 2015
Send message: Process 5954's time is Mon Apr 20 12:37:33 2015
Send message: Process 5954's time is Mon Apr 20 12:37:34 2015
Send message: Process 5954's time is Mon Apr 20 12:37:35 2015
Send message: Process 5954's time is Mon Apr 20 12:37:36 2015
Send message: Process 5954's time is Mon Apr 20 12:37:37 2015

[songlee@localhost]$ ./read_fifo
Read message: Process 5954's time is Mon Apr 20 12:37:28 2015
Read message: Process 5954's time is Mon Apr 20 12:37:29 2015
Read message: Process 5954's time is Mon Apr 20 12:37:30 2015
Read message: Process 5954's time is Mon Apr 20 12:37:31 2015
Read message: Process 5954's time is Mon Apr 20 12:37:32 2015
Read message: Process 5954's time is Mon Apr 20 12:37:33 2015
Read message: Process 5954's time is Mon Apr 20 12:37:34 2015
Read message: Process 5954's time is Mon Apr 20 12:37:35 2015
Read message: Process 5954's time is Mon Apr 20 12:37:36 2015
Read message: Process 5954's time is Mon Apr 20 12:37:37 2015

上述例子可以扩展成客户进程—服务器进程通信的实例，write_fifo的作用类似于客户端，可以打开多个客户端向一个服务器发送请求信息。

read_fifo类似于服务器，它适时监控着FIFO的读端，当有数据时，读出并进行处理，但是有一个关键的问题是，每一个客户端必须预先知道服务器提供的FIFO接口。

三、消息队列

消息队列，是消息的链接表，存放在内核中。一个消息队列由一个标识符（即队列ID）来标识。

1、特点

消息队列是面向记录的，其中的消息具有特定的格式以及特定的优先级。
消息队列独立于发送与接收进程。进程终止时，消息队列及其内容并不会被删除。
消息队列可以实现消息的随机查询,消息不一定要以先进先出的次序读取,也可以按消息的类型读取。

2、原型

#include <sys/msg.h>
// 创建或打开消息队列：成功返回队列ID，失败返回-1
int msgget(key_t key, int flag);
// 添加消息：成功返回0，失败返回-1
int msgsnd(int msqid, const void *ptr, size_t size, int flag);
// 读取消息：成功返回消息数据的长度，失败返回-1
int msgrcv(int msqid, void *ptr, size_t size, long type,int flag);
// 控制消息队列：成功返回0，失败返回-1
int msgctl(int msqid, int cmd, struct msqid_ds *buf);

在以下两种情况下，msgget将创建一个新的消息队列：

如果没有与键值key相对应的消息队列，并且flag中包含了IPC_CREAT标志位。
key参数为IPC_PRIVATE。
函数msgrcv在读取消息队列时，type参数有下面几种情况：

type == 0，返回队列中的第一个消息；
type > 0，返回队列中消息类型为 type 的第一个消息；
type < 0，返回队列中消息类型值小于或等于 type 绝对值的消息，如果有多个，则取类型值最小的消息。

可以看出，type值非 0 时用于以非先进先出次序读消息。也可以把 type 看做优先级的权值。

3、例子

下面写了一个简单的使用消息队列进行IPC的例子，服务端程序一直在等待特定类型的消息，当收到该类型的消息以后，发送另一种特定类型的消息作为反馈，客户端读取该反馈并打印出来。

msg_server.c

#include <stdio.h>
#include <stdlib.h>
#include <sys/msg.h>// 用于创建一个唯一的key
#define MSG_FILE "/etc/passwd"// 消息结构
struct msg_form {long mtype;char mtext[256];
};int main()
{int msqid;key_t key;struct msg_form msg;// 获取key值if((key = ftok(MSG_FILE,'z')) < 0){perror("ftok error");exit(1);}// 打印key值printf("Message Queue - Server key is: %d.\n", key);// 创建消息队列if ((msqid = msgget(key, IPC_CREAT|0777)) == -1){perror("msgget error");exit(1);}// 打印消息队列ID及进程IDprintf("My msqid is: %d.\n", msqid);printf("My pid is: %d.\n", getpid());// 循环读取消息for(;;) {msgrcv(msqid, &msg, 256, 888, 0);// 返回类型为888的第一个消息printf("Server: receive msg.mtext is: %s.\n", msg.mtext);printf("Server: receive msg.mtype is: %d.\n", msg.mtype);msg.mtype = 999; // 客户端接收的消息类型sprintf(msg.mtext, "hello, I'm server %d", getpid());msgsnd(msqid, &msg, sizeof(msg.mtext), 0);}return 0;
}

msg_client.c

#include <stdio.h>
#include <stdlib.h>
#include <sys/msg.h>// 用于创建一个唯一的key
#define MSG_FILE "/etc/passwd"// 消息结构
struct msg_form {long mtype;char mtext[256];
};int main()
{int msqid;key_t key;struct msg_form msg;// 获取key值if ((key = ftok(MSG_FILE, 'z')) < 0) {perror("ftok error");exit(1);}// 打印key值printf("Message Queue - Client key is: %d.\n", key);// 打开消息队列if ((msqid = msgget(key, IPC_CREAT|0777)) == -1) {perror("msgget error");exit(1);}// 打印消息队列ID及进程IDprintf("My msqid is: %d.\n", msqid);printf("My pid is: %d.\n", getpid());// 添加消息，类型为888msg.mtype = 888;sprintf(msg.mtext, "hello, I'm client %d", getpid());msgsnd(msqid, &msg, sizeof(msg.mtext), 0);// 读取类型为777的消息msgrcv(msqid, &msg, 256, 999, 0);printf("Client: receive msg.mtext is: %s.\n", msg.mtext);printf("Client: receive msg.mtype is: %d.\n", msg.mtype);return 0;
}

【Linux编程】进程间通信（IPC）C语言实现相关推荐

Linux进程+进程间通信IPC
一 Linux进程 1) 进程的内存映像 2)解释 BSS段:在采用段式内存管理的架构中,BSS段(bss segment)通常是指用来存放程序中未初始化的全局变量的一块内存区域.BSS是英文Bloc ...
linux：进程间通信 IPC
文章目录 1.管道 1.1.匿名管道 1.2.有名管道 2.信号 3.共享内存 3.1.共享内存接口 3.1.1.生成 key 值 3.1.2.创建共享内存 3.1.3.创建共享内存映射 3.1.4. ...
linux操作系统进程间通信IPC之管道pipe及FIFO
linux环境下,各进程相互独立,如果想要交换两个进程之间的数据,需要通过内核,在内存中提供一个缓存区,一个进程往缓存区中写数据,一个往缓存区读数据,内核提供的这种机制称为进程间通信(IPC),常见的 ...
linux操作系统进程间通信IPC之共享存储映射
(1)文件存储映射I/O(Memory-mapped I/O) 一个磁盘文件与存储空间中的一个缓存区相对应,这样可以在不适合read/write函数的情况下,使用地址(指针)完成I/O操作.具体实现通 ...
Linux C编程--进程间通信（IPC）5--System V IPC 机制1--消息队列
System V IPC 机制 1.基本概念 IPC对象一经创建,系统内核即为该对象分配相关的数据结构.为方便对IPC对象的管理,Linux提供了专门的IPC控制命令,主要包括查看IPC对象信息的ip ...
Unix/Linux编程：进程间通信(IPC)总结
IPC工具分类如上,Unix系统上IPC根据功能可以分为三类通信:这些工具关注进程间的数据交换同步:这些进程关注进程和线程操作之间的同步信号:虽然信号的主要作用不为此,但是在特定场景下仍然可以 ...
Linux C编程--进程间通信（IPC）1--进程间通信机制概述
linux下进程间通信的几种主要手段简介: 管道(Pipe)及有名管道(named pipe):管道可用于具有亲缘关系进程间的通信,有名管道克服了管道没有名字的限制,因此,除具有管道所具有的功能外,它 ...
Linux系统编程学习笔记（九）进程间通信IPC
进程间通信IPC: 我们以前介绍过进程控制原语,看到怎么创建多个进程.但是进程之间交互信息的方式只介绍了通过fork或者exec继承父进程的打开文件或者通过文件系统. 经典的进程通信方式有:管道.FI ...
linux进程间通信 ipc,进程间通信IPC (InterProcess Communication)
一.进程间通信的概念每个进程各自有不同的用户地址空间,任何一个进程的全局变量在另一个进程中都看不到,所以进程之间要交换数据必须通过内核,在内核中开辟一块缓冲区,进程1把数据从用户空间拷到内核缓冲区, ...

【Linux编程】进程间通信（IPC）C语言实现

一、管道

二、FIFO

三、消息队列

【Linux编程】进程间通信（IPC）C语言实现相关推荐

最新文章

热门文章