消息队列接口API(posix 接口和 system v接口)

怼烎@ 2022-03-29 09:21 429阅读 0赞

**消息队列 posix API**

消息队列（也叫做报文队列）能够克服早期unix通信机制的一些缺点。信号这种通信方式更像\\"即时\\"的通信方式，它要求接受信号的进程在某个时间范围内对信号做出反应，因此该信号最多在接受信号进程的生命周期内才有意义，信号所传递的信息是接近于随进程持续的概念（process-persistent）；管道及有名管道则是典型的随进程持续IPC，并且，只能传送无格式的字节流无疑会给应用程序开发带来不便，另外，它的缓冲区大小也受到限制消息队列就是一个消息的链表。可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息；对消息队列有读权限的进程则可以从消息队列中读走消息。消息队列是随内核持续的。

**mq\_open** - 打开一个消息队列

概要

**\#include <fcntl.h>** /\* 定义 了O\_\* 常量 \*/

**\#include <sys/stat.h>** /\* 定义了 mode 常量 \*/

**\#include <mqueue.h>**

**mqd\_t mq\_open(const char \****name***, int ***oflag***);**

**mqd\_t mq\_open(const char \****name***, int ***oflag***, mode\_t ***mode***, struct mq\_attr \****attr***);**

需要 *-lrt* 来链接。

描述

**mq\_open**() 创建一个新的 POSIX 消息队列或打开一个存在的队列。这个队列使用 *name* 标识。每个消息队列都通过形如 */somename* 的名字来区分，这是一个包含起始斜杠在内的最大长度不超过 **NAME\_MAX**(如 225)的以空字符结尾的字符串，在起始斜杠之后不允许再有斜杠。

参数 *oflag* 参数指定控制操作的标志。(这个标志的值可以通过包含 *<fcntl.h>* 来获得。)下面给出的标志至少需要指定一个：

O\_RDONLY 以只能收取消息的方式打开队列。 O\_WRONLY 以只能发送消息的方式打开的队列。 O\_RDWR 以可发送也可收取消息的方式打开队列。

零个或多个下面列出的标志可以用 *位或* 到 *oflag* 里：

O\_NONBLOCK 以非阻塞的方式打开队列。具体情况是在 **mq\_receive**(3) 和 **mq\_send**(3) 要阻塞的时候，这些函数使用错误 **EAGAIN** 来替代。 O\_CREAT 如果不存在则创建消息队列。消息队列的所有者(用户 ID)被设置为调用进程的有效用名 ID。组属性(组 ID)被设置为调用进程的有效组 ID。 O\_EXCL 如果 **O\_CREAT** 在 *oflag* 里指定，当名为 *name* 队列已经存在时，让函数以 **EEXIST** 失败。

如果 **O\_CREAT** 在 *oflag* 里指定，那么两个额外的参数也必须给定。*mode* 参数指定新队列的权限，这与 **open**(2) 一样。(描述权限的符号常量可以通过包含 *<sys/stat.h>* 来获得。)权限设置会被进程掩码处理。参数 *attr* 指定队列的属性。参考 **mq\_getattr**(3) 来了解细节。如果 *attr* 是 NULL，队列将使用实现定义的默认属性来创建。

返回值

成功时，**mq\_open**() 返回一个能被其它消息队列函数使用的消息队列描述符。失败时，**mq\_open**() 返回 *(mqd\_t) -1*，并设置 *errno* 来指明错误。

错误 EACCES 队列存在，但是调用者没有权限以指定的方式打开。 EACCES *name* 包含多个斜杠。 EEXIST 在 *oflag* 里同时指定了**O\_CREAT** 和 **O\_EXCL**，但是名字 *name* 的队列已经存在。 EINVAL **O\_CREAT** 在 *oflag* 里存在，并且 *attr* 不是 NULL，但是 *attr->mq\_maxmsg* 或 *attr->mq\_msqsize* 是无效的。这两个域都必须大于零。对于一个非特权(没有 **CAP\_SYS\_RESOURCE** 能力)进程 *attr->mq\_maxmsg* 必须小于或等于 *msg\_max* 限制，并且 *attr->mq\_msgsize* 也必须小于或等于 *msgsize\_max* 限制。此外，就算是特权进程，*attr->mq\_maxmsg* 也不能超过 **HARD\_MAX** 限制。(参看 **mq\_overview**(7) 了解限制的更多细节。) EMFILE 进程已经达到打开的文件和消息队列的最大数目。 ENAMETOOLONG *name* 太长了。 ENFILE 达到系统允许打开文件个数和消息队列的全局上限。 ENOENT**O\_CREAT** 没有在 *oflag* 里指定，并且没有名字 *name* 的队列存在。 ENOENT *name* 只是 "/" 而没有其它字符。 ENOMEM 内存不足。 ENOSPC 没有足够的内存来创建新的消息队列。这个可能是因为达到 *queues\_max* 限制而引起的，参考 **mq\_overview**(7)。

