实例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

结果