Linux System V IPC 消息队列

Linux System V IPC 消息队列

模型:

获取key值 :ftok()

创建/获取消息队列 :msgget()

发消息到消息队列/从消息队列收信息 :msgsnd()/msgrcv()

删除消息队列 :msgctl()

使用的头文件 #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> ftok() //获取key值, key值是System V IPC的标识符，成功返回key，失败返回-1设errno //同pathname+同 proj_id==>同key_t; key_t ftok(const char *pathname, int proj_id);

pathname :文件名
proj_id: 1~255的一个数，表示project_id

key_t key=ftok(".",100); //“.”就是一个存在且可访问的路径, 100是假设的proj_id if(-1==key) perror("ftok"),exit(-1); msgget() //创建/获取消息队列，成功返回shmid，失败返回-1 int msgget(key_t key, int msgflg); //ATTENTION:用int msqid=msgget()比较好看

msgflg:具体的操作标志

IPC_CREAT 若不存在则创建, 需要在msgflg中＂|权限信息＂; 若存在则打开

IPC_EXCL若存在则创建失败

0 获取已经存在的消息队列

消息队列的容量由msg_qbytes控制，在消息队列被创建的过程中，这个大小被初始化为MSGMNB，这个限制可以通过msgctl()修改

int msqid=msgget(key,IPC_CREAT|IPC_EXCL|0664); if(-1==msqid) perror("msgget"),exit(-1); msgsnd() //向指定的消息队列发送指定的消息，如果消息队列已经满了，默认的行为是堵塞，直到队列有空间容纳新的消息，成功返回0,失败返回-1设errno int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

msqid msgget()返回的消息队列的ID
msgp消息的的首地址, 消息的参考数据类型如下

struct msgbuf { long mtype; /* message type, must be > 0 */ //消息的类型 char mtext[1]; /* message data */ //消息的内容 }; ATTENTION:The mtext field is an array (or other structure) whose size is specified by msgsz, a nonnegative integer value.

msgsz消息的大小, 该参数用于指定消息内容的大小, 不包括消息的类型。只能sizeof(Msgbuf.mtext),不能sizeof(Msgbuf)
msgflg发送的标志, 默认给0即可

Msg msg1={1,"hello"};//消息的类型是1,内容是hello int res=msgsnd(msqid,&msg2,sizeof(msg2.buf),0); if(-1==res) perror("msgsnd"),exit(-1); msgrcv() //向指定的消息队列取出指定的消息，成功返回实际接受到的byte数，失败返回-1设errno ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

msqid: 消息队列的ID(returned by msgget)
msgp: 存放接收到消息的缓冲区首地址
msgsz: 消息的最大大小, 不包括消息的类型==>只能sizeof(Msgbuf.mtext),不能sizeof(Msgbuf)

如果消息的长度>msgsz且msgflg里有MSG_NOERROR，则消息会被截断，被截断的部分会丢失

如果消息的长度>msgsz且msgflg里没有MSG_NOERROR，那么会出错，报E2BIG。

msgtyp: 消息的类型

0:读取消息队列中的第一个消息

>0:读取消息队列中第一个type为msgtype的消息, 除非msg_flg里有MSG_EXCEPT，此时队列中的第一个不是msgtyp的消息会被读取

<0读取消息队列中type<=|msgtype|的消息, 这里再优先读取最小的

msgflg: 发送的标志, 默认给0即可

Msg msg1; int res=msgrcv(msqid,&msg1,sizeof(msg1.buf),1,0); if(-1==res) perror("msgrcv"),exit(-1); msgctl() // 消息操作，成功返回0,失败返回-1设errno int msgctl(int msqid, int cmd, struct msqid_ds *buf);