**mq\_close** - 关闭一个消息队列描述符

概要**\#include <mqueue.h> int mq\_close(mqd\_t ***mqdes***);**

需要 *-lrt* 来链接。

描述

**mq\_close**() 关闭消息队列描述符 *mqdes*。

如果调用进程在消息队列 *mqdes* 绑定了通知请求，那么这个请求被删除，此后其它进程就可以绑定通知请求到此消息队列。

返回值

成功时，**mq\_close**() 返回 0；错误时，返回 -1，并把 *errno* 设置为合适的值。

错误 EBADF *mqdes* 指定的描述符无效。

**mq\_getattr, mq\_setattr** - 取得/设置消息队列属性

概要

**\#include <mqueue.h>**

**int mq\_getattr(mqd\_t ***mqdes***, struct mq\_attr \****attr***);**

**int mq\_setattr(mqd\_t ***mqdes***, struct mq\_attr \****newattr***, struct mq\_attr \****oldattr***);**

需要 *-lrt* 来链接。

描述**mq\_getattr**() 和 **mq\_setattr**() 取得和更改 *mqdes* 引用的消息队列的属性。

**mq\_getattr**() 在 *attr* 指向的内存里返回一个 *mq\_attr* 结构体。这个结构定义为：

struct mq\_attr \{

long mq\_flags; /\* 标志：0 或 O\_NONBLOCK \*/

long mq\_maxmsg; /\* 队列中消息个数最大值 \*/

long mq\_msgsize; /\* 消息大小最大值 \*/

long mq\_curmsgs; /\* 队列中当前消息个数 \*/

\};

*mq\_flags* 的域包含打开消息队列描述符相关的标志。这个标志由 **mq\_open**(3) 初始化。能存在于这个标志的域只有**O\_NONBLOCK**。

**mq\_maxmsg** 和 *mq\_msgsize* 两个域由 **mq\_open**(3) 在队列创建时设置的。*mq\_maxmsg* 是使用 **[mq\_sen][mq_sen]**(3) 发送数据大小的上限。*mq\_msgsize* 是当前队列可以缓存消息个数的上限。用于设置这些域的软上限的两个 */proc* 文件在**mq\_open**(3) 中有描述。

*mq\_curmsgs* 域用于返回当前队列里已经有消息个数。

**mq\_setattr**() 设置消息队列的属性，设置时使用由 *newattr* 指针指向的 *mq\_attr* 结构的信息。属性中只有标志*mq\_flasgs* 里的 **O\_NONBLOCK** 标志可以更改，其它在 *newattr* 内的域都被忽略。如果 *oldattr* 不是空指针，那么它指向的内存用于返回现有的属性结构 *mq\_attr*，此时包含信息与通过 **mq\_getattr**() 取得的信息相同。

返回值成功时 **mq\_getattr**() 和 **mq\_setattr**() 返回 0；错误时，-1 被返回，并同时设置 *errno* 值来指明错误。 错误 EBADF *mqdes* 指定的描述符无效。 EINVAL *newattr->mq\_flags* 包含除 **O\_NONBLOCK** 之外的位。

**mq\_notify** - 注册一个当消息到达时的通知

概要

**\#include <mqueue.h>**

**int mq\_notify(mqd\_t ***mqdes***, const struct sigevent \****sevp***);**

需要 *-lrt* 来链接。

描述**mq\_notify**() 允许调用进程针对 *mqdes* 引用的空队列注册或注销新消息异步通知的递送。

*sevp* 参数是一个指向 *sigevent* 结构的指针。关于这个结构的定义与相关细节，见 **sigevent**(7)。

如果 *sevp* 是一个非空指针，那么 **mq\_notify**() 注册调用进程以在消息到达时收到通知。*sevp* 指向的 *sigevent* 结构中的*sigev\_notify* 域用于指明通知的方式。这个域可以有如下几个值：

