标签：
消息队列可以认为是一个链表。进程（线程）可以往里写消息，也可以从里面取出消息。一个进程可以往某个消息队列里写消息，然后终止，另一个进程随时可以从消息队列里取走这些消息。这里也说明了，消息队列具有随内核的持续性，也就是系统不重启，消息队列永久存在。
1、创建/获取一个消息队列
#include <fcntl.h> /* For O_* constants */ #include <sys/stat.h> /* For mode constants */ #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);
参数:
name: 消息队列名字;
注意-Posix IPC名字限制:
1. 必须以”/”开头, 并且后面不能还有”/”, 形如:/file-name（为了便于移植）;
2. 名字长度不能超过NAME_MAX
oflag: 与open函数类型, 可以是O_RDONLY, O_WRONLY, O_RDWR, 还可以按位或，除此之外还可以指定O_CREAT（没有该对象则创建）、O_EXCL（如果O_CREAT指定，但name不存在，
就返回错误），O_NONBLOCK（以非阻塞方式打开消息队列，在正常情况下mq_receive和mq_send函数会阻塞的地方，使用该标志打开的消息队列会返回EAGAIN错误）。
当操作一个新队列时，使用O_CREAT标识，此时后面两个参数需要被指定，
mode: mode为指定权限位
attr: 指定新创建消息队列的属性;
返回值:
成功: 返回消息队列文件描述符;
失败: 返回-1;注意：使用此函数后，编译链接时需要 link with -lrt
2、关闭一个消息队列
#include <mqueue.h>
int mq_close(mqd_t mqdes);
Link with -lrt.
关闭之后调用进程不在使用该描述符，但消息队列不会从系统中删除，进程终止时，会自动关闭已打开的消息队列，和调用mq_close一样。
参数为mq_open()函数返回的值。
3、删除一个消息队列
#include <mqueue.h> int mq_unlink(const char *name); Link with -lrt.
删除会马上发生，即使该队列的描述符引用计数仍然大于0。
参数为mq_open()函数第一个参数。
4、获取/设置消息队列属性
#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);
Link with -lrt.
struct mq_attr {
long mq_flags; /* Flags: 0 or O_NONBLOCK */
long mq_maxmsg; /* Max. # of messages on queue */
long mq_msgsize; /* Max. message size (bytes) */
long mq_curmsgs; /* # of messages currently in queue */
};
5、发送/读取消息
mq_send() 函数 和mq_receive()函数分别用于向消息队列放置和取走消息。
#include <mqueue.h>
int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio);
ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_prio);
Link with -lrt.
6、建立/删除异步通知事件
Posix消息队列容许异步事件通知，以告知何时有一个消息放置到某个空消息队列中，这种通知有两种方式可以选择:
（1）产生一个信号
（2）创建一个线程来执行一个指定的函数
注意: 这种注册的方式只是在消息队列从空到非空时才产生消息通知事件, 而且这种注册方式是一次性的!
#include <mqueue.h>
int mq_notify(mqd_t mqdes, const struct sigevent *sevp);
Link with -lrt.
参数sevp:
(1)如果sevp参数为非空，那么当前进程希望在有一个消息到达所指定的先前为空的对列时得到通知。
//sigevent结构体
struct sigevent
{
int sigev_notify; /* Notification method */
int sigev_signo; /* Notification signal */
union sigval sigev_value; /* Data passed with notification */
void (*sigev_notify_function) (union sigval); /* Function used for thread notification (SIGEV_THREAD) */
void *sigev_notify_attributes; /* Attributes for notification thread (SIGEV_THREAD) */
pid_t sigev_notify_thread_id; /* ID of thread to signal (SIGEV_THREAD_ID) */
};
union sigval /* Data passed with notification */
{
int sival_int; /* Integer value */
void *sival_ptr; /* Pointer value */
};
sigev_notify代表通知的方式: 一般常用两种取值:SIGEV_SIGNAL, 以信号方式通知; SIGEV_THREAD, 以线程方式通知
如果以信号方式通知: 则需要设定一下两个参数:
sigev_signo: 信号的代码
sigev_value: 信号的附加数据(实时信号)
如果以线程方式通知: 则需要设定以下两个参数:
sigev_notify_function
sigev_notify_attributes
查看已经成功创建的Posix消息队列
#其存在与一个虚拟文件系统中, 需要将其挂载到系统中才能查看
Mounting the message queue filesystem On Linux, message queues are created in a virtual filesystem.
(Other implementations may also provide such a feature, but the details are likely to differ.) This
file system can be mounted (by the superuser, 注意是使用root用户才能成功) using the following commands:
mkdir /dev/mqueue
mount -t mqueue none /dev/mqueue
还可以使用cat查看该消息队列的状态, rm删除:
cat /dev/mqueue/abc
rm abc
还可umount该文件系统
umount /dev/mqueue
细说linux IPC（九）：posix消息队列 http://blog.csdn.net/shallnet/article/details/41749613
Linux IPC实践(7) --Posix消息队列 http://blog.csdn.net/zjf280441589/article/details/43878041
Posix消息队列——mq_notify函数 http://www.xuebuyuan.com/1694248.html
POSIX消息队列的异步通信机制 http://blog.csdn.net/bat603/article/details/19978025
标签：
原文地址：http://www.cnblogs.com/wujing-hubei/p/5763028.html
