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