Posix消息队列
一、函數(shù)
mq_open
頭文件
mqueue.h；
?
原型
mqd_t mq_open(const char *name, int oflag, .../*mode_t mode,struct mq_attr* attr*/);
?
函數(shù)功能
創(chuàng)建消息隊(duì)列；
?
參數(shù)
name?：消息隊(duì)列的名字，根據(jù)消息隊(duì)列的規(guī)則，為了更好的可移植性，該名字必須以‘／’開頭，創(chuàng)建一個消息隊(duì)列的時候無須路徑，給出名字就好，其存放位置可有自己指定(創(chuàng)建前后都可以)。
?
oflag：O_RDONLY（只讀）?O_WRONLY（只寫）?O_RDWR（可讀可寫）O_CREAT（創(chuàng)建）?O_EXCL?（當(dāng)消息已存在時，返回EEXIST錯誤到errno中）O_NONBLOCK（設(shè)置非阻塞）
?
mode：在oflag中指定O_CREAT時，此參數(shù)是需要的。表示創(chuàng)建消息隊(duì)列的權(quán)限，S_IRUSR,S_IWUSR,S_IXUSR,S_IRGRP,S_IWGRP,S_IXGRP,S_IROTH,S_IWOTH,S_IXOTH相或組成或者寫成0777(表示rwxrwxrwx)等用八進(jìn)制表示也可以。
?
attr：在oflag中指定O_CREAT時，此參數(shù)是需要的。存放消息隊(duì)列的屬性。其中mq_flags為0，表示阻塞，為O_NONBLOCK為非阻塞。
(這里可以填寫哪些參數(shù)具體看：二、Posix IPC)
?
返回值
若創(chuàng)建成功則返回消息隊(duì)列的描述符，否則返回－1。
?
?
?
mq_close函數(shù)
頭文件
mqueue.h
原型
int mq_close(mqd_t mqdes);
函數(shù)功能
關(guān)閉已打開的消息隊(duì)列，關(guān)閉后調(diào)用進(jìn)程不可以再使用該描述符，但其消息隊(duì)列并沒有被刪除。一個進(jìn)程終止時，它的所有打開著的消息隊(duì)列都關(guān)閉，就像調(diào)用了mq_close一樣。
參數(shù)
mqdes?消息隊(duì)列的描述符，即消息隊(duì)列創(chuàng)建成功后的返回值。
返回值
成功返回0，失敗返回-1。
?
?
mq_unlink
頭文件
mqueue.h
原型
int mq_unlink(const char *name);
函數(shù)功能
從系統(tǒng)中刪除名為name的消息隊(duì)列，但刪除的只是我們可以在系統(tǒng)中看見的文件的名字，但文件本身并沒有被從磁盤上刪除，除非該名稱是文件的最后一個鏈接，并且該文件已關(guān)閉，才會將該文件真正從磁盤上刪除。即如果某前該詳細(xì)隊(duì)列的文件還在其他進(jìn)程中打開，那么不會將其從磁盤上刪除，又或者這是最后一個鏈接，但它還為關(guān)閉，即未執(zhí)行ma_close操作，或打開它的進(jìn)程為結(jié)束就執(zhí)行mq_unlink，它也不會從磁盤上刪除。
參數(shù)
name消息隊(duì)列的名稱，以‘／’開始。
返回值
成功返回0，出錯返回－1。
?
?
mq_getattr
頭文件
mqueue.h
原型
int mq_getattr(mqd_t mqdes, struct mq_attr *attr);
函數(shù)功能
獲取mqdes指的消息隊(duì)列的屬性，存放到attr結(jié)構(gòu)體中。
struct mq_attr
{
?
long int mq_flags;????/* Message queue flags：0，O_NONBLOCK */
long int mq_maxmsg;???/* Maximum number of messages.??*/
long int mq_msgsize;??/* Maximum message size.??*/
long int mq_curmsgs;??/* Number of messages currently queued.??*/
long int __pad[4];
?
};
參數(shù)
mqdes為消息隊(duì)列描述符，attr為上面解釋的存放消息隊(duì)列屬性的結(jié)構(gòu)體。
返回值
成功返回0，失敗返回－1。
?
?
mq_setattr
頭文件
mqueue.h
原型
int mq_setattr(mqd_t mqdes, const struct mq_attr *attr,
?struct mq_attr *oattr);
函數(shù)功能
設(shè)置消息隊(duì)列的屬性，但是只使用attr結(jié)構(gòu)體中的mq_flags屬性，以設(shè)置(O_NONBLOCK)或清除(0)非阻塞標(biāo)志。該結(jié)構(gòu)體的另外三個屬性被忽略，每個隊(duì)列的最大消息數(shù)和每個消息的最大字節(jié)數(shù)都只能在創(chuàng)建時設(shè)置，當(dāng)前隊(duì)列中的消息數(shù)是隨傳送消息和讀取消息的操作改變的，只能讀取不能設(shè)置。如果oattr非空，那么指定隊(duì)列的先前屬性(4個)全將返回到由該指針指向的結(jié)構(gòu)體中。
參數(shù)
mqdes?消息隊(duì)列的屬性
attr?函數(shù)功能解釋中
oattr?函數(shù)功能解釋中
返回值
成功返回0，失敗返回－1。
?
?
?
mq_send
頭文件
mqueue.h
原型
int mq_send(mqd_t mqdes, const char *ptr, size_t len,
?unsigned int prio);
函數(shù)功能
給描述符mqdes指向的消息隊(duì)列發(fā)送消息，大小為len，內(nèi)容存放在ptr中，prio為優(yōu)先級。
參數(shù)
mqdes為要發(fā)送消息的消息隊(duì)列描述符;
ptr為要發(fā)送的數(shù)據(jù);
len為消息的長度;
prio為消息的優(yōu)先級;
返回值
成功返回0，失敗返回－1。
?
?
mq_receive
頭文件
mqueue.h
原型
ssize_t mq_receive(mqd_t mqdes, char *ptr, size_t len,
?unsigned int *proip);
函數(shù)功能
從描述符mqdes指向的消息隊(duì)列中讀取消息存放ptr中。
參數(shù)
mqdes為要從中讀取消息的消息隊(duì)列的描述符;
ptr為存放接受到的消息的指針;
len為接受的最大長度;
該值不能小于能加到該消息對列上的最大大小，如果len小于該值，就立即返回EMSGSIZE錯誤。
返回值
成功返回讀取消息的內(nèi)容的字節(jié)數(shù)，出錯返回－1。
?
?
mq_notify
頭文件
mqueue.h;
signal.h;
原型
int mq_notify(mqd_t mqdes, const struct sigevent *notification);
函數(shù)功能
為指定隊(duì)列建立或刪除異步事件通知。
參數(shù)
在<signal.h>中：
???typedef union sigval {
????????int sival_int;
????????void __user *sival_ptr;
} sigval_t;
typedef struct sigevent {
????????sigval_t sigev_value;
????????int sigev_signo;
????????int sigev_notify;
????????void??(*sigev_notify_function)(union sigval);
????????Pthread_attr_t *sigev_notify_attributes;
} sigevent_t;
(1).如果notification參數(shù)非空，那么當(dāng)前進(jìn)程希望在有一個消息到達(dá)所指定的先前為空的隊(duì)列時得到通知。我們說“該進(jìn)程被注冊為接收該隊(duì)列的通知”。
(2).如果notification參數(shù)為空指針，而且當(dāng)前進(jìn)程目前被注冊為接收所指定隊(duì)列的通知，那么已存在的注冊將被撤銷。
(3).任意時刻只有一個進(jìn)程可以被注冊為接收某個指定隊(duì)列的通知。
(4).當(dāng)有一個消息到達(dá)某個先前為空的隊(duì)列，而且已有一個進(jìn)程被注冊為接收該隊(duì)列的通知時，只有在沒有任何線程阻塞在該隊(duì)列的mq_receive調(diào)用中的前提下，通知才會發(fā)出。這就是說，在mq_receive調(diào)用中的阻塞比任何通知的注冊都優(yōu)先。
(5).當(dāng)該通知被發(fā)送給它的注冊進(jìn)程時，其注冊即被撤銷。該進(jìn)程必須再次調(diào)用mq_notify重新注冊(如果想要的話)。
返回值
成功返回0，失敗返回－1。
轉(zhuǎn)載于:https://www.cnblogs.com/caiguoqing/p/4963264.html
總結(jié)
- 上一篇： 初步剖析SDN架构
- 下一篇： sockjs.js:1609 GET h