LInux进程间通信之消息队列编程实例

　　本文主要通过消息队列的编程实例来加深对消息队列的理解.

一、消息队列之创建

　　创建一个消息队列，需要用到一个函数:

#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>

int msgget(key_t key,int msgflg);

　　key:需要调用ftok函数来获取.

　　msgflg:IPC_CREAT,不存在则创建,存在则返回已有的qid.

　　　　　IPC_CREAT|IPC_EXCL,不存在则创建,存在则返回出错.

　　ftok函数原型如下:

#include<sys/types.h>
#include<sys/ipc.h>

key_t ftok(const char*pathname,int proj_id);

　　ftok函数通过给定的路径名称取得其stat结构中的st_dev字段和st_info字段,然后将它们和项目id结合起来,然后产生一个键返回.

　　为了方便使用,我们将创建消息队列与获取消息队列封装为两个函数:

//创建与打开消息队列公共函数
int MessageCommon(key_t key,int flag){
	int ret = 0;
	if((ret=msgget(key,flag))==-1){
		perror("msgget:");
		exit(-1);
	}
	return ret;
}
//创建全新的消息队列(服务端)
int CreateMessage(key_t qid){
        //消息队列也是具有权限结构的,因此在创建时给666权限
	return MessageCommon(qid,IPC_CREAT|IPC_EXCL|0666);
}
//打开已有的消息队列(客户端)
int GetMessage(key_t qid){
	return MessageCommon(qid,IPC_CREAT);
}

二、消息队列之发送消息

　　使用消息队列发送消息用到了一个函数和一个结构体:

#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>

int msgsnd(int msgid,const void* msgp,size_t magsz,int msgflg);

　　msgid:消息队列标识符

　　msgp:发送的消息结构体指针

　　msgsz:结构体中消息的大小(不是整个结构体的大小)

　　msgflg:IPC_NOWAIT,消息队列满时返回-1

　　　　　0,消息队列满时阻塞.

　　在通过msgsnd发送数据时,需要一个结构体来存放所发送的数据,及发送者的类型.

struct msgbuf{
        long mtype;        //消息类型,由用户自定义
        char mtext[1024];//发送的消息(长度、类型可以自行指定)
}

　　因此,我们将发送消息也做一层封装:

//发送消息
void SendMessage(int msgid,const char* msg,int who){
	msgbuf buf;
	buf.mtype = who;                //消息类型
	strcpy(buf.mtext,msg);        //消息内容
	if(msgsnd(msgid,&buf,sizeof(buf.mtext),0) == -1){
		perror("msgsnd");
		DestoryMessage(msgid);
		exit(-2);
	}
}

三、消息队列之接收消息

　　消息队列接收消息的函数原型如下:

#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>

ssize_t msgrcv(int qid,void *msgp,size_t msgsz,long msgtyp,int msgflg);

　　qid:消息队列的标识符

　　msgp:消息结构体指针

　　msgsz:消息内容大小

　　msgtyp:消息类型

　　msgflg:同上

　　封装之后的代码如下:

void ReceiveMessage(int msgid,char* msg,int who){
	msgbuf buf;
	if(msgrcv(msgid,&buf,sizeof(buf.mtext),who,0)==-1){
		perror("msgrcv");
		DestoryMessage(msgid);
		exit(-3);
	}
	strcpy(msg,buf.mtext);
}

四、消息队列的删除

　　其函数原型如下:

#include<sys/type.h>
#include<sys/ipc.h>
#Include<sys/msg.h>

int msgctl(int msgid,int cmd,struct msgid_ds *buf);

　　msgid:消息队列标识符

　　cmd:所要采取的命令.IPC_RMID删除消息队列

　　buf:权限信息

　　封装后函数如下:

//消息队列的删除
void DestoryMessage(int msgid){
	if(msgctl(msgid,IPC_RMID,NULL) == -1){
		perror("msgctl");
		exit(-4);
	}
}

　　以上便是消息队列的基本操作,关于消息队列通信实例为节省文章篇幅,请移步至:https://github.com/gaoxiaodiao/Linux/tree/master/LinuxCode/MessageQueue