《linux进程间通信程序设计2》由会员分享，可在线阅读，更多相关《linux进程间通信程序设计2（15页珍藏版）》请在金锄头文库上搜索。
1、进程间通信程序设进程间通信程序设计计2 定义unix早期通信机制之一的早期通信机制之一的信号能够传送的信息量有信号能够传送的信息量有限，管道则只能传送无格式的字节流限，管道则只能传送无格式的字节流，这无疑会给，这无疑会给应用程序开发带来不便。消息队列（也叫做报文队应用程序开发带来不便。消息队列（也叫做报文队列）则克服了这些缺点。列）则克服了这些缺点。发展消息队列就是一个消息的链表。可以把消息队列就是一个消息的链表。可以把消息消息看作一看作一个记录，个记录，具有特定的格式具有特定的格式。进程可以向消息队列中按照一定的规则添加新消息；进程可以向消息队列中按照一定的规则添加新消息；另一些进程则可以从
2、消息队列中读走消息。另一些进程则可以从消息队列中读走消息。目前主要有两种类型的消息队列：目前主要有两种类型的消息队列：POSIX消息队列消息队列以及以及系统系统V消息队列消息队列，系统，系统V消息队列目前被大量使消息队列目前被大量使用。用。分类持续性系统系统V消息队列是随内核持续的，只有在内核重起消息队列是随内核持续的，只有在内核重起或者人工删除时，该消息队列才会被删除。或者人工删除时，该消息队列才会被删除。键值消息队列的内核持续性要求每个消息队列都在系统范围内对应唯一的键值，所以，要获得一个消息队列的描述字，必须提供该消息队列的键值。如下：#include #include key_t ft
3、ok (char*pathname, char proj)功能：返回文件名对应的键值。pathname:文件名；proj:项目名（随意，不为0即可）打开/创建消息队列#include #include #include int msgget(key_t key, int msgflg)key：键值，由ftok获得。msgflg：标志位。返回值：与健值key相对应的消息队列描述字。IPC_CREAT：创建新的消息队列vIPC_EXCL：与IPC_CREAT一同使用，表示如果要创建的消息队列已经存在，则返回错误。vIPC_NOWAIT：读写消息队列要求无法得到满足时，不阻塞。在以下两种情况下，将创
4、建一个新的消息队列：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 #include #include int msgsnd(int msqid,struct msgbuf*msgp,int msgsz,int msgflg)功能：向消息队列中发送一条消息。msqid：已打开的
5、消息队列id；msgp：存放消息的结构；msgsz：消息数据长度；msgflg：发送标志，有意义的msgflg标志为IPC_NOWAIT，指明在消息队列没有足够空间容纳要发送的消息时，msgsnd是否等待。struct msgbuf long mtype; /* 消息类型 0 */char mtext1; /* 消息数据的首地址 */;接收消息#include #include #include int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg)功能：从msqid代表的消息队列中读取一个m
6、sgtyp类型的消息，并把消息存储在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)=-1) return(-1); return(result); msg.c演示创建key=ftok(/tmp/2,a);获取键值之后，试图利用这个键值将
7、消息队列打开，key指向的消息队列有两种情况：第一种情况是消息队列已经存在，可以打开它，返回打开消息队列的描述符msgid；第二种情况是这个消息队列并不存在，由于有IPC_CREAT这个参数可以创建消息队列，同样打开消息队列的描述符msgid。创建好之后，就有了msgid。发送msgsnd()函数来完成。第一个参数msgid，第二个参数是要发送的消息队列保存在那一个结构体中，这里保存在msgbuf中（这是自己定义的结构）。不过msgbuf已经保存好了数据，通过使用msgbuf.mtype=getpid()，把进程id作为消息的类型（取值自己决定，只要发送和接收的类型值一致即可）；strcpy()函数给data中放入了数据。接收如果是另一个进程接收这个消息，还要使用msgget()函数打开这个消息队列。 发送和接收消息体必须是一致的。
