消息队列是消息的连接表,存放在内核中并由消息队列标识符标识。一般将消息队列称为“队列”,其标识符为“队列ID”。
消息队列中使用的函数有以下几个:
1、msgget
该函数用来创建和访问一个消息队列。它的原型为:int msgget(key_t, key, int msgflg);
与其他的IPC机制一样,程序必须提供一个键来命名某个特定的消息队列。msgflg是一个权限标志,表示消息队列的访问权限,它与文件的访问权限一样。msgflg可以与IPC_CREAT做或操作,表示当key所命名的消息队列不存在时创建一个消息队列,如果key所命名的消息队列存在时,IPC_CREAT标志会被忽略,而只返回一个标识符。它返回一个以key命名的消息队列的标识符(非零整数),失败时返回-1.
2、msgsnd
该函数用来把消息添加到消息队列中。它的原型为:int msgsend(int msgid, const void *msg_ptr, size_t msg_sz, i
nt msgflg); (msgid是由msgget函数返回的消息队列标识符)
msg_ptr是一个指向准备发送消息的指针,但是消息的数据结构却有一定的要求,指针msg_ptr所指向的消息结构一定要是以一个长整型成员变量开始的结构体,接收函数将用这个成员来确定消息的类型。所以消息结构要定义成这样:
struct my_message
{
long int message_type;
/* The data you wish to transfer*/
};
msg_sz是msg_ptr指向的消息的长度,注意是消息的长度,而不是整个结构体的长度,也就是说msg_sz是不包括长整型消息类型成员变量的长度。
msgflg用于控制当前消息队列满或队列消息到达系统范围的限制时将要发生的事情。
如果调用成功,消息数据的一分副本将被放到消息队列中,并返回0,失败时返回-1.
3、msgrcv该函数用来从一个消息队列获取消息,它的原型为
int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg); (msgid, msg_ptr, msg_st的作用也函数msgsnd函数的一样)
msgtype可以实现一种简单的接收优先级。如果msgtype为0,就获取队列中的第一个消息。如果它的值大于零,将获取具有相同消息类型的第一个信息。如果它小于零,就获取类型等于或小于msgtype的绝对值的第一个消息。
msgflg用于控制当队列中没有相应类型的消息可以接收时将发生的事情。
调用成功时,该函数返回放到接收缓存区中的字节数,消息被复制到由msg_ptr指向的用户分配的缓存区中,然后删除消息队列中的对应消息。失败时返回-1.
4、msgctl该函数用来控制消息队列,它与共享内存的shmctl函数相似,它的原型为:
int msgctl(int msgid, int command, struct msgid_ds *buf);
command是将要采取的动作,它可以取3个值:
IPC_STAT:把msgid_ds结构中的数据设置为消息队列的当前关联值,即用消息队列的当前关联值覆盖msgid_ds的值。
IPC_SET:如果进程有足够的权限,就把消息列队的当前关联值设置为msgid_ds结构中给出的值
IPC_RMID:删除消息队列
buf是指向msgid_ds结构的指针,它指向消息队列模式和访问权限的
结构。
msgid_ds结构至少包括以下成员:
struct msgid_ds
{
uid_t shm_perm.uid;
uid_t shm_perm.gid;
mode_t shm_perm.mode;
};
成功时返回0,失败时返回-1.
三、使用消息队列进行进程间通信的代码实现:
“msg.h”
#ifndef __MSG_H
#define __MSG_H
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<assert.h>
#include <sys/msg.h>
typedef struct
Node
{
long type;
char text[128];
}MsgData;
#endif
“msga.c”
#include "msg.h"
int main()
{
int msgid = msgget((key_t)1234, IPC_CREAT | 0664);
assert(msgid != -1);
MsgData data; // sizeof(data) = 128 + 4
data.type = 1000;
strcpy(data.text, "hello");
msgsnd(msgid, (void *)&data, strlen(data.text) + 4, 0);
data.type = 2000;
strcpy(data.text, "wolrd");
msgsnd(msgid, (void *)&data, strlen(data.text) + 4, 0);
data.type = 1000;
strcpy(data.text, "Linux");
msgsnd(msgid, (void *)&data, strlen(data.text) + 4, 0);
}
“msgb.c”
#include "msg.h"
int main()
{
int msgid = msgget((key_t)1234, IPC_CREAT | 0664);
assert(msgid != -1);
MsgData data;
msgrcv(msgid, &data, sizeof(data), 2000, 0);
printf("%s\n", data.text);
}