systemV的工作原理+原理代码

news2024/11/24 6:31:39

概念

我们知道进程间的通信有管道的方式进程通信管道制作_云的小站的博客-CSDN博客

但是我们的管道通信其实属于一种取巧的方式,利用了打开的文件可读写的特性上,两个进程对此分别进行读写操作就会产生所谓的通信现象,但是外面的管道依旧得再磁盘上创建一个文件,然后文件打开加载在内存上才可以使用,那么有什么方法可以直接加载在内存,而无需对磁盘操作呢?

---------利用systemV共享内存通信

利用系统函数shmget在内存中开辟一块空间用于进程通信的交互点。因为两个进程之间不可以直接通信,所以需要加一个中间层。

 

学计算机,当两个东西不通的时候,我们最经常干的事情就是加一个中间层,既保护了独立性,又处理了我们需要完成的事情

工具

shmget(创建共享内存)

shmid_t shmget(key_t key, size_t size, int shmflg);

 返回值:

失败返回-1,成功返回一个shmid唯一的共享内存标识符。

key:

唯一值,两个进程需要同一个key值才可以访问到同一共享内存空间。

size:

设置共享内存大小

shmflg

共享内存创建选项,IPC_CREAT | IPC_EXCL|0666 

IPC_CREAT:如果内存存在key标识符的共享内存直接使用,如果不存在就创建

IPC_EXCL:如果内存存在key标识符的共享内存直接失败退出。

0666:共享内存的使用权限。

shmctl(操作共享内存)

int shmctl(int shmid, int cmd, struct shmid_ds *buf);

返回值:

如果操作成功返回0,操作失败返回-1;

shmid:

对该shmid的共享内存进行操作;

cmd:

对共享内存的操作选项,一般我们删除共享内存用的使用:IPC_RMID

buf:

获取该共享内存的数据结构地址。(共享内存也需要被描述组织)。

shmat(进程的挂接操作)

void *shmat(int shmid, const void *shmaddr, int shmflg);

返回值:

成功返回共享内存的地址,失败返回-1,并设置errno错误原因。

shmid:

挂接在shmid标识符的共享内存上。

shmaddr:

理论上可以自己设置将共享内存挂接在自己指定的位置,但是不建议。所以一般设置为nullptr,

shmflg

设置访问方式只读、只写等等。设置为0,读写操作。

shmdt(进程的拆除操作)

int shmdt(const void *shmaddr);

返回值:

成功拆除返回0,失败返回-1;

shmaddr:

将进程地址空间shmaddr的共享内存,进行拆除。

ftok(生成一个key值为shmget服务)

key_t ftok(const char *pathname, int proj_id);

返回值:

返回有个随机数字。

pathname:

传一个文件路径,使用文件的inode值,对了文件必须要有访问权限。

proj_id:

项目id,0~255,其实可以随便写,会截断。

ps:ftok不进行系统调用,他只是一个算法

代码

来来来,工具说完了直接上代码:

头文件

日志+需要的接口

日志

  1 #ifndef _LOG_H_
  2 #define _LOG_H_
  3 #include <ctime>
  4 #include <iostream>
  5 
  6 #define Debug 0
  7 #define Notice 1
  8 #define Warning 2
  9 #define Error 3
 10 
 11 std::string mgs[] = {
 12     "Debug",
 13     "Notice",
 14     "Warning",
 15     "Error"};
 16 
 17 std::ostream &Log(std::string message, int level)
 18 {
 19     std::cout << " | " << (unsigned)time(nullptr)
 20     << " | " << mgs[level] << " | "<<message;
 21     return std::cout;                                                                                                           
 22 }
 23 
 24 #endif
~

所需头文件

 1 #pragma once                                                                                                                    
  2 #include<iostream>
  3 #include<cstdio>
  4 #include<sys/shm.h>
  5 #include<sys/ipc.h>
  6 #include<sys/types.h>
  7 #include"Log.hpp"
  8 #include<assert.h>
  9 #include<unistd.h>
 10 using namespace std;
 11 #define SIZE 4096
 12 #define PATH_NAME "."
 13 #define PROJ_ID 0x66
 14 
 15 
 16 string TransToHex(key_t k)
 17 {
 18     char buffer[32];
 19     snprintf(buffer,sizeof(buffer),"0x%x",k);
 20     return buffer;
 21 }

