目录

1.消息队列的原理：

2.消息队列的接口：

        （1）创建消息队列

        （2）向消息队列发送消息

        （3）接收消息

         （4）操作消息队列的接口

---

1.消息队列的原理：

消息队列（messagequeue）以链表作为基础，实现消息队列，由操作系统维护该链表

操作系统中，使用消息队列描述符（qid）来区分每个消息队列（qid是唯一的）

进程在消息队列的末尾增加消息，需要信息的进程按照所需的类型在队列中取消息

2.消息队列的接口：

（1）创建消息队列

        int megget(key_t,int msgflg)

参数： 

key：消息队列的标识符

megflg：创建的标志，如IPC_CREAT

IPC_CREAT :如果不存在就创建，按位或上一个权限

返回值：

成功：返回队列ID

失败：返回-1，并设置erron 

2）向消息队列发送消息      

 

int msgsnd（int msqid, const void *msgp, size_t msgsz, int msgflg）

参数：

msqid：消息队列的ID

msgp：指向msgbuf的指针，用来发送指定的消息，在写msgsnd、msgrev函数时，要提前定义该结构体，主要是指定mtext大小。

      msgp指向的msgbuf为发送的结构体，操作系统指定了函数发送消息的格式，只定义了一部分，mtext可以由程序员自己改变。

 msgsz：要发送的消息的长度，该参数的值不是表示msgp指向的msgbuf结构体的大小，而是该结构体中mtext的大小。

msgflg：创建标记，如果指定了IPC_NOWAIT，失败会立即返回。       

         0：阻塞发送

         IPC_NOWAIT：非阻塞发送

返回值：

        0：成功

        -1：失败，并设置errno

(3）接收消息

ssize_t msgrcv(int msqid , void *msgp,size_t msgsz,long msgtyp,int msgflg)

参数：

msgid：消息队列的ID

msgp：指向msgbuf的指针，用来接收消息

**struct  msgbuf{……}为输出型参数

msgsz：需要接受的消息的长度，注意msgsz是由msgp所指向的结构体的成员 mtext的最大大小决定的（byte）

msgtyp有三种形式：

        1.msgtyp=0：读取队列的第一个消息

        2.msgtyp>0：读取队列类型为msgtyp的第一条消息，除非在msgflg中指定了 MSG_EXCEPT，否则将读取类型不等于 megtyp的队列中的第一条消息，

        3.msgtyp<0:读取队列中最小类型小于或等于msgtyp绝对值的第一条消息

msgflg：创建标记，若指定了IPC_NOWAIT，获取失败后就直接返回 

     （4）操作消息队列的接口

int msgctl(int msqid , int cmd, struct msqid_ds *buf)

参数：

        msqid：消息队列的ID

        cmd：控制命令：

                IPC_RMID,删除命令

                IPC_STAT,获取命令

        buf：存储队列的相关信息的buf

返回值：

        成功：根据不同的cmd有不同的返回值

        失败： 返回-1，并设置errno

5.代码实现：

写端发送消息，读端从队列读取

mesgrcv:

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

struct msgbuf
{
   long mtype;
   char mtext[1024];

};


int main()
{
 int msg_id=msgget(0x06060606,IPC_CREAT|0664);
 if(msg_id<0 )
{
 perror("msgget \n" );
return 0;
}

printf("msggqueued id is %d\n",msg_id );
struct msgbuf mq;
msgrcv(msg_id,&mq,sizeof(mq.mtext),1,0);
printf("接受的消息：%s \n",mq.mtext);

return 0;
}

msgsnd:

#include<stdio.h>
#include<unistd.h>
#include<sys/msg.h>

struct msgbuf
{
     long mtype;        //message type
     char mtext[512];   //message data

};

int main()
{
 int msg_qid=msgget(0x06060606,IPC_CREAT|0664);
 if(msg_qid<0 )
  {
    perror("msgget\n");
  return 0;
  }

  struct msgbuf mq;

  int i;
  for(i=0;i<10;i++)
 {
   mq.mtype=i+1;
   sprintf(mq.mtext,"%s,%d ","xxxxxxxxxx ",i+1);
   msgsnd(msg_qid,&mq,sizeof(mq.mtext),0);
 }

return 0;
}

查看系统中的message queue：

 

 

当多次读出时，由于消息已经出了队列，所以不能再读出。