1.1        Posix消息队列

1.1.1       消息队列的创建和删除

1.1.1.1     mq_open( )

#include<mqueue.h>

mqd_tmq_open( const char *name, int flag )

mqd_t mq_open( const char *name, int flag, mode_t mode, mq_attrattr )

创建或获取一个消息队列。成功返回消息队列描述符；失败返回-1。

参数name指定与消息队列相关联的名字。

参数flags可以取：

O_RDONLY     O_WRONLY      O_RDWR（三选一）

O_CREAT

单独使用O_CREAT，如果不存在与name相关联的消息队列，就创建一个新的消息队列，并返回其描述符，如果已经存在与name相关联的消息队列，就返回该消息队列的描述符。

如果指定了O_CREAT，需要使用mq_open( )的第二种形式，其中参数mode指定了新创建消息队列的访问权限，参数attr指定了新创建消息队列的属性。

O_EXCL。

单独使用O_EXCL是没有意义的，如果O_EXCL和O_CREAT一起使用，当与name相关联的消息队列已经存在时，就失败返回。

O_NONBLOCK

决定在mq_send( )和mq_receive( )时是否会挂起当前进程，直到读取或发送消息成功。

1.1.1.2      mq_close( )

#include <mqueue.h>

int mq_close( mqd_t mqdes )

关闭当前进程和指定消息队列之间的联系。

成功返回0，失败返回-1。

1.1.1.3      mq_unlink( )

#include <mqueue.h>

int mq_unlink( const char *name )

删除指定的消息队列，但是如果当前仍有其它进程正在使用消息队列，则暂时放弃删除操作，并立即返回，直到其它进程通过调用mq_close( )关闭之后，再进行删除操作。

成功返回0，失败返回-1。

1.1.2       消息队列的属性

1.1.2.1     mq_getattr( )

#include<mqueue.h>

intmq_getattr( mqd_t mqdes, struct mq_attr *attr )

成功返回0，失败返回-1。

struct mq_attr

{

long       mq_flags；         //message queue flags

long       mq_maxmsg;       //maximum number of messages

long       mq_msgsize; // maximummessage size

long       mq_curmsgs;       // numberof messages currently queued

}

1.1.2.2     mq_setattr( )

#include<mqueue.h>

intmq_setattr( mqd_t mqdes, const struct mq_attr *newAttr, struct mq_attr *oldAttr)

注意：只能设定mq_attr结构中的mq_flags，mq_attr结构中的其它成员将被忽略。

成功返回0，失败返回-1。

1.1.3       消息队列的操作

1.1.3.1     mq_notify()

#include<mqueue.h>

int mq_notify( mqd_t mqdes, const struct sigevent*notification )

成功返回0，失败返回-1。

为当前进程在指定的消息队列上注册notify操作，当消息队列由空变为非空时，也就是说有消息加入原本为空的消息队列时，会触发进程注册的nofity操作。

参数notification指定需要注册的nofity操作。如果参数notification为NULL，而且进程之前注册过notify操作，会取消之前注册的notify操作。

需要注意的是：

1．只能有唯一的一个进程在消息队列上注册notify操作。如果已经有其它进程在消息队列上注册了notify操作，试图再次进行notify()会失败返回；

2．当进程注册的nofity操作被触发之后，该nofity操作就会被删除，其它进程可以重新向该消息队列注册notify操作。

如果进程已经注册过notify操作，而且进程在消息队列为空时，阻塞调用了mq_receive( )（即在mq_open()时设定了O_NONBLOCK），如果有一个消息到达，会先满足mq_receive( )调用，所以消息队列仍然为空，不会触发notify操作。

struct sigevent

{

int   sigev_notify;

int   sigev_signo;  // signal numbersent to current process when the timer expires

union sigval         sigev_value;  // info carried with signal

NotifyFUN         sigev_notify_function;      //typedef  void (*NotifyFUN)( union sigval)

pthread_attr_t*   sigev_notify_attributes;

}

sigev_notify的取值：

SIGEV_NONE        ：No notification will be delivered when the event ofinterest occurs.

