使用消息队列完成两个进程间相互通信

代码：

msgsnd.c

#include<myhead.h>

//定义消息类型
struct msgbuf
{
	long mtype;
	char mtext[1024];
};

//宏表示消息正文大小
#define MSGSIZE sizeof(struct msgbuf)-sizeof(long)


int main(int argc, const char *argv[])
{
	//1.创建key值
	key_t key=0;
	if((key=ftok("/",'k'))==-1)
	{
		perror("ftok error");
		return -1;
	}

	//1.根据key值创建一个消息队列
	int msqid = -1;
	if((msqid=msgget(key,IPC_CREAT|0664))==-1)
	{
		perror("msgget error");
		return -1;
	}
	
	//创建一个子进程
	pid_t pid=fork();

	if(pid>0)
	{
		//父进程向消息队列中写入类型为1的正文
		//定义一个消息
		struct msgbuf sbuf;
		sbuf.mtype=1;
		while(1)
		{
			//清空容器
			bzero(sbuf.mtext,sizeof(sbuf.mtext));

			printf("发送的消息：");
			fgets(sbuf.mtext,sizeof(sbuf.mtext),stdin);
			sbuf.mtext[strlen(sbuf.mtext)-1]='\0';

			//将消息存放到队列中
			msgsnd(msqid,&sbuf,MSGSIZE,0);
			printf("发送成功\n");

			if(strcmp(sbuf.mtext,"quit")==0)
			{
				break;
			}
		}
		wait(NULL);
	}
	else if(pid==0)
	{
		//子进程从消息队列中读取类型为2的正文
		//定义一个消息
		struct msgbuf rbuf;

		while(1)
		{
			//清空容器
			bzero(rbuf.mtext,sizeof(rbuf.mtext));

			//从消息队列中读取类型为2的消息正文
			msgrcv(msqid,&rbuf,MSGSIZE,2,0);
			printf("收到的消息为：%s\n",rbuf.mtext);
			if(strcmp(rbuf.mtext,"quit")==0)
			{
				break;
			}
			
		}
		exit(0);

	}
	else 
	{
		perror("fork error");
		return -1;
	}


	return 0;
}

msgrev,c

#include<myhead.h>

//定义消息类型
struct msgbuf
{
	long mtype;
	char mtext[1024];
};

//宏表示消息正文大小
#define MSGSIZE sizeof(struct msgbuf)-sizeof(long)


int main(int argc, const char *argv[])
{
	//1.创建key值
	key_t key=0;
	if((key=ftok("/",'k'))==-1)
	{
		perror("ftok error");
		return -1;
	}

	//1.根据key值创建一个消息队列
	int msqid = -1;
	if((msqid=msgget(key,IPC_CREAT|0664))==-1)
	{
		perror("msgget error");
		return -1;
	}
	
	//创建一个子进程
	pid_t pid=fork();

	if(pid==0)
	{
		//子进程向消息队列中写入类型为2的正文
		//定义一个消息
		struct msgbuf sbuf;
		sbuf.mtype=2;
		while(1)
		{
			//清空容器
			bzero(sbuf.mtext,sizeof(sbuf.mtext));

			printf("发送的消息：");
			fgets(sbuf.mtext,sizeof(sbuf.mtext),stdin);
			sbuf.mtext[strlen(sbuf.mtext)-1]='\0';

			//将消息存放到队列中
			msgsnd(msqid,&sbuf,MSGSIZE,0);
			printf("发送成功\n");

			if(strcmp(sbuf.mtext,"quit")==0)
			{
				break;
			}
		}
		exit(0);
	}
	else if(pid>0)
	{
		//父进程从消息队列中读取类型为1的正文
		//定义一个消息
		struct msgbuf rbuf;

		while(1)
		{
			//清空容器
			bzero(rbuf.mtext,sizeof(rbuf.mtext));

			//从消息队列中读取类型为1的消息正文
			msgrcv(msqid,&rbuf,MSGSIZE,1,0);
			printf("收到的消息为：%s\n",rbuf.mtext);
			if(strcmp(rbuf.mtext,"quit")==0)
			{
				break;
			}
			
		}
		wait(NULL);

	}
	else 
	{
		perror("fork error");
		return -1;
	}


	return 0;
}

运行结果：

 

思维导图：