https://www.ibm.com/developerworks/cn/linux/l-ipc/part3/
继续坚持，或许不能深刻理解，但至少要保证有印象。
~~~~~~~~~~~~~~
消息队列（也叫做报文队列）能够克服早期unix通信机制的一些缺点。作为早期unix通信机制之一的信号能够传送的信息量有限，后来虽然POSIX 1003.1b在信号的实时性方面作了拓广，使得信号在传递信息量方面有了相当程度的改进，但是信号这种通信方式更像"即时"的通信方式，它要求接受信号的进程在某个时间范围内对信号做出反应，因此该信号最多在接受信号进程的生命周期内才有意义，信号所传递的信息是接近于随进程持续的概念（process-persistent），见 附录 1；管道及有名管道及有名管道则是典型的随进程持续IPC，并且，只能传送无格式的字节流无疑会给应用程序开发带来不便，另外，它的缓冲区大小也受到限制。
消息队列就是一个消息的链表。可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息；对消息队列有读权限的进程则可以从消息队列中读走消息。消息队列是随内核持续的（参见 附录 1）。
目前主要有两种类型的消息队列：POSIX消息队列以及系统V消息队列，系统V消息队列目前被大量使用。考虑到程序的可移植性，新开发的应用程序应尽量使用POSIX消息队列。
在本系列专题的序（深刻理解Linux进程间通信（IPC））中，提到对于消息队列、信号灯、以及共享内存区来说，有两个实现版本：POSIX的以及系统V的。Linux内核（内核2.4.18）支持POSIX信号灯、POSIX共享内存区以及POSIX消息队列，但对于主流Linux发行版本之一redhad8.0（内核2.4.18），还没有提供对POSIX进程间通信API的支持，不过应该只是时间上的事。
~~~~~~~~~~~~~~~
/***************** * * test.c* * ******************/ #include <sys/msg.h> #include <sys/types.h> #include <unistd.h> #include <stdio.h> #include <stdlib.h> void msg_stat(int, struct msqid_ds); main() { int gflags, sflags, rflags; key_t key; int msgid; int reval; struct msgsbuf{ int mtype; char mtext[1]; }msg_sbuf; struct msgmbuf{ int mtype; char mtext[10]; }msg_rbuf; struct msqid_ds msg_ginfo, msg_sinfo; char* msgpath = "/tmp/msgqueue"; key=ftok(msgpath, 'a'); gflags = IPC_CREAT|IPC_EXCL; msgid = msgget(key, gflags|00666); if(msgid == -1) { printf("msg create error\n"); return; } msg_stat(msgid, msg_ginfo); sflags=IPC_NOWAIT; msg_sbuf.mtype = 10; msg_sbuf.mtext[0] = 'a'; reval = msgsnd(msgid, &msg_sbuf, sizeof(msg_sbuf), sflags); if(reval == -1) { printf("message send error\n"); } msg_stat(msgid, msg_ginfo); rflags = IPC_NOWAIT|MSG_NOERROR; reval = msgrcv(msgid, &msg_rbuf, 4, 10, rflags); if(reval == -1) printf("read msg error\n"); else printf("read from msg queue %d bytes\n", reval); msg_stat(msgid, msg_ginfo); msg_sinfo.msg_perm.uid = 8; msg_sinfo.msg_perm.gid = 8; msg_sinfo.msg_qbytes = 16388; reval = msgctl(msgid, IPC_SET, &msg_sinfo); if(reval == -1) { printf("msg set info error\n"); return; } msg_stat(msgid, msg_ginfo); reval = msgctl(msgid, IPC_RMID, NULL); if(reval == -1) { printf("unlink msg queue error\n"); return; } } void msg_stat(int msgid, struct msqid_ds msg_info) { int reval; sleep(1); reval = msgctl(msgid, IPC_STAT, &msg_info); if(reval == -1) { printf("get msg info error\n"); return; } printf("\n"); printf("current number of bytes on queue is %d\n", msg_info.msg_cbytes); printf("number of messages in queue is %d\n",msg_info.msg_qnum); printf("max number of bytes on queue is %d\n",msg_info.msg_qbytes); printf("pid of last msgsnd is %d\n",msg_info.msg_lspid); printf("pid of last msgrcv is %d\n",msg_info.msg_lrpid); printf("last msgsnd time is %s", ctime(&(msg_info.msg_stime))); printf("last msgrcv time is %s", ctime(&(msg_info.msg_rtime))); printf("last change time is %s", ctime(&(msg_info.msg_ctime))); printf("msg uid is %d\n",msg_info.msg_perm.uid); printf("msg gid is %d\n",msg_info.msg_perm.gid); }
