進(jìn)程間通信之：消息隊(duì)列
加入技術(shù)交流群
表8.26列舉了msgctl()函數(shù)的語(yǔ)法要點(diǎn)。
表8.26 msgctl()函數(shù)語(yǔ)法要點(diǎn)
所需頭文件 | #includesys/types.h> #includesys/ipc.h> #includesys/shm.h> | |
函數(shù)原型 | intmsgctl(intmsgqid,intcmd,structmsqid_ds*buf) | |
函數(shù)傳入值 | msqid：消息隊(duì)列的隊(duì)列ID | |
cmd： 命令參數(shù) | IPC_STAT：讀取消息隊(duì)列的數(shù)據(jù)結(jié)構(gòu)msqid_ds，并將其存儲(chǔ)在buf指定的地址中 | |
IPC_SET：設(shè)置消息隊(duì)列的數(shù)據(jù)結(jié)構(gòu)msqid_ds中的ipc_perm域（IPC操作權(quán)限描述結(jié)構(gòu)）值。這個(gè)值取自buf參數(shù) | ||
IPC_RMID：從系統(tǒng)內(nèi)核中刪除消息隊(duì)列 | ||
buf：描述消息隊(duì)列的msgqid_ds結(jié)構(gòu)類型變量 | ||
函數(shù)返回值 | 成功：0 | |
出錯(cuò)：-1 | ||
3．使用實(shí)例
這個(gè)實(shí)例體現(xiàn)了如何使用消息隊(duì)列進(jìn)行兩個(gè)進(jìn)程（發(fā)送端和接收端）之間的通信，包括消息隊(duì)列的創(chuàng)建、消息發(fā)送與讀取、消息隊(duì)列的撤消和刪除等多種操作。
消息發(fā)送端進(jìn)程和消息接收端進(jìn)程之間不需要額外實(shí)現(xiàn)進(jìn)程之間的同步。在該實(shí)例中，發(fā)送端發(fā)送的消息類型設(shè)置為該進(jìn)程的進(jìn)程號(hào)（可以取其他值），因此接收端根據(jù)消息類型確定消息發(fā)送者的進(jìn)程號(hào)。注意這里使用了函數(shù)fotk()，它可以根據(jù)不同的路徑和關(guān)鍵字產(chǎn)生標(biāo)準(zhǔn)的key。以下是消息隊(duì)列發(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;
/*根據(jù)不同的路徑和關(guān)鍵字產(chǎn)生標(biāo)準(zhǔn)的key*/
if((key=ftok(.,'a'))==-1)
{
perror(ftok);
exit(1);
}
/*創(chuàng)建消息隊(duì)列*/
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();
/*添加消息到消息隊(duì)列*/
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操作系統(tǒng)文章專題:linux操作系統(tǒng)詳解（linux不再難懂）
評(píng)論