Linux消息队列编程示例(linux消息队列阻塞)

推荐整理分享Linux消息队列编程示例(linux消息队列阻塞)，希望有所帮助，仅作参考，欢迎阅读内容。

文章相关热门搜索词:linux消息队列编程,linux 消息队列 系统参数,linux 消息队列查看和删除,linux消息队列msgrcv,linux 消息队列 系统参数,linux消息队列编程,linux消息队列编程,linux消息队列编程,内容如对您有帮助，希望把文章链接给更多的朋友！

一、概念

消息队列就是一个消息的链表。可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息；有读权限的进程则可以读走消息。读走就没有了。消息队列是随内核持续的。 只有内核重启或人工删除时，该消息才会被删除。在系统范围内，消息队列与键值唯一对应。

二、步骤及思路

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 0x、打开、创建消息队列复制代码代码如下: int msgget(key_t key, int msgflg) 头文件为<sys/msg.h>。key由ftok获得。

msgflg有：

IPC_CREAT 创建新的消息队列，应配有文件权限。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[]; };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 </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|))==-1){ //key值随便写一个数也能用 printf("mgs queue create errorn"); return -1; } pid=fork(); if(pid <0){ printf("fork create error!n"); _exit(1); } if(pid == 0){ printf("welcome in child processn 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 processn 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;}

Percona Server 5.5.-.3/5.6.-.0 发布 PerconaServer5.5.-.3发布，此版本基于MySQL5.5.，包括其所有bug修复，是当前5.5系列最新的稳定版本。此版本现已提供下载，也提供在PerconaSoftwareRepositories

Linux iptables的备份和恢复操作详解 1、iptables的配置文件位置：/etc/sysconfig/iptables主控机：即业务运行中的机子；备份机：即主控机故障时，切换到备份的机子--在主控机上的操作-------------

轻量化 Java 开发框架Hasor 1.0.0 正式发布 Hasor是一款开源的轻量级Java应用程序开发框架，它的核心目标是提供一个简单、切必要的开发环境给开发者，开发者可以在此基础上构建出更加完善的