SIGEV\_NONE 一个“空”通知：调用进程作为通知的目标被注册，但是当消息达到时，没有通知被递送。 SIGEV\_SIGNAL 通过发送在*sigev\_signo* 指定的信号来通知进程。见 **sigevent**(7) 中的细节描述。*siginfo\_t* 结构中的 *si\_code* 域将被设置为 **SI\_MESGQ**。进一步说，*si\_pid* 将被设置为发送消息的进程的进程 ID，同时 *si\_uid* 将被设置为发送进程的真实用户 ID。 SIGEV\_THREAD 当消息到达时，启动一个新线程来调用 *sigev\_notify\_function*。参见 **sigevent**(7) 来了解其中细节。

对于一个消息队列只能有一个进程可以注册到达通知。

如果 *sevp* 是 NULL，并且调用进程当前已经在相应的队列里注册过通知，则这个注册被删除；此后其它进程就可以注册到这个队列里以接收通知。

消息通知只有在一个新消息到达且之前队列是空的情况下被递送。如果 **mq\_notify**() 调用时队列非空，则通知会在队列变空之后且有新消息到达时递送。

如果其它进程或线程正在通过 **mq\_receive**(3) 等待一个空队列的消息到达，则任何新到达的消息都被忽略：这些消息会传递给调用 **mq\_receive**(3) 进程或线程，而消息通知注册仍然有效。

通知只发生一次：在一个通知递送之后，这个通知注册会被删除，并且其它进程可以注册一个通知。如果收到消息的进程想接收下一个通知，它可能使用 **mq\_notify**() 请求一个全新通知。这可以在所有未读消息被收到完之前来执行。(此时把队列设置非阻塞模式会很有用，在清空队列消息的时候而不用担心一旦队列变空之后被阻塞。)

返回值成功时，**mq\_notify**() 返回 0；错误时，返回 -1，并把 *errno* 设置为合适的值。 错误 EBADF *mqdes* 指定的描述符无效。 EBUSY 其它进程已经在这个消息队列里注册的通知。 EINVAL *sevp->sigev\_notify* 不是一个合法的值；或 *sevp->sigev\_notify* 是 **SIGEV\_SIGNAL**而 *sevp->sigev\_signo* 不是一个信号值。 ENOMEM 内存不足。

POSIX.1-2008 说当 *sevp* 是 NULL 时，实现*可以*产生一个 **EINVAL** 错误，并且调用进程不会被注册到队列 *mqdes* 的通知里。

**mq\_send, mq\_timedsend** - 发送一个消息到消息队列

**\#include <mqueue.h>**

**int mq\_send(mqd\_t ***mqdes***, const char \****msg\_ptr***, size\_t ***msg\_len***, unsigned ***msg\_prio***); \#include <time.h>**

**\#include <mqueue.h>**

**int mq\_timedsend(mqd\_t ***mqdes***, const char \****msg\_ptr***, size\_t ***msg\_len***, unsigned ***msg\_prio***, const struct timespec \****abs\_timeout***);**

需要 *-lrt* 来链接。

glibc 需要特性测试宏(参看 **feature\_test\_macros**(7))：

**mq\_timedsend**()：

\_XOPEN\_SOURCE >= 600 || \_POSIX\_C\_SOURCE >= 200112L

**mq\_send**() 把 *msg\_ptr* 指向的消息加入由 *mqdes* 引用的消息队列里。参数 *msg\_len* 指定消息 *msg\_ptr* 的长度：这个长度必须小于或等于队列 *mq\_msgsize* 属性的值。零长度的消息是允许。

*msg\_prio* 是一个用于指定消息优先级的非负整数。消息在队列里依据优先级排序，相同优先级的消息新消息放于旧消息后面。

如果消息队列已经满了(如当前队列消息个数等于队列的 *mq\_maxmsg* 属性)，那么，默认地，**mq\_send**() 会一直阻塞到有足够的空间来把当前消息入队，或者在阻塞的时候被一个信号处理器中断。如果 **O\_NONBLOCK** 标志在消息队列描述符里有设置，那么调用将直接由 **EAGAIN** 错误返回。

**mq\_timedsend**() 的行为与 **mq\_send**() 很类似，只是消息队列满且 **O\_NONBLOCK** 标志没有设置时，*abs\_timeout* 指向的结构指定了一个阻塞的软上限时间。这个上限通过从 Epoch 1970-01-01 00:00:00 +0000 (UTC) 开始的绝对的秒和纳秒数指定超时，它的结构定义如下：

