Linux_4.9_消息队列

(1) 基本概念:



posix消息队列与system v消息队列的差别：
0、对posix消息队列的读总是返回最高优先级的最早消息，对system v消息队列的读则可以返回任意指定优先级的消息。

1、当往一个空队列放置一个消息时，posix消息队列允许产生一个信号或启动一个线程，system v消息队列则不提供类似机制。



队列中的每个消息具有如下属性：
0、一个无符号整数优先级(posix)或一个长整数类型(system v)

1、消息的数据部分长度(可以为0)

2、数据本身(如果长度大于0)

(2) 函数学习

1. msgget函数原型

msgget(得到消息队列标识符或创建一个消息队列对象)
所需头文件	#include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h>
函数说明	得到消息队列标识符或创建一个消息队列对象并返回消息队列标识符
函数原型	int msgget(key_t key, int msgflg)
函数传入值	key	0(IPC_PRIVATE)：会建立新的消息队列
大于0的32位整数：视参数msgflg来确定操作。通常要求此值来源于ftok返回的IPC键值
msgflg	0：取消息队列标识符，若不存在则函数会报错
IPC_CREAT：当msgflg&IPC_CREAT为真时，如果内核中不存在键值与key相等的消息队列，则新建一个消息队列；如果存在这样的消息队列，返回此消息队列的标识符
IPC_CREAT|IPC_EXCL：如果内核中不存在键值与key相等的消息队列，则新建一个消息队列；如果存在这样的消息队列则报错
函数返回值	成功：返回消息队列的标识符
出错：-1，错误原因存于error中
附加说明	上述msgflg参数为模式标志参数，使用时需要与IPC对象存取权限（如0600）进行|运算来确定消息队列的存取权限
错误代码	EACCES：指定的消息队列已存在，但调用进程没有权限访问它 EEXIST：key指定的消息队列已存在，而msgflg中同时指定IPC_CREAT和IPC_EXCL标志 ENOENT：key指定的消息队列不存在同时msgflg中没有指定IPC_CREAT标志 ENOMEM：需要建立消息队列，但内存不足 ENOSPC：需要建立消息队列，但已达到系统的限制

如果用msgget创建了一个新的消息队列对象时，则msqid_ds结构成员变量的值设置如下：

Ÿ msg_qnum、msg_lspid、msg_lrpid、 msg_stime、msg_rtime设置为0。

Ÿ msg_ctime设置为当前时间。

Ÿ msg_qbytes设成系统的限制值。

Ÿ msgflg的读写权限写入msg_perm.mode中。

Ÿ msg_perm结构的uid和cuid成员被设置成当前进程的有效用户ID，gid和cuid成员被设置成当前进程的有效组ID。

2. msgctl函数原型

msgctl (获取和设置消息队列的属性)
所需头文件	#include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h>
函数说明	获取和设置消息队列的属性
函数原型	int msgctl(int msqid, int cmd, struct msqid_ds *buf)
函数传入值	msqid	消息队列标识符
cmd	IPC_STAT:获得msgid的消息队列头数据到buf中
IPC_SET：设置消息队列的属性，要设置的属性需先存储在buf中，可设置的属性包括：msg_perm.uid、msg_perm.gid、msg_perm.mode以及msg_qbytes
buf：消息队列管理结构体，请参见消息队列内核结构说明部分
函数返回值	成功：0
出错：-1，错误原因存于error中
错误代码	EACCESS：参数cmd为IPC_STAT，确无权限读取该消息队列 EFAULT：参数buf指向无效的内存地址 EIDRM：标识符为msqid的消息队列已被删除 EINVAL：无效的参数cmd或msqid EPERM：参数cmd为IPC_SET或IPC_RMID，却无足够的权限执行

3. msgsnd函数原型

msgsnd (将消息写入到消息队列)
所需头文件	#include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h>
函数说明	将msgp消息写入到标识符为msqid的消息队列
函数原型	int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg)
函数传入值	msqid	消息队列标识符
msgp	发送给队列的消息。msgp可以是任何类型的结构体，但第一个字段必须为long类型，即表明此发送消息的类型，msgrcv根据此接收消息。msgp定义的参照格式如下： struct s_msg{ /*msgp定义的参照格式*/ long type; /* 必须大于0,消息类型 */ char mtext[256]; /*消息正文，可以是其他任何类型*/ } msgp;
msgsz	要发送消息的大小，不含消息类型占用的4个字节,即mtext的长度
msgflg	0：当消息队列满时，msgsnd将会阻塞，直到消息能写进消息队列
IPC_NOWAIT：当消息队列已满的时候，msgsnd函数不等待立即返回
IPC_NOERROR：若发送的消息大于size字节，则把该消息截断，截断部分将被丢弃，且不通知发送进程。
函数返回值	成功：0
出错：-1，错误原因存于error中
错误代码	EAGAIN：参数msgflg设为IPC_NOWAIT，而消息队列已满 EIDRM：标识符为msqid的消息队列已被删除 EACCESS：无权限写入消息队列 EFAULT：参数msgp指向无效的内存地址 EINTR：队列已满而处于等待情况下被信号中断 EINVAL：无效的参数msqid、msgsz或参数消息类型type小于0

