推荐
实例1
实例1：一个程序，自己发消息，然后自己再从队列上读消息
代码
msgque.c
/*msgque.c*/ #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #define BUFSZ 512 struct message { long msg_type; char msg_text[BUFSZ]; }; int main() { int qid; key_t key; int len; struct message msg; /*根据不同的路径和关键表示产生标准的key*/ if ((key = ftok(".", 'a')) == -1) { perror("ftok"); exit(1); } /*创建消息队列*/ if ((qid = msgget(key,IPC_CREAT|0666)) == -1) { perror("msgget"); exit(1); } printf("Opened queue %d\n",qid); puts("Please enter the message to queue:"); if ((fgets((&msg)->msg_text, BUFSZ, stdin)) == NULL) //消息内容 { puts("no message"); exit(1); } msg.msg_type = getpid(); //消息类型，可以理解为发信人名字 len = strlen(msg.msg_text); /*添加消息到消息队列*/ if ((msgsnd(qid, &msg, len, 0)) < 0) //把消息加到队列 { perror("message posted"); exit(1); } /*读取消息队列*/ if (msgrcv(qid, &msg, BUFSZ, getpid(), 0) < 0) //读发信人为getpid()的消息 { perror("msgrcv"); exit(1); } printf("message is:%s\n",(&msg)->msg_text); /*从系统内核中移走消息队列 */ if ((msgctl(qid, IPC_RMID, NULL)) < 0) { perror("msgctl"); exit(1); } exit(0); }
结果
实例2
实例2：一个程序发送消息 ，另一个接收消息，读的是第一条消息不判断是不是自己想要的消息
代码
msgsnd.c
/* msgsnd.c */ #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #define BUFFER_SIZE 512 struct message { long msg_type; char msg_text[BUFFER_SIZE]; }; int main() { int qid; key_t key; struct message msg; /*根据不同的路径和关键表示产生标准的key*/ if ((key = ftok(".", 'a')) == -1) { perror("ftok"); exit(1); } /*创建消息队列*/ if ((qid = msgget(key, IPC_CREAT|0666)) == -1) { perror("msgget"); exit(1); } printf("Open queue %d\n",qid); while(1) { printf("Enter some message to the queue(enter 'quit' to exit):"); if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL) { puts("no message"); exit(1); } msg.msg_type = getpid(); /*添加消息到消息队列*/ if ((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0) { perror("message posted"); exit(1); } if (strncmp(msg.msg_text, "quit", 4) == 0) { break; } } exit(0); }
msgrcv.c
/* msgrcv.c */ #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #define BUFFER_SIZE 512 struct message { long msg_type; char msg_text[BUFFER_SIZE]; }; int main() { int qid; key_t key; struct message msg; /*根据不同的路径和关键表示产生标准的key*/ if ((key = ftok(".", 'a')) == -1) { perror("ftok"); exit(1); } /*创建消息队列*/ if ((qid = msgget(key, IPC_CREAT|0666)) == -1) { perror("msgget"); exit(1); } printf("Open queue %d\n", qid); do { /*读取消息队列*/ memset(msg.msg_text, 0, BUFFER_SIZE); if (msgrcv(qid, (void*)&msg, BUFFER_SIZE, 0, 0) < 0) //读取消息不管是谁发的 { perror("msgrcv"); exit(1); } printf("The message from process %d : %s", msg.msg_type, msg.msg_text); } while(strncmp(msg.msg_text, "quit", 4)); /*从系统内核中移走消息队列 */ if ((msgctl(qid, IPC_RMID, NULL)) < 0) { perror("msgctl"); exit(1); } exit(0); }
结果
实例3
设计两个程序，要求用消息队列实现聊天程序。
输入bye,结束聊天
代码
comm.h
#ifndef _COMM_H_ #define _COMM_H_ #include <stdio.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <string.h> #define SERVER 1 #define CLIENT 2 #define PATHNAME "." #define PROJ_ID 0x6666 struct msgbuf{ long mtype; char mtext[1024]; }; int creat();//创建消息队列 int send(int msgid,int who,char *msg); //发送消息 int recv(int msgid, int type, char out[]);//接收消息 int destory(int msgid);//销毁消息队列 int get();//获得消息队列的标识符 #endif
comm.c
#include "comm.h" static int com(int flags){ key_t key=ftok(PATHNAME,PROJ_ID); if(key<0){ perror("ftok"); return -1; } int msgid=msgget(key,flags); if (msgid<0){ perror("msgget"); return -2; } return msgid; } int creat(){ return com(IPC_CREAT|IPC_EXCL|0666); } int destory(int msgid){ if(msgctl(msgid,IPC_RMID,NULL)<0){ perror("msgctl"); return -1; } } int get(){ return com(IPC_CREAT); } int send(int msgid,int who,char*msg){ struct msgbuf buf; buf.mtype=who; strcpy(buf.mtext,msg); if(msgsnd(msgid,(void*)&buf,sizeof(buf.mtext),0)<0) { perror("msgsnd"); return -1; } } int recv(int msgid,int type,char out[]){ struct msgbuf buf; if(msgrcv(msgid,(void*)&buf,sizeof(buf.mtext),type,0)<0){ perror("msgrcv"); return -1; } strcpy(out,buf.mtext); return 0; }
server.c
#include"comm.h" int main(){ int msgid=creat(); char buf[1024]; while(1){ buf[0]=0; recv(msgid,CLIENT,buf); printf("client say #%s\n",buf); if(strcmp(buf,"bye\n")==0){ printf("通信结束\n"); break; } printf("please enter#"); fflush(stdout); ssize_t s=read(0,buf,sizeof(buf)-1); if(s>0){ buf[s]=0; send (msgid,SERVER,buf); } } destory(msgid); return 0; }
client.c
#include"comm.h" int main(){ int msgid=get(); char buf[1024]; while(1){ buf[0]=0; printf("please enter#"); fflush(stdout); ssize_t s=read(0,buf,sizeof(buf)-1); if(s>0){ buf[s]=0; send (msgid,CLIENT,buf); } recv(msgid,SERVER,buf); printf("server say #%s\n",buf); if(strcmp(buf,"bye\n")==0){ printf("通信结束\n"); break; } } destory(msgid); return 0; }
Makefile
.PHONY:all all:server client server:server.c comm.c gcc -o $@ $^ client:client.c comm.c gcc -o $@ $^ .PHONY:clean clean: rm -f server client
结果