struct timespec \{ time\_t tv\_sec; /\* 秒 \*/ long tv\_nsec; /\* 纳秒 \*/ \};

如果消息队列满，并且调用时超时设置已经达到，**mq\_timedsend**() 立刻返回。

返回值

成功时，**mq\_send**() 和 **mq\_timedsend**() 返回零；错误时，返回 -1，并把 *errno* 设置为合适的值。

错误 EAGAIN 队列已满，并且由 *mqdes* 消息队列描述符 **O\_NONBLOCK** 标志设置。 EBADF *mqdes* 指定的描述符无效。 EINTR 这个调用被信号处理器中断，参看 **signal**(7)。 EINVAL 调用需要阻塞，但 *abs\_timeout* 无效，要么因为 *tv\_sec* 小于零，要么因为 *tv\_nsec* 小于零或大于 100 百万。 EMSGSIZE *msg\_len* 大于消息队列的 *mq\_msgsize* 属性。 ETIMEDOUT 在消息传输完成之前已超时。

**mq\_receive, mq\_timedreceive** - 从一个消息队列里收一条消息

概要

**\#include <mqueue.h>**

**ssize\_t mq\_receive(mqd\_t ***mqdes***, char \****msg\_ptr***, size\_t ***msg\_len***, unsigned \****msg\_prio***);**

**\#include <time.h>**

**\#include <mqueue.h>**

**ssize\_t mq\_timedreceive(mqd\_t ***mqdes***, char \****msg\_ptr***, size\_t ***msg\_len***, unsigned \****msg\_prio***, const struct timespec \****abs\_timeout***);**

需要 *-lrt* 来链接。

glibc 需要特性测试宏(参看 **feature\_test\_macros**(7))：

**mq\_timedreceive**()：

\_XOPEN\_SOURCE >= 600 || \_POSIX\_C\_SOURCE >= 200112L 描述**mq\_receive**() 从由描述符 *mqdes* 引用的队列时删除优先级最高的最老的消息，并把放置到 *msg\_ptr* 的缓存区内。参数 *msg\_len* 指定缓冲区 *msg\_ptr* 的大小：它必须大于队列的 *mq\_msgsize* 属性(参数**mq\_getattr**(3))。如果 *prio* 不是 NULL，那么它指向的内存用于返回收到消息相关的优先级。

如果队列是空的，默认情况下，**mq\_receive**() 会阻塞到有消息准备好为止，或者被信号处理器中断为止。如果消息队列描述符的 **O\_NONBLOCK** 标志启用，则调用会以错误 **EAGAIN** 立即返回。

**mq\_timedreceive**() 的行为与 **mq\_receive**() 很相似，只不过当队列是空且 **O\_NONBLOCK** 标志没有针对相应消息队列描述符启用时，调用会阻塞到 *abs\_timeout* 时间点时返回。这个软上限是一个绝对的时刻值，它计算从 Epoch 1970-01-01 00:00:00 +0000 (UTC) 开始的秒数和纳秒数，这个结构的定义如下：

struct timespec \{ time\_t tv\_sec; /\* 秒 \*/ long tv\_nsec; /\* 纳秒 \*/ \}; 如果没有消息有效，并且超时的时刻已经达到，**mq\_timedreceive**() 立即返回。 返回值成功时，**mq\_receive**() 和 **mq\_timedreceive**() 返回收到的消息字节数；失败时，-1 被返回，并设置 *errno* 来指明错误。 错误 EAGAIN 队列是空的，并且 **O\_NONBLOCK** 标志在 *mqdes* 引用的消息队列描述符上启用。 EBADF *mqdes* 指定的描述符无效。 EINTR 这个调用被信号处理器中断，参看 **signal**(7)。 EINVAL 调用需要阻塞，但 *abs\_timeout* 无效，要么因为 *tv\_sec* 小于零，要么因为*tv\_nsec* 小于零或大于 100 百万。 EMSGSIZE *msg\_len* 小于消息队列的 *mq\_msgsize* 属性。 ETIMEDOUT 在消息传输完成之前已超时。

**mq\_unlink** - 删除消息队列

概要

**\#include <mqueue.h>**

**int mq\_unlink(const char \****name***);**

需要 *-lrt* 来链接。

