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

代码：

进程1代码：

#include<myhead.h>
struct msgbuf
{long mtype;//消息类型char mtext[1024];//消息正文
};
//宏定义结构体消息正文大小
#define MSGSIZE (sizeof(struct msgbuf)-sizeof(long))
int main(int argc, const char *argv[])
{key_t key=0;//获取key值；if((key=ftok("/",'a'))==-1){perror("ftok error");return -1;}int msqid=-1;//根据key创建消息队列 获取队列msqidif((msqid=msgget(key,IPC_CREAT|0664))==-1){perror("msgget error");return -1;}//定义用于写入和读取队列数据的结构体；struct msgbuf sbuf,rbuf;pid_t pid=fork();//创建父子进程，一个负责发送一个负责接收消息if(pid>0){while(1){bzero(sbuf.mtext,sizeof(sbuf.mtext));//清空数据域printf("请输入当前消息类型：");scanf("%ld",&sbuf.mtype);//存入输入的消息类型getchar();//吸收回车printf("请输入正文：");fgets(sbuf.mtext,sizeof(sbuf.mtext),stdin);//终端输入数值存入数据域；sbuf.mtext[strlen(sbuf.mtext)-1]='\0';//输入结尾的换行换成0；msgsnd(msqid,&sbuf,MSGSIZE,0);//放入消息队列if(strcmp(sbuf.mtext,"quit")==0)//输入quit结束break;}wait(NULL);//阻塞等待回收子进程}else if(pid==0){while(1){bzero(sbuf.mtext,sizeof(sbuf.mtext));//清空数据域msgrcv(msqid,&rbuf,MSGSIZE,1,0);//读取队列中类型1的第一个数据printf("收到消息：%s\n",rbuf.mtext);if(strcmp(rbuf.mtext,"quit")==0)break;}exit(EXIT_SUCCESS);//子进程退出}else{perror("fork error");return -1;}if(msgctl(msqid,IPC_RMID,NULL)!=0){perror("msgctl error");return -1;}return 0;
}

 进程2代码：

#include<myhead.h>
struct msgbuf
{long mtype;//消息类型char mtext[1024];//消息正文
};
//宏定义结构体消息正文大小
#define MSGSIZE (sizeof(struct msgbuf)-sizeof(long))
int main(int argc, const char *argv[])
{key_t key=0;//获取key值；if((key=ftok("/",'a'))==-1){perror("ftok error");return -1;}int msqid=-1;//根据key创建消息队列 获取队列msqidif((msqid=msgget(key,IPC_CREAT|0664))==-1){perror("msgget error");return -1;}//定义用于写入和读取队列数据的结构体；struct msgbuf sbuf,rbuf;pid_t pid=fork();//创建父子进程，一个负责发送一个负责接收消息if(pid>0){while(1){bzero(sbuf.mtext,sizeof(sbuf.mtext));//清空数据域printf("请输入当前消息类型：");scanf("%ld",&sbuf.mtype);//存入输入的消息类型getchar();//吸收回车printf("请输入正文：");fgets(sbuf.mtext,sizeof(sbuf.mtext),stdin);//终端输入数值存入数据域；sbuf.mtext[strlen(sbuf.mtext)-1]='\0';//输入结尾的换行换成0；msgsnd(msqid,&sbuf,MSGSIZE,0);//放入消息队列if(strcmp(sbuf.mtext,"quit")==0)//输入quit结束break;}wait(NULL);//阻塞等待回收子进程}else if(pid==0){while(1){bzero(sbuf.mtext,sizeof(sbuf.mtext));//清空数据域msgrcv(msqid,&rbuf,MSGSIZE,2,0);//读取队列中类型1的第一个数据printf("收到消息：%s\n",rbuf.mtext);if(strcmp(rbuf.mtext,"quit")==0)break;}exit(EXIT_SUCCESS);//子进程退出}else{perror("fork error");return -1;}if(msgctl(msqid,IPC_RMID,NULL)!=0){perror("msgctl error");return -1;}return 0;
}

 运行：

思维导图：