進(jìn)程間通信之：消息隊列
加入技術(shù)交流群
表8.26列舉了msgctl()函數的語(yǔ)法要點(diǎn)。
表8.26 msgctl()函數語(yǔ)法要點(diǎn)
所需頭文件 | #includesys/types.h> #includesys/ipc.h> #includesys/shm.h> | |
函數原型 | intmsgctl(intmsgqid,intcmd,structmsqid_ds*buf) | |
函數傳入值 | msqid：消息隊列的隊列ID | |
cmd： 命令參數 | IPC_STAT：讀取消息隊列的數據結構msqid_ds，并將其存儲在buf指定的地址中 | |
IPC_SET：設置消息隊列的數據結構msqid_ds中的ipc_perm域（IPC操作權限描述結構）值。這個(gè)值取自buf參數 | ||
IPC_RMID：從系統內核中刪除消息隊列 | ||
buf：描述消息隊列的msgqid_ds結構類(lèi)型變量 | ||
函數返回值 | 成功：0 | |
出錯：-1 | ||
3．使用實(shí)例
這個(gè)實(shí)例體現了如何使用消息隊列進(jìn)行兩個(gè)進(jìn)程（發(fā)送端和接收端）之間的通信，包括消息隊列的創(chuàng )建、消息發(fā)送與讀取、消息隊列的撤消和刪除等多種操作。
消息發(fā)送端進(jìn)程和消息接收端進(jìn)程之間不需要額外實(shí)現進(jìn)程之間的同步。在該實(shí)例中，發(fā)送端發(fā)送的消息類(lèi)型設置為該進(jìn)程的進(jìn)程號（可以取其他值），因此接收端根據消息類(lèi)型確定消息發(fā)送者的進(jìn)程號。注意這里使用了函數fotk()，它可以根據不同的路徑和關(guān)鍵字產(chǎn)生標準的key。以下是消息隊列發(fā)送端的代碼：
/*msgsnd.c*/
#includesys/types.h>
#includesys/ipc.h>
#includesys/msg.h>
#includestdio.h>
#includestdlib.h>
#includeunistd.h>
#includestring.h>
#defineBUFFER_SIZE512
structmessage
{
longmsg_type;
charmsg_text[BUFFER_SIZE];
};
intmain()
{
intqid;
key_tkey;
structmessagemsg;
/*根據不同的路徑和關(guān)鍵字產(chǎn)生標準的key*/
if((key=ftok(.,'a'))==-1)
{
perror(ftok);
exit(1);
}
/*創(chuàng )建消息隊列*/
if((qid=msgget(key,IPC_CREAT|0666))==-1)
{
perror(msgget);
exit(1);
}
printf(Openqueue%dn,qid);
while(1)
{
printf(Entersomemessagetothequeue:);
if((fgets(msg.msg_text,BUFFER_SIZE,stdin))==NULL)
{
puts(nomessage);
exit(1);
}
msg.msg_type=getpid();
/*添加消息到消息隊列*/
if((msgsnd(qid,msg,strlen(msg.msg_text),0))0)
{
perror(messageposted);
exit(1);
}
if(strncmp(msg.msg_text,quit,4)==0)
{
break;
}
}
exit(0);
}
linux操作系統文章專(zhuān)題:linux操作系統詳解（linux不再難懂）
評論