消息队列（定义、结构、如何创建、消息队列的发送与接收、发送与接收实例）

一、定义 1、消息队列是一种先进先出的队列型数据结构，实际上是系统内核中的一个内部链表。消息被顺序插入队列中，其中发送进程将消息添加到队列末尾，接受进程从队列头读取消息。 2、多个进程可同时向一个消息队列发送消息，也可以同时从一个消息队列中接收消息。发送进程把消息发送到队列尾部，接受进程从消息队列头部读取消息，消息一旦被读出就从队列中删除。 二、结构 1、消息队列中消息本身由消息类型和消息数据组成，通常使用如下结构：

1）mtype指定了消息类型，为正整数。 引入消息类型之后，消息队列在逻辑上由一个消息链表转化为多个消息链表。发送进程仍然无条件把消息写入队列的尾部，但接收进程却可以有选择地读取某个特定类型的消息中最接近队列头的一个，即使该消息不在队列头。相应消息一旦被读取，就从队列中删除，其它消息维持不变。 2）成员mtext指定了消息的数据。我们可以定义任意的数据类型甚至包括结构来描述消息数据。 例1 ：定义消息结构，它的消息数据是一个整型数据。

例2：定义消息结构，它的消息数据是一个字符数组和一个整型数据。

例3：定义消息结构，它的消息数据是一个结构，该结构由一个字符数组和一个整型数据组成。

三、消息队列的创建 1、在UNIX中，采用函数msgget创建消息队列，原型：

函数创建一个新的消息队列，或访问一个已经存在的消息队列。 1）参数key是消息队列的关键字。 注：当参数key取值IPC_PRIVATE时，函数创建关键字为0的消息队列。在UNIX内核中虽然要求消息队列关键字唯一，但也可以创建多个关键字为0的消息队列。 2）参数msgflg的低9位指定队列的属主、属组和其他用户的访问权限，其它位指定消息队列的创建方式。 创建方式参数： IPC_CREAT：创建，如存在则打开； IPC_EXCL：与IPC_CREAT使用，单独使用无意义。创建时，如存在则失败。 例1：创建关键字为0x1234，访问权限为0666的消息队列，如队列已存在返回其标识号。

例2：创建关键字为0x1234，访问权限为0666的消息队列，如队列已存在则报错。

四、消息队列的发送与接收

类似于底层文件编程的函数read和write，函数msgsnd应用于消息队列的发送，函数msgrcv用于消息队列的接收。

1、在UNIX中函数msgsnd向消息队列发送消息，原型：

1）函数msgsnd向队列消息msgid发送消息，相关参数的含义： msgid：指定发送消息队列的标识号； msgp：指向存储待发送消息内容的内存地址，用户可设计自己的消息结构； msgsz：指定长度，仅记载数据的长度，不包括消息类型部分，且必须大于0； msgflg：控制消息发送的方式，有阻塞和非阻塞（IPC_NOWAIT）两种方式。 2)导致msgsnd函数阻塞的原因： 消息队列满：阻塞条件为msg_cbytes + msgsz > msg_qbytes； (msg_cbytes：消息队列中已使用字节数； msg_qbytes：消息队列中可以容纳的最大字节数；) 消息总数满：系统中所有消息队列记载的消息总数已达到系统上限值。 3）以阻塞方式向阻塞队列（关键字为KEY）中写入字符串“Helo UNIX！”，消息类型为TYPE。 全部过程分为5步： 第一步：定义消息结构

第二步：打开消息队列

4、实例：以阻塞方式不断从消息队列（关键字为0x1234）中读取消息，并打印接收到的消息类型、长度和数据等，当接收到内容为“exit”的消息时程序结束。