linux两个进程通过消息队列互发信息
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
struct my_msg_st
{
long int my_msg_type;
unsigned char msg_data_buf[36];
};
int main(void)
{
int i;
int running=1;
int rtn_rcv;
int msg_rcv_id;
int msg_snd_id;
key_t msg_snd_key;
key_t msg_rcv_key;
struct my_msg_st data_msg1;
long int msg_to_receive=0;
msg_snd_key = ftok("/tmp/TTMS/GM", 'b');
msg_rcv_key = ftok("/tmp/TTMS/GM", 'a');
/*创建消息队列*/
msg_rcv_id=msgget(msg_rcv_key,0666 | IPC_CREAT);
msg_snd_id=msgget(msg_snd_key,0666 | IPC_CREAT);
if(msg_rcv_id==-1)
{
fprintf(stderr,"msgget failed with error: %d\n",errno);
exit(EXIT_FAILURE);
}
printf("the message1 rcv id:%d\n", msg_rcv_id);
if(msg_snd_id==-1)
{
fprintf(stderr,"msgget failed with error: %d\n",errno);
exit(EXIT_FAILURE);
}
printf("the message1 snd id:%d\n", msg_snd_id);
for (i=0; i<36; i++)
{
data_msg1.msg_data_buf[i] = 36 + i;
}
data_msg1.my_msg_type = getpid();
/*循环从消息队列中接收消息*/
while(running)
{
if(msgsnd(msg_snd_id,&data_msg1,36,0)==-1)
{
fprintf(stderr,"msgsed failed\n");
exit(EXIT_FAILURE);
}
/*读取消息*/
if((rtn_rcv = msgrcv(msg_rcv_id,&data_msg1,36,msg_to_receive,0))==-1)
{
fprintf(stderr,"msgrcv failed with error: %d\n",errno);
exit(EXIT_FAILURE);
}
for (i=0; i<rtn_rcv; i++)
{
printf("rcv data size:%d\n", rtn_rcv);
printf(">>>%d>>>",data_msg1.msg_data_buf[i]);
}
/* 重新进行赋值 */
for (i=0; i<36; i++)
{
data_msg1.msg_data_buf[i] = i;
}
sleep(3);
}
}
这里明明创建了两个消息队列,为何打印出来的消息队列的ID值确实一样的。
msg_rcv_id=msgget(msg_rcv_key,0666 | IPC_CREAT);
msg_snd_id=msgget(msg_snd_key,0666 | IPC_CREAT);
这个程序想在一个进程中创建两个消息队列,一个用来发送消息给另一个进程,一个队列用来接受另一个进程的消息。
可是这里怎么创建了以后只是一个消息了呢?导致自己发送了信息,自己接受了信息?????为什么啊???
你在哪里创建另一个进程了?都是在同一进程下的操作,当然是自己发给自己了
IPC_CREAT | 0066 表式权限0066,如果消息队列不存在则新建。
如果单独使用IPC_CREAT,则msgget()要么返回一个新创建的消息队列的标识符,要么返回具有相同关键字值的队列的标识符。
所以,你打印出来的消息队列的ID值是一样的。