linux环境进程间通信（三）：消息队列.htm

本资源中含有有关LINUX进程通信的一些文章

              border=0></CENTER></LI></OL>
            <P>从上图可以看出，全局数据结构 struct ipc_ids msg_ids 可以访问到每个消息队列头的第一个成员：struct 
            kern_ipc_perm；而每个struct 
            kern_ipc_perm能够与具体的消息队列对应起来是因为在该结构中，有一个key_t类型成员key，而key则唯一确定一个消息队列。kern_ipc_perm结构如下：</P>
            <TABLE cellSpacing=0 cellPadding=5 width="100%" bgColor=#cccccc 
            border=1>
              <TBODY>
              <TR>
                <TD><PRE><CODE>struct kern_ipc_perm{   //内核中记录消息队列的全局数据结构msg_ids能够访问到该结构；
            key_t   key;    //该键值则唯一对应一个消息队列
            uid_t   uid;
            gid_t   gid;
uid_t   cuid;
gid_t   cgid;
mode_t  mode;
unsigned long seq;
}
</CODE>
</PRE></TD></TR></TBODY></TABLE><BR>
            <P><A id=2 name=2><SPAN class=atitle2>二、操作消息队列</SPAN></A></P>
            <P><SPAN class=atitle3>对消息队列的操作无非有下面三种类型：</SPAN></P>
            <P>1、 
            打开或创建消息队列<BR>消息队列的内核持续性要求每个消息队列都在系统范围内对应唯一的键值，所以，要获得一个消息队列的描述字，只需提供该消息队列的键值即可；</P>
            <P>注：消息队列描述字是由在系统范围内唯一的键值生成的，而键值可以看作对应系统内的一条路经。</P>
            <P>2、 读写操作</P>
            <P>消息读写操作非常简单，对开发人员来说，每个消息都类似如下的数据结构：</P>
            <TABLE cellSpacing=0 cellPadding=5 width="100%" bgColor=#cccccc 
            border=1>
              <TBODY>
              <TR>
                <TD><PRE><CODE>struct msgbuf{
long mtype;
char mtext[1];
};</CODE>
</PRE></TD></TR></TBODY></TABLE><BR>
            <P>mtype成员代表消息类型，从消息队列中读取消息的一个重要依据就是消息的类型；mtext是消息内容，当然长度不一定为1。因此，对于发送消息来说，首先预置一个msgbuf缓冲区并写入消息类型和内容，调用相应的发送函数即可；对读取消息来说，首先分配这样一个msgbuf缓冲区，然后把消息读入该缓冲区即可。</P>
            <P>3、 获得或设置消息队列属性：</P>
            <P>消息队列的信息基本上都保存在消息队列头中，因此，可以分配一个类似于消息队列头的结构(struct msqid_ds，见<A 
            href="http://www-900.ibm.com/developerWorks/cn/linux/l-ipc/part3/index.shtml#listing2">附录 
            2</A>)，来返回消息队列的属性；同样可以设置该数据结构。</P><BR>
            <CENTER><IMG height=219 alt="" src="" width=507 
            border=0></CENTER><BR>
            <P><SPAN class=atitle3>消息队列API</SPAN></P>
            <P><B>1、文件名到键值</B></P>
            <TABLE cellSpacing=0 cellPadding=5 width="100%" bgColor=#cccccc 
            border=1>
              <TBODY>
              <TR>
                <TD><PRE><CODE>#include &lt;sys/types.h&gt;
#include &lt;sys/ipc.h&gt;
key_t ftok (char*pathname, char proj)；
</CODE>
</PRE></TD></TR></TBODY></TABLE><BR>
            <P>它返回与路径pathname相对应的一个键值。该函数不直接对消息队列操作，但在调用ipc(MSGGET,…)或msgget()来获得消息队列描述字前，往往要调用该函数。典型的调用代码是：</P>
            <TABLE cellSpacing=0 cellPadding=5 width="100%" bgColor=#cccccc 
            border=1>
              <TBODY>
              <TR>
                <TD><PRE><CODE>   key=ftok(path_ptr, 'a');
    ipc_id=ipc(MSGGET, (int)key, flags,0,NULL,0);
    …
