目录

消息队列

 消息队列的使用

发送消息

消息的接收

消息队列的控制

消息队列

概念：

消息队列是system V IPC对象的一种；

消息队列有消息队列ID来唯一标识；

消息队列就是一个消息的列表。用户可以在消息队列中添加消息、读取消息等；

消息队列可以按照类型来发送/接收消息

内核过程（链表）：

 消息队列的使用

发送端：

1、申请 key；

2、打开 / 创建消息队列  msgget

3、向消息队列发信息  msgand

接收端：

1、打开 / 创建消息队列  msgget

2、从消息队列接收信息  msgrcv

3、控制（删除）消息队列  msgctl

打开 / 创建消息队列：

#include <sys/ipc.h>
#include <sys/msg.h>
int msgget(key_t key, int msgflg);

成功时返回消息队列的ID，失败返回EOF

key ：和消息队列关联的key ，IPC_PRIVATE 或 ftok

msgflg ：标志位 IPC_CREAT | 0666  ， IPC_CREAT:  没有则创建，有则打开。

发送消息

#include <sys/ipc.h>
#include <sys/msg.h>
int msgsnd(int msgid, const void *msgp, size_t size, int msgflg);

成功时返回0，失败时返回-1；

参数：

msgid ：消息队列id；

msgp ：消息缓冲区地址；

size：消息正文长度；

msgflg：标志位 0 或 IPC_NOWAIT；

msgflg ：

                  0：当消息队列满时，msgsnd会阻塞，知道消息能写进消息队列

IPC_NOWAT：  当消息队列已满时，msgsnd函数不等待。立即返回

消息格式：

typedef struct {long msg_type;char buf[128];
}msgT;

注意：

1、消息结构必须有long类型的msg_type字段，表示消息的类型；

2、消息长度不包括首类型long；

消息的接收

#include <sys/ipc.h>#include <sys/msg.h>int msgrcv(int msgid, void *msgp, size_t size, long msgtype, int msgflg);

成功时返回收到的消息长度，失败时返回-1

参数：

  msgid ：消息队列id

  msgp ： 消息缓冲区地址

  size ：指定接收的消息长度

  msgflg ：标志位 

  msgtype ：指定接收的消息类型  

  msgtype：

                msgtype=0：收到的第一条消息，任意类型。

                msgtype>0：收到的第一条 msg_type类型的消息。

                msgtype<0：接收类型等于或者小于msgtype绝对值的第一个消息。

例子：如果msgtype=-4，只接受类型是1、2、3、4的消息

msgflg：

                0：阻塞式接收消息

                IPC_NOWAIT：如果没有返回条件的消息调用立即返回，此时错误码为ENOMSG

                MSG_EXCEPT：与msgtype配合使用返回队列中第一个类型不为msgtype的消息

消息队列的控制

删除消息

#include <sys/ipc.h>#include <sys/msg.h>int msgctl(int msgid, int cmd, struct msqid_ds *buf);

  成功时返回0，失败时返回-1

参数：

  msgid ：消息队列id

  cmd ： 要执行的操作  IPC_STAT / IPC_SET / IPC_RMID（删除）

  buf： 存放消息队列属性的地址