Linux消息队列

 #include <stdio.h>
 #include <sys/types.h>
 #include <sys/ipc.h>
 #include <sys/msg.h>
 #include <errno.h>
 #include <string.h>
 #include <stdlib.h>

 int msg_key = ;

 struct MsgNode
 {
     long nMsgType;
     char sBuf[];
 };

 int main(int argc,char** argv)
 {
     int nMsgId = ;
     if((argc == ) && (strcmp(argv[],"c") == ))
     {
         nMsgId = msgget(msg_key,IPC_EXCL);
         if(nMsgId < )
         {
             nMsgId = msgget(msg_key,|IPC_CREAT);
             if(nMsgId < )
             {
                 perror("msgget");
                 printf("msgget failed\n");
                 exit(-);
             }
         }

         for(int i =  ;i < ; ++i)
         {
             MsgNode node;
             node.nMsgType = ;
             sprintf(node.sBuf,"This is the %d msg from client.\n",i);

             if(i == )
             {
                 strcpy(node.sBuf,"end\n");
             }

             printf("%s",node.sBuf);

             int ret = msgsnd(nMsgId,&node,sizeof(node.sBuf),IPC_NOWAIT);
             if(ret < )
             {
                 perror("msgsend");
                 printf("msgsend failed");
                 exit(-);
             }
         }
     }
     else
     {
         nMsgId = msgget(msg_key,IPC_EXCL);
         if(nMsgId < )
         {
             printf("msgget failed\n");
             exit(-);
         }

         bool flag = true;
         while(flag)
         {
             MsgNode node;
             int ret = msgrcv(nMsgId,&node,sizeof(node.sBuf),,IPC_NOWAIT);
             if(ret == -)
             {
                 perror("msgrecv");
                 printf("msgrecv failed\n");
                 exit(-);
             }
             printf("Receive Msg:%s",node.sBuf);
             //if(strncmp(node.sBuf,"end",3) == 0)
             //{
             //    flag = false;
             //};
         }

         int ret = msgctl(nMsgId,IPC_RMID,);
         if( ret == -)
         {
             printf("msgctl failed\n");
             exit(-);
         }
     }

     return ;
 }

需要注意的是

int msgsend(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg);

及

int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg);  

其中 size_t msg_st并不是消息结构体的大小，而是消息的大小。
如代码中定义了结构

 struct MsgNode
 {
     long nMsgType;
     char sBuf[];
 };

则 size_t msg_st指的是 sizeof(MsgNode.sBuf)即不包括结构中消息类型的长度。
在接受/发送消息时如果不设置为IPC_NOWAIT则发送时如果消息队列已满则阻塞，接收时如果消息队列为空则阻塞。

消息队列跟命名管道有不少的相同之处，通过与命名管道一样，消息队列进行通信的进程可以是不相关的进程，同时它们都是通过发送和接收的方式来传递数据的。在命名管道中，发送数据用write，接收数据用read，则在消息队列中，发送数据用msgsnd，接收数据用msgrcv。而且它们对每个数据都有一个最大长度的限制。

与命名管道相比，消息队列的优势在于，1、消息队列也可以独立于发送和接收进程而存在，从而消除了在同步命名管道的打开和关闭时可能产生的困难。2、同时通过发送消息还可以避免命名管道的同步和阻塞问题，不需要由进程自己来提供同步方法。3、接收程序可以通过消息类型有选择地接收数据，而不是像命名管道中那样，只能默认地接收。