首页 > 代码库 > LInux进程间通信之消息队列编程实例
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
LInux进程间通信之消息队列编程实例