實(shí)驗(yàn)6消息隊(duì)列通信實(shí)驗(yàn)?zāi)康?、了解什么是消息、消息隊(duì)列2、掌握消息傳送的機(jī)理實(shí)驗(yàn)內(nèi)容1、消息的創(chuàng)建、發(fā)送和接受。使用系統(tǒng)調(diào)用msgget(),msgsnd(),msgrev()，及msget1()編制一長(zhǎng)度為1k的消息發(fā)送和接受的程序。Msgqid.c#incIude<stdio.h>#inckide<sys/types.h>#include<sys/msg.h>#inckide<sys/ipc.h>#defineMSGKEY75/*定義關(guān)鍵詞MEGKEY*/structmsgform/*消息結(jié)構(gòu)*/{1ongm(ype；charmtext[1030]；/*文本長(zhǎng)度*/}msg；intmsgqid,i;voidCLIENTO{inti；msgqid=msgget(MSGKEY,0777);for(i=10;i>=1;i-)msg.mtype=i；printf("(c1ient)sent'n")；msgsnd(msgqid,&msg,1024,0);/*發(fā)送消息msg入msgid消息隊(duì)列*/)exit(0);)voidSERVER(){msgqid=msgget(MSGKEY,0777|IPC_CREAT);/*由關(guān)鍵字獲得消息隊(duì)列*/do|msgrcv(msgqid,&msg,1030,0,0)；/*從msgqid隊(duì)列接受消息msg*/printf("(server)received\n");}while(msg.mtype1=1);/*消息類(lèi)型為1時(shí),釋放隊(duì)列*/msgctl(msgqid,IPC_RMID,0);exit(0);)main(){while((i=fork())==-l);if(!i)SERVER();while((i=fork())=-l);if(!i)CLIENT();wait(0)；實(shí)驗(yàn)結(jié)果:FileEditViewTerminalTabsHelpmsgqid.c:32:warning:incompatibleimplicitdeclarationofbuilt-infunction'exptif[root(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)received(server)received(server)received(server)received(server)received(server)received(server)received(server)received[root(aiocalhost-]#口2、選做實(shí)驗(yàn)：模擬從c/s通信客戶(hù)端client功能:1）顯示服務(wù)功能菜單teryourchoice:Savenoney2.Takemoney2）接受用戶(hù)鍵入的功能號(hào)進(jìn)行選擇；3）將用戶(hù)鍵入的功能號(hào)作為一條消息發(fā)送到消息隊(duì)列，然后結(jié)束服務(wù)端功能：1）從消息隊(duì)列接受c1ient發(fā)送的一條消息；2）根據(jù)消息作如下解決：若消息為“1”，創(chuàng)建子進(jìn)程1,子進(jìn)程1加載服務(wù)模塊save,該模塊顯示以下信息:Yourmoneywassavcd!若消息為“2”，創(chuàng)建子進(jìn)程2,子進(jìn)程2加載服務(wù)模塊take,該模塊顯示以下信息：P1easetakeyourmoney!3）等待子進(jìn)程終止后,server消息對(duì)列結(jié)束。注意:l）save和take要事先編譯連接好，放在同一目錄下；2）先運(yùn)營(yíng)客戶(hù)端進(jìn)程，再運(yùn)營(yíng)服務(wù)端進(jìn)程。1、client.cinclude<sys/types.h>inelude<sys/msg.h>inc1ude<sys/ipc,h>include<stdio.h>#include<std1ib.h>#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid；voidclient（）inti;msgqid=msgget(MSGKEY,0777);/*打開(kāi)75#消息隊(duì)列*/for(i=20;i>=l;i-)msg.mtype=i；printf("(client)sent%d\n',,i);sleep(3);msgsnd(msgqid.&msg,1024,0);/*發(fā)送消息*/)exit(0);)main()(client();)server.cinclude<sys/types.h>incIude<sys/msg.h>inc1ude<sys/ipc.h>inc1udc<stdio.h>include<std1ib.h>defineMSGKEY75structmsgfbrm{1ongmtype;charmtex([10001;}msg;intmsgqid;voidservcr()msgqid=msgge((MSGKEY,0777|IPC.CREAT)；/*創(chuàng)建75#消息隊(duì)列號(hào)msgrcv(msgqid,&msg,1030Q0)；/*接受消息*/printf("(server)received%1d\n”,msg.mtype);s1eep(3)；}whilc(msg.mtypc!=l);msgctl(msgqidJPC_RMID,0);/火刪除消息隊(duì)列,歸還資源*/exit(0)；Imain(){server();

實(shí)驗(yàn)結(jié)果:qroot@localhost:~1FileEditViewTerminalTabsHelp[root@localhostgcc-oclientclient.c[root@local.host?J#./client(client)sent20(client)sent19(client)sent18(client)sent17(client)sent16(client)sent15(client)sent14(client)sent13(client)sent12(client)sent11(client)sent10(client)sent9(client)sent8(client)sent7(client)sent6(client)sent5(client)sent4(client)sent3(client)sent2(client)sent1[root@localhost?]#口root@localhost:~FileEditViewTerminalTabsHelp[root(aiocalhostgcc-oserverserver.c[root@localhost-]#./server(server)received20(server)received19(server)received18(server)received17(server)received16(server)received15(server)received14(server)received13(server)received12(server)received11(server)rec