描述**mq\_unlink**() 删除名为 *name* 的消息队列。消息队列名将被直接删除。消息队列本身在所有引用这个队列的描述符被关闭时销毁。 返回值成功时 **mq\_unlink**() 返回0；错误时，返回 -1，并把 *errno* 设置为合适的值。 错误 EACCES 调用者没有权限删除这个消息队列。 ENAMETOOLONG *name* 太长了。 ENOENT 没有名为 *name* 的消息队列。mq\_overview - POSIX 消息队列概述 描述POSIX 消息队列允许进程以消息的形式交换数据。这组 API 与 System V 的消息队列(**msgget**(2)、**msgsnd**(2)、**msgrcv**(2) 等等)有所不同，但是提供了相似的功能。

消息队列通过 **mq\_open**(3) 创建和打开，这个函数返回一个 *消息队列描述符* (*mqd\_t*)，它将在之后调用中被用于引用那个打开的消息队列。每个消息队列都通过形如 */somename* 的名字来区分，这是一个包含起始斜杠在内的最大长度不超过 **NAME\_MAX**(如 225)的以空字符结尾的字符串，在起始斜杠之后不允许再有斜杠。两个进程可能通过在使用**mq\_open**(3) 时传递相同的名字来打开相同的消息队列。

消息可以使用 **mq\_send**(3) 和 **mq\_receive**(3) 在一个队列里传入和传出。当一个进程不再使用队列时，可以通过**mq\_close**(3) 来关闭它，并且要是这个队列在将来也不会使用时，可以通过 **mq\_unlink**(3) 来删除它。队列属性可以通过**mq\_getattr**(3) 和 **mq\_setattr**(3) 来取得和更改(在一些情况下)。一个进程可以使用 **mq\_notify**(3) 在一个空的队列时请求异步的卡片消息到达通知。

一个消息队列描述符引用一个 *消息队列打开描述符* (参考 **open**(2))。在调用 **fork**(2) 之后，子进程继承了父亲消息队列描述符的复本，并且这些描述符引用与父亲中相应描述符相同消息队列打开描述符。在两个进程里相关描述符共享消息队列打开描述符相关的标志位(*mq\_flags*)。

每个消息都有一个相关的 *优先级*，并且高优先级的消息总是首先传递给接收进程。消息优先级范围在 0(低优先级) 到*sysconf(\_SC\_MQ\_PRIO\_MAX) - 1* (高优先级)。在 Linux 系统里，*sysconf(\_SC\_MQ\_PRIO\_MAX)* 返回 32768，但是 POSIX.1-2001 只要求实现提供优先级范围 0 到 31；一些实现只提供了这个范围。

版本POSIX 消息队列 Linux 内核从 2.6.6 开始支持。Glibc 从版本 2.3.4 开始支持。 内核选项对 POSIX 消息队列的支持可以内核配制选项**CONFIG\_POSIX\_MQUEUE** 来控制。这个选项在默认是打开的。 生命期(持续性)POSIX 消息队列是内核生命期的；如果没有使用**mq\_unlink**(3) 删除的话，一个消息队列会一直存在，直到系统关闭。 链接使用 POSIX 消息队列 API 的程序必须在链接的时候加入选项 *cc -lrt* 来链接实时库，*librt*。 /proc 接口下列接口可以用于限制 POSIX 消息队列消耗的内存数目： /proc/sys/fs/mqueue/msg\_max 这个文件可以用于查看和更改队列里缓存的软最大消息数目。这个值是 **mq\_open**(3) 中参数 *attr->mq\_maxmsg* 的软上限。*msg\_max* 的默认值是 10。最小允许的值是 1(在内核 2.6.28 前是 10)。物理上限是 **HARD\_MAX**：*(131072 / sizeof(void \*))* (在 Linux/86 上是 32678)。这个软限制可以被特权(**CAP\_SYS\_RESOURCE**)进程忽略，但是 **HARD\_MAX** 不能被突破。 /proc/sys/fs/mqueue/msgsize\_max 这个文件可以用于查看和更改最大消息长度的软上限。这个值作用于 **mq\_open**(3) 的参数 *attr->mq\_msgsize*。*msgsize\_max* 的默认值是 8192 个字节。允许的最小值是 128(在 2.6.28 内核之前是 8192)。*msgsize\_max* 的上限是 1,048,576(内核 2.6.28 之前上限是 **INT\_MAX**：对于 Linux/86 而言是 2,147,483,647 )。这个限制可以被特权(**CAP\_SYS\_RESOURCE**)进程忽略。 /proc/sys/fs/mqueue/queues\_max 这个文件可以用于查看和更改系统范围内的消息队列个数的限制。一旦这个限制达到了，只有特权进程(**CAP\_SYS\_RESOURCE**)可以创建新的队列。*queues\_max* 的默认值是 256，它可以被更改为 0 到 INT\_MAX 的任何值。资源限制**RLIMIT\_MSGQUEUE** 是一个资源限制值，它限制进程真实 UID 可以用于消息的最大内存数目。在 **getrlimit**(2) 中有详细说明。 挂载消息队列文件系统在 Linux 系统里，已创建的消息队列在一个虚拟的文件系统里。(其它实现可能也提供类似的特性，但具体细节可能不同。)这个文件系统可以(被超级用户)使用下面命令挂载： \#** mkdir /dev/mqueue** \#** mount -t mqueue none /dev/mqueue** 粘滞位会自动在挂载的目录打开。

