一、函数参考以下博客
(2条消息) Linux下进程间通信--消息队列详解_Janskid的博客-CSDN博客https://blog.csdn.net/Janskid/article/details/77199914?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522165177450316782248564450%2522%252C%2522scm%2522%253A%252220140713.130102334..%2522%257D&request_id=165177450316782248564450&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~sobaiduend~default-1-77199914.142%5Ev9%5Epc_search_result_control_group,157%5Ev4%5Econtrol&utm_term=linux%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97%E8%AF%A6%E8%A7%A3&spm=1018.2226.3001.4187(2条消息) Linux消息队列讲解_Amarao的博客-CSDN博客_linux 消息队列
https://blog.csdn.net/jinmie0193/article/details/79887888?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522165177450316782248564450%2522%252C%2522scm%2522%253A%252220140713.130102334..%2522%257D&request_id=165177450316782248564450&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~sobaiduend~default-2-79887888.142%5Ev9%5Epc_search_result_control_group,157%5Ev4%5Econtrol&utm_term=linux%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97%E8%AF%A6%E8%A7%A3&spm=1018.2226.3001.4187二、代码实现
serMain.cpp
#include<stdlib.h>
#include"server.h"
int main(int argc, char* argv[]){
server(argv[1],atol(argv[2]));
return 0;
}
server.h
void server(const char *msgname,const long msgtype);
server.cpp
#include<iostream>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<string.h>
#include"server.h"
#include"message.h"
const int PROID=100;
void han_mes(Message& m){
switch(m.op){
case 0:
m.res=m.oprand1+m.oprand2;
break;
case 1:
m.res=m.oprand1-m.oprand2;
break;
case 2:
m.res=m.oprand1*m.oprand2;
break;
case 3:
if(m.oprand2!=0){
m.res=m.oprand1/m.oprand2;
}else{
m.status='F';
}
break;
default:
m.status='N';
break;
}
}
void process(const int msgid,const long msgtype){
while(true){
Message m;
memset(&m,0,sizeof(m));
msgrcv(msgid,&m,sizeof(m)-sizeof(long),msgtype,0);
long rtype=m.rtype;
han_mes(m);
m.mtype=rtype;
msgsnd(msgid,&m,sizeof(m)-sizeof(long),0);
}
}
void server(const char* msgname,const long msgtype){
int msgid;
do{
key_t msgkey=ftok(msgname,PROID);
if(msgkey == -1){
std::cerr<<"ftok wrong\n";
break;
}
msgid=msgget(msgkey,IPC_CREAT|0664);
if(msgid == -1){
std::cerr<<"msgget wrong\n";
break;
}
process(msgid,msgtype);
}while(0);
}
cliMain.cpp
#include<stdlib.h>
#include"client.h"
int main(int argc,char* argv[]){
client(argv[1],atol(argv[2]));
return 0;
}
client.h
void client (const char* msgname,const long msgtype);
client.cpp
#include<iostream>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<unistd.h>
#include<string.h>
#include"client.h"
#include"message.h"
const int PROID=100;
void process(const int msgid,const long msgtype){
while(true){
Message m;
memset(&m,0,sizeof(m));
std::cout<<"please enter expression:";
std::cin>>m;
if(std::cin.eof()) break;
m.status='S';
m.mtype=msgtype;
long rtype=getpid();
m.rtype=rtype;
msgsnd(msgid,&m,sizeof(m)-sizeof(long),0);
msgrcv(msgid,&m,sizeof(m)-sizeof(long),rtype,0);
std::cout<<m<<std::endl;
}
}
void client(const char* msgname,const long msgtype){
int msgid;
do{
key_t msgkey=ftok(msgname,PROID);
if(msgkey == -1){
std::cerr<<"ftok wrong\n";
break;
}
msgid=msgget(msgkey,IPC_CREAT|0664);
if(msgid == -1){
std::cerr<<"msgget wrong\n";
break;
}
process(msgid,msgtype);
}while(0);
}
message.h
#include<iostream>
struct Message{
long mtype;
long rtype;
int oprand1;
int op;
int oprand2;
int res;
char status;
};
std::istream &operator >>(std::istream& in, Message& m);
std::ostream &operator <<(std::ostream& out,const Message& m);
message.cpp
#include"message.h"
std::istream& operator >>(std::istream& in ,Message& m){
in>>m.oprand1>>m.op>>m.oprand2;
return in;
}
std::ostream& operator <<(std::ostream& out ,const Message& m){
char ops[]={'+','-','*','/'};
if(m.status=='S'){
out<<m.oprand1<<ops[m.op]<<m.oprand2<<"="<<m.res;
}else if(m.status=='F'){
out<<"The divisor cannot be 0";
}else if(m.status=='N'){
out<<"Opreator iuput error";
}
return out;
}
msg.mk
GCC=g++
CFLAG=-c
OFLAG=-o
SEXE=serMain
SOBJ=serMain.o server.o
CEXE=cliMain
COBJ=cliMain.o client.o message.o
all:${SEXE} ${CEXE}
${SEXE}:${SOBJ}
${GCC} ${OFLAG} $@ $^
${CEXE}:${COBJ}
${GCC} ${OFLAG} $@ $^
%.o:%.cpp
${GCC} ${CFLAG} $^
clean:
rm *.o
三、运行结果