S10、并發(fā)程序-消息傳遞通信S10、并發(fā)程序-消息傳遞通信S10、并發(fā)程序-消息傳遞通信1、消息傳遞通信寫程序msgwrite.c：#include<sys/types.h>#include<sys/ipc.h>#include<sys/msg.h>#include<stdio.h>#include<stdlib.h>typedefstruct_msg_buf{//消息結(jié)構(gòu)體 longtype; //消息類型 charbuf[100]; //消息內(nèi)容}msg_buf;S10、并發(fā)程序-消息傳遞通信intmain(){ intkey,qid; intwc=1; msg_bufbuf; key=ftok(".",10); qid=msgget(key,IPC_CREAT|0666); printf("key:%d\nqid:%d\n",key,qid); buf.type=10; system("ipcs-q"); printf("請(qǐng)輸入一些消息，每條消息以回車結(jié)束。如果輸入quit，則程序結(jié)束\n");S10、并發(fā)程序-消息傳遞通信 while(1) {//循環(huán)輸入消息到隊(duì)列 printf("輸入第%d條消息：",wc++); fgets(buf.buf,100,stdin); //從鍵盤輸入不超過(guò)100個(gè)字符的消息到消息緩沖區(qū) if(strncmp(buf.buf,"quit",4)==0) {//如果輸入"quit"，則刪除消息隊(duì)列并結(jié)束程序 if((msgctl(qid,IPC_RMID,NULL))<0) /*刪除指定的消息隊(duì)列*/ { exit(1); }S10、并發(fā)程序-消息傳遞通信 else { system("ipcs-q"); printf("successfullyremoved%dqueue/n",qid);/*刪除隊(duì)列成功*/ exit(0); } } if(msgsnd(qid,(void*)&buf,100,0)<0) {//發(fā)送消息緩沖區(qū)中的信息到消息隊(duì)列 perror("msgsnd"); exit(-1); } } return0;}S10、并發(fā)程序-消息傳遞通信讀程序msgread.c：#include<sys/types.h>#include<sys/ipc.h>#include<sys/msg.h>#include<stdio.h>#include<stdlib.h>typedefstruct_msg_buf{//消息結(jié)構(gòu)體 longtype; //消息類型 charbuf[100]; //消息內(nèi)容}msg_buf;S10、并發(fā)程序-消息傳遞通信intmain(){ intkey,qid; //消息隊(duì)列鍵值和標(biāo)識(shí)符 msg_bufbuf; //消息緩沖區(qū) key=ftok(".",10); //將當(dāng)前目錄和10轉(zhuǎn)換為消息隊(duì)列IPC鍵值 qid=msgget(key,IPC_CREAT|0666); //創(chuàng)建或獲得消息隊(duì)列標(biāo)識(shí)符 printf("key:%d\nqid:%d\n",key,qid); //輸出消息隊(duì)列鍵值和標(biāo)識(shí)符S10、并發(fā)程序-消息傳遞通信 while(1) { if(msgrcv(qid,(void*)&buf,100,0,0)<0) {//循環(huán)讀取隊(duì)列中消息到緩沖區(qū) perror("msgrcv"); exit(-1); } printf("type:%ld\nget:%s\n",buf.type,buf.buf); //輸出所讀信息 } return0;}S10、并發(fā)程序-