UNP（卷2：进程间通信）—— 第6章：System V消息队列

本文主要是介绍UNP（卷2：进程间通信）—— 第6章：System V消息队列，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

System V 消息队列使用消息队列标识符（Message Queue Identifier）。具有足够特权的任何进程都可以往一个给定进程放置一个消息。也可以读出一个消息。跟Posix消息队列一样，在写消息之前，不求另外某个进程正在等待该队列上一个消息的到达。

对于每个消息队列，内核维护一个定义在<sys/msg.h>头文件中的信息结构。

struct msqid_ds {struct ipc_perm   msg_perm;   /* read_write perms */struct msg       *msg_first;  /* first message on queue,unused  */struct msg       *msg_last;   /* last message in queue,unused */time_t            msg_stime;  /* last msgsnd time */time_t            msg_rtime;  /* last msgrcv time */time_t            msg_ctime;  /* last change time */unsigned long  msg_lcbytes;   /* Reuse junk fields for 32 bit */unsigned long  msg_lqbytes;   /* ditto */msglen_t          msg_cbytes; /* current number of bytes on queue */msgqnum_t         msg_qnum;   /* number of messages in queue */msglen_t          msg_qbytes; /* max number of bytes on queue */pid_t             msg_lspid;  /* pid of last msgsnd */pid_t             msg_lrpid;  /* last receive pid */
};

msgget

创建一个新的消息队列或者访问一个已存在的消息队列。

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgget(key_t key, int msgflg);// 返回：若成功则为非负标识符，出错为-1

key：既可以是ftok的返回值，也可以是常值IPC_PRIVATE。

msgflg：读写权限位的组合（MSG_R、MSG_W），还可以与 IPC_CREATE、IPC_CREATE | IPC_EXCL 按为或。

当创建一个新的消息队列时，msqid_ds结构的如下成员被初始化：
（1）msg_perm结构的uid和cuid成员被设置成当前进程的有效用户ID，gid和cgid成员被设置成当前进程的有效组ID
（2）msgflg中的读写权限位存放在msg_perm.mode中
（3）msg_qnum,msg_lspid,msg_lrpid,msg_stime,msg_rtime被置为0
（4）msg_ctime被设置成当前时间
（5）msg_qbytes被设置成系统限制值

msgsnd、msgrcv

msgsnd使用msgget打开一个消息队列后，使用msgsnd往其上放置一个消息。

msgrcv从某个消息队列中读出一个消息。

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);// 返回：若成功则为0，出错-1ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);// 返回：若成功则为读入缓冲区中的数据的字节数，出错-1struct msgbuf {
long mtype;      /* message type, must be > 0 */
char mtext[1];    /* message data */
};

-------------------------------------- msgsnd -----------------------------------------

msqid：由msgget返回的标识符。

msgp：结构指针，msgbuf。通常一个字节的数据是不够用的，可以自定义。

msgflg：可以是0，可以是IPC_NOWAIT（使得msgsnd调用非阻塞nonblocking，如果没有存放新消息的可用空间，就立马返回）。

在指定的队列中已有太多的字节；
在系统范围存在太多的消息。

如果这两个条件有一个存在，而且IPC_NOWAIT已指定，msgsnd就返回一个EAGAIN错误。如果有一个存在，且未指定IPC_NOWAIT标志，那么调用线程被投入睡眠，直到：

具备存放新消息的空间；
由msqid标识的消息队列从系统中删除（返回EIDRM错误）；
调用线程被某个信号所中断（返回EINTR错误。）

------------------------------------ msgrcv -----------------------------------------------

msgtyp：指定希望读出什么样的消息。

type == 0：表示将会返回队列中的第一个消息。
type > 0 ：表示将会返回队列中消息类型的值等于type参数的第一个消息。
type < 0 ：表示将会返回队列中小于或者等于type的绝对值中最小的第一个消息。

msgflg指定所请求的消息不在队列时的处理。在没有消息可得的情况下，如果设置了IPC_NOWAIT位，立即返回一个ENOMSG错误，否则阻塞到下列某个事件发生为止
（1）有一个所请求类型的消息可获取
（2）由msqid标识的消息队列被从系统中删除
（3）调用线程被某个捕获的信号所中断
msgflg参数中另有一位可以指定MSG_NOERROR,当所接收消息的真正数据部分大于length参数时，如果设置了该位，msgrcv函数只是截短数据部分，而不返回错误，否则，返回一个E2BIG错误。

msgctl

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgctl(int msqid, int cmd, struct msqid_ds *buf);// 返回：若成功则为0，出错-1

msgctl提供在一个消息队列上的各种控制操作。

有三个命令：
（1）IPC_RMID：从系统中删除msqid指定的消息队列。当前在该队列上的任何消息都被丢弃
（2）IPC_SET ：给队列设置其中的msqid_ds结构的四个成员:msg_perm.uid, msg_perm.gid, msg_perm.mode和msg_qbytes
（3）IPC_STAT：给调用者返回指定队列的当前msqid_ds结构

复用消息

　　与一个队列中的每个消息相关联的类型字段提供了两个特性：

（1）类型字段可以用于标识消息，从而允许多个进程在单个队列上复用消息。

（2）类型字段可以用做优先级，允许接收者以不同于先进先出的某个顺序读出各个消息。

限制