Linux进程间通信(IPC)机制之一:共享内存

                                               🎬慕斯主页修仙—别有洞天

                                              ♈️今日夜电波:Nonsense—Sabrina Carpenter

                                                                0:50━━━━━━️💟──────── 2:43
                                                                    🔄   ◀️   ⏸   ▶️    ☰  

                                      💗关注👍点赞🙌收藏您的每一次鼓励都是对我莫大的支持😍


目录

什么是共享内存?

共享内存介绍

共享内存原理

函数接口详解

通过ftok获取key值

通过shmget创建共享内存

一些小细节

通过shmat挂接进程

通过shmdt取消与共享内存的关联

通过shmctl控制共享内存

IPC_RMID:删除共享内存

IPC_STAT:获取共享内存的状态

IPC_SET:改变共享内存的状态

共享内存的拓展

Makefile

server.cc

client.cc

代码效果


什么是共享内存?

共享内存介绍

        Linux共享内存是一种快速的数据交换手段,允许多个进程访问同一块内存区域

        共享内存在Linux中是一种高效的进程间通信(IPC)机制,它使得不同的进程可以访问同一段内存区域,从而实现数据共享和传输。它是内核级别的资源,并且通常是进程间通信方式中最快的一种。Linux共享内存的使用方式主要有以下几种(本文主要介绍基于system V的共享内存):

  1. 基于system V的共享内存:这是传统的方法,历史悠久,但API较为复杂。如果编译内核时没有选择CONFIG_SYSVIPC,则不会支持这种方式。
  2. 基于POSIX mmap文件映射实现共享内存:这种方法使用mmap系统调用将文件映射到内存中,从而实现共享。
  3. 通过memfd_create()和fd跨进程共享:这是一种较新的方法,用于创建匿名内存区域,并通过文件描述符在不同进程间共享。
  4. 基于dma-buf的共享内存:这在多媒体和图形领域广泛使用,适用于高性能的数据传输需求。

        共享内存的优势在于其高速的数据传输能力,因为数据不需要在用户空间和内核空间之间复制。然而,它也有一些劣势,比如需要手动管理同步和并发访问,以及可能的安全问题,因为它绕过了操作系统的正常内存保护机制。为了提高安全性,可以使用命名管道等机制来实现访问控制。

共享内存原理

        我们还是需要遵守一句话:进程间通信的前提是让不同的进程看到同一块资源(必须由OS提供)。共享内存区是最快的IPC形式。一旦这样的内存映射到共享它的进程的地址空间,这些进程间数据传递不再涉及到内核,换句话说是进程不再通过执行进入内核的系统调用来传递彼此的数据。也就是说他是在用户空间中的而不是在内核空间中(缓冲区、文件属性等等就是在此)。如下是简易的图示:

​        更为详细的图示:

        共享内存的原里实际上就是(1)在物理内存中申请一块空间(2)将申请的空间通过页表映射到进程的虚拟内存中的共享区中,共享区通过返回虚拟地址的首地址就可让进程看到资源。接着再让另外的进程做同样的操作,不够需要注意的是要指向同一块物理空间。这样我们就让不同的进程看到了同一块资源。(3)当我们去掉页表的映射关系。(4)释放物理内存的空间后,就解除了共享内存。

        需要注意的是:系统中一定会有很多的共享内存存在,操作系统需要管理全部共享内存,因此我们会按照“先描述,在组织”的原则创建对应的数据结构进行管理。共享内存会必须要求有唯一标识符来区分,我们需要制定一定的规则、约定让不同的进程识别同一块共享内存从而得以通信

函数接口详解

        共享内存函数Linux共享内存的相关函数主要包括shmgetshmatshmdtshmctl。具体如下:

         1、shmget:这是创建或获取共享内存段的函数。它的原型是

#include <sys/ipc.h>
#include <sys/shm.h>
int shmget(key_t key, size_t size, int shmflg);
    • key:用于指定共享内存的键值,可以是任意非负整数,通常通过ftok函数生成。
    • size:指定共享内存段的大小。
    • shmflg:设置共享内存段的权限和属性。

         2、shmat:这个函数用于将共享内存段附加到进程的地址空间上。它的原型是

