進(jìn)程間通信之:消息隊(duì)列
表8.26列舉了msgctl()函數(shù)的語法要點(diǎn)。
表8.26 msgctl()函數(shù)語法要點(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)論