msgsnd()为阻塞函数，当消息队列容量满或消息个数满会阻塞。消息队列已被删除，则返回EIDRM错误；被信号中断返回E_INTR错误。

如果设置IPC_NOWAIT消息队列满或个数满时会返回-1，并且置EAGAIN错误。

msgsnd()解除阻塞的条件有以下三个条件：

① 不满足消息队列满或个数满两个条件，即消息队列中有容纳该消息的空间。

② msqid代表的消息队列被删除。

③ 调用msgsnd函数的进程被信号中断。

4. msgrcv函数原型

msgrcv (从消息队列读取消息)
所需头文件	#include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h>
函数说明	从标识符为msqid的消息队列读取消息并存于msgp中，读取后把此消息从消息队列中删除
函数原型	ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
函数传入值	msqid	消息队列标识符
msgp	存放消息的结构体，结构体类型要与msgsnd函数发送的类型相同
msgsz	要接收消息的大小，不含消息类型占用的4个字节
msgtyp	0：接收第一个消息
>0：接收类型等于msgtyp的第一个消息
<0：接收类型等于或者小于msgtyp绝对值的第一个消息
msgflg	0: 阻塞式接收消息，没有该类型的消息msgrcv函数一直阻塞等待
IPC_NOWAIT：如果没有返回条件的消息调用立即返回，此时错误码为ENOMSG
IPC_EXCEPT：与msgtype配合使用返回队列中第一个类型不为msgtype的消息
IPC_NOERROR：如果队列中满足条件的消息内容大于所请求的size字节，则把该消息截断，截断部分将被丢弃
函数返回值	成功：实际读取到的消息数据长度
出错：-1，错误原因存于error中
错误代码	E2BIG：消息数据长度大于msgsz而msgflag没有设置IPC_NOERROR EIDRM：标识符为msqid的消息队列已被删除 EACCESS：无权限读取该消息队列 EFAULT：参数msgp指向无效的内存地址 ENOMSG：参数msgflg设为IPC_NOWAIT，而消息队列中无消息可读 EINTR：等待读取队列内的消息情况下被信号中断

msgrcv()解除阻塞的条件有以下三个：

① 消息队列中有了满足条件的消息。

② msqid代表的消息队列被删除。

③ 调用msgrcv()的进程被信号中断。

实例:
send.c文件:

#include <stdio.h>

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/msg.h>

#include <errno.h>

#include <string.h>

#include <stdlib.h>

#define MSGKEY 1024

struct msgstru

{

long msgtype;

char msgtext[2048];

};

int main(void)

{

struct msgstru msgs;

int msg_type;

char str[256];

int ret_value;

int msqid;

/*check message queue whether to create*/

msqid = msgget(MSGKEY,IPC_EXCL);

/*if not exist,then create message queue*/

if(msqid < 0)

{

msqid = msgget(MSGKEY,IPC_CREAT|0666);

if(msqid < 0)

{

printf("failed to create msq | errno=%d [%s]\n",errno,strerror(errno));

exit(-1);

}

}

while(1)

{

printf("input message type(end:0):");

scanf("%d",&msg_type);

if(msg_type == 0)

{

break;

}

printf("input messge to be sent:");

scanf("%s",str);

msgs.msgtype = msg_type;

strcpy(msgs.msgtext,str);

/*send message queue*/

ret_value = msgsnd(msqid,&msgs,sizeof(struct msgstru),IPC_NOWAIT);

if(ret_value < 0)

{

printf("msgsnd() write msg failed, errno=%d [%s]\n",errno,strerror(errno));

exit(-1);

}
}

/*delete message queue*/

msgctl(msqid,IPC_RMID,0);

return 0;

}

receive.c文件:

#include <stdio.h>

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/msg.h>

#include <errno.h>

#define MSGKEY 1024

struct msgstru

{

long msgtype;

char msgtext[2048];

};

/*child process ,monitor message queue*/

void childproc()

{

struct msgstru msgs;

int msgid,ret_value;

char str[512];

while(1)

{

/*check message queue whether to create*/

msgid = msgget(MSGKEY,IPC_EXCL);

if(msgid < 0)

{

printf("msq not existed! errno = %d [%s]\n",errno,strerror(errno));

sleep(2);

continue;

}

/*receiver message queue*/

ret_value = msgrcv(msgid,&msgs,sizeof(struct msgstru),0,0);

printf("text=[%s] pid=[%d]\n",msgs.msgtext,getpid());

}

return ;

}

int main(void)

{

int i,cpid;

/*create 31 child process*/

for(i=0;i<5;i++)

{

cpid = fork();

if(cpid < 0)

{

printf("fork failed\n");

}

else if(cpid == 0) /*child process*/

{

childproc();

}

}

return 0;

}