#include <sys/types.h>
#include <sys/shm.h>
void *shmat(int shmid, const void *shmaddr, int shmflg);
    • shmid:由shmget返回的共享内存标识符。
    • shmaddr:可选参数,通常设置为nullptr,让系统自动选择一个地址来附加共享内存。
    • shmflg:附加标志,如SHM_RDONLY以只读方式附加。

         3、shmdt:当进程完成对共享内存的使用后,需要使用shmdt函数将其从进程的地址空间中分离(detach)。它的原型是

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
int shmdt(void *addr);
    • addr:之前通过shmat附加的共享内存地址。

         4、shmctl:这个函数用于对共享内存段进行控制操作,如删除共享内存段。它的原型是:

#include <sys/ipc.h>
#include <sys/shm.h>
int shmctl(int shmid, int cmd, struct shmid_ds *buf);
  • shmid:共享内存标识符,即要控制的共享内存段的标识符。
  • cmd:控制命令,可取值如下:
    • IPC_STAT:获取共享内存的状态。
    • IPC_SET:改变共享内存的状态。
    • IPC_RMID:删除共享内存。
  • buf:指向struct shmid_ds结构的指针,该结构用于存储共享内存的状态信息。当cmd为IPC_STAT或IPC_SET时,需要使用此参数。

        在实际应用中,通常会结合信号量或互斥锁等同步机制来确保数据的一致性和访问的安全性。此外,共享内存的使用也需要考虑到系统的资源限制,例如共享内存段的大小和数量都可能受到系统配置的限制。

通过ftok获取key值

        如果我们要找到或者创建一个共享内存,我们需要约定一个相同的key值,这样才能找到对应的共享内存,才能让进程间相互通信。因此,这也是创建共享内纯的前提。ftok函数用于将一个已存在的路径名和一个整数标识符转换成IPC键值,以便在进程间通信中使用

    ftok函数是Linux系统编程中用于创建唯一键值的工具,这个键值通常用于进程间通信(IPC)的机制,如消息队列、信号量和共享内存。它的函数原型如下:

#include <sys/types.h>
#include <sys/ipc.h>
key_t ftok(const char *pathname, int proj_id);
  • 参数说明
    • pathname:这是一个已存在的文件路径名,ftok会从这个路径名导出信息。
    • proj_id:这是一个与路径名相关的项目ID,通常是0到255之间的整数。
  • 返回值:函数返回一个key_t类型的键值,这个键值是由pathname导出的信息与proj_id的低序8位组合而成的。

        在使用ftok时,需要注意以下几点:

  • 确保提供的pathname确实存在,因为ftok会根据这个路径名生成键值的一部分。
  • proj_id应该是一个相对较小的整数,因为它只会使用其低序8位。
  • 生成的键值应该是唯一的,以确保不同的进程间通信不会相互干扰。

        如下示例:

#include <iostream>
#include <cstdlib>
#include <string>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <cstring>const std::string pathname = "/home/land/109/pip/systemV";
const int proj_id = 0x11223344;key_t GetKey()
{key_t key = ftok(pathname.c_str(), proj_id);if (key < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;exit(1);}std::cout <<"key:"<< key << std::endl;return key;
}

通过shmget创建共享内存

        通过手册理解:

​        我们最经常使用的是IPC_CREAT、IP_EXCL。他们分别的含义是:

IPC_CREAT//shm不存在,就创建。存在,就获取并返回。
IP_EXCL//不能单独使用,shm不存在就创建,存在就出错返回。

        如下示例:

    key_t key = GetKey();int shmid = shmget(key, size, IPC_CREAT | IPC_EXCL);if (shmid < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;exit(1);}std::cout << "shmid:" << shmid << std::endl;return 0;

​        穿插认识一下查看和删除共享内存的命令:

ipcs -m//显示共享内存的属性
ipcrm -m shmid//删除指定的共享内存