</CODE>
</PRE></TD></TR></TBODY></TABLE><BR>
            <P><B>2、linux为操作系统V进程间通信的三种方式（消息队列、信号灯、共享内存区）提供了一个统一的用户界面：</B><BR><CODE><FONT 
            face=新宋体><B>int ipc</B>(unsigned int <B>call</B>, int <B>first</B>, 
            int <B>second</B>, int <B>third</B>, void *<B>ptr</B>, long 
            <B>fifth</B>);</FONT></CODE></P>
            <P>第一个参数指明对IPC对象的操作方式，对消息队列而言共有四种操作：MSGSND、MSGRCV、MSGGET以及MSGCTL，分别代表向消息队列发送消息、从消息队列读取消息、打开或创建消息队列、控制消息队列；first参数代表唯一的IPC对象；下面将介绍四种操作。</P>
            <UL class=n01>
              <LI><B>int ipc</B>(<B>MSGGET, int</B> first, <B>int</B> second, 
              <B>int</B> third, <B>void</B> *ptr, <B>long</B> 
              fifth);<BR>与该操作对应的系统V调用为：int msgget( (key_t)first，second)。 
              <LI><B>int ipc</B>(<B>MSGCTL, int</B> first, <B>int</B> second, 
              <B>int</B> third, <B>void</B> *ptr, <B>long</B> 
              fifth)<BR>与该操作对应的系统V调用为：int msgctl( first，second, (struct 
              msqid_ds*) ptr)。 
              <LI><B>int ipc</B>(<B>MSGSND, int</B> first, <B>int</B> second, 
              <B>int</B> third, <B>void</B> *ptr, <B>long</B> 
              fifth);<BR>与该操作对应的系统V调用为：int msgsnd( first, (struct msgbuf*)ptr, 
              second, third)。 
              <LI><B>int ipc</B>(<B>MSGRCV, int</B> first, <B>int</B> second, 
              <B>int</B> third, <B>void</B> *ptr, <B>long</B> 
              fifth);<BR>与该操作对应的系统V调用为：int msgrcv( first，(struct msgbuf*)ptr, 
              second, fifth,third)， </LI></UL><BR>
            <P>注：本人不主张采用系统调用ipc()，而更倾向于采用系统V或者POSIX进程间通信API。原因如下：</P>
            <UL class=n01>
              <LI>虽然该系统调用提供了统一的用户界面，但正是由于这个特性，它的参数几乎不能给出特定的实际意义（如以first、second来命名参数），在一定程度上造成开发不便。 

              <LI>正如ipc手册所说的：ipc()是linux所特有的，编写程序时应注意程序的移植性问题； 
              <LI>该系统调用的实现不过是把系统V IPC函数进行了封装，没有任何效率上的优势； 
              <LI>系统V在IPC方面的API数量不多，形式也较简洁。 </LI></UL><BR>
            <P><B>3.系统V消息队列API</B><BR>系统V消息队列API共有四个，使用时需要包括几个头文件：</P>
            <TABLE cellSpacing=0 cellPadding=5 width="100%" bgColor=#cccccc 
            border=1>
              <TBODY>
              <TR>
                <TD><PRE><CODE>#include &lt;sys/types.h&gt;