一旦这个文件系统被挂载，系统里的消息队列就可以使用大家熟悉的命令(如 **ls**(1) 和 **rm**(1))来查看和维护了。

目录里的每一个文件都只包含相应队列信息一行内容：

$** cat /dev/mqueue/mymq**

QSIZE:129 NOTIFY:2 SIGNO:0 NOTIFY\_PID:8260

这些域的含意如下： QSIZE 队列里所有消息的总字节数 NOTIFY\_PID 如果这不是零，那么 进程号为 PID 进程已经使用 **mq\_notify**(3) 来注册异步消息通知，并且剩余的域用来描述通知如何发出。 NOTIFY 通知方式：0 是 **SIGEV\_SIGNAL**；1 是 **SIGEV\_NONE**；以及 2 是**SIGEV\_THREAD**。 SIGNO 对于 **SIGEV\_SIGNAL** 方式所使用信号数字。轮询消息队列描述符在 Linux 里，一个消息队列描述符是一个真实的文件描述符，冻僵可以使用 **select**(2)、**poll**(2) 或 **epoll**(7) 来监视。这不具移植性。

**mq\_overview** - POSIX 消息队列概述

描述POSIX 消息队列允许进程以消息的形式交换数据。这组 API 与 System V 的消息队列(**msgget**(2)、**msgsnd**(2)、**msgrcv**(2) 等等)有所不同，但是提供了相似的功能。

POSIX 消息队列 Linux 内核从 2.6.6 开始支持。Glibc 从版本 2.3.4 开始支持。 内核选项对 POSIX 消息队列的支持可以内核配制选项**CONFIG\_POSIX\_MQUEUE** 来控制。这个选项在默认是打开的。 生命期(持续性)POSIX 消息队列是内核生命期的；如果没有使用**mq\_unlink**(3) 删除的话，一个消息队列会一直存在，直到系统关闭。 链接使用 POSIX 消息队列 API 的程序必须在链接的时候加入选项 *cc -lrt* 来链接实时库，*librt*。 /proc 接口下列接口可以用于限制 POSIX 消息队列消耗的内存数目： /proc/sys/fs/mqueue/msg\_max 这个文件可以用于查看和更改队列里缓存的软最大消息数目。这个值是 **mq\_open**(3) 中参数 *attr->mq\_maxmsg* 的软上限。*msg\_max* 的默认值是 10。最小允许的值是 1(在内核 2.6.28 前是 10)。物理上限是 **HARD\_MAX**：*(131072 / sizeof(void \*))* (在 Linux/86 上是 32678)。这个软限制可以被特权(**CAP\_SYS\_RESOURCE**)进程忽略，但是 **HARD\_MAX** 不能被突破。 /proc/sys/fs/mqueue/msgsize\_max 这个文件可以用于查看和更改最大消息长度的软上限。这个值作用于 **mq\_open**(3) 的参数 *attr->mq\_msgsize*。*msgsize\_max* 的默认值是 8192 个字节。允许的最小值是 128(在 2.6.28 内核之前是 8192)。*msgsize\_max* 的上限是 1,048,576(内核 2.6.28 之前上限是 **INT\_MAX**：对于 Linux/86 而言是 2,147,483,647 )。这个限制可以被特权(**CAP\_SYS\_RESOURCE**)进程忽略。 /proc/sys/fs/mqueue/queues\_max 这个文件可以用于查看和更改系统范围内的消息队列个数的限制。一旦这个限制达到了，只有特权进程(**CAP\_SYS\_RESOURCE**)可以创建新的队列。*queues\_max* 的默认值是 256，它可以被更改为 0 到 INT\_MAX 的任何值。资源限制**RLIMIT\_MSGQUEUE** 是一个资源限制值，它限制进程真实 UID 可以用于消息的最大内存数目。在 **getrlimit**(2) 中有详细说明。 挂载消息队列文件系统在 Linux 系统里，已创建的消息队列在一个虚拟的文件系统里。(其它实现可能也提供类似的特性，但具体细节可能不同。)这个文件系统可以(被超级用户)使用下面命令挂载： \#** mkdir /dev/mqueue** \#** mount -t mqueue none /dev/mqueue** 粘滞位会自动在挂载的目录打开。