一些小细节

        前面我们在shmget的shmflg的介绍中知道这实际上还包含权限的设置,实际上要设置权限只需要在选完IPC_CREAT或IP_EXCL等后 | 上对应权限即可,如下:

    key_t key = GetKey();int shmid = shmget(key, size, IPC_CREAT | IPC_EXCL | 0666);if (shmid < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;exit(1);}std::cout << "shmid:" << shmid << std::endl;return 0;

        当我们设置要申请的共享内存大小时,强烈建议申请4096的整数倍数大的大小,因为低层分配是按4096的整数倍数来分配大小的,比如:你申请4097大小,但是低层实际上是4096*2的大小。

通过shmat挂接进程

        通过shmaddr可以选择一个地址来附加共享内存,但是通常我们会填nullptr,shmflg填是0值得注意的是:它的返回值是一个void* 的挂接成功后的虚拟地址空间的起始地址,也就是之前原理所述start_addr。如下是对应的手册:

        如下示例:

int main()
{key_t key = GetKey();int shmid = shmget(key, size, IPC_CREAT | IPC_EXCL | 0666);if (shmid < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;exit(1);}sleep(5);std::cout << "shmid:" << shmid << std::endl;std::cout<<"开始将shm映射到进程的地址空间中"<<std::endl;char* s=(char*)shmat(shmid,nullptr,0);sleep(10);return 0;
}

通过shmdt取消与共享内存的关联

        根据上shmat的返回值,也就是虚拟地址空间的起始地址来实现取消与共享内存的关联。实际上,取消关联的本质就是修改页表,我们可以从起始地址连续释放对应的虚拟内存的大小,在页表中连续释放对应大小的映射关系。根据shmat的示例来取消关联:

int main()
{key_t key = GetKey();int shmid = shmget(key, size, IPC_CREAT | IPC_EXCL | 0666);if (shmid < 0){std::cerr << "errno: " << errno << ", errstring: " << strerror(errno) << std::endl;exit(1);}sleep(5);std::cout << "shmid:" << shmid << std::endl;std::cout<<"开始将shm映射到进程的地址空间中"<<std::endl;char* s=(char*)shmat(shmid,nullptr,0);sleep(10);shmdt((char*)s);sleep(5);return 0;
}

通过shmctl控制共享内存

IPC_RMID:删除共享内存

        如下示例:

// 定义共享内存结构体变量,当然也可直接传nullptr
struct shmid_ds shmbuffer;
// 获取共享内存状态
int ret = shmctl(shmid, IPC_STAT, &shmbuffer);
if (ret == -1) {perror("shmctl");exit(1);
}

IPC_STAT:获取共享内存的状态

        如下示例:

#include <sys/ipc.h>
#include <sys/shm.h>
#include <stdio.h>int main() {key_t key = GetKey();// 共享内存标识符int shmid = shmget(key, size, IPC_CREAT | IPC_EXCL | 0664);// 定义共享内存状态结构体变量struct shmid_ds shmbuffer;// 获取共享内存状态int ret = shmctl(shmid, IPC_STAT, &shmbuffer);if (ret == -1) {perror("shmctl");return 1;}// 打印共享内存状态信息printf("共享内存状态信息:\n");printf("当前连接数: %d\n", shmbuffer.shm_nattch);printf("最后一次操作进程ID: %d\n", shmbuffer.shm_lpid);printf("最后一次操作时间: %ld\n", shmbuffer.shm_change_time);printf("共享内存大小: %ld\n", shmbuffer.shm_segsz);return 0;
}

IPC_SET:改变共享内存的状态

        如下示例:

#include <sys/ipc.h>
#include <sys/shm.h>
#include <stdio.h>int main() {key_t key = GetKey();// 共享内存标识符int shmid = shmget(key, size, IPC_CREAT | IPC_EXCL | 0664);// 定义共享内存状态结构体变量struct shmid_ds shmbuffer;// 获取共享内存状态int ret = shmctl(shmid, IPC_STAT, &shmbuffer);if (ret == -1) {perror("shmctl");return 1;}// 修改共享内存状态shmbuffer.shm_perm.mode |= 0666; // 设置共享内存权限为可读写shmbuffer.shm_perm.uid = getuid(); // 设置共享内存所有者为用户IDshmbuffer.shm_perm.gid = getgid(); // 设置共享内存所属组为用户组ID// 更新共享内存状态ret = shmctl(shmid, IPC_SET, &shmbuffer);if (ret == -1) {perror("shmctl");return 1;}printf("共享内存状态已成功更新。\n");return 0;
}

