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

一、消息队列之创建

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

#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