进程间通讯－－消息队列

       #include<sys/types.h>51Testing软件测试网
]wH R6D3|_*Ic.ho\&y
       #include<sys/ipc.h>
}Q?Hz0       #include<sys/msg.h>51Testing软件测试网!}O3hl-^?$p
       intmsgget(key_t key,intmsgflg);

       #include<sys/types.h>51Testing软件测试网w-mg1mYu'j
       #include<sys/ipc.h>51Testing软件测试网mU2smNjo
       key_t ftok(constchar*pathname,intproj_id);51Testing软件测试网8f4g~1YLsu

       #include<sys/types.h>51Testing软件测试网&J&xc*H jF6|
       #include<sys/ipc.h>
5TKE UTr0       #include<sys/msg.h>51Testing软件测试网2oe0_IhZ4eI[3V

ssize_t msgrcv(intmsqid,structmsgbuf*msgp,size_tmsgsz,longmsgtyp,intmsgflg);51Testing软件测试网p;K0|Y5njx5nmJh

structmsgbuf{
2z[ Pn\,oX!M0longmtype;    /* 消息类型 must be > 0 */51Testing软件测试网@?!g-AAl?6|5G!A~
charmtext[1];/* 消息数据 这里只是一个数组的首地址，并非是只有一个字符 */
+@Mx%v8{2fD pFp0            };51Testing软件测试网!`,~.jf%Gj+fJ2Dp?

       #include<sys/types.h>
z'PA.t_0       #include<sys/ipc.h>
#L-U*h@c!}2qgX;o0       #include<sys/msg.h>    
7W(q'f O_4qM0       intmsgctl(intmsqid,intcmd,structmsqid_ds*buf);

structmsqid_ds51Testing软件测试网^ qF"D\)lgGF
{51Testing软件测试网mx+Yg(k,s?
  structipc_perm msg_perm;/* structure describing operation permission */
'B]~-M|L-crq0  __time_t msg_stime;/*最后一次发送消息的时间 */51Testing软件测试网}r'O6bT
  unsignedlongint__unused1;/*保留*/
9^)qwFq0  __time_t msg_rtime;/* 最后一次接收数据时间 */
%GT7P;[i
I z0  unsignedlongint__unused2;    /*保留*/51Testing软件测试网9QsEBS K3U
  __time_t msg_ctime;/* 最后修改时间 */
bbp Jl0EB0  unsignedlongint__unused3;/*保留*/
iD.G5R5|q5h0  unsignedlongint__msg_cbytes;/* 当前队列字节数 */
f[.A-du ]2L8ZD0  msgqnum_t msg_qnum;/* 当前队列的消息数 */51Testing软件测试网va3b*b,OZ
  msglen_t msg_qbytes;/* 队列中容量 */51Testing软件测试网?$V?:J&r8w
  __pid_t msg_lspid;/* 最后发送消息的进程号 */
;K2l jaTe-QP_9k0  __pid_t msg_lrpid;/* 最后接收队列的进程号*/
!tyct^,TVJ0  unsignedlongint__unused4;/*保留*/
|FyGTb$WSK,?0  unsignedlongint__unused5;/*保留*/51Testing软件测试网]B"~1qSq-F'\
};

#include<sys/types.h>51Testing软件测试网i_)UJ+ENrX_
#include<sys/msg.h>51Testing软件测试网fNF^.kNnKE6b!S
#include<unistd.h>51Testing软件测试网"q&`h.Z&M,tL
#definemsgkey 0x1100000151Testing软件测试网:Te O/IbtS-Zr]R
structmsg_buf51Testing软件测试网L+H5y
^:F
    {51Testing软件测试网"JUI/XQS~
        intmtype;51Testing软件测试网u;b1C#ZhqM
        chardata[255];
-{B"z0UV0    };
M^ t4Zr0 
g9Q
I r'aEBC0intmain()
9n].alR`0{51Testing软件测试网"l'N0x.Zg.n NVwm
        key_t key;
br eN.NP-f0        intmsgid;51Testing软件测试网I|6h)X!?f0kblb
        intret;51Testing软件测试网wNE1I,t6Y]hT
        structmsg_buf msgbuf;
&ZX s:Z A.X\k0 51Testing软件测试网^+bb^^NAHG
        key=ftok("/tmp/1",'a');51Testing软件测试网{(i1_Q3Yn$nh _)an
        printf("key =[%x]\n",key);
XDnu!Q!KdT0        //msgid=msgget(key,IPC_CREAT|IPC_EXCL|0666); /*通过文件对应*/51Testing软件测试网v$q pJ$Lc u
        msgid=msgget(msgkey,IPC_CREAT|IPC_EXCL|0666);/*或者取常量*/51Testing软件测试网GEVmJ"m%J `
        if(msgid==-1)51Testing软件测试网r'P4o [S3Nu_5G,a d
        {
A_KL-xX?0                printf("create error\n");51Testing软件测试网.r2qg:dw,W4T s
                return-1;
,X4G9QQK4n[R*S0        }51Testing软件测试网!l!eL2K X5hc9uljzh
 
Hd
N){xl0        msgbuf.mtype=getpid();
~Mm4c,G'^%e e$t0        strcpy(msgbuf.data,"test haha");51Testing软件测试网9],n%md*A
b j4\Y
        ret=msgsnd(msgid,&msgbuf,sizeof(msgbuf.data),IPC_NOWAIT);51Testing软件测试网u%k*u*K*g
        if(ret==-1)51Testing软件测试网Z:N$gW3]sk0B3}.F
        {51Testing软件测试网dfEE&^
                printf("send message err\n");
5X,LsU'| leGi{/Z
ps0                return-1;
QC%l5b6F`WZ0        }51Testing软件测试网j5[ifjq
 51Testing软件测试网/~bh;N&r;Q,R
~k"?
        memset(&msgbuf,0,sizeof(msgbuf));51Testing软件测试网r? @K](PMn
        ret=msgrcv(msgid,&msgbuf,sizeof(msgbuf.data),getpid(),IPC_NOWAIT);
X)`#` \8GD%oh2?0        if(ret==-1)
O'u g@0G%p5tj;S M0        {51Testing软件测试网 p;d#]QT-Mb,v7U
                printf("recv message err\n");
)hs7AmT+\w0                return-1;51Testing软件测试网)G{U\.L
N
        }51Testing软件测试网2^I(QW[L r
        printf("recv msg =[%s]\n",msgbuf.data);
O|8x6Cw/Y,](q0 
\u PB-_m#F|S5c0        ret=msgctl(msgid,IPC_RMID,NULL);//删除消息队列
!Vwj7b|"v[1T8I0
dQ9JF8ss7yU0        if(ret==-1)51Testing软件测试网\W%m'c6o&H-}`
        {51Testing软件测试网Uyb~}
                printf("del msg err\n");51Testing软件测试网x$|0G|
M6u+\
hQ:@
                return-1;
lX(Qe'Q_ V~0        }51Testing软件测试网_\O9M%vES6KV
 51Testing软件测试网'e
EZ,rRF"ec
}