IO第6天

实现AB进程对话

A进程发送一句话后，B进程接收到打印。然后B进程发送一句话，A进程接收后打印b。重复上述步骤。直到AB接收或者发送完quit后，结束AB进程

使用消息队列实现

//A文件
#include <myhead.h>struct msgbuf{long mtype;char mtext[128];
};int main(int argc, const char *argv[])
{//创建keykey_t key=ftok("/home/ubuntu/",1);if(key<0){perror("ftok");return -1;}//找到或创建消息队列int msgid=msgget(key,IPC_CREAT|0664);if(msgid<0){perror("msgget");return -1;}system("ipcs -q");//准备数据struct msgbuf snd;struct msgbuf rcv;while(1){//写printf("请输入消息类型>>>");scanf("%ld",&snd.mtype);getchar();printf("请输入消息内容>>>");fgets(snd.mtext,sizeof(snd.mtext),stdin);snd.mtext[strlen(snd.mtext)-1]='\0';//发送消息if(msgsnd(msgid,&snd,sizeof(snd.mtext),0)<0){perror("msgsnd");break;}if(strcmp(snd.mtext,"quit")==0){printf("退出\n");break;}printf("发送成功\n");//读	if(msgrcv(msgid,&rcv,sizeof(rcv.mtext),0,0)<0){perror("msgrcv");break;}if(strcmp(rcv.mtext,"quit")==0){printf("退出\n");break;}printf("mtype=%ld mtext=%s\n",rcv.mtype,rcv.mtext);}//关闭消息队列if(msgctl(msgid,IPC_RMID,NULL)<0){perror("msgctl");return -1;}system("ipcs -q");return 0;
}

//B文件
#include <myhead.h>struct msgbuf{long mtype;char mtext[128];
};int main(int argc, const char *argv[])
{//创建keykey_t key=ftok("/home/ubuntu/",1);if(key<0){perror("ftok");return -1;}//找到或创建消息队列int msgid=msgget(key,IPC_CREAT|0664);if(msgid<0){perror("msgget");return -1;}//准备数据struct msgbuf snd;struct msgbuf rcv;while(1){//读if(msgrcv(msgid,&rcv,sizeof(rcv.mtext),0,0)<0){perror("msgrcv");break;}if(strcmp(rcv.mtext,"quit")==0){printf("退出\n");break;}                                    printf("mtype=%ld mtext=%s\n",rcv.mtype,rcv.mtext);//写printf("请输入消息类型>>>");scanf("%ld",&snd.mtype);getchar();printf("请输入消息内容>>>");fgets(snd.mtext,sizeof(snd.mtext),stdin);snd.mtext[strlen(snd.mtext)-1]='\0';//发送消息if(msgsnd(msgid,&snd,sizeof(snd.mtext),0)<0){perror("msgsnd");break;}if(strcmp(snd.mtext,"quit")==0){printf("退出\n");break;}printf("发送成功\n");}//关闭消息队列if(msgctl(msgid,IPC_RMID,NULL)<0){perror("msgctl");return -1;}system("ipcs -q");return 0;
}

要求在共享内存中存入字符串“1234567”。