一旦这个文件系统被挂载，系统里的消息队列就可以使用大家熟悉的命令(如 **ls**(1) 和 **rm**(1))来查看和维护了。

目录里的每一个文件都只包含相应队列信息一行内容：

$** cat /dev/mqueue/mymq** QSIZE:129 NOTIFY:2 SIGNO:0 NOTIFY\_PID:8260 这些域的含意如下： QSIZE 队列里所有消息的总字节数 NOTIFY\_PID 如果这不是零，那么 进程号为 PID 进程已经使用 **mq\_notify**(3) 来注册异步消息通知，并且剩余的域用来描述通知如何发出。 NOTIFY 通知方式：0 是 **SIGEV\_SIGNAL**；1 是 **SIGEV\_NONE**；以及 2 是 **SIGEV\_THREAD**。 SIGNO 对于 **SIGEV\_SIGNAL** 方式所使用信号数字。轮询消息队列描述符在 Linux 里，一个消息队列描述符是一个真实的文件描述符，冻僵可以使用 **select**(2)、**poll**(2) 或**epoll**(7) 来监视。这不具移植性。 遵循于POSIX.1-2001. 注意System V 消息队列(**msgget**(2)、**msgsnd**(2)、**msgrcv**(2) 等等)是一组老的用于进程交互消息的 API 。POSIX 消息队列提供了一组优于 System V 消息队列的接口设计；另一方面 POSIX 消息队列又不如 System V 消息队列受到的支持程度好(尤其是老的系统里)。

目前(2.6.26) Linux 不支持在 POSIX 消息队列里应用访问控制列表(ACLs)。

**====================================================**

**消息队列system v接口API**

**int msgget(key\_t *key*, int *msgflg*);**

**描述**

**msgget**() 系统调用返回一个与参数 *key* 相关联的消息队列标识符。如果这个 *key*是值 **IPC\_PRIVATE** 或 *key* 不是**IPC\_PRIVATE** 而又不存在关联于给定*key* 的消息队列并且 **IPC\_CREAT** 在 *msgflg*中指定，那么一个新的消息队列被创建。

如果 *msgflg* 同时指定了 **IPC\_CREAT** 和 **IPC\_EXCL** 并且一个关联*key* 的消息队列存在，则 **msgget**() 将失败并且设置*errno* 为**EEXIST**。(这与 **open**(2) 组合**O\_CREAT | O\_EXCL** 有相同效果。)

如果创建了消息，则参数 *msgflg* 有意义的最后几个位定义了消息队列的权限。这些权限位的格式与语义同**open**(2) 中的*mode*参数相同。(执行权限没有使用。)

如果新消息队列被创建了，那么它关联的 *msqid\_ds* 结构(参考 **msgctl**(2))按如下方式初始化：

*msg\_perm.cuid* 和 *msg\_perm.uid* 被设置用调用进程的有效用户ID。

*msg\_perm.cgid* 和 *msg\_perm.gid* 设置为调用进程的有效组 ID。

*msg\_perm.mode* 最后有效的 9 个位使用 *msgflg* 最后有效的 9个位来设置。

*msg\_qnum*、*msg\_lspid*、*msg\_lrpid*、*msg\_stime*和 *msg\_rtime* 都设置为 0。

*msg\_ctime* 设置为当前时间。

*msg\_qbytes* 设置为系统限制 **MSGMNB**。

如果一个消息队列已经存在并且权限认证通过，则会额外查看一下队列是不是被标志为释放。

返回值如果成功，返回值将是消息队列标识符(一个非负整数)，否则的话 -1 被返回并设置 *errno* 来指明错误。错误如果失败，*errno* 可能被设置为如下值：EACCES已经有一个关联于 *key* 的消息队列，但是调用进程没有对这个队列的访问权限，同时这个进程没有**CAP\_IPC\_OWNER** 特权。

EEXIST关联 *key* 的消息队列已经存在而 *msgflg* 却同时设置了 **IPC\_CREAT**和 **IPC\_EXCL**。

