POSIX IPC名字限定：

必須以/打頭，並且後續不能有其它/ ，形如/somename

長度不能超過NAME_MAX

通過下面的命令將訊息佇列掛載到/dev/mqueue下，可通過cat/dev/mqueue/name檢視訊息佇列狀態

mount -t mqueue none /dev/mqueue

mq_open函式：

功能：用來建立和訪問一個訊息佇列

原型

mqd_t mq_open(const char *name, int oflag);

mqd_t mq_open(const char *name, int oflag, mode_tmode, struct mq_attr *attr);

引數

name: 某個訊息佇列的名字

oflag:與open函式類似，可以是O_RDONLY、O_WRONLY、O_RDWR，還可以按位或上O_CREAT、O_EXCL、O_NONBLOCK等。

mode:如果oflag指定了O_CREAT，需要設定mode。

返回值：成功返回訊息佇列檔案描述符；失敗返回-1

mq_unlink函式：

功能：刪除訊息佇列

原型

mqd_t mq_unlink(const char *name);

引數

name: 訊息佇列的名字

返回值：成功返回0；失敗返回-1

mq_getattr/mq_setattr函式：

功能：獲取/設定訊息佇列屬性

原型

mqd_t mq_getattr(mqd_t mqdes, struct mq_attr *attr);

mqd_t mq_setattr(mqd_t mqdes, struct mq_attr *newattr,struct mq_attr *oldattr);

返回值：成功返回0；失敗返回-1

mq_attr結構體：

struct mq_attr {

    longmq_flags;    /* Flags: 0 or O_NONBLOCK */

    longmq_maxmsg;   /* Max. # of messages onqueue */

    longmq_msgsize;  /* Max. message size (bytes)*/

    longmq_curmsgs;  /* # of messages currently inqueue */

};

mq_send函式：

功能：傳送訊息

原型

mqd_t mq_send(mqd_t mqdes, const char *msg_ptr, size_tmsg_len, unsigned msg_prio);

引數

mqdes:訊息佇列描述符

msg_ptr:指向訊息的指標

msg_len:訊息長度

msg_prio:訊息優先順序

返回值：成功返回0；失敗返回-1

mq_receive函式：

功能：接收訊息

原型

ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_tmsg_len, unsigned *msg_prio);

引數

mqdes:訊息佇列描述符

msg_ptr:返回接收到的訊息

msg_len:訊息長度

msg_prio:返回接收到的訊息優先順序

返回值：成功返回接收到的訊息位元組數；失敗返回-1

注意：返回指定訊息佇列中最高優先順序的最早訊息

mq_notify函式：

功能：建立或者刪除訊息到達通知事件

原型

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

引數

mqdes:訊息佇列描述符

notification：

非空表示當訊息到達且訊息佇列先前為空，那麼將得到通知;

NULL表示撤消已註冊的通知

返回值：成功返回0；失敗返回-1

通知方式：

產生一個訊號

建立一個執行緒執行一個指定的函式

union sigval {         /* Data passed with notification */

    int     sival_int;   /*Integer value */

    void   *sival_ptr;   /*Pointer value */

};

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 for thread notification */

    void       *sigev_notify_attributes;

                  /*Thread function attributes */

};

mq_notify注意：

任何時刻只能有一個程序可以被註冊為接收某個給定佇列的通知

當有一個訊息到達某個先前為空的佇列，而且已有一個程序被註冊為接收該佇列的通知時，只有沒有任何執行緒阻塞在該佇列的mq_receive呼叫的前提下，通知才會發出。

當通知被髮送給它的註冊程序時，其註冊被撤消。程序必須再次呼叫mq_notify以重新註冊（如果需要的話），重新註冊要放在從訊息佇列讀出訊息之前而不是之後。