又见消息队列

Posted 2021-07-27 背时的哥哥

前言：

system v提供的ipc(inter-process communication)机制主要有消息队列，信号量，共享内存。

---

使用：

一个ipc工具至少包含key值，ID等属性值； 使用ipc工具前必须先创建；

1. 使用ftok函数创建key值
2. 使用msgget函数创建消息队列
3. 使用msgctl函数对属性值进行操作
4. 使用msgrcv函数接收队列中的消息
5. 使用msgsnd函数发送信息到队列

---

实例：

这里用一个实验题作为实例：编写一段程序，使其用消息缓冲队列来实现父进程和子进程之间的通信。父进程先建立一个关键字为MSGKEY(如75)（即#define MSGKEY 75）的消息队列，然后等待接收类型为1的消息；在收到请求消息后，它便显示字符串“serving for client ”和接收到的子进程的进程标识数，表示正在为子进程服务；然后再向子进程发送一应答消息，该消息的类型是该子进程的进程标识数，而正文则是父进程自己的标识数。子进程则向消息队列发送类型为1的消息(消息的正文为自己的进程标识数)，以取得父进程的服务，并等待父进程发来的应答；然后显示字符串“receive reply from ”和接收到的父进程的标识数。

---

 #include<stdio.h>
  #include<stdlib.h>
   #include<sys/ipc.h>
   #include<sys/msg.h>
   #include<string.h>
  
   #define MSGKEY 75
   struct msgform{
           long mtype;  //消息类型
          char mtext[1024];  //消息正文
  };
 
  int main(){
                  //创建消息队列
          int msgid = msgget(MSGKEY,IPC_CREAT|0666);//创建一个消息队列
  
          struct msgform childmsg,parentmsg;
  
          if(msgid<0){
                  printf("error when user msget");
                  return 0;
          }
  
          int pid = fork();  //创建子进程

        if(pid<0){
                  printf("error when use fork");
                  return 0;
          }else if(pid==0){
                  childmsg.mtype = 1;
                  char *childmessage = "serving for client";
                  sprintf(childmsg.mtext,"%s %d",childmessage,getpid());
                  msgsnd(msgid,&childmsg,strlen(childmsg.mtext)+1,0);//发送消息到队列
                  printf("child send message:%s\\n",childmsg.mtext);
                  printf("wait for parent\\n");
                  sleep(3);
                  childmsg.mtype=1;
  
                  int res = msgrcv(msgid,&parentmsg,1024,0,0);
                  printf("child receive message:%s\\n",parentmsg.mtext);
                  printf("child end\\n");
          }else{
          //父进程接受
                  sleep(3);
                  msgrcv(msgid,&parentmsg,1024,0,0);
                  printf("parent receive:%s\\n",parentmsg.mtext);
  
          //父进程发送
                  parentmsg.mtype = pid;
                  char *parentmessage = "receive reply from";
                  sprintf(parentmsg.mtext,"%s %d",parentmessage,getpid());
                 printf("%s\\n",parentmsg.mtext);
                  msgsnd(msgid,&parentmsg,strlen(parentmsg.mtext)+1,0);
                  printf("parent end\\n");
                  sleep(2);
          }
  
  
  }
                                                                                          

结果为：