消息队列通信实验报告

1、消息队列通信实验报告实验6消息队列通信实验目的1、了解什么是消息、消息队列2、掌握消息传送的机理实验内容1、 消息的创建、发送和接收。使用系统调用 msgget( ),msgsnd( ),msgrev(),及 msgctl()编制一长度为1 k 的消息 发送和接收的程序。Msgqid.c#in elude #in elude#i nclude#in clude#defi ne MSGKE Y 75/* 定义关键词 MEGKEY*/struct msgform/* 消息结构*/long mtype;char mtext1030; /* 文本长度 */msg;int msgqid,i;void C

2、LIENT() int i;msgqid=msgget(MSGKE Y,0777); for(i=10;i=1;i-)msg.mtype=i;prin tf(clie nt)se ntn);msgsnd(msgqid,&msg,1024,0); /* 发送消息 msg 入msgid消息队列*/exit(0);void SERVER()msgqid=msgget(MSGKE Y,0777|IPC_CREAT);/*由关键字获得消息队列*/domsgrcv(msgqid,&msg,1030,0,0);/* 从 msgqid队列接收消息msg */prin tf(server)receivedn);

3、while(msg.mtype!=1); /* 消息类型为1时，释放队列*/msgctl(msgqid,IPC_RMID,O); exit(O);mai n()while (i=fork()=-1);if(!i) SERVER();while (i=fork()=-1);if(!i) CLIENT();wait(O);wait(O);实验结果:rc at fiscal host:-1 X日& Edit胚m刃Jerminil labs H*lpmsgqid.c:32: warnings lnconpatlble lrrpliclt declaration of built-in function

4、 *ckLrootjdLQcainost j# .ymsgqLd I cl lent Jsprtfclient)sentI client)sentclient)sentclient)sentclient)sentcliont )s?nt；ciiefit)snt:client)sentI client)sentI server)received server)receivedI server)receivedserver)received|se rver J re匚电直打时Ise rver)rece丄h已dserver)received|server)receivedserve it)皀serv

5、er)receivedrootlocolhost -書，2、选做实验：模拟从c/s通信客户端client功能：1）显示服务功能菜单En ter your choice:1. Save noney2. Take money2）接收用户键入的功能号进行选择；3）将用户键入的功能号作为一条消息发送到消息队列，然后结束 服务端功能：1）从消息队列接收client发送的一条消息；2）根据消息作如下处理：若消息为“ 1”，创建子进程1,子进程1加载服务模块save,该模块显示 以下信息： Your money was saved!若消息为“ 2”，创建子进程2,子进程2加载服务模块take，该模块显示以下

6、信息：Please take your mon ey!3) 等待子进程终止后，server消息对列结束。 注意：1) save和take要事先编译连接好，放在同一目录下;2)先运行客户端进程，再运行服务端进程。1、client.c#in clude #i nclude #in clude #i nclude #i nclude #defi ne MSGKE Y 75 struct msgform long mtype;char mtext1000;msg;int msgqid;void clie nt()/*打开int i;msgqid=msgget(MSGKE Y,0777);75#消息队列

7、*/for(i=20;i=1;i-)msg.mtype=i;prin tf(clie nt)se nt%dn,i);sleep(3);/*发送msgs nd(msgqid,&msg,1024,0);消息*/exit(O);mai n()clie nt();server.c#in clude #in clude #in clude #in clude #in clude #defi ne MSGKE Y 75struct msgform long mtype;char mtext1000;msg;int msgqid;void server() msgqid=msgget(MSGKE Y,077

8、7|IPC_CREAT);/*创建75#消肖息队列*/domsgrcv(msgqid,&msg,1030,0,0);/* 接收消息*/prin tf(server)received %ldn,msg.mtype); sleep(3);while(msg.mtype!=1); msgctl(msgqid,IPC_RMID,O); /* 删 除消息 队 列，归还资源*/exit(O); mai n()server();实验结果:rootlo c a Iho st:File Edit ViewTerminalTabs 旦 elprootlocalhostgcc-o clientrootlocalho

9、st. /client(client)sent20(cllent)sent19(client)sent18(client)sent17(client)sent16(client)sent15(client)sent14(cllent)sent13(client)sent12(client)sent11(client)sent10(client)sent9(client)sent8(client)sent7(client)sent6(client)sent5(client)sent4(client)sent3(client)sent2(client)sent1rootlocalhost # 11

10、client crootJlocalhost:-*File Edit View Terminal labs Helprootlocalhost -# gcc -o serverrootQlocalhost # ./server(server)received20(server)received19(server)received18(server)received17(server)received16(server)received15(server)received14(server)received13(server)received12(server)received11(server)received10(server)received9