SIGEV_SIGNAL     ：A queued signal will be generated when theevent of interest occurs.

SIGEV_THREAD   ：A notification function will be called toperform notification.

1.2.3.2     mq_receive( )

#include<mqueue.h>

ssize_tmq_receive( mqd_t mqdes, char *msg, size_t len, unsigned int *prio )

读取the oldest of the highest priority message。

参数len指定读取消息的长度，如果len＜attr(mq_msgsize)，失败返回。

mq_open( )是否设定O_NONBLOCK，会决定mq_receive( )是否进行阻塞读取。

成功返回读取消息的字节数，失败返回-1。

1.2.3.3     mq_send( )

#include<mqueue.h>

intmq_send( mqd_t mqdes, const char *msg, size_t len, unsigned int prio )

参数len指定发送消息的长度，如果len＞attr(mq_msgsize)，失败返回。

参数prio＜MQ_PRIO_MAX。

mq_open( )是否设定O_NONBLOCK，会决定mq_send( )是否进行阻塞发送。

成功返回0，失败返回-1。

2.1  Code

2.1.1 创建一个消息队列

 1 /*
 2 @Author: shaosli
 3 @data: 2016/1/5
 4 @function: test create mq of posxi
 5 */
 6
 7 #include <stdio.h>
 8 #include <stdlib.h>
 9 #include <unistd.h>
10 #include <mqueue.h>
11 #include <fcntl.h>
12 #include <errno.h>
13 #include <sys/stat.h>
14
15 int main( int argc, char* argv[])
16 {
17
18     mqd_t mqd;
19     struct mq_attr attr;
20     int flags = O_RDWR | O_CREAT | O_EXCL;
21     char *pdName = "/mqu";
22     printf("create mqueue.\n");
23     //create a new queue.
24     if( mqd = mq_open(pdName, flags, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH, NULL) == -1)
25     {
26         perror("open failure.");
27         exit(-1);
28     }
29
30     mq_getattr(mqd, &attr);
31     printf("max msgs = %ld, mq_msgsize = %ld,mq_curmsgs = %ld\n", attr.mq_maxmsg, attr.mq_msgsize, attr.mq_curmsgs);
32     mq_close(0);
33     return 0;
34 }

View Code

2.1.2 发送消息

 1 /*
 2 @Author: shaosli
 3 @data: 2016/1/5
 4 @function: test send mq of posxi
 5 */
 6 #include <stdio.h>
 7 #include <stdlib.h>
 8 #include <unistd.h>
 9 #include <mqueue.h>
10 #include <fcntl.h>
11 #include <errno.h>
12 #include <sys/stat.h>
13
14 int main()
15 {
16     mqd_t mqd;
17     char *pdName = "/mqu";
18     char* ptr = "hi";
19     mqd = mq_open(pdName, O_WRONLY);
20
21     if( mq_send(mqd, ptr, 10, 10) == -1)
22     {
23         perror("mq_send(),error.");
24         exit(-1);
25     }
26
27     return 0;
28 }

View Code

2.1.3 接受消息

 1 /*
 2 @Author: shaosli
 3 @data: 2016/1/5
 4 @function: test receive mq of posxi
 5 */
 6 #include <stdio.h>
 7 #include <stdlib.h>
 8 #include <unistd.h>
 9 #include <mqueue.h>
10 #include <fcntl.h>
11 #include <errno.h>
12 #include <sys/stat.h>
13
14 int main()
15 {
16     mqd_t mqd;
17     int priot, n;
18     struct mq_attr attr;
19     char *pdName = "/mqu";
20     mqd = mq_open(pdName, O_RDONLY);
21
22     mq_getattr(mqd, &attr);
23     char *buf = malloc(10);
24
25     if( (n = mq_receive(mqd, buf, attr.mq_msgsize,  &priot)) == -1)
26     {
27         perror("mq_receive(),error.");
28         exit(-1);
29     }
30     printf("priot = %d, recbuf=%s, attr.mq_msgsize =%ld", priot, buf,attr.mq_msgsize);
31
32     return 0;
33 }

View Code