进程通信_消息队列_hmm.ppt

消息队列 消息队列（也叫做报文队列）能够克服早期unix通信机制的一些缺点。 信号：传递信息有限，并且要求接受信号的进程在某个时间范围内对信号做出反应，信号这种通信方式更像“即时”的通信方式。 消息队列就是一个消息的链表。可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息；对消息队列有读权限的进程则可以从消息队列中读走消息。消息队列是随内核持续的。 操作消息队列 1、 打开或创建消息队列 2、 读写操作 3、 获得或设置消息队列属性 1、 打开或创建消息队列 消息队列的内核持续性要求每个消息队列都在系统范围内对应唯一的键值，所以，要获得一个消息队列的描述字，只需提供该消息队列的键值即可； 注：消息队列描述字是由在系统范围内唯一的键值生成的，而键值可以看作对应系统内的一条路经。 2、 读写操作 消息读写操作非常简单，对开发人员来说，每个消息都类似如下的数据结构： struct msgbuf{ long mtype; char mtext[1]; }; mtype成员代表消息类型，从消息队列中读取消息的一个重要依据就是消息的类型；mtext是消息内容，当然长度不一定为1。因此，对于发送消息来说，首先预置一个msgbuf缓冲区并写入消息类型和内容，调用相应的发送函数即可；对读取消息来说，首先分配这样一个msgbuf缓冲区，然后把消息读入该缓冲区即可。 3、 获得或设置消息队列属性 （消息队列的信息基本上都保存在消息队列头中，因此，可以分配一个类似于消息队列头的结构(struct msqid_ds，如下），来返回消息队列的属性；同样可以设置该数据结构。 结构msqid_ds用来设置或返回消息队列的信息，存在于用户空间； struct msqid_ds { struct ipc_perm msg_perm; struct msg *msg_first; /* first message on queue,unused */ struct msg *msg_last; /* last message in queue,unused */ __kernel_time_t msg_stime; /* last msgsnd time */ __kernel_time_t msg_rtime; /* last msgrcv time */ __kernel_time_t msg_ctime; /* last change time */ unsigned long msg_lcbytes; /* Reuse junk fields for 32 bit */ unsigned long msg_lqbytes; /* ditto */ unsigned short msg_cbytes; /* current number of bytes on queue */ unsigned short msg_qnum; /* number of messages in queue */ unsigned short msg_qbytes; /* max number of bytes on queue */ __kernel_ipc_pid_t msg_lspid; /* pid of last msgsnd */ __kernel_ipc_pid_t msg_lrpid; /* last receive pid */ };  系统V消息队列API 系统V消息队列API共有四个，使用时需要包括几个头文件： #include sys/types.h #include sys/ipc.h #include sys/msg.h 1）int msgget(key_t key, int msgflg) 参数key是一个键值；msgflg参数是一些标志位。该调用返回与健值key相对应的消息队列描述字。 在以下两种情况下，该调用将创建一个新的消息队列： 如果没有消息队列与健值key相对应，并且msgflg中包含了IPC_CREAT标志位； key参数为IPC_PRIVATE； 参数msgflg可以为以下：IPC_CREAT、IPC_EXCL、IPC_NOWAIT或三者的或结果。 调用返回：成功返回消息队列描述字，否则返回-1。 注：参数key设置成常数IPC_PRIVATE并不意味着其他进程不能访问该消息队列，只意味着即将创建新的消息队列。 系统V消息队列API 2）int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg); 该系统调用从msgid代表的消息队列中