实验七进程通信--消息队列

《实验七进程通信--消息队列》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、实验七进程通信——消息队列实验目的1.了解Linux系统的进程间通信机构（IPC）；2.理解Linux关于消息队列的概念；3.掌握Linux支持消息队列的系统调用；4.巩固进程同步概念。实验内容实现并发进程间消息的发送与接收。实验步骤（一）消息的发送与接收编制两个程序client.c和server.c，分别用于消息的发送与接收，如图1所示。server建立一个key为75的消息队列，等待其它进程发来的消息。当遇到类型为1的消息，则作为结束信号，取消该队列，并退出server。server每接收到一个消息后显示一句“(server)received”。

2、client使用key为75的消息队列，先后发送类型从10到1的消息，然后退出。最后一个消息，即是server端需要的结束信号。client每发送一条消息后显示一句“(client)sent”。二个程序分别编辑、编译为client与server，并按以下方式执行：./server&ipcs–q./clientclient和server分别发送和接收了10条消息。观察运行结果，注意发送方发送消息和接收方接收消息的顺序。#include#include#include#defineMS

3、GKEY75#include#include#include#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidclient(){inti;/*打开75#消息队列*/msgqid=msgget(MSGKEY,0777);for(i=10;i>=1;i--){msg.mtype=i;printf("(client)sent");/*发送消息*/msgsnd(msgqid,&msg,10

4、24,0);}exit(0);}main(){client();}structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidserver(){/*创建75#消息队列*/msgqid=msgget(MSGKEY,0777

5、IPC_CREAT);do{/*接收消息*/msgrcv(msgqid,&msg,1030,0,0);printf("(server)received");}while(msg.mtype!=1);/*删除消息队列，归还资源*/msgctl(msgqid,IPC_RMID

6、,0);exit(0);}main(){server();}图1消息发送方client.c和消息接收方server.c思考：在上述程序中，使用系统调用msgget,msgsndh和msgrcv完成消息的传送和控制，不能保证消息发送和接受的完全同步。请尝试添加同步控制，实现同步运行。在运行发送方./ss时，同时实现了接收方./cc（二）编写程序使用消息队列，实现具有下列功能两个程序（进程）：1.程序A负责接受用户来自键盘的输入；1.程序B负责实时输出用户由程序A接收的字符。程序A和程序B可分别在两个进程上同时运行。发送#include

7、s.h>#include#include#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidclient(){inti;msgqid=msgget(MSGKEY,0777);for(i=10;i>=1;i--){msg.mtype=i;scanf("%s",msg.mtext);msgsnd(msgqid,&msg,1024,0);}exit(0);}main(){client();}接收#include

8、/types.h>#include#include#defineMSGKEY75structmsgform{longmtype;charmtext[1000];}msg;intmsgqid;voidserver(){msgqid=msgget(MSGKEY,0777

9、IPC_CREAT);do{msgrcv(msgqid,&msg,1030,0,0);printf("(server)received:%s",msg.mtext);}while(msg.mtype!=1);msgctl(msgqid,IP

10、C_RMID,0);exit(0);}main(){server();}