实现进程间相互通信操作流程

龙大神随笔：
经典操作：ABC三个进程，实现三个进程之间任一通信。
//进程A

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>

struct msgbuf{
long mtype;
char text[640];
};

struct msgbuf t_msg,r_msg;

int msqid;

int main(void)
{
key_t key;
pid_t ret;

key=ftok("./1234.txt",1);
msqid = msgget(key,IPC_CREAT|0600);
printf("msqid=%d\r\n",msqid);

ret=fork();
if(ret==-1)
{
	perror("fork failed\r\n");
	return -1;
}
if(ret==0)
{
	//child
	while(1)
	{
	
		memset(&t_msg,0,sizeof(t_msg));
		scanf("%s",t_msg.text);
		if(strncmp("toB",t_msg.text,3)==0)
		{
			t_msg.mtype=2;
			msgsnd(msqid,&t_msg,sizeof(t_msg.text),0);
		}
		if(strncmp("toC",t_msg.text,3)==0)
		{
			t_msg.mtype=4;
			msgsnd(msqid,&t_msg,sizeof(t_msg.text),0);
		}

	}

}else
{
	//parent
	int len1,len2;
	while(1)
	{
		len1 = msgrcv(msqid,&r_msg,sizeof(r_msg.text),1,IPC_NOWAIT);
		if(len1==-1)
		{
			;
		}
		else
		{
			printf("fromB:%s\r\n",r_msg.text+4);
		}
		len2 = msgrcv(msqid,&r_msg,sizeof(r_msg.text),3,IPC_NOWAIT);
		if(len2==-1)
		{
			;
		}			
		else
		{
			printf("fromC:%s\r\n",r_msg.text+4);
		}
	}
}

}

//进程B

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>

struct msgbuf{
long mtype;
char text[640];
};

struct msgbuf t_msg,r_msg;

int msqid;
int main(void)
{
key_t key;
pid_t ret;

key=ftok("./1234.txt",1);
msqid = msgget(key,IPC_CREAT|0600);
printf("msqid=%d\r\n",msqid);

ret=fork();
if(ret==-1)
{
	perror("fork failed\r\n");
	return -1;
}
else if(ret==0)
{
	//child
	while(1)
	{
		memset(&t_msg,0,sizeof(t_msg));
		scanf("%s",t_msg.text);
		if(strncmp("toA",t_msg.text,3)==0)
		{
			t_msg.mtype=1;
			msgsnd(msqid,&t_msg,sizeof(t_msg.text),0);
		}
		if(strncmp("toC",t_msg.text,3)==0)
		{
			t_msg.mtype=5;
			msgsnd(msqid,&t_msg,sizeof(t_msg.text),0);
		}
	}

}else
{
	//parent
	int len1,len2;
	while(1)
	{
		len1 = msgrcv(msqid,&r_msg,sizeof(r_msg.text),2,IPC_NOWAIT);
		if(len1==-1)
		{
			;
		}
		else
		{
			printf("fromA:%s\r\n",r_msg.text+4);
		}
		len2 = msgrcv(msqid,&r_msg,sizeof(r_msg.text),6,IPC_NOWAIT);
		if(len2==-1)
		{
			;
		}			
		else
		{
			printf("fromC:%s\r\n",r_msg.text+4);
		}
	}
}

}

//进程C

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>

struct msgbuf{
long mtype;
char text[640];
};

struct msgbuf t_msg,r_msg;

int msqid;
int main(void)
{
key_t key;
pid_t ret;

key=ftok("./1234.txt",1);
msqid = msgget(key,IPC_CREAT|0600);
printf("msqid=%d\r\n",msqid);

ret=fork();
if(ret==-1)
{
	perror("fork failed\r\n");
	return -1;
}
else if(ret==0)
{
	//child---send
	while(1)
	{
		memset(&t_msg,0,sizeof(t_msg));
		scanf("%s",t_msg.text);
		if(strncmp("toA",t_msg.text,3)==0)
		{
			t_msg.mtype=3;
			msgsnd(msqid,&t_msg,sizeof(t_msg.text),0);
		}
		if(strncmp("toB",t_msg.text,3)==0)
		{
			t_msg.mtype=6;
			msgsnd(msqid,&t_msg,sizeof(t_msg.text),0);
		}
	}

}else
{
	//parent---receive
	int len1,len2;
	while(1)
	{
		len1 = msgrcv(msqid,&r_msg,sizeof(r_msg.text),4,IPC_NOWAIT);
		if(len1==-1)
		{
			;
		}			
		else
		{
			printf("fromA:%s\r\n",r_msg.text+4);
		}
		len2 = msgrcv(msqid,&r_msg,sizeof(r_msg.text),5,IPC_NOWAIT);
		if(len2==-1)
		{
			;
		}			
		else
		{
			printf("fromB:%s\r\n",r_msg.text+4);
		}
	}
}

}