消息队列是消息的链接表，存储在内核中，用队列标识符标识(XSI的标识符)。消息队列的每个消息对象至少两个对象：消息类型(长整型表示)和消息主体。结构体定义如下：
struct msg
{
long type;
char data[50];
};//此消息结构体由用户定义，开头一定是消息类型
每个消息队列都有一个msgid_ds的结构体(XSI IPC都有)。主要内容如下：
struct msgid_ds
{
struct ipc_perm;
msgnum_t msg_qnum; //number of message on queue
msg_len_t msg_qbytes; //max length of message on queue
pid_t msg_lspid; //pid of last msgsnd()
pid_t msg_lrpid; //pid of last msgrcv()
};
该结构体的内容可以通过msgctl()获取(使用方法见进程通信之共享内存3.2)。
消息队列的使用方式通常是：发送方调用msgget()创建消息队列，调用msgsnd()发送消息；接收方调用msgget()获取消息队列ID，调用msgrcv()接收消息，在退出时调用msgctl()删除该消息队列。每个函数的具体使用方法如下：
/*
函数名：msgget
key：IPC的键，通常调用ftok生成或直接指定
msgflg：
IPC_CREAT：创建新的IPC，如果有，则打开
IPC_EXCL：通常和IPC_CREAT一起使用，如果IPC已经存在，创建失败，errno显示EEXIST
关于读写权限见下图
返回值：消息队列ID
*/
int msgget(key_t key, int msgflg);
/*
函数名：msgsnd
msqid：消息队列标识符
msg_ptr：消息格式的结构体
msg_sz：消息主体大小(不包含消息类型)
msgflg：如果为0，则在发送到消息队列前一直等待；如果为IPC_NOWAIT，则当队列满时，出错返回EAGAIN
*/
int msgsnd(int msqid, const void *msg_ptr, size_t msg_sz, int msgflg);
/*
函数名：msgrcv
参数基与msgsnd一致
msgtype：期望接收的消息类型，如果为0，则表示接收消息队列头的一条消息
*/
msgrcv(int msqid, void *msg_ptr, size_t msg_sz, long int msgtype, int msgflg);
/*
函数名：msgctl
通常用来删除消息队列
*/
int msgctl(int msqid, int command, struct msqid_ds *buf);
//删除消息队列时用法为：
msgctl(msgid,IPC_RMID,NULL);
关于msgget函数第二个参数msgflag,除了IPC_CREAT和IPC_EXCL，还有读写控制权限，如下图：
通常在调用一个XSI IPC时，都用如下形式：
msgget(key,IPC_CREAT|0666);//创建或打开一个消息队列并赋予所有读写权限
下面看一个完整的例子：写进程创建并写入消息；读进程读取消息，并在退出时删除消息队列
1 //写进程
2 #include <sys/msg.h>
3 #include <string.h>
4 #include <stdio.h>
5 #include <stdlib.h>
6 #include <errno.h>
7 #include <fcntl.h>
8 #include <sys/ipc.h>
9
10 struct MSG
11 {
12 long type;
13 char msg[50];
14 };
15
16 int main()
17 {
18 key_t key=ftok("/tmp",1);
19 int msgid=msgget(key,IPC_CREAT|0666);
20 if(msgid<0)
21 {
22 printf("msgget error\n");
23 msgid=msgget(key,O_RDONLY); //获取ID
24 msgctl(msgid,IPC_RMID,NULL); //删除消息队列
25 exit(1);
26 }
27 MSG m;
28 char c;
29 while(1)
30 {
31 printf("Input type\n");
32 scanf("%ld",&(m.type));
33 scanf("%c",&c); //处理换行
34 printf("Input message\n");
35 fgets(m.msg,sizeof(m)-sizeof(long),stdin);
36 if(msgsnd(msgid,(void*)&m,50,0)==EAGAIN)
37 printf("Queue has no volumn\n");
38 if(strncmp(m.msg,"Quit",4)==0)
39 break;
40
41 }
42 exit(0);
43 }
44
45
46
47
48 //读进程，头文件与写进程相同
49 struct MSG
50 {
51 long type;
52 char msg[50];
53 };
54
55 int main()
56 {
57 MSG m;
58 key_t key=ftok("/tmp",1);
59 int msgid=msgget(key,IPC_CREAT|0666);
60 if(msgid<0)
61 {
62 printf("msgget error\n");
63 exit(1);
64 }
65 while(1)
66 {
67 if(msgrcv(msgid,(void*)&m,50,0,0)<0) //接收任何消息类型
68 {
69 printf("receive error\n");
70 if(errno==E2BIG) printf("E2BIG");
71 if(errno==EACCES) printf("EACCES");
72 if(errno==EAGAIN) printf("EAGAIN");
73 if(errno==EFAULT) printf("EFAULT");
74 if(errno==EIDRM) printf("EIDRM");
75 if(errno==EINTR) printf("EINTR");
76 if(errno==EINVAL) printf("EINVAL");
77 if(errno==ENOMSG)printf("ENOMSG");
78 exit(1);
79 }
80 printf("type:%ld msg:%s\n",m.type,m.msg);
81 if(strncmp(m.msg,"Quit",4)==0) break;
82 }
83 msgctl(msgid,IPC_RMID,NULL);
84 exit(0);
85 }
注：消息队列一旦创建，除非显示删除(调用msgctl,或命令行ipcrm -q msgid)，将一直存在于内存中。当一个进程删除了某个消息队列后，其他进程再次调用该消息队列将出错。