Linux进程间通信之消息队列

#include<sys/msg.h>#消息队列相关函数及数据结构头文件

intmsgctl(intmsqid,intcmd,structmsqid_ds*buf);#控制消息队列函数

intmsgget(key_tkey,intmsgflg);#创建消息队列，key值唯一标识该消息队列

intmsgrcv(intmsqid,void*msg_ptr,size_tmsg_sz,longintmsgtype,intmsgflg);#接收消息

intmsgsnd(intmsqid,constvoid*msg_ptr,size_tmsg_sz,intmsgflg);#发送消息

#msg1.c接收端

#include<stdlib.h>

#include<stdio.h>

#include<string.h>

#include<errno.h>

#include<unistd.h>

#include<sys/msg.h>#包含消息队列相关函数及数据结构的头文件

structmy_msg_st{

longintmy_msg_type;

charsome_text[BUFSIZ];

};#消息格式

intmain()

{

intrunning=1;

intmsgid;

structmy_msg_stsome_data;

longintmsg_to_receive=0;

msgid=msgget((key_t)1234,0666|IPC_CREAT);#创建标识符为key=1234的消息队列，注意发送端与接收端该值的一致性

if(msgid==-1){

fprintf(stderr,“msggetfailedwitherror:%d\n”,errno);

exit(EXIT_FAILURE);

}#错误处理：msgget调用成功返回消息队列标识符，调用失败返回-1

while(running){

if(msgrcv(msgid,(void*)&some_data,BUFSIZ,msg_to_receive,0)==-1){#从消息队列接收消息，如果接收失败执行if语句并退出

fprintf(stderr,“msgrcvfailedwitherror:%d\n”,errno);

exit(EXIT_FAILURE);

}

printf(“Youwrote:%s”,some_data.some_text);

if(strncmp(some_data.some_text,“end”,3)==0){#如果接收到文本含有“end”，将running设置为0，效果是：退出while循环

running=0;

}

}

if(msgctl(msgid,IPC_RMID,0)==-1){#删除消息队列，如果删除失败执行if语句并退出

fprintf(stderr,“msgctl(IPC_RMID)failed\n”);

exit(EXIT_FAILURE);

}

exit(EXIT_SUCCESS);

}

#msg2.c发送端

#include<stdlib.h>

#include<stdio.h>

#include<string.h>

#include<errno.h>

#include<unistd.h>

#include<sys/msg.h>

#defineMAX_TEXT512

structmy_msg_st{

longintmy_msg_type;

charsome_text[MAX_TEXT];

};#消息格式，与接收端一致

intmain()

{

intrunning=1;

structmy_msg_stsome_data;

intmsgid;

charbuffer[BUFSIZ];

msgid=msgget((key_t)1234,0666|IPC_CREAT);#创建消息标识符key=1234的消息队列。如果该队列已经存在，则直接返回该队列的标识符，以便向该消息队列收发消息

if(msgid==-1){

fprintf(stderr,“msggetfailedwitherror:%d\n”,errno);

exit(EXIT_FAILURE);

}#错误处理，同接收者msg1

while(running){

printf(“Entersometext:“);

fgets(buffer,BUFSIZ,stdin);#由控制台输入文本，并将其存放在buffer之中

some_data.my_msg_type=1;#类型填充，在本例中没有特别含义

strcpy(some_data.some_text,buffer);#将buffer数据复制到some_text之中

if(msgsnd(msgid,(void*)&some_data,MAX_TEXT,0)==-1){#向消息队列发送消息，如果发送失败执行if语句并退出

fprintf(stderr,“msgsndfailed\n”);

exit(EXIT_FAILURE);

}

if(strncmp(buffer,“end”,3)==0){#如果发送的“end”，则在发送“end”之后，退出while，结束程序

running=0;

}

}

exit(EXIT_SUCCESS);

}