消息隊列通信實驗報告

消息隊列通信實驗報告

實驗6消息隊列通信實驗目的1、 了解什么是消息、消息隊列2、 掌握消息傳送的機理實驗內(nèi)容1、消息的創(chuàng)建、發(fā)送和接收。使用系統(tǒng)調(diào)用msgget(),msgsnd(),msgrev(),及msgctl()編制一長度為1k的消息發(fā)送和接收的程序。Msgqid?c#includevstdio?h>#includevsys/types?h>#includevsys/msg?h>/*定義關鍵/*消息結(jié)構(gòu)#includevsys/ipc?h>#defineMSGKEY75/*定義關鍵/*消息結(jié)構(gòu)*/{longmtypecharmtext[1030];/*文本長度*/}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消息隊列*/}exit(0);}voidSERVER。{msgqid=msgget(MSGKEY,0777IIPC_CREAT);/*由關鍵字獲得消息隊列*/domsgrcv(msgqid,&msg,1030,0,0);/*從msgqid隊列接收消息msg*/printf("(server)received\n");}while(msg.mtype!=1); /*消息類型為1時，釋放隊列*/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、選做實驗：模擬從c/s通信客戶端client功能：1）顯示服務功能菜單Enteryourchoice:SavenoneyTakemoney2） 接收用戶鍵入的功能號進行選擇;3） 將用戶鍵入的功能號作為一條消息發(fā)送到消息隊列，然后結(jié)束服務端功能：1） 從消息隊列接收client發(fā)送的一條消息；2） 根據(jù)消息作如下處理：若消息為“1”創(chuàng)建子進程1,子進程1加載服務模塊save,該模塊顯示以下信息：Yourmoneywassaved!若消息為“2”，創(chuàng)建子進程2,子進程2加載服務模塊take,該模塊顯示

以下信息：Pleasetakeyourmoney!等待子進程終止后，server消息對列結(jié)束。注意：1)save和take要事先編譯連接好，放在同一目錄下;2)先運行客戶端進程，再運行服務端進程。1、client?c#includevsys/types?h>#includevsys/msg?h>#includevsys/ipc.h>#includevstdio.h>#includevstdlib.h>#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidclient(){/*打開/*打開75#消息隊列*/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#消息隊列*/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);/*刪除消息隊列，歸還資源*/exit(0);}main(){server();實驗結(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