Linux消息队列编程示例
2015-07-09 11:31
691 查看
一、概念
消息队列就是一个消息的链表。可以把消息看作一个记录,具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息;有读权限的进程则可以读走消息。读走就没有了。消息队列是随内核持续的。 只有内核重启或人工删除时,该消息才会被删除。在系统范围内,消息队列与键值唯一对应。
二、步骤及思路
1、取得键值
2、打开、创建消息队列
3、发送消息
4、接收消息
下***体看看:
1、取得键值
头文件为<sys/ipc.h>。返回文件名对应的键值,失败返回 -1。proj是项目名,随便写,不为0就行。
fname就是你指定的文件名(已经存在的文件名)。需要有-t 的权限,或用root权限执行,通常设为/tmp或设为" . "。这里我感觉不用这个函数也行,因为key值可以自己指定,例如: #define KEY_MSG 0x101
2、打开、创建消息队列
头文件为<sys/msg.h>。key由ftok获得。
msgflg有:
IPC_CREAT 创建新的消息队列,应配有文件权限0666。
IPC_EXCL 与IPC_CREAT一同使用,表示如果要创建的消息队列已经存在,则返回错误。
IPC_NOWAIT 读写消息不阻塞。
当没有与key相对应的消息队列并且msgflg中包含了IPC_CREAT标志 或 key的参数为IPC_PRIVATE 时,创建一个新的消息队列。
3、发送消息
向消息队列发送一条消息。msqid为消息队列的id,msgp为存放消息的结构体。msgsz是消息的长度,和数组的大小不一样哦。msgflg为消息标志,通常为0,也可以为IPC_NOWAIT。出错返回 -1。
消息格式
4、接收消息
从msqid代表的消息队列中读取一个msgtyp类型的消息,并把消息存储在msgp指定的msgbuf结构中。读取后队列中的消息将会删除。size为结构体中数据的大小,不要计算msgtyp。出错返回 -1。
三、举例
创建一消息队列,子进程发数据,父进程收数据。实现向队列中存放数据与读取数据。
消息队列就是一个消息的链表。可以把消息看作一个记录,具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息;有读权限的进程则可以读走消息。读走就没有了。消息队列是随内核持续的。 只有内核重启或人工删除时,该消息才会被删除。在系统范围内,消息队列与键值唯一对应。
二、步骤及思路
1、取得键值
2、打开、创建消息队列
3、发送消息
4、接收消息
下***体看看:
1、取得键值
key_t ftok(char *pathname, char proj)
头文件为<sys/ipc.h>。返回文件名对应的键值,失败返回 -1。proj是项目名,随便写,不为0就行。
fname就是你指定的文件名(已经存在的文件名)。需要有-t 的权限,或用root权限执行,通常设为/tmp或设为" . "。这里我感觉不用这个函数也行,因为key值可以自己指定,例如: #define KEY_MSG 0x101
2、打开、创建消息队列
int msgget(key_t key, int msgflg)
头文件为<sys/msg.h>。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<stdio.h> #include<sys/msg.h> #include<fcntl.h> #include<stdlib.h> #include<string.h> #define max 100</p> <p>struct haha{ long mtype; char data[max]; };</p> <p>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'))<0){ //这里文件夹必须存在,有t属性并且上级目录也要有t属性 printf("Getting key error! \n"); return -1; } int mgsid; if((mgsid=msgget(key,IPC_CREAT|0666))==-1){ //key值随便写一个数也能用 printf("mgs queue create error\n"); return -1; } pid=fork(); if(pid <0){ printf("fork create error!\n"); _exit(1); } if(pid == 0){ printf("welcome in child process\n Sending the message......\n"); sleep(1); struct haha hehe; hehe.mtype=getppid(); strcpy(hehe.data,argv[1]); if(msgsnd(mgsid,&hehe,sizeof(hehe.data),0)<0){ //此处注意长度 printf("Sending error!!!\n"); _exit(1); }else { printf("Sending complete!\n"); _exit(0); } }else{ wait(NULL); printf("welcome in parents process\n Receiving the message......\n"); sleep(1); struct haha gaga; if(msgrcv(mgsid,&gaga,max,getpid(),0)<0){ printf("Receiving error!!!\n"); _exit(1); }else { printf("Receiving complete!\n"); printf("The message is %s \n",gaga.data); } } return 0; }
相关文章推荐
- linux sed命令详解
- Linux时间同步配置方法
- Linux共享内存编程示例
- linux下查看光驱信息
- Linux管道通信C语言编程示例
- LXC Linux Containers内核轻量级虚拟化技术
- 编译64bit Linux Kernel 时报 genksyms 找不到
- Linux常用命令集合
- linux上SVN解决冲突的办法
- Hyper-V下安装linux没有网卡的解决方法
- Linux服务器运行命令df -h无响应
- linux编程获取本机IP地址
- Linux下合并前缀相同的文件的程序流程及其C代码实现
- Linux中变量$#,$@,$0,$1,$2,$*,$$,$?的含义
- Linux学习之CentOS(二十九)--Linux网卡高级命令、IP别名及多网卡绑定
- Linux学习之CentOS(二十八)--RAID原理基础及Linux下软件RAID配置
- Linux学习之CentOS(二十五)--Linux磁盘管理:LVM逻辑卷基本概念及LVM的工作原理
- Linux学习之CentOS(二十六)--Linux磁盘管理:LVM逻辑卷的创建及使用
- Linux Platform总线+SPI总线分析
- Linux学习之CentOS(二十七)--Linux磁盘管理:LVM逻辑卷的拉伸及缩减