接收方代码

#include"comm.hpp"
  2 
  3 int main()
  4 {
  5     // 1.创建公共key
  6     key_t k=ftok(PATH_NAME,PROJ_ID);
  7     assert(k!=-1);
  8     Log("create key done",Debug)<<" sgmrevice key: "<< TransToHex(k)<<endl;
  9     sleep(10);
 10     //2.创建共享内存
 11 
 12     int shmid = shmget(k,SIZE,IPC_CREAT | IPC_EXCL|0666 );
 13     if(shmid==-1)
 14     {
 15         perror("shmger fail!!\n");
 16         exit(-1);
 17     }
 18 
 19     Log("create shm done",Debug)<<" sgmrevice shmid: "<<shmid<<endl;
 20 
 21 
 22     sleep(10);
 23     //挂接内存
 24     char*shmaddr=(char*)shmat(shmid,nullptr,0);
 25     if(*shmaddr==-1)
 26     {
 27         perror("shmat fail!\n");
 28     }
 29     Log("shmat shm seccese",Debug)<<" sgmrevice shmid: "<<shmid<<endl;
 30     sleep(10);
 31 
 32     //工作
 33 
 34     //拆除链接
 35     int n=shmdt(shmaddr);                                                                                                                                                                                                                                                                                                                                           
 36     assert(n!=-1);
 37     (void)n;
 38     Log("shmdt shm done",Debug)<<" sgmrevice shmid: "<<shmid<<endl;
 39 
 40     sleep(10);
 41     // n.删除共享内存
 42     n=shmctl(shmid,IPC_RMID,nullptr);
 43     assert(n!=-1);
 44     (void)n;
 45     Log("delete shm done",Debug)<<" sgmrevice shmid: "<<shmid<<endl;
 46 
 47     return 0;
 48 }
~

发送方代码

 1 #include"comm.hpp"                                                                                                                                                                                                               
  2 int main()
  3 {         
  4   //获取k值
  5   key_t k=ftok(PATH_NAME,PROJ_ID);
  6   assert(k!=-1);                  
  7   (void)k;                        
  8   Log("create key done  郑建云",Debug)<<"key:"<<TransToHex(k)<<endl;
  9   sleep(10);                                                        
 10   //创建共享内存                                                    
 11   //由于在receive已经创建共享内存,所以我们主要是找到内存挂接
 12   //IPC_CREAT==0                                             
 13   int shmid = shmget(k,SIZE,IPC_CREAT);                      
 14   if(!shmid)                           
 15   {                                    
 16     perror("shmget fail!!\n");
 17     exit(-1);                 
 18   }                           
 19              
 20   Log("create shm domw",Debug)<<" shmid: "<<shmid<<endl;
 21   int cnt=10;                                           
 22   while(cnt)                                            
 23   {          
 24     printf("time:%d\r",cnt--);
 25     sleep(1);                 
 26     fflush(stdout);           
 27   }                
 28   printf("\n");    
 29   //挂接,shmaddr,不要自己写,避免把其他数据覆盖
 30   char*shmaddr=(char*)shmat(shmid,nullptr,0);  
 31   if(shmaddr==nullptr)                         
 32   {                                          
 33     perror("shmat fail\n");
 34     exit(-1);              
 35   }                        
 36   Log("shmat sueecss done",Debug)<<"shmid: "<<shmid<<endl;
 37   sleep(10);                                              
 38                                                           
 39   //工作    
 40         
 41   //拆除共享内存                                                                                                            
 42   int n=shmdt(shmaddr);                                                                                                     
 43   printf("n=%d\n",n);                                                                                                       
 44   assert(n==0);                                                                                                             
 45   (void)n;                                                                                                                  
 46   Log("shmdt success done",Debug)<<" shmid "<<shmid<<endl;                                                                  
 47   printf("%p\n",shmaddr);                                                                                                   
 48   return 0;                                                                                                                 
 49 }                                          

执行顺序必须先执行接收代码,因为接收代码必须先创建好共享内存,然后发送方才可以链接。