#include &lt;sys/ipc.h&gt;
#include &lt;sys/msg.h&gt;
</CODE>
</PRE></TD></TR></TBODY></TABLE><BR>
            <P><B>1）int msgget(key_t key, int msgflg)</B></P>
            <P>参数key是一个键值，由ftok获得；msgflg参数是一些标志位。该调用返回与健值key相对应的消息队列描述字。</P>
            <P>在以下两种情况下，该调用将创建一个新的消息队列：</P>
            <UL class=n01>
              <LI>如果没有消息队列与健值key相对应，并且msgflg中包含了IPC_CREAT标志位； 
              <LI>key参数为IPC_PRIVATE； </LI></UL><BR>
            <P>参数msgflg可以为以下：IPC_CREAT、IPC_EXCL、IPC_NOWAIT或三者的或结果。</P>
            <P><B>调用返回：</B>成功返回消息队列描述字，否则返回-1。</P>
            <P>注：参数key设置成常数IPC_PRIVATE并不意味着其他进程不能访问该消息队列，只意味着即将创建新的消息队列。</P>
            <P><B>2）int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long 
            msgtyp, int 
            msgflg);</B><BR>该系统调用从msgid代表的消息队列中读取一个消息，并把消息存储在msgp指向的msgbuf结构中。</P>
            <P>msqid为消息队列描述字；消息返回后存储在msgp指向的地址，msgsz指定msgbuf的mtext成员的长度（即消息内容的长度），msgtyp为请求读取的消息类型；读消息标志msgflg可以为以下几个常值的或：</P>
            <UL class=n01>
              <LI>IPC_NOWAIT 如果没有满足条件的消息，调用立即返回，此时，errno=ENOMSG 
              <LI>IPC_EXCEPT 与msgtyp&gt;0配合使用，返回队列中第一个类型不为msgtyp的消息 
              <LI>IPC_NOERROR 如果队列中满足条件的消息内容大于所请求的msgsz字节，则把该消息截断，截断部分将丢失。 
            </LI></UL><BR>
            <P>msgrcv手册中详细给出了消息类型取不同值时(&gt;0; &lt;0; =0)，调用将返回消息队列中的哪个消息。</P>
            <P>msgrcv()解除阻塞的条件有三个：</P>
            <OL class=n01>
              <LI>消息队列中有了满足条件的消息； 
              <LI>msqid代表的消息队列被删除； 
              <LI>调用msgrcv（）的进程被信号中断； </LI></OL><BR>
            <P><B>调用返回：</B>成功返回读出消息的实际字节数，否则返回-1。</P>
            <P><B>3）int msgsnd(int msqid, struct msgbuf *msgp, int msgsz, int 
            msgflg);</B><BR>向msgid代表的消息队列发送一个消息，即将发送的消息存储在msgp指向的msgbuf结构中，消息的大小由msgze指定。</P>
            <P>对发送消息来说，有意义的msgflg标志为IPC_NOWAIT，指明在消息队列没有足够空间容纳要发送的消息时，msgsnd是否等待。造成msgsnd()等待的条件有两种：</P>
            <UL class=n01>
              <LI>当前消息的大小与当前消息队列中的字节数之和超过了消息队列的总容量； 
              <LI>当前消息队列的消息数（单位"个"）不小于消息队列的总容量（单位"字节数"），此时，虽然消息队列中的消息数目很多，但基本上都只有一个字节。 
              </LI></UL><BR>msgsnd()解除阻塞的条件有三个： 
            <OL class=n01>
              <LI>不满足上述两个条件，即消息队列中有容纳该消息的空间； 
              <LI>msqid代表的消息队列被删除； 
              <LI>调用msgsnd（）的进程被信号中断； </LI></OL><BR>
            <P><B>调用返回：</B>成功返回0，否则返回-1。</P>
            <P><B>4）int msgctl(int msqid, int cmd, struct msqid_ds 
            *buf);</B><BR>该系统调用对由msqid标识的消息队列执行cmd操作，共有三种cmd操作：IPC_STAT、IPC_SET 
            、IPC_RMID。</P>
            <OL class=n01>
              <LI>IPC_STAT：该命令用来获取消息队列信息，返回的信息存贮在buf指向的msqid结构中； 
              <LI>IPC_SET：该命令用来设置消息队列的属性，要设置的属性存储在buf指向的msqid结构中；可设置属性包括：msg_perm.uid、msg_perm.gid、msg_perm.mode以及msg_qbytes，同时，也影响msg_ctime成员。 

              <LI>IPC_RMID：删除msqid标识的消息队列； </LI></OL><BR>
            <P><B>调用返回：</B>成功返回0，否则返回-1。</P>
            <P><A id=3 name=3><SPAN 
            class=atitle2>三、消息队列的限制</SPAN></A><BR>每个消息队列的容量（所能容纳的字节数）都有限制，该值因系统不同而不同。在后面的应用实例中，输出了redhat 
            8.0的限制，结果参见<A 
            href="http://www-900.ibm.com/developerWorks/cn/linux/l-ipc/part3/index.shtml#listing3">附录 
            3</A>。</P>
            <P>另一个限制是每个消息队列所能容纳的最大消息数：在redhad 
            8.0中，该限制是受消息队列容量制约的：消息个数要小于消息队列的容量（字节数）。</P>
            <P>注：上述两个限制是针对每个消息队列而言的，系统对消息队列的限制还有系统范围内的最大消息队列个数，以及整个系统范围内的最大消息数。一般来说，实际开发过程中不会超过这个限制。</P>
            <P><A id=4 name=4><SPAN 
            class=atitle2>四、消息队列应用实例</SPAN></A><BR>消息队列应用相对较简单，下面实例基本上覆盖了对消息队列的所有操作，同时，程序输出结果有助于加深对前面所讲的某些规则及消息队列限制的理解。</P>
            <TABLE cellSpacing=0 cellPadding=5 width="100%" bgColor=#cccccc 
            border=1>
              <TBODY>
              <TR>
                <TD><PRE><CODE>#include &lt;sys/types.h&gt;
#include &lt;sys/msg.h&gt;
#include &lt;unistd.h&gt;
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="/unix/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,&amp;msg_sbuf,sizeof(msg_sbuf.mtext),sflags);
if(reval==-1)
{
    printf("message send error\n");
}
//发送一个消息后，输出消息队列属性
msg_stat(msgid,msg_ginfo);
rflags=IPC_NOWAIT|MSG_NOERROR;
reval=msgrcv(msgid,&amp;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;//just a try
msg_sinfo.msg_perm.gid=8;//
msg_sinfo.msg_qbytes=16388;
//此处验证超级用户可以更改消息队列的缺省msg_qbytes
//注意这里设置的值大于缺省值
reval=msgctl(msgid,IPC_SET,&amp;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)
{