IO编程——消息队列

 题目:

 代码实现:

#include <myhead.h>
//正文大小
#define MSGSZ (sizeof(struct msgbuf)-sizeof(long))
//定义要发送的消息类型
struct msgbuf{long msgtype;    //消息类型char mtext[1024];  //消息正文
};int main(int argc, const char *argv[])
{pid_t pid;pid=fork();struct msgbuf buf;if(pid>0){//父进程进行写操作//创建一个key值,方便定位到相应的消息队列中key_t key=ftok("./",'A');if(-1==key){perror("ftok error");return -1;}printf("key=%#x\n",key);//创建消息队列,为了写入数据到队列中int msqid=msgget(key,IPC_CREAT|0664);//IPC_CREAT创建消息队列    IPC_EXCL检测错误   0664队列的权限if(-1==msqid){perror("msgget error");return -1;}printf("msqid=%d\n",msqid);while(1){printf("请输入存放数据的类型(填入类型为long)------->\n");scanf("%ld",&buf.msgtype);getchar();printf("请输入正文的内容------->\n");fgets(buf.mtext,MSGSZ,stdin);buf.mtext[strlen(buf.mtext)-1]=0;//将‘\n’转换成‘0’msgsnd(msqid,&buf,MSGSZ,0);//0表示阻塞printf("写入到信息队列成功!(^<>^)!\n");if(0==strcmp(buf.mtext,"quit")){break;}}}else if(pid==0){//子进程读取队列节点中数据//创建一个key值,方便定位到相应的消息队列中key_t key=ftok("./",'A');if(-1==key){perror("ftok error");return -1;}printf("key=%#x\n",key);//创建消息队列,为了写入数据到队列中int msqid=msgget(key,IPC_CREAT|0664);//IPC_CREAT创建消息队列    IPC_EXCL检测错误   0664队列的权限if(-1==msqid){perror("msgget error");return -1;}printf("msqid=%d\n",msqid);while(1){//从消息队列中读取消息//第一个0表示一直取第一个消息//第二个0表示阻塞方式取出msgrcv(msqid, &buf, MSGSZ, 0, 0);printf("收到消息为:%s\n", buf.mtext);if(strcmp(buf.mtext, "quit") == 0){break;}}}return 0;
}

 注意事项:

        进程中包含读写操作,读取节点时用msgrcv(msqid, &buf, MSGSZ, 0, 0);,那么终端一的读操作和终端二的写操作会发生竟态,故目前有两种解决方案:

        方案一:创建两个消息队B

        方案二:分类获取信息,终端一获取"A"类型节点,终端二获取"B"类节点;

                                               终端一获取"B"类型节点,终端二获取"A"类节点;                   

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/57121.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

linux下建立软链接

深度学习训练中经常会遇到数据量庞大或者工程中模型报错太多导致磁盘空间不够&#xff0c;但是又不想修改原来在代码中写的路径&#xff0c;这个时候制作软连接很有作用&#xff0c;把占用量大的目录移到别的空闲磁盘&#xff0c;然后在原来的目录做一个软连接指向那个移到的空…

k8s ETCD数据备份与恢复

在 Kubernetes 集群中&#xff0c;etcd 是一个分布式键值存储&#xff0c;它保存着整个集群的状态&#xff0c;包括节点、Pod、ConfigMap、Secrets 等关键信息。因此&#xff0c;定期对 etcd 进行备份是非常重要的&#xff0c;特别是在集群发生故障或需要恢复数据的情况下。本文…

Java--集合(三)之vectorlinkedlisthashset结构

文章目录 0.架构图1.vector解析2.LinkedList分析2.1源码分析2.2迭代器遍历的三种方式 3.set接口的使用方法3.1基本使用说明3.2基本遍历方式3.3HashSet引入3.4数组链表模拟3.5hashset扩容机制3.6hashset源码解读3.7扩容*转成红黑树机制**我的理解 0.架构图 1.vector解析 和之前介…

【Vue】Vue3.0(十四)接口,泛型和自定义类型的概念及使用

上篇文章&#xff1a; 【Vue】Vue3.0&#xff08;十三&#xff09;中标签属性ref&#xff08;加在普通标签上、加在组件标签上&#xff09;、局部样式 &#x1f3e1;作者主页&#xff1a;点击&#xff01; &#x1f916;Vue专栏&#xff1a;点击&#xff01; ⏰️创作时间&…

Windows进程的睡眠与唤醒

在总体架构庞大、包含很多进程协同工作的系统中。有时把系统内某些后台进程睡眠&#xff0c;待需要时再唤醒&#xff0c;可以节约操作系统资源&#xff0c;提升系统运行效率。 进程睡眠&#xff1a; bool Widget::suspendProcess(DWORD targetProcessId) {// 获取进程句柄HAN…

数据结构——二叉树的基本操作及进阶操作

前言 介绍 &#x1f343;数据结构专区&#xff1a;数据结构 参考 该部分知识参考于《数据结构&#xff08;C语言版 第2版&#xff09;》116 ~ 122页 及 《数据结构教程》201 ~ 213页 重点 树的基本实现并不难&#xff0c;重点在于对递归的理解才是树这部分知识带来的最大收…

python绝对值怎么表示

python abs()函数用于获取数字的绝对值&#xff0c;参数可以是负数、正数、浮点数或者长整形。 语法&#xff1a; abs( x ) 下面是详细参数&#xff1a; X&#xff1a;这是一个数值表达式。 返回值&#xff1a; x的绝对值。 例如&#xff1a; #!/usr/bin/python print &q…

smbms(2)

目录 一、修改密码功能实现 二、优化密码修改&#xff0c;加入旧密码确认环节【使用Ajax】 三、用户管理实现 获取用户数量 获取用户列表 获取角色列表 Servlet 一、修改密码功能实现 1、导入前端素材 2、UserDao接口 3、UserDaoImpl实现类 4、UserService接口 5、Us…

解决ffmpeg通过srt文件给视频添加字幕时乱码问题

ffmpeg添加字幕乱码 #添加源 echo "deb http://deb.debian.org/debian bookworm contrib non-free" > /etc/apt/sources.list.d/contrib.list #更新源 apt-get install ttf-mscorefonts-installer apt-get install fontconfig apt-get update cd /usr/share/fon…

Unity中常用组件介绍

在Unity中&#xff0c;组件是构建游戏对象功能的基本单元。以下是一些常见的Unity组件及其作用&#xff1a; Transform&#xff1a;控制对象的位置、旋转和缩放。每个游戏对象都默认为有这个组件。 Rigidbody&#xff1a;使对象受物理影响&#xff08;如重力、碰撞等&#xff…

人脸识别系统概述

人脸识别是目前人工智能领域中成熟较早、落地较广的技术之一&#xff0c;广泛应用于手机解锁、支付验证、安防布控等多个领域。其核心在于通过特定的算法识别图像或视频中人脸的身份&#xff0c;这一过程的实现离不开特征算法的支持。以下是对人脸识别特征算法的详细介绍&#…

力扣76~80题

题76&#xff08;困难&#xff09;&#xff1a; 分析&#xff1a; 这道题其实不难&#xff0c;但是是我做最久的了&#xff0c;我居然去用res去接所有可能得值&#xff0c;然后再求长度导致空间暴力&#xff0c;我还以为是我queue的问题。。。 最后用暴力求解解的&#xff0c…

hardhat部署智能合约

Hardhat安装 安装node 可以使用 nvm 安装node GitHub - nvm-sh/nvm: Node Version Manager - POSIX-compliant bash script to manage multiple active node.js versions 安装Hardhat 打开命令行工具&#xff0c;输入&#xff1a; mkdir hardhat-demo cd hardhat-demo npm i…

【wpf】08 xml文件的存取操作

在使用wpf编程过程中&#xff0c;会用到xml的配置文件&#xff0c;实现对其读取和存储的操作是必须的。 1 xml说明 可扩展标记语言 (Extensible Markup Language, XML) &#xff0c;标准通用标记语言的子集&#xff0c;可以用来标记数据、定义数据类型&#xff0c;是一种允许…

数据库`addtime(t, n)` 函数

在编程中&#xff0c;addtime(t, n) 这个函数并不是一个标准的内置函数&#xff0c;但我们可以根据这个函数的描述来构想一个实现方式。假设 t 是一个表示时间的对象或值&#xff08;比如时间戳、日期时间对象等&#xff09;&#xff0c;而 n 是一个时间间隔&#xff08;比如秒…

破局汽车基础软件发展丨昂辉科技亮相2024芜湖新能源汽车零部件和后市场生态博览会

10月14—17日&#xff0c;2024芜湖新能源汽车零部件和后市场生态博览会在芜湖市宜居国际博览中心盛大开幕。昂辉科技携新一代EasySAR车载基础软件工具链产品亮相核心零部件展区。 作为新能源汽车行业的一次盛会&#xff0c;本届博览会以“会议论坛展区展示”为特色&#xff0c…

【算法学习】冒泡排序

1. 冒泡排序 详情在下列注释里 package com.tool.tooladmin.algorithm;import com.tool.tooladmin.config.result.AjaxResult; import com.tool.tooladmin.config.result.BaseController; import org.springframework.web.bind.annotation.*;import java.math.BigDecimal;/**…

cefsharp79.1.360(Chromium 79.0.3945.130)支持H264视频播放-PDF预览 老版本回顾系列体验

一、关于此版本 版本:Cef 79.1.36/CefSharp 79.1.360/Chromium 79.0.3945.130/支持H264/支持PDF预览 支持PDF预览和H264推荐版本 63/79/84/88/100/111/125 运行环境需要 visual c++ 2015不支持xp/vista/2003/2008默认不支持h264(版权问题)支持打印预览 print preview已知问题…

网络资源模板--Android Studio 实现简易新闻App

目录 一、项目演示 二、项目测试环境 三、项目详情 四、完整的项目源码 一、项目演示 网络资源模板--基于Android studio 实现的简易新闻App 二、项目测试环境 三、项目详情 登录页 用户输入&#xff1a; 提供账号和密码输入框&#xff0c;用户可以输入登录信息。支持“记…

HiveOnSpark环境下,Spark 挂了问题排查思路

在 Hive on Spark 模式下&#xff0c;Hive 使用 Spark 作为其执行引擎运行查询。如果 Spark 挂了&#xff0c;分析和解决错误通常需要查看多个地方的日志和配置。以下是分析 Spark 挂掉问题的详细步骤和方法。 1. 检查 Hive 查询日志 首先&#xff0c;在 Hive 中执行的查询都会…