使用消息队列完成两个进程间的通信
进程1
#include <myhead.h>
struct migbuf
{
long a;//消息类型
char b[1024];//消息正文
};
#define SIZE (sizeof(struct migbuf)-sizeof(long))
int main(int argc, const char *argv[])
{
//创建key值
key_t key=0;
if((key=ftok("./",'t'))==-1)
{
perror("ftok error");
return -1;
}
printf("key=%#x\n",key);
//使用key值创建消息队列
int msgid=0;
if((msgid=msgget(key,IPC_CREAT|0664))==-1)
{
perror("msgget error");
return -1;
}
printf("msgid=%d\n",msgid);
//创建子进程
int pid=fork();
if(pid==0)
{
//子
//定义数据类型并循环写入数据
struct migbuf buf={.a=100};
while(1)
{
printf("请输入:");
scanf("%s",buf.b);
msgsnd(msgid,&buf,SIZE,0);
if(strcmp(buf.b,"quit")==0)
break;
printf("发送成功\n");
}
exit(EXIT_SUCCESS);
}else if(pid>0)
{
//父
//定义数据类型并循环读取数据
struct migbuf buf={.a=200};
while(1)
{
msgrcv(msgid,&buf,SIZE,200,0);
printf("收到消息:%s\n",buf.b);
if(strcmp(buf.b,"quit")==0)
break;
}
wait(NULL);
//退出时删除消息队列
msgctl(msgid,IPC_RMID,NULL);
}else
{
perror("fork error");
return -1;
}
return 0;
}
进程2
#include <myhead.h>
struct migbuf
{
long a;//消息类型
char b[1024];//消息正文
};
#define SIZE (sizeof(struct migbuf)-sizeof(long))
int main(int argc, const char *argv[])
{
//创建key值
key_t key=0;
if((key=ftok("./",'t'))==-1)
{
perror("ftok error");
return -1;
}
printf("key=%#x\n",key);
//使用key值创建消息队列
int msgid=0;
if((msgid=msgget(key,IPC_CREAT|0664))==-1)
{
perror("msgget error");
return -1;
}
printf("msgid=%d\n",msgid);
//创建子进程
int pid=fork();
if(pid==0)
{
//子
//定义数据类型并循环写入数据
struct migbuf buf={.a=100};
while(1)
{
msgrcv(msgid,&buf,SIZE,100,0);
printf("收到消息:%s\n",buf.b);
if(strcmp(buf.b,"quit")==0)
break;
}
exit(EXIT_SUCCESS);
}else if(pid>0)
{
//父
//定义数据类型并循环读取数据
struct migbuf buf={.a=200};
while(1)
{
printf("请输入:");
scanf("%s",buf.b);
msgsnd(msgid,&buf,SIZE,0);
if(strcmp(buf.b,"quit")==0)
break;
printf("发送成功\n");
}
wait(NULL);
}else
{
perror("fork error");
return -1;
}
return 0;
}