共享内存的拓展

        值得注意的是:共享内存是没有同步机制的,但是可以通过其他方法实现同步。由于多个进程可能同时读写共享内存,因此需要一种同步机制来确保数据的一致性和防止竞态条件的发生。以下是一些常用的同步方法:

  • 互斥锁(Mutexes):互斥锁是一种用于保护共享资源不被多个线程同时访问的同步机制。在Linux中,可以使用pthread库中的互斥锁来实现进程间的同步。
  • 信号量(Semaphores):信号量是另一种用于同步不同进程或线程的机制。它可以控制对共享资源的访问数量。在Linux中,可以使用POSIX有名信号量或POSIX基于内存的信号量来实现同步。
  • 信号(Signals):虽然信号主要用于进程间的通知,但它们也可以用于同步。例如,一个进程可以发送信号给另一个进程,告知它共享内存已经更新,从而触发接收进程执行某些操作。

        需要注意的是:在使用这些同步机制时,应当小心避免死锁和活锁的情况。此外,设计良好的同步策略对于提高系统性能和可靠性至关重要。

        下面是一个通过命名管道控制共享内存同步的例子:通过命名管道控制client每秒向共享内存写入一个字母,每次写入成功后会发送一个信号给server,server在收到信号后才去读取共享内存中的内容,并且将读取到的内容打印出来,如下为完整的代码以及效果:

Makefile

.PHONY:all
all:server clientserver:server.ccg++ -o $@ $^ -std=c++11
client:client.ccg++ -o $@ $^ -std=c++11
.PHONY:clean
clean:rm -f server client fifo

server.cc

#include <iostream>
#include <cstring>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <unistd.h>
#include "comm.hpp"class Init
{
public:Init(){bool r = MakeFifo();if (!r)return;key_t key = GetKey();std::cout << "key : " << ToHex(key) << std::endl;shmid = CreateShm(key);std::cout << "shmid: " << shmid << std::endl;std::cout << "开始将shm映射到进程的地址空间中" << std::endl;s = (char *)shmat(shmid, nullptr, 0);fd = open(filename.c_str(), O_RDONLY);}~Init(){shmdt(s);std::cout << "开始将shm从进程的地址空间中移除" << std::endl;shmctl(shmid, IPC_RMID, nullptr);std::cout << "开始将shm从OS中删除" << std::endl;close(fd);unlink(filename.c_str());}public:int shmid;int fd;char *s;
};int main()
{Init init;//TODOwhile (true){// waitint code = 0;ssize_t n = read(init.fd, &code, sizeof(code));if (n > 0){// 直接读取std::cout << "共享内存的内容: " << init.s << std::endl;sleep(1);}else if (n == 0){break;}}sleep(10);return 0;
}

client.cc

#include <iostream>
#include <cstring>
#include <unistd.h>
#include <sys/ipc.h> //Inter-Process Communication
#include <sys/shm.h>
#include "comm.hpp"int main()
{key_t key = GetKey();int shmid = GetShm(key);char *s = (char*)shmat(shmid, nullptr, 0);std::cout << "attach shm done" << std::endl;int fd = open(filename.c_str(), O_WRONLY);// sleep(10);// TODO// 共享内存的通信方式,不会提供同步机制, 共享内存是直接裸露给所有的使用者的,一定要注意共享内存的使用安全问题// char c = 'a';for(; c <= 'z'; c++){s[c-'a'] = c;std::cout << "write : " << c << " done" << std::endl;sleep(1);// 通知对方int code = 1;write(fd, &code, sizeof(4));}shmdt(s);std::cout << "detach shm done" << std::endl;close(fd);return 0;
}

