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

描述unix,linux下进程间通信方式

</CODE>
</PRE></TD></TR></TBODY></TABLE><BR>
      <P><B>2、linux为操作系统V进程间通信的三种方式（消息队列、信号灯、共享内存区）提供了一个统一的用户界面：</B><BR><CODE><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>);</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 bgColor=#cccccc border=1 cellPadding=5 cellSpacing=0 
        width="100%"><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 bgColor=#cccccc border=1 cellPadding=5 cellSpacing=0 
        width="100%"><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)
{
int reval;
sleep(1);//只是为了后面输出时间的方便
reval=msgctl(msgid,IPC_STAT,&amp;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);
//每个消息队列的容量（字节数）都有限制MSGMNB，值的大小因系统而异。在创建新的消息队列时，//msg_qbytes的缺省值就是MSGMNB
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(&amp;(msg_info.msg_stime)));
printf("last msgrcv time is %s", ctime(&amp;(msg_info.msg_rtime)));
printf("last change time is %s", ctime(&amp;(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);