1.1????????Posix消息隊(duì)列

1.1.1???????消息隊(duì)列的創(chuàng)建和刪除

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 )

創(chuàng)建或獲取一個(gè)消息隊(duì)列。成功返回消息隊(duì)列描述符；失敗返回-1。

參數(shù)name指定與消息隊(duì)列相關(guān)聯(lián)的名字。

參數(shù)flags可以取：

O_RDONLY???? O_WRONLY????? O_RDWR（三選一）

O_CREAT

單獨(dú)使用O_CREAT，如果不存在與name相關(guān)聯(lián)的消息隊(duì)列，就創(chuàng)建一個(gè)新的消息隊(duì)列，并返回其描述符，如果已經(jīng)存在與name相關(guān)聯(lián)的消息隊(duì)列，就返回該消息隊(duì)列的描述符。

如果指定了O_CREAT，需要使用mq_open( )的第二種形式，其中參數(shù)mode指定了新創(chuàng)建消息隊(duì)列的訪問權(quán)限，參數(shù)attr指定了新創(chuàng)建消息隊(duì)列的屬性。

O_EXCL。

單獨(dú)使用O_EXCL是沒有意義的，如果O_EXCL和O_CREAT一起使用，當(dāng)與name相關(guān)聯(lián)的消息隊(duì)列已經(jīng)存在時(shí)，就失敗返回。

O_NONBLOCK

決定在mq_send( )和mq_receive( )時(shí)是否會(huì)掛起當(dāng)前進(jìn)程，直到讀取或發(fā)送消息成功。

1.1.1.2????? mq_close( )

#include <mqueue.h>

int mq_close( mqd_t mqdes )

關(guān)閉當(dāng)前進(jìn)程和指定消息隊(duì)列之間的聯(lián)系。

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

1.1.1.3????? mq_unlink( )

#include <mqueue.h>

int mq_unlink( const char *name )

刪除指定的消息隊(duì)列，但是如果當(dāng)前仍有其它進(jìn)程正在使用消息隊(duì)列，則暫時(shí)放棄刪除操作，并立即返回，直到其它進(jìn)程通過調(diào)用mq_close( )關(guān)閉之后，再進(jìn)行刪除操作。

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

1.1.2???????消息隊(duì)列的屬性

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)

注意：只能設(shè)定mq_attr結(jié)構(gòu)中的mq_flags，mq_attr結(jié)構(gòu)中的其它成員將被忽略。

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

1.1.3???????消息隊(duì)列的操作

1.1.3.1?????mq_notify()

#include<mqueue.h>

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

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

為當(dāng)前進(jìn)程在指定的消息隊(duì)列上注冊notify操作，當(dāng)消息隊(duì)列由空變?yōu)榉强諘r(shí)，也就是說有消息加入原本為空的消息隊(duì)列時(shí)，會(huì)觸發(fā)進(jìn)程注冊的nofity操作。

參數(shù)notification指定需要注冊的nofity操作。如果參數(shù)notification為NULL，而且進(jìn)程之前注冊過notify操作，會(huì)取消之前注冊的notify操作。

需要注意的是：

1．只能有唯一的一個(gè)進(jìn)程在消息隊(duì)列上注冊notify操作。如果已經(jīng)有其它進(jìn)程在消息隊(duì)列上注冊了notify操作，試圖再次進(jìn)行notify()會(huì)失敗返回；

2．當(dāng)進(jìn)程注冊的nofity操作被觸發(fā)之后，該nofity操作就會(huì)被刪除，其它進(jìn)程可以重新向該消息隊(duì)列注冊notify操作。

如果進(jìn)程已經(jīng)注冊過notify操作，而且進(jìn)程在消息隊(duì)列為空時(shí)，阻塞調(diào)用了mq_receive( )（即在mq_open()時(shí)設(shè)定了O_NONBLOCK），如果有一個(gè)消息到達(dá)，會(huì)先滿足mq_receive( )調(diào)用，所以消息隊(duì)列仍然為空，不會(huì)觸發(fā)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。

參數(shù)len指定讀取消息的長度，如果len＜attr(mq_msgsize)，失敗返回。

mq_open( )是否設(shè)定O_NONBLOCK，會(huì)決定mq_receive( )是否進(jìn)行阻塞讀取。

成功返回讀取消息的字節(jié)數(shù)，失敗返回-1。

1.2.3.3?????mq_send( )

#include<mqueue.h>

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

參數(shù)len指定發(fā)送消息的長度，如果len＞attr(mq_msgsize)，失敗返回。

參數(shù)prio＜MQ_PRIO_MAX。

mq_open( )是否設(shè)定O_NONBLOCK，會(huì)決定mq_send( )是否進(jìn)行阻塞發(fā)送。

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

?

2.1? Code

2.1.1 創(chuàng)建一個(gè)消息隊(duì)列

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 發(fā)送消息

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

?

轉(zhuǎn)載于:https://www.cnblogs.com/shaosli/p/5103054.html

總結(jié)

以上是生活随笔為你收集整理的POSIX 消息队列基础知识复习，以及相关例程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。