代码效果


                   感谢你耐心的看到这里ღ( ´・ᴗ・` )比心,如有哪里有错误请踢一脚作者o(╥﹏╥)o! 

                                       

                                                                        给个三连再走嘛~  

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

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

相关文章

智能小程序事件系统——SJS响应事件实现方案

背景信息 如有频繁用户交互&#xff0c;在小程序上表现是比较卡顿的。例如&#xff0c;页面有 2 个元素 A 和 B&#xff0c;用户在 A 上做 touchmove 手势&#xff0c;要求 B 也跟随移动&#xff0c;movable-view 就是一个典型的例子。一次 touchmove 事件的响应过程为&#x…

可以举一反三的动态规划问题(最短编辑问题)

给定两个字符串 A 和 B&#xff0c;现在要将 A经过若干操作变为 B&#xff0c;可进行的操作有&#xff1a; 删除–将字符串 A 中的某个字符删除。插入–在字符串 A 的某个位置插入某个字符。替换–将字符串 A 中的某个字符替换为另一个字符。 现在请你求出&#xff0c;将 A 变…

第9章 安全漏洞、威胁和对策(9.1-9.2)

9.1 共担责任(shared responsibility) 共担责任是安全设计的原则&#xff0c;表明任何机构都不是孤立运行的。 相反&#xff0c;它们与世界有着千丝万缕的联系。我们使用相同的基本技术&#xff0c;遵循相同的通信协议规范&#xff0c;在同一个互联网上漫游&#xff0c;共用操…

Shell脚本——免交互

目录 一、Here Document免交互 1、免交互概述 2、语法格式 2.1示例&#xff1a;免交互方式实现对行数的统计&#xff0c;将要统计的内容置于标记EOF之间&#xff0c;直接将内容传给wc-l来统计 3、变量设定 ①变量图换成实际值 ②整行内容作为变量并输出结果 ③使输出内…

基于深度学习的鸟类识别系统matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 4.1 卷积神经网络基础 4.2 GoogLeNet模型 4.3 鸟类识别系统 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 matlab2022a 3.部分核心程序 ............................…

STM32 IIC电量计LTC2944

1 描述 LTC2944 可在便携式产品应用中测量电池充电状态、电池电压、电池电流及其自身温度。宽输入电压范围允许使用高达 60V 的多节电池。精密库仑反向积分电流通过电池正极端子与负载或充电器之间的检测电阻器。 电压、电流和温度由内部 14 位无延迟 ΔΣ™ ADC 测量。测量结…

Linux:理解信号量以及内核中的三种通信方式

文章目录 共享内存的通信速度消息队列msggetmsgsndmsgrcvmsgctl 信号量semgetsemctl 内核看待ipc资源单独设计的模块ipc资源的维护 理解信号量总结 本篇主要是基于共享内存&#xff0c;延伸出对于消息队列和信号量&#xff0c;再从内核的角度去看这三个模块实现进程间通信 共享…

【教学类-44-04】20240130 print dashed(虚线字体)制作的数字描字帖

作品展示&#xff1a;背景需求&#xff1a; 制作绿色数字的数字描字帖 选用字体&#xff1a;print dashed&#xff08;虚线字体&#xff09; 【教学类-44-03】20240111阿拉伯数字字帖的字体&#xff08;三&#xff09;——德彪钢笔行书&#xff08;实线字体&#xff09;和pri…

如何使用Docker部署JSON Crack

文章目录 1. 在Linux上使用Docker安装JSONCrack2. 安装Cpolar内网穿透工具3. 配置JSON Crack界面公网地址4. 远程访问 JSONCrack 界面5. 固定 JSONCrack公网地址 JSON Crack 是一款免费的开源数据可视化应用程序&#xff0c;能够将 JSON、YAML、XML、CSV 等数据格式可视化为交互…

Kafka运维相关知识

目录 一、基本概念 二、技术特性 三、设计思想 四、运维建议 一、基本概念 Apache kafka 是一个分布式的基于push-subscribe的消息系统&#xff0c;它具备快速、可扩展、可持久化的特点。它的最大的特性就是可以实时的处理大量数据以满足各种需求场景&#xff1a;比如基于h…

Mysql基础篇笔记

数据表 链接&#xff1a;https://pan.baidu.com/s/1dPitBSxLznogqsbfwmih2Q 提取码&#xff1a;b0rp --来自百度网盘超级会员V5的分享 sql的执行顺序 根据顺序 也就是说 select后面的字段别名 只能在order by中使用 mysql不支持sql92的外连接 mysql不支持满外连接 可以…

java反射常用方法

反射思维导图 使用案例 package Reflection.Work.WorkTest01;import java.lang.reflect.Constructor; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.util.Arrays;public class WorkDe…

10-Nacos-灰度发布配置

用于生产上线后&#xff0c;针对指定主机IP做定向测试 1、在配置编辑中&#xff0c;勾选Beta发布&#xff0c;在文本框中勾选需要下发服务的IP地址&#xff0c;多个用英文逗号分隔。 正式版&#xff1a;这个是针对除了Beta版中指定的IP服务生效Beta版&#xff1a;灰度配置&am…

粤Z车牌申请需要什么条件?

深圳湾口岸: 上一年度纳税数额达到15万元以上的&#xff0c;可以申办1个商务车指标 上一年度的纳税数额达到50万元以上的&#xff0c;可以申办第2个商务车指标; 上一年度的纳税数额达到100万元以上的&#xff0c;可以申办第3个商务车指标; 从申办第4个商务车指标起&#xff0c;…

yolov8:pt 转 onnx

yolov8官方教程 1.安装包 我使用的是虚拟环境&#xff0c;yolov8包已经下载到本地了&#xff0c;因此直接在anaconda prompt 命令行继续安装 首先激活自己的虚拟环境&#xff0c;然后执行安装命令 pip install ultralytics yolov8中没有requirement.txt文件&#xff0c;直接…

RTC实时时钟之读取时间

1. RTC 基本介绍 RTC(Real Time Clock) 即实时时钟&#xff0c;它是一个可以为系统提供精确的时间基准的元器件&#xff0c;RTC一般采用精度较高的晶振作为时钟源&#xff0c;有些RTC为了在主电源掉电时还可以工作&#xff0c;需要外加电池供电 2. RTC 控制器 2.1 RTC的特点是:…

知识点积累系列(四)Kubernetes篇【持续更新】

云原生学习路线导航页&#xff08;持续更新中&#xff09; 本文是 知识点积累 系列文章的第四篇&#xff0c;记录日常学习中遇到的 Kubernetes 相关的知识点 1.Kubernetes琐碎知识点 1.1.为什么要有annotations annotation中除了能够记录一些额外信息&#xff0c;还可以解决k…

[BUUCTF]-PWN:cmcc_pwnme2解析

保护 ida 完整exp&#xff1a; from pwn import* context(log_leveldebug) #premote(node5.buuoj.cn,26964) pprocess(./pwnme2) addhome0x8048644 addflag0x8048682 getfile0x80485CB main0x80486F8 pop_ebp0x8048680 ret0x80483f2 pop_ebx0x8048409 pop_edi_ebp0x804867f st…

常见的网络安全威胁和防护方法

随着数字化转型和新兴技术在各行业广泛应用&#xff0c;网络安全威胁对现代企业的业务运营和生产活动也产生了日益深远的影响。常见的网络安全威胁通常有以下几种&#xff1a; 1. 钓鱼攻击 攻击者伪装成合法的实体&#xff08;如银行、电子邮件提供商、社交媒体平台等&#xf…

超越传统—Clean架构打造现代Android架构指南

超越传统—Clean架构打造现代Android架构指南 1. 引言 在过去几年里&#xff0c;Android应用开发经历了巨大的变革和发展。随着移动设备的普及和用户对应用的期望不断提高&#xff0c;开发人员面临着更多的挑战和需求。传统的Android架构在应对这些挑战和需求时显得有些力不从…