ENOENT不存在关联于 *key* 的消息队列可 *msgflg* 没有指定**IPC\_CREAT**。

ENOMEM必需创建一个消息队列但系统没有足够的内存来建立相应的数据结构。

ENOSPC必需创建一个消息队列但是系统允许的最大消息队列个数(**MSGMNI**) 已经达到。遵循于SVr4, POSIX.1-2001。注意**IPC\_PRIVATE** 不是一个标志域而一个 *key\_t* 类型的值。如果使用这一个特殊值作为*key*，*msgflg* 除了最后 9 位以外的其它内容都会被系统调用忽略，并且新建一个(成功)消息。

下面是一些对 **msgget**() 有效果的系统限制：

MSGMNI系统范围内的消息队列最大数目：策略相关的(在 Linux 系统里，这个限制可能通过*/proc/sys/kernel/msgmni*读取和悠。

**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);**

参数：   
msqid：消息队列的识别码。  
msgp：指向消息缓冲区的指针，此位置用来暂时存储发送和接收的消息，是一个用户可定义的通用结构，形态如下

struct msgbuf \{  
long mtype;   
char mtext\[1\];   
\};

msgsz：消息的大小。  
msgtyp：从消息队列内读取的消息形态。如果值为零，则表示消息队列中的所有消息都会被读取。  
msgflg：用来指明核心程序在队列没有数据的情况下所应采取的行动。如果msgflg和常数IPC\_NOWAIT合用，则在msgsnd()执行时若是消息队列已满，则msgsnd()将不会阻塞，而会立即返回-1，如果执行的是msgrcv()，则在消息队列呈空时，不做等待马上返回-1，并设定错误码为ENOMSG。当msgflg为0时，msgsnd()及msgrcv()在队列呈满或呈空的情形时，采取阻塞等待的处理模式。

返回说明：   
成功执行时，msgsnd()返回0，msgrcv()返回拷贝到mtext数组的实际字节数。失败两者都返回-1，errno被设为以下的某个值  
\[对于msgsnd\]   
EACCES：调用进程在消息队列上没有写权能，同时没有CAP\_IPC\_OWNER权能  
EAGAIN：由于消息队列的msg\_qbytes的限制和msgflg中指定IPC\_NOWAIT标志，消息不能被发送  
EFAULT：msgp指针指向的内存空间不可访问  
EIDRM：消息队列已被删除  
EINTR：等待消息队列空间可用时被信号中断  
EINVAL：参数无效  
ENOMEM：系统内存不足，无法将msgp指向的消息拷贝进来  
\[对于msgrcv\]  
E2BIG：消息文本长度大于msgsz，并且msgflg中没有指定MSG\_NOERROR  
EACCES：调用进程没有读权能，同时没具有CAP\_IPC\_OWNER权能  
EAGAIN：消息队列为空，并且msgflg中没有指定IPC\_NOWAIT  
EFAULT：msgp指向的空间不可访问  
EIDRM：当进程睡眠等待接收消息时，消息已被删除  
EINTR：当进程睡眠等待接收消息时，被信号中断  
EINVAL：参数无效  
ENOMSG：msgflg中指定了IPC\_NOWAIT，同时所请求类型的消息不存在

**int msgctl(int msqid, int cmd, struct msqid\_ds \*buf)**

msgctl 系统调用对 msgqid 标识的消息队列执行 cmd 操作，系统定义了 3 种 cmd 操作： IPC\_STAT ,  IPC\_SET , IPC\_RMID ，意义分别如下：

*  IPC\_STAT :  该命令用来获取消息队列对应的 msqid\_ds 数据结构，并将其保存到 buf  指定的地址空间。
 *  IPC\_SET :    该命令用来设置消息队列的属性，要设置的属性存储在 buf 中，可设置的属性包括： msg\_perm.uid , msg\_perm.gid , msg\_perm.mode 以及 msg\_qbytes .
 *  IPC\_RMID :  从内核中删除 msqid 标识的消息队列。

当cmd是IPC\_RMID时，buf指定为NULL，对msqid对应的消息队列进行删除

当cmd是IPC\_SET 时，将buf  set为  msqid对应的消息队列

当cmd是IPC\_STAT ,将msqid对应的消息队列 get到buf

[mq_sen]: http://blog.chinaunix.net/link.php?url=http://cpp.ezbty.org%2Fimport_doc%2Flinux_manpage%2Fmq_send.3.html