Linux消息队列编程示例 |
您所在的位置:网站首页 › java中消息队列的使用举例子 › Linux消息队列编程示例 |
Linux消息队列编程示例
一、概念 消息队列就是一个消息的链表。可以把消息看作一个记录,具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息;有读权限的进程则可以读走消息。读走就没有了。消息队列是随内核持续的。 只有内核重启或人工删除时,该消息才会被删除。在系统范围内,消息队列与键值唯一对应。 二、步骤及思路 1、取得键值2、打开、创建消息队列3、发送消息4、接收消息 下面具体看看: 1、取得键值 复制代码代码如下: key_t ftok(char *pathname, char proj) 头文件为。返回文件名对应的键值,失败返回 -1。proj是项目名,随便写,不为0就行。 fname就是你指定的文件名(已经存在的文件名)。需要有-t 的权限,或用root权限执行,通常设为/tmp或设为" . "。这里我感觉不用这个函数也行,因为key值可以自己指定,例如: #define KEY_MSG 0x1012、打开、创建消息队列复制代码代码如下: int msgget(key_t key, int msgflg) 头文件为。key由ftok获得。msgflg有: IPC_CREAT 创建新的消息队列,应配有文件权限0666。IPC_EXCL 与IPC_CREAT一同使用,表示如果要创建的消息队列已经存在,则返回错误。 IPC_NOWAIT 读写消息不阻塞。 当没有与key相对应的消息队列并且msgflg中包含了IPC_CREAT标志 或 key的参数为IPC_PRIVATE 时,创建一个新的消息队列。3、发送消息 复制代码代码如下: int msgsnd(int msqid, struct msgbuf *msgp, int msgsz, int msgflg) 向消息队列发送一条消息。msqid为消息队列的id,msgp为存放消息的结构体。msgsz是消息的长度,和数组的大小不一样哦。msgflg为消息标志,通常为0,也可以为IPC_NOWAIT。出错返回 -1。 消息格式复制代码代码如下: struct msgbuf { long mtype; char mtext[100]; };4、接收消息复制代码代码如下: int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg) 从msqid代表的消息队列中读取一个msgtyp类型的消息,并把消息存储在msgp指定的msgbuf结构中。读取后队列中的消息将会删除。size为结构体中数据的大小,不要计算msgtyp。出错返回 -1。三、举例创建一消息队列,子进程发数据,父进程收数据。实现向队列中存放数据与读取数据。 复制代码代码如下:#include#include#include#include#include#define max 100struct haha{ long mtype; char data[max];}; int main(int argc,char *argv[]){ int pid; if(argc!=2){ printf("Usage: msg [Message]\n"); return -1; } key_t key; if((key=ftok("/tmp",'g')) |
今日新闻 |
点击排行 |
|
推荐新闻 |
图片新闻 |
|
专题文章 |
CopyRight 2018-2019 实验室设备网 版权所有 win10的实时保护怎么永久关闭 |