位置: 编程技术 - 正文

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

编辑:rootadmin

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

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

一、概念

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

二、步骤及思路

1、取得键值2、打开、创建消息队列3、发送消息4、接收消息

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

下面具体看看:

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应用程序开发框架,它的核心目标是提供一个简单、切必要的开发环境给开发者,开发者可以在此基础上构建出更加完善的

标签: linux消息队列阻塞

本文链接地址:https://www.jiuchutong.com/biancheng/364797.html 转载请保留说明!

上一篇:Linux 多线程编程实例(linux多线程编程电子书)

下一篇:Percona Server 5.5.44-37.3/5.6.25-73.0 发布

  • 北京增值税发票网上申领流程
  • 银行贴现属于贷款吗
  • 企业进口葡萄酒也要缴纳消费税吗
  • 小微企业城建税优惠政策2022
  • 加计扣除企业所得税季报申报
  • 事业支出中的其他支出
  • 增值税专票逾期抵扣怎么操作
  • 进项税额留底月底销项税金如何结转?
  • 企业如何认定
  • 计提个人生产经营所得个税需要贴附件吗
  • 哪些金融资产不计提减值
  • 发票专用章的规格大小
  • 分红 实缴比例
  • 对外开具发票
  • 长期待摊费用的内容和特征
  • 预付卡充值赠送的金额确认收入
  • 进项是普票销项是专票,怎么交税
  • 报废的周转物怎么处理?
  • 转口贸易需要申报什么税
  • linux aptx
  • 一般纳税人接受固定资产投资时相关的科目可能有
  • 鸿蒙系统快捷键
  • 装电脑系统的方法和步骤
  • 房租收入怎么做会计分录
  • 葛根泡水喝的七大功效
  • php string
  • 发票开出后只收到部分款怎么处理?
  • nddeagnt.exe - nddeagnt是什么进程 有什么用
  • 赠送礼品进项税需要转出吗
  • 从国际空间站看木星
  • 增值税减免税的征管规定有哪些
  • php索引类型
  • echarts.
  • for of 与for in
  • 物业收取停车费需要业主同意吗
  • 一般企业预缴税额怎么算
  • 从公账发工资是什么凭证
  • 网上申报完还需要去税务局吗
  • js 自定义类型
  • 报销有专票和普票,怎么出分录
  • 小型微利企业的认定标准2023年
  • 建筑服务的劳务费交印花税吗
  • 金税四期有很多不实的传言
  • 企业所得税退税有风险吗
  • 服务费可以计入主营业务成本吗
  • 主营业务收入净额在哪个报表里面
  • 小规模纳税人未开票收入如何申报增值税
  • 豆制品属于农副产品吗为什么
  • 发票一般会失效几天
  • 客户是否需要向客户介绍
  • 生产成本核算的步骤
  • 已付款发票未到怎么做分录
  • 员工加班打车费报销
  • 结转完工入库产品成本的会计分录
  • 银行转出去的账可以追回吗?
  • 企业一般户怎么查询
  • 应收票据和应付票据的区别
  • MySQL在Linux系统中隐藏命令行中的密码的方法
  • win10的时间设置
  • windows xp计算器
  • centos如何运行程序
  • 修改注册表显示隐藏文件
  • ubuntu系统安装SSH服务
  • macos手势
  • Win10怎么修改hosts文件
  • linux必学的60个命令rar
  • Unity3D游戏开发引擎
  • sku分析的作用
  • eclipse从本地导入项目
  • shell自动化
  • unity 循环列表
  • 自定义progressbar
  • javascript学习指南
  • JavaScript入门教程
  • jquery禁用输入框
  • 数字图像处理软件idl和matlab有什么异同点
  • python自定义min_self函数
  • jquery事件的响应
  • 安全生产管理局和应急局
  • 个体工商户开发票怎么开
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设