消息隊(duì)列通信實(shí)驗(yàn)報(bào)告

消息隊(duì)列通信實(shí)驗(yàn)報(bào)告

實(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(),及msgctl()編制一長(zhǎng)度為1k的消息發(fā)送和接收的程序。Msgqid?c#includevstdio?h>#includevsys/types?h>#includevsys/msg?h>/*定義關(guān)鍵/*消息結(jié)構(gòu)#includevsys/ipc?h>#defineMSGKEY75/*定義關(guān)鍵/*消息結(jié)構(gòu)*/{longmtypecharmtext[1030];/*文本長(zhǎng)度*/}msg;intmsgqid,i;voidCLIENT(){inti;msgqid=msgget(MSGKEY,0777);

for(i=10;i>=1;i--){msg.mtype=i;printf("(client)sent\n");msgsnd(msgqid,&msg,1024,0);/*發(fā)送消息msg入msgid消息隊(duì)列*/}exit(0);}voidSERVER。{msgqid=msgget(MSGKEY,0777IIPC_CREAT);/*由關(guān)鍵字獲得消息隊(duì)列*/domsgrcv(msgqid,&msg,1030,0,0);/*從msgqid隊(duì)列接收消息msg*/printf("(server)received\n");}while(msg.mtype!=1); /*消息類型為1時(shí)，釋放隊(duì)列*/msgctl(msgqid,IPC_RMID,O);exit(0);}main(){while((i=fork())==-1);if(!i)SERVER。；while((i=fork())==-1);if(!i)CLIENT。；wait(0);wait(0);2、選做實(shí)驗(yàn)：模擬從c/s通信客戶端client功能：1）顯示服務(wù)功能菜單Enteryourchoice:SavenoneyTakemoney2） 接收用戶鍵入的功能號(hào)進(jìn)行選擇;3） 將用戶鍵入的功能號(hào)作為一條消息發(fā)送到消息隊(duì)列，然后結(jié)束服務(wù)端功能：1） 從消息隊(duì)列接收client發(fā)送的一條消息；2） 根據(jù)消息作如下處理：若消息為“1”創(chuàng)建子進(jìn)程1,子進(jìn)程1加載服務(wù)模塊save,該模塊顯示以下信息：Yourmoneywassaved!若消息為“2”，創(chuàng)建子進(jìn)程2,子進(jìn)程2加載服務(wù)模塊take,該模塊顯示

以下信息：Pleasetakeyourmoney!等待子進(jìn)程終止后，server消息對(duì)列結(jié)束。注意：1)save和take要事先編譯連接好，放在同一目錄下;2)先運(yùn)行客戶端進(jìn)程，再運(yùn)行服務(wù)端進(jìn)程。1、client?c#includevsys/types?h>#includevsys/msg?h>#includevsys/ipc.h>#includevstdio.h>#includevstdlib.h>#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidclient(){/*打開/*打開75#消息隊(duì)列*/for(i=20;i>=1;i--){msg?mtype=i;

/*發(fā)送/*發(fā)送msgsnd(msgqid,&msg,1024,0);消息*/}exit(O);}main(){client();}server.c#includevsys/types?h>#includevsys/msg.h>#includevsys/ipc.h>#includevstdio?h>#includevstdlib.h>#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidserver(){msgqid=msgget(MSGKEY,0777IIPC_CREAT);/*創(chuàng)建75#消息隊(duì)列*/do{msgrcv(msgqid,&msg,1O3O,O,0); /*接收消息*/printf("(server)received%ld\n",msg?mtype);sleep(3);}while(msg?mtype!=1);msgctl(msgqid,IPC_RMID,0);/*刪除消息隊(duì)列，歸還資源*/exit(0);}main(){server();實(shí)驗(yàn)結(jié)果：FileEditViewJemninalTabsHelp[rootf&localhost-]#gcc-oclientclient.c[root^localhost~./client(ctiErit)5已仃t20(client)sent19(client)sent18(client)sent17(client)sent16(client)sent15(client)sent14(client)sent13(client)sent12(client)5ent11(client)5ent10(client)sent9(client)sent8(cLi亡nt亡仃t7(client)sent5(client)5ent5(client)5ent4(client)sent3(client)^ent2(cLi亡nt亡仃t1[rootfaiocalhostT#[]root^fccafhost:^-[root(31ocalhost-]■#gcc-oserverserver.c[root^loolhost-]#./server(server-)received20(server1)received19(server-)received18(server-)received17(server-)received16(server-)received15(server-)received14(server-)received13(server-)received12(server-)received11(server-)received10(server-)received9(serverlreceivedS(server')received7(server-)received6(s