否者,发送方先建立了,在执行中接收方将检查出内存中已经存在该key的共享内存,直接报错,返回一个-1到shmid。

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

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

相关文章

【社区图书】快速入门go程序开发——《Go程序开发实战宝典》书评

《Go程序开发实战宝典》书评 一、介绍二、简要概述三、内容分析3.1、第一部分&#xff1a;Go语言基础知识3.2、第二部分&#xff1a;介绍服务端开发经常需要处理的问题3.3、第三部分&#xff1a;Go语言开发实践实战案例 四、我的看法和评价4.1、对本书整体评价4.2、我对这本书的…

Office Visio 2021安装

哈喽&#xff0c;大家好。今天一起学习的是Visio 2021的安装&#xff0c;这是一个绘制流程图的软件&#xff0c;用有效的绘图表达信息&#xff0c;比任何文字都更加形象和直观。Office Visio 是office软件系列中负责绘制流程图和示意图的软件&#xff0c;便于IT和商务人员就复杂…

Vue.js 中的插槽和动态组件

Vue.js 中的插槽和动态组件 Vue.js 是一款流行的 JavaScript 框架&#xff0c;它提供了一种简单而灵活的方式来构建交互式 Web 应用程序。在 Vue.js 中&#xff0c;插槽和动态组件是两个常用的概念。它们可以帮助开发者更方便地组织和管理组件的结构和行为。但是这两个概念有什…

(opencv)图像几何变换——平移

图像的平移操作是将图像的所有像素坐标进行水平或垂直方向移动&#xff0c;也就是将所有像素点按照给定的偏移量在水平方向沿x轴、垂直方向上沿y轴移动。平移变换分为两种类型&#xff1a;图像大小变化与图像大小不变。第一种类型保证图像平移的完整信息&#xff0c;第二种图像…

Vue.js 中的 $refs 和 $emit 有什么关系?

Vue.js 中的 $refs 和 $emit 有什么关系&#xff1f; 在 Vue.js 中&#xff0c;$refs 和 $emit 都是非常常用的 API。$refs 用于访问组件、元素和子组件等&#xff0c;而 $emit 则用于在组件之间进行通信。本文将会从语法、使用方式、适用场景等方面进行介绍&#xff0c;并探讨…

接招吧! selenium环境+元素定位大法

selenium 与 webdriver Selenium 是一个用于 Web 测试的工具&#xff0c;测试运行在浏览器中&#xff0c;就像真正的用户在手工操作一样。支持所有主流浏览器 WebDriver 就是对浏览器提供的原生API进行封装&#xff0c;使其成为一套更加面向对象的Selenium WebDriver API。 …

【数据结构与算法分析】使用C语言实现队列的两种(带头结点与不带头结点)链式存储,并且给出一种循环队列的设计思想

文章目录 前言队列实现带头结点单向队列不带头结点单向队列循环队列 总结 前言 当我们编写程序时&#xff0c;经常需要处理各种数据结构。队列是一种常见的数据结构&#xff0c;它有着广泛的应用场景。队列的基本操作包括入队和出队&#xff0c;应用于模拟等待队列、消息队列、…

LVS-DR集群

LVS-DR集群 一.LVS-DR工作原理 1.数据包流向 数据包流向分析&#xff1a; &#xff08;1&#xff09;客户端发送请求到 Director Server&#xff08;负载均衡器&#xff09;&#xff0c;请求的数据报文&#xff08;源 IP 是 CIP,目标 IP 是 VIP&#xff09;到达内核空间。 &…

Flowable工作流入门完整SpringBoot案例

文章目录 一 、Flowable 的出现是为了什么二、Flowable 的优势三、常见的Java类/实例3.1 ProcessEngine3.2 RepositoryService3.3 ProcessDefinition3.4 Deployment3.5 RuntimeService3.6 ProcessInstance3.7 TaskService3.8 JavaDelegate3.9 其他 四、核心数据库表4.1 数据库4…

CET4写译学习

学习记录笔记&#xff1a; 05.四级写译技巧(上)_哔哩哔哩_bilibili 不会的东西不要往上写。寻找可以替换的词。 保证写的所有内容都是正确的。 切题&#xff0c;论证清楚。 要有自己的观点&#xff0c;然后去论证。 词汇&#xff0c;语法&#xff0c;句子结构都整好。 文…

