今天我們來分享一下程序通行（IPC）-實現訊息佇列。

訊息佇列由作業系統提供一個連結串列（也就是說訊息佇列需要作業系統介面），以連結串列節點為一個數據塊（有型別），基於訊息，每條訊息有上限且訊息的總數也是有限的。

與管道通行的區別是，管道通訊以位元組流為通訊單位，訊息佇列是以有型別的資料塊為通訊單位。

訊息佇列實現原理：

一個程序建立訊息佇列(本文為serves)，另一個程序(本文為client)開啟該訊息佇列即可。此後兩個程序可以相互讀寫以此來進行通訊。

訊息佇列實現步驟：

1》建立（開啟）訊息佇列

2》傳送訊息/接收訊息

3》接收訊息/傳送訊息

4》銷燬訊息佇列（誰建立誰銷燬）

進行傳遞訊息的資料塊（結構體）如下示：

  struct msgbuf{

      long mtype;//訊息的發起者的型別(標誌)

      char mtext[1024];//訊息內容

  };

訊息佇列是隨核心的，除了需要呼叫系統介面去建立訊息佇列，還需要呼叫系統介面去銷燬訊息佇列。

最後，介紹關於檢視訊息佇列和銷燬訊息佇列的系統命令，截圖如下：

程式碼和執行結果如下：

Commom.h

 #ifndef _COMMOM_H_
   #define _COMMOM_H_
   
   #include<stdio.h>
   #include<sys/types.h>
   #include<sys/ipc.h>
   #include<sys/msg.h>
   #include<string.h>
   #include<unistd.h>
  
  struct msgbuf{
      long mtype;
      char mtext[1024];
  };
  
  #define PATHNAME "."
  #define PROJ_ID 0x6666
  
  #define SERVE 1
  #define CLIENT 2
  
  int CreatMsgQueue();
  int GetMsgQueue();
  int SendMsgQueue(int msgid, int who, char* msg);
  int RecvMsgQueue(int msgid, int recvtype, char* out);
  int DestroyMsgQueue(int msgid);
  
  #endif
 

Commom.c

#include"commom.h"
 
   int commMsgQueue(int flags)
   {
       key_t keys = ftok(PATHNAME, PROJ_ID);
       if(keys<0){
           perror("ftok");
           return -2;
       }
 
      int msgid = msgget(keys, flags);
      if(msgid <0){
          perror("msgget");
          return -1;
      }
      return msgid;
  }
  
  int CreatMsgQueue()
  {
      return commMsgQueue(IPC_CREAT|IPC_EXCL);
  }
  int GetMsgQueue(){
      return commMsgQueue(IPC_CREAT);
  }
  int SendMsgQueue(int msgid, int who, char* msg){
      struct msgbuf buf;
      buf.mtype = who;
      strcpy(buf.mtext,msg);
  
      Int flag = msgsnd(msgid,(void*)&buf, sizeof(buf.mtext),0);
      if(flag<0){
          perror("msgsnd");
         return -4;
      }
      return 0;
  }
  int RecvMsgQueue(int msgid, int recvtype, char* out){
      struct msgbuf buf;
      ssize_t s = msgrcv(msgid,(void*)&buf, sizeof(buf.mtext), recvtype, 0);
      if(s<0){
      perror("msgvcv");
     return -5;
      }
  
      strcpy(out, buf.mtext);
      return s;
  }
  int DestroyMsgQueue(int msgid){
      int flag = msgctl(msgid, IPC_RMID, NULL);
      if(flag<0){
          perror("");
          return -3;
      }
      return 0;
 }
 

Client.c

 #include"commom.h"
   #include"commom.c"
  
int main(){
       int msgid = GetMsgQueue();
   
       char msg[1024];
       while(1){
       int r = RecvMsgQueue(msgid, SERVE,msg);
      if(r<0){
      perror("recv wrong");
      return -3;
      }
      printf("serve say:%s\n", msg);
  
      printf("please write: ");
      fflush(stdout);
      ssize_t s=read(0, msg, sizeof(msg)-1);
      if(s<0){
          perror("fread");
          return -1;
      }
      msg[s-1] = 0;
  
      int k = SendMsgQueue(msgid, CLIENT, msg);
      if(k<0){
      perror("send wrongs");
      return -2;
      }
      }
     
      return 0;
  }

Serves.c

   #include"commom.h"
   #include"commom.c"
 
 int main(){
       umask(0);
       int msgid = CreatMsgQueue();
   
       char msg[1024];
       while(1){
      printf("please write: ");
      fflush(stdout);
      ssize_t s=read(0, msg, sizeof(msg)-1);
      if(s<0){
          perror("fread");
          return -1;
      }
      msg[s-1] = 0;
  
      int k = SendMsgQueue(msgid, SERVE, msg);
      if(k<0){
      perror("send wrongs");
      return -2;
      }
      int r = RecvMsgQueue(msgid, CLIENT,msg);
      if(r<0){
      perror("recv wrong");
      return -3;
      }
      printf("client say:%s\n", msg);
      }
      
      DestroyMsgQueue(msgid);
      return 0;
  }

Makefile

.PHONY:all
   all:client serve
   
   client:client.c  commom.h
      gcc -o [email protected] $^
   serve:serves.c  commom.h
       gcc -o [email protected] $^
   
  .PHONY:clean
  clean:
      rm -f client serve

執行介面（先執行serve再執行client）

分享如上，如有錯誤望指標，共同學習！