linux进程间通信程序设计2.ppt

消息队列用于运行于同一台机器上的进程间通信，它和管道很相似，是一个在系统内核中用来保存消息的队列，它在系统内核中是以消息链表的形式出现。消息链表中节点的结构用msg声明。事实上，它是一种正逐渐被淘汰的通信方式，我们可以用流管道或者套接口的方式来取代它，所以，我们对此方式也不再解释，也建议忽略这种方式 * 整个程序可以分为三个大的部分：消息队列的创建、消息发送、消息接收（在此程序中，消息的发送和接收在同一个进程中） * 进程间通信程序设计2  定义 unix早期通信机制之一的信号能够传送的信息量有限，管道则只能传送无格式的字节流，这无疑会给应用程序开发带来不便。消息队列（也叫做报文队列）则克服了这些缺点。 发展 消息队列就是一个消息的链表。可以把消息看作一个记录，具有特定的格式。进程可以向消息队列中按照一定的规则添加新消息；另一些进程则可以从消息队列中读走消息。 目前主要有两种类型的消息队列：POSIX消息队列以及系统V消息队列，系统V消息队列目前被大量使用。 分类 持续性 系统V消息队列是随内核持续的，只有在内核重起或者人工删除时，该消息队列才会被删除。 键值 消息队列的内核持续性要求每个消息队列都在系统范围内对应唯一的键值，所以，要获得一个消息队列的描述字，必须提供该消息队列的键值。如下： 　　#include sys/types.h 　　#include sys/ipc.h　　key_t ftok (char*pathname, char proj)　　功能：返回文件名对应的键值。　　pathname:文件名；proj:项目名（随意，不为0即可） 打开/创建消息队列 #include sys/types.h　　#include sys/ipc.h 　　#include sys/msg.h　　int msgget(key_t key, int msgflg)　　key：键值，由ftok获得。　　msgflg：标志位。　　返回值：与健值key相对应的消息队列描述字。　　IPC_CREAT：创建新的消息队列　　vIPC_EXCL：与IPC_CREAT一同使用，表示如果要创建的消息队列已经存在，则返回错误。　　vIPC_NOWAIT：读写消息队列要求无法得到满足时，不阻塞。 在以下两种情况下，将创建一个新的消息队列： 1）如果没有与健值key相对应的消息队列，并且msgflg中包含了IPC_CREAT标志位。 2）key参数为IPC_PRIVATE。 创建代码如下： int open_queue(key_t keyval) { 　　int qid; 　　if((qid=msgget(keyval,IPC_CREAT))==-1) 　　{ 　　　　return(-1); 　　} 　　return(qid); } 发送消息 　　#include sys/types.h 　　#include sys/ipc.h 　　#include sys/msg.h 　　int msgsnd(int msqid,struct msgbuf*msgp,int msgsz,int msgflg) 　　功能：向消息队列中发送一条消息。 　　msqid：已打开的消息队列id； 　　msgp：存放消息的结构； 　　msgsz：消息数据长度； 　　msgflg：发送标志，有意义的msgflg标志为IPC_NOWAIT，指明在消息队列没有足够空间容纳要发送的消息时，msgsnd是否等待。 　　struct msgbuf 　　{ 　　　　long mtype; /* 消息类型 0 */ 　　　　char mtext[1]; /* 消息数据的首地址 */ 　　}; 接收消息 #include sys/types.h 　　#include sys/ipc.h 　　#include sys/msg.h 　　int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg) 　　功能：从msqid代表的消息队列中读取一个msgtyp类型的消息，并把消息存储在msgp指向的msgbuf结构中。在成功地读取了一条消息以后，队列中的这条消息将被删除。 int read_message(int qid,long type,struct mymsgbuf*qbuf) { 　　int result,length; 　　length=sizeof(struct mymsgbuf)-sizeof(long); 　　if((result=msgrcv(qid,qbuf,length,type,0))