2023年消息队列通信实验报告.docx

《2023年消息队列通信实验报告.docx》由会员分享，可在线阅读，更多相关《2023年消息队列通信实验报告.docx（7页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、实验6消息队列通信实验目的1、了解什么是消息、消息队列2、掌握消息传送的机理实验内容1、 消息的创建、发送和接受。使用系统调用msgget ( ), m s gsnd(), m s grev ()，及ms get 1()编制一长度为1 k的消息发送和接受 的程序。Msg q id. c#in c I u d e # in c kid e #inclu d e #i n ckid e #def i ne MSG KEY 7 5/ *定义关键词 M EGK E Y* /struct msgf o r m/*消息结构*/1 ong m(y p e；ch a r mtext10 3 0； /*文本长度

2、*/ms g ；int msgqi d , i ;void CLIENTOint i；m s gqid=msgge t (M S GKEY, 0 777);for(i=10; i = 1 ;i-)ms g . m t yp e =i；pri n t f(c 1 ien t )se n t n)；msg s nd(m s g qi d ,&ms g ,1024, 0); / *发送消息 msg 入msgid消息队列*/)ex i t (0);)void S ERVER ()msgq i d=msg get(MSGKE Y,0777|IPC_C REAT); / *由关键字获得消 息队列*/do|

3、msg r cv (ms g qid, &m s g, 1030,0,0)； /*从 msgq i d 队列 接受消息msg */prin t f(server) r e c e i v edn );wh i le (m s g.m t yp e 1=1);/ *消息类型为1时,释放队列*/m s gctl(m s gqid, IPC_RMID,0);e x it( 0 );)main()wh i le (i=f o rk()=-l);i f(! i) SERV E R();wh i le (i=fork()=-l);if(! i ) C L I ENT();wai t (0)；实验结果:Fi

4、le Edit View Terminal Tabs Helpmsgqid.c:32: warning: incompatible implicit declaration of built-in function expt ifroot(aiocalhost # ./msgqid(client)sent(client)sent(client)sent(client)sent(client)sent(client)sent(cllent)sent(cllent)sent(client)sent(client)sent(server)received(server)received(server

5、)received(server)received(server)received(server)received(server)received(server)received(server)received(server)receivedroot(aiocalhost -# 口2、选做实验：模拟从c/s通信客户端cl i e n t功能:1）显示服务功能菜单t er yo u r choice:Save n one y2. T a ke mo n e y2）接受用户键入的功能号进行选择；3）将用户键入的功能号作为一条消息发送到消息队列，然后结束服务端功能：1）从消息队列接受c 1 ien

6、t发送的一条消息；2）根据消息作如下解决：若消息为“1”，创建子进程1,子进程1加载服务模块save,该模块显示 以下信息:Your mo n e y w as sa v cd!若消息为“2”，创建子进程2,子进程2加载服务模块t ake,该模块显示 以下信息：P 1 e a se tak e your m o n ey!3）等待子进程终止后,se r ve r消息对列结束。注意:l）sa v e和t ake要事先编译连接好，放在同一目录下；2 ）先运营客户端进程，再运营服务端进程。1、client.c# in c lude # i n elude # i n c 1 u d e # i nc

7、l u d e # incl u d e #define MSG KEY 7 5s t r uctmsg form lo n g mtype;ch a r m t e x t 1000;msg;in t msgq i d；void cl i ent（）int i;msgqi d =msgget(MSGKEY,0777);/* 打开 7 5 #消息队列* /for (i=20; i =l;i-)msg. mtyp e =i；printf(cl i ent) s ent %d n, i );sleep(3);msgsnd(msgqid.&m s g, 1024,0);/*发送消息*/)ex i t

8、(0);)m a in ()(client();)s e rver.ci nclude # i n c I u de in c 1 u de # inc 1 udc in c lud e # de f ine MSGKEY75s truct msgfb r m1 ong mt y p e;char m t e x(10001; m s g;int msgqid;voi d ser v cr( )msgqid=msgg e (MSGKEY, 0 777|I PC.CRE AT)；/ *创建 75# 消息队列号msgr c v(msgqi d ,&msg, 1 0 30Q 0 )；/ *接受消息*

9、/prin t f (server) r e ce i ve d%1 d n ”,m s g . mt y p e );s 1 e e p(3)； w hilc(msg.mt y pc!=l);msgctl(msgqidJPC_RMID,0 ) ; /火删除消息队列,归还资源*/e x i t(0)；Imain()serv e r ();实验结果:qrootlocalhost:1File Edit ViewTerminalTabsHelprootlocalhostgcc -o client client.crootlocal.host J# ./client(client)sent 20(cl

10、ient)sent 19(client)sent 18(client)sent 17(client)sent 16(client)sent 15(client)sent 14(client)sent 13(client)sent 12(client)sent 11(client)sent 10(client)sent 9(client)sent 8(client)sent 7(client)sent 6(client)sent 5(client)sent 4(client)sent 3(client)sent 2(client)sent 1rootlocalhost # 口rootlocalh

11、ost:File Edit View Terminal Tabs Helproot(aiocalhost gcc -o server server.crootlocalhost -# ./server(server)received 20(server)received 19(server)received 18(server)received 17(server)received 16(server)received 15(server)received 14(server)received 13(server)received 12(server)received 11(server)received 10(server)received 9(server)received 8(server)received 7(server)received 6(server)received 5(server)received 4(server)received 3(server)received 2(server)received 1rootlocalhost |