#include int msgget(key_t key, into flag);
該函數(shù)在執(zhí)行正常返回時,返回的是一個整數(shù)標識符,其他三個函數(shù)就用它來指代該隊列。該標識符是基于指定的key產(chǎn)生的,而key即可以是ftok的返回值,也可以是常值IPC_PRIVATE。
oflag可以是讀寫權限的值的組合,它還可以與IPC_CREAT或IPC_CREAT|IPC_EXCL按位或。
當創(chuàng)建一個新消息隊列時,msqid_ds結(jié)構的一些成員被初始化。
往一個打開的消息隊列上放置一個消息。
#include int msgsnd(int msqid, const void *ptr, size_t length, int flag);
該函數(shù)的第一參數(shù)msqid是由msgget的返回值提供。Ptr是一個結(jié)構指針,該結(jié)構可以如下定義:
struct my_msg{
long types;
char text[MAX_LENGTH];
}
該結(jié)構中的types是這個消息的類型,text這個數(shù)組就是發(fā)送的消息的正文部份。msgsnd的length參數(shù)以字節(jié)為單位指定待發(fā)送消息的長度。如果待發(fā)送消息的結(jié)構如上定義,則length的取值是sizeof(struct my_msg) – sizeof(long)。第四個參數(shù)flag即可以是0,也可以是IPC_NOWAIT。當flag是0時,使得msgsnd調(diào)用阻塞,如果是IPC_NOWAIT,使得msgsnd調(diào)用非阻塞。
使用msgrcv函數(shù)從某個消息隊列中讀出一個消息。
#include ssize_t smgrcv(int msqid, void *ptr, size_t length, long type, int flag);
其中ptr參數(shù)指定所接收消息的存放位置,和msgsnd一個,該指針指向緊挨在真正的消息數(shù)據(jù)之前返回的長整數(shù)類型字段。Length指定了由ptr指向的緩沖區(qū)中數(shù)據(jù)部分的大小,這是該函數(shù)能返回的最大數(shù)據(jù)量,該長度不包含消息類型占的字節(jié)數(shù)。type指定希望從消息隊列中讀出什么類型的消息,type以下的幾種取值有不同的效果,如下:
⑴、type為0時,則返回隊列中的第一個消息,也就是最早的那個消息。
⑵、type為大于0時,則返回其類型值為type的第一個消息。
⑶、type為小于0時,則返回其類型值小于或等于type參數(shù)的絕對值的消息中類型最小的第一個消息。flag的可能取值同msgsnd一樣,代表著同樣的意思。只不過msgrcv多了一個選擇,那就是MSG_NOERROR,如果設置了該位,當所接收消息的真正數(shù)據(jù)部分大于length參數(shù)時,msgrcv只截短數(shù)據(jù)部分,面不返回錯誤。該函數(shù)成功返回時,msgrcv返回的是所接收消息中數(shù)據(jù)的字節(jié)數(shù)。它不包括消息類型所占有字節(jié)數(shù)。
使用msgctl對消息隊列進行控制。
#include int msgctl(int msqid, int cmd, struct msqid_ds *buff);
該函數(shù)提供了三個控制命令,分別如下:
IPC_RMID 從系統(tǒng)中刪除由msqid指定的消息隊列,對于該命令,msgctl第三個參
數(shù)被忽略。
IPC_SET 給所指定的消息隊列設置其msqid_ds結(jié)構的幾個成員。
IPC_STAT 給調(diào)用者返回與所指定消息隊列對應的當前msqid_ds結(jié)構。