消息队列:
消息队列本质上是提供了一种从一个进程向另一个进程发送数据快的方法。每个数据快都被认为是有一个类型,接受者进程接收的数据块可以有不同的类型值。
消息队列和管道的区别:
(1)、消息队列是基于消息的,而管道是基于字节流的,且消息队列的读取不一定是先进先出的。
(2)、消息队列的生命周期是随内核的(不随进程的结束而结束),而管道的生命周期是随进程的。
(3)、消息队列与命名管道有一样的不足,就是每个消息的最大长度是有上限的(MSGMAX),每个消息队列的总的字节数是有上限的(MSGMNB),系统上的消息队列的总数也有一个上限(MSGMNI)。
IPC对象的数据结构:
内核为每个IPC对象维护了一个数据结构(/usr/include/linux/ipc.h)
消息队列,共享内存和信号量都有这样一个共同的数据结构。
消息队列的结构(/usr/include/linux/msg.h)
可以看到第一个条目就是IPC结构体,即是公有的,后面的都是消息队列私有的成员。消息队列是用链表实现的。
构建消息队列的接口:
1、创建新消息队列或取得已存在消息队列
参数:
key:可以认为是一个端口号,也可以由函数ftok生成
msgflg:
IPC_CREAT:如果IPC不存在,则创建一个IPC资源,否则打开操作。
IPC_EXCL:只有在共享内存不存在的时候,新的共享内存才建立,否则就产生错位。如何单独使用IPC_CREAT,msgget()函数要么返回一个已经存在的共享内存的操作符,要么返回一个新建的内存的标识符。
如果IPC_CREAT和IPC_EXCL标志一起使用,msgget()将返回一个新建的IPC标识符;如果该IPC资源已存在,或者返回-1。
IPC_EXEL标志本身并没有太大的意义,但是和IPC_CREAT标志一起使用可以用来保证所得的对象是新建的,而不是打开已有的对象。
2、向队列读/写消息
参数:msgid:消息队列的标识码
msgp:指向消息缓冲区的指针,此位置用来暂时存储发送和接收的消息,是一个用户可以定义的通用结构,形态如下:
msgsz:消息的大小。
msgtyp:从消息队列内读取的消息形态。如果值为零,则表示消息队列中的所有消息都会被读取。
msgflg:用来指明核心程序在队列没有数据的情况下所应采取的行动。如果msgflg和常数IPC_NOWAIT合用,则在
msgsnd()执行时若是消息队列已满,则msgsnd()将不会阻塞,而会立即返回-1,如果执行的是msgrcv(),则在消息队
列呈空时,不做等待马上返回-1,并设定错误码为ENOMSG。当msgflg为0时,msgsnd()及msgrcv()在队列呈满或呈
空的情形时,采取阻塞等待的处理模式。
3、设置消息队列属性
参数:
msgctl 系统调用对 msgqid 标识的消息队列执行 cmd 操作,系统定义了 3 种 cmd 操作: IPC_STAT , IPC_SET , IPC_RMID
IPC_STAT : 该命令用来获取消息队列对应的 msqid_ds 数据结构,并将其保存到 buf 指定的地址空间。
IPC_SET : 该命令用来设置消息队列的属性,要设置的属性存储在buf中。
IPC_RMID : 从内核中删除 msqid 标识的消息队列。
Key_t键
System V IPC使用key_t值作为它们的名字,在 Readhat linux(后续验证默认都在该平台下)下key_t被定义为int类型。
ftok函数
参数 [proj_id]:指的是本应用所用到的IPC的一个序列号,成功返回IPC键,失败返回-1。
注:两进程如在pathname和proj_id上达成一致(或约定好),双方就都能够通过调用ftok函数得到同一个IPC键。
pathname的实现是组合了三个键,分别是:
(1)、pathname所在文件系统的信息(stat结构的st_dev成员)。
(2)、pathname在本文件系统内的索引节点号(stat结构的st_ino成员)。
(3)、id的低序8位(不能为0)。
ftok调用返回的整数IPC键由 proj_id的低序8位,st_dev成员的低序8位,st_info的低序16位组合而成。
不能保证两个不同的路径名与同一个proj_id的组合产生不同的键,因为上面所列的三个条目(文件系统标识符、索引节点、proj_id)中的信息位数可能大于一个整数的信息位数。
模拟实现代码如下
在linux下查看消息队列ipcs -q, 而删除消息队列为ipcrm -q msgid
运行结果和实验代码