進(jìn)程間通信之：消息隊(duì)列

表8.26列舉了msgctl()函數(shù)的語(yǔ)法要點(diǎn)。

表8.26 msgctl()函數(shù)語(yǔ)法要點(diǎn)

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);

}