【软件测试】接口测试工具APIpost

说实话&#xff0c;了解APIpost是因为&#xff0c;我的所有接口相关的文章下&#xff0c;都有该APIpost水军的评论&#xff0c;无非就是APIpost是中文版的postman&#xff0c;有多么多么好用&#xff0c;虽然咱也还不是什么啥网红&#xff0c;但是不知会一声就乱在评论区打广告…

Linux日志

rsyslog系统日志管理 哪类程序产生的什么日志放到什么地方 处理日志的进程 第一类&#xff1a; rsyslogd&#xff1a;系统专职日志程序&#xff0c;处理绝大部分日志记录&#xff0c;系统操作相关的信息&#xff0c;如登录信息&#xff0c;程序启动关闭相关信息&#xff0c…

C#语言实现4K图片放大缩小和平移显示性能的速度测试

在介绍“熊猫视图.Net图形控件”系列文章中&#xff0c; 【“熊猫视图.Net图形控件”介绍链接】https://blog.csdn.net/mosangbike/article/details/126026801有对显示图像文件的测试结果&#xff0c;当时测试的不太严谨。今天抽时间详细测试了一下。 从网上找了一张Jpg图像作…

亲宝宝 实习 面经

目录 1.char varchar 长度是字符数还是字节数 编码格式2.整型数据类型3.decimal及其实现4.慢查询5.索引失效6.explain7.for foreach性能差异8.数据库事务隔离级别9.binlog redolog 二阶段提交10.redis数据类型11.redis实现消息队列12.mybatis传参方法13.insert返回主键 1.char …

数据库实验一 数据库和数据表的建立、修改和删除

任务描述 本关任务&#xff1a;建立数据库 为了完成本关任务&#xff0c;你需要掌握&#xff1a; 如何创建数据库&#xff0c;显示已经建立的数据库 相关知识 创建数据库 创建数据库是在系统磁盘上划分一块区域用于数据的存储和管理。 命令格式&#xff1a; CREATE DATABA…

粮油智能制造MES追溯系统源码

粮油生产加工MES追溯系统源码 粮油生产加工MES追溯系统&#xff0c;实现从种植、加工、检验、销售各个环节的数据采集。 粮油MES质量管控防伪溯源系统可广泛用于粮油生产加工领域。实现种植主体、种植基地、生产计划、压榨、精炼、包装、销售、物料管理、检验检测等各个环节的…

Java对象拷贝MapStruct

介绍 编译期即可生成对象复制代码。简单理解&#xff0c;功能定位org.springframework.beans.BeanUtils。 官网&#xff0c;GitHub-MapStruct。 入门 maven项目引入依赖&#xff1a; mapstruct&#xff1a;包含必要注解&#xff0c;如Mappingmapstruct-processor&#xff1…

Cereal 靶机

环境准备 靶机链接&#xff1a;百度网盘 请输入提取码 提取码&#xff1a;bcj2 虚拟机网络链接模式&#xff1a;桥接模式 攻击机系统&#xff1a;kali linux 2021.1 信息收集 1.探测目标靶机 arp-scan -l 2.nmap -p- -A -T4 192.168.1.107 探测目标靶机开放端口和服务 漏…

我是如何入门网络安全?有什么自学心得?

我是如何入门&#xff0c;网络安全的 那年我高三毕业的时候要填志愿前几天 我妈问我想学什么专业。 我说&#xff0c;想学网络设计、或者计算机、网络安全工程师 那时候还比较年轻&#xff0c;也对网络&#xff0c;计算机这方面感兴趣嘛 于是我妈和我爸决定让我学网管。 我…

卡尔曼滤波与组合导航原理(十三)无迹卡尔曼滤波UKF

一、蒙特卡洛仿真 蒙特卡洛仿真的基本原理是通过生成大量的随机样本&#xff0c;以近似地估计实际事件的概率和预测结果。 它是以蒙特卡洛赌场命名的&#xff0c;因为它使用随机数和概率统计的方法来模拟现实世界中的各种情况和结果&#xff0c;就像在赌场中抛骰子或发牌一样。…