【Linux】进程间通信之共享内存
文章目录
- 引入
- 共享内存的原理
- 共享内存的相关接口
- shmget()
- shmat()
- shmdt()
- shmctl()
- 共享内存的简单使用
- 共享内存的特点
引入
进程间通信,顾名思义就是一个进程和另一个进程之间进行对话,以此完成数据传输、资源共享、通知事件或进程控制等。
众所周知,进程具有独立性,即使是父子进程也会彼此独立,互相看不到对方的任何信息。
而独立性是阻碍通信的,所以进程间通信要打破这种阻碍,打破进程独立性,也就是要让两个不想干的进程看到同一份资源。
在上一篇文章中我们分别介绍了匿名管道和命名管道两种通信方式,通过建立一个内存级文件,一个进程向该文件写内容,另一个进程从该文件中读内容,这样就完成了两个进程之间的通信。
既然可以建立一个内存级文件,能否省去文件,直接开辟一块内存,要通信的进程能同时使用这块内存呢?
这就是下面要介绍的共享内存(Shared Memory)。
共享内存的原理
在介绍共享内存之前先了解一下它的工作原理。
我们肯定了解C语言中有malloc
函数,可以开辟一块内存空间,这块空间能通过页表映射到进程地址空间的堆区。但是进程空间不止有堆区,还有什么栈区、初始化数据区、未初始化数据区等等…其中在堆区和栈区之间还有一个共享区。我们今天要讲的共享内存,就是要映射到共享区的。
我们同样可以使用类似于malloc
功能的接口来申请一块内存空间。然后将申请的这部分内存空间映射到进程地址空间的共享区,在另一个进程中我们也做相同的事情,这样两个进程就同时关联了同一块物理内存空间,一个进程向这段内存中写,另一个进程从这块内存读取,这样同样也能实现两个进程之间的通信。当两个进程之间不再需要通信时,我们先不急着释放这块内存,因为释放之后所有共享这块内存的进程都无法使用了,我们也不知道究竟有几个进程同时使用这块内存通信。所以首先取消内存和不再需要通信的进程之间的映射,也就是去关联。当这块内存真不需要的时候,再将其释放掉。
如此就是通过共享内存进行通信的简单原理:
共享内存的相关接口
有了原理层面的简单了解,就可以学习一下相关接口了。下面主要介绍四个接口s。
#include <sys/ipc.h>
#include <sys/shm.h>int shmget(key_t key, size_t size, int shmflg);
void *shmat(int shmid, const void *shmaddr, int shmflg);
int shmdt(const void *shmaddr);
int shmctl(int shmid, int cmd, struct shmid_ds *buf);
shmget()
int shmget(key_t key, size_t size, int shmflg);
功能:用来创建共享内存
参数:key: 可以唯一标识共享内存段的key值size: 共享内存块的大小,一般是4kb的整数倍shmflag: 共享内存块的权限,用二进制数中的位进行标识
返回值:成功返回一个非负整数,即该共享内存段的标识码;失败返回-1
对于
key
值,是需要我们设计传过去的,它的类型是key_t
,实际是int。key值要保证唯一性,以此保证共享内存可以唯一标识,我们可以通过ftok()
函数进行获取,所以再简单介绍一下ftok()
函数:#include <sys/types.h> #include <sys/ipc.h>key_t ftok(const char *pathname, int proj_id);
很简单,参数为一个字符串和一个整数,字符串一般传我们要创建的共享内存块的路径,
proj_id
可以设一个随机数,ftok
就会生成一个key
并返回,如果出错了则返回-1。
size
就不多介绍了,还是需要注意size
虽然可以随便填,但一般是4kb的整数倍。
shmfalg
为创建文件的一些权限选项,其选项常用的主要就两个:IPC_CREAT
和IPC_EXCL
。IPC_CREAT
的作用是如果key
对应的共享内存块不存在,则创建一块,然后返回该内存块的shmid
;如果已经存在相应的共享内存块了,则直接返回对应的id
。而IPC_EXCL
通常要配合IPC_CREAT
使用,当要获取的共享内存块不存在时不起作用,当其已经存在时则会获取失败,保证要获取的共享内存块是新鲜的。除此之外还要加上要创建的共享内存块的权限,就跟用open
创建文件时的参数mode
一样,比如0x0666
是所有人可读可写,0x0600
是只有自己可读可写。如果忘记加权限则创建出来的共享内存是无法使用的。
shmat()
全称是shm attach,功能就是将进程与共享内存挂接。
void *shmat(int shmid, const void *shmaddr, int shmflg);
功能:将共享内存段连接到进程地址空间
参数:shmid: 共享内存的id,可以唯一标识共享内存shmaddr: 指定链接到进程空间中的地址shmflg: 常用的标识有两个,SHM_RND和SHM_RDONLY
返回值:成功返回一个指针,指向共享内存的首地址,类似于malloc;失败返回-1
对于
shmid
,这个就是shmget
的返回值,和key
一样都能进行唯一性标识,区别就是key
是内核层的,shmid
是应用层的。进程要挂接共享内存时手里肯定得有id。
shmaddr
如果传参的话要传一个地址,意思是指定映射到进程地址空间的哪个位置。如果传nullptr
则会随机映射,一般都是传nullptr
。
shmflg
如果传了SHM_RDONLY
则进程只能从共享内存块中读取。SHM_RND
通常要配合shmaddr
使用,会使映射的位置不一定在shmaddr
处,会向下舍入到SHMLAB
的整数倍。用的也很少。如果shmflg
传个0过去,则表示可读可写。
shmdt()
全称是shm detach,功能就是取消进程与共享内存的挂接,也就是去关联。
int shmdt(const void *shmaddr);
功能:将共享内存段与当前进程脱离
参数:shmaddr: 由shmat所返回的指针,也就是共享内存的首地址,用法类似于free()
返回值:成功返回0;失败返回-1
该函数的功能仅仅是去关联,并不是删除共享内存段。
当进程不再需要通过该共享内存通信时应及时取消挂接。
shmctl()
全称是shm control,功能就是控制共享内存。
int shmctl(int shmid, int cmd, struct shmid_ds *buf);
功能:用于控制共享内存
参数:shmid: 由shmget返回的共享内存标识码cmd: 将要采取的动作,常用的有三个取值buf: 输出型参数,指向一个存储共享内存块部分属性结构体,如果需要时会将shmid对应的共享内存块的信息拷贝到该结构体中,为输出型参数
cmd
的取值主要有IPC_STAT
,IPC_SET
和IPC_RMID
。
IPC_STAT
的功能是将共享内存内核数据结构中的属性拷贝到buf
中,用来开获取共享内存的状态信息,如果要使用这个选项,共享内存必须要可读。
IPC_SET
和上面的选项功能相反,是要把buf
中的信息写入到内核数据结构中,使用时要谨慎。只有创建或者拥有该共享内存块或被赋予权限的人才能进行此操作。
IPC_RMID
就是删除共享内存了,但是只有当没有进程挂接共享内存时该共享内存块才会真正删除。只有创建或者拥有该共享内存块或被赋予权限的人才能进行此操作。一般就是谁创建的谁删除。
buf
是struct shmid_ds
结构体类型指针,指向这样一个结构,man手册中给出了该结构的部分信息:struct shmid_ds {struct ipc_perm shm_perm; /* Ownership and permissions */size_t shm_segsz; /* Size of segment (bytes) */time_t shm_atime; /* Last attach time */time_t shm_dtime; /* Last detach time */time_t shm_ctime; /* Last change time */pid_t shm_cpid; /* PID of creator */pid_t shm_lpid; /* PID of last shmat(2)/shmdt(2) */shmatt_t shm_nattch; /* No. of current attaches */... };
其中还包含一个
struct ipc_perm shm_perm
结构体成员,其信息如下:struct ipc_perm {key_t __key; /* Key supplied to shmget(2) */uid_t uid; /* Effective UID of owner */gid_t gid; /* Effective GID of owner */uid_t cuid; /* Effective UID of creator */gid_t cgid; /* Effective GID of creator */unsigned short mode; /* Permissions + SHM_DEST andSHM_LOCKED flags */unsigned short __seq; /* Sequence number */ };
共享内存的简单使用
下面举一个使用共享内存进行通信的简单例子。
为了便于使用,我们把一些公共信息比如key
和pathname
和共享内存的接口进行封装一下,放在一个头文件common.hpp
中:
// common.hpp#pragma once#include <iostream>
#include <cerrno> // 用于打印报错信息
#include <cstring> // 调用C的部分字符串相关的接口
#include <cstdlib>
#include <cstdio>
#include <sys/ipc.h> // 共享内存的相关接口
#include <sys/shm.h>
using namespace std;#define PATHNAME "." // 在当前目录下创建共享内存
#define PROJ_ID 0x66 // ftok()创建key时的参数,任意取值都行
#define MAX_SIZE 4096 // 共享内存的大小,建议4kb的整数倍// 通过ftok()获取key
key_t getKey()
{key_t k = ftok(PATHNAME, PROJ_ID);if (k < 0){cerr << errno << ":" << strerror(errno) << endl;exit(-1);}return k;
}// 辅助函数,结合后面两个函数看
int getShmHelper(key_t k, int flags)
{int shmid = shmget(k, MAX_SIZE, flags);if (shmid < 0){cerr << errno << ":" << strerror(errno) << endl;exit(-1);}return shmid;
}// 获取shm,如果不存在就创建
int getShm(key_t k)
{return getShmHelper(k, IPC_CREAT);
}// 创建新的shm
int createShm(key_t k)
{return getShmHelper(k, IPC_CREAT | IPC_EXCL | 0600);
}// 挂接shm
void* attachShm(int shmid)
{void* mem = shmat(shmid, nullptr, 0);if (mem == (void*)(-1)){cerr << errno << ":" << strerror(errno) << endl;exit(-1);}return mem;
}// 去关联
void detachShm(void* mem)
{if (shmdt(mem) == -1){cerr << errno << ":" << strerror(errno) << endl;exit(-1);}
}// 删除shm
void delShm(int shmid)
{if(shmctl(shmid, IPC_RMID, nullptr) == -1){std::cerr << errno << " : " << strerror(errno) << std::endl;exit(-1);}
}
在server.cpp
中创建共享内存,然后等待接受信息:
// server.cpp#include "common.hpp"
#include <unistd.h> // 在该文件中会调用getpid()函数int main()
{key_t k = getKey();printf("key: 0x%x\n", k); // keyint shmid = createShm(k);printf("shmid: %d\n", shmid); // shmid// 直接以char*类型使用共享内存段,也就是把共享内存段存储的数据看成字符串// 后续使用就跟使用用malloc开辟的空间一样char *start = (char *)attachShm(shmid);printf("attach success, address start: %p\n", start);struct shmid_ds ds; // 保存共享内存信息的结构体shmctl(shmid, IPC_STAT, &ds); // 获取共享内存的部分属性信息并打印一下printf("获取属性: size: %d, pid: %d, myself: %d, key: 0x%x\n",ds.shm_segsz, ds.shm_cpid, getpid(), ds.shm_perm.__key);// 使用while (true){printf("client say : %s\n", start);sleep(1);}// 去关联detachShm(start);sleep(10);delShm(shmid); // 删除共享内存return 0;
}
在client.cpp
中向共享内存写入信息:
// clent.cpp#include "common.hpp"
#include <unistd.h> // 在该文件中会调用getpid()函数int main()
{key_t k = getKey(); printf("key: 0x%x\n", k); // keyint shmid = getShm(k);printf("shmid: %d\n", shmid); // shmidchar *start = (char*)attachShm(shmid);printf("attach success, address start: %p\n", start);const char* message = "hello server, 我是另一个进程,正在和你通信";pid_t id = getpid();int cnt = 1;while(true){snprintf(start, MAX_SIZE, "%s[pid:%d][消息编号:%d]", message, id, cnt++);sleep(1);}detachShm(start);return 0;
}
在client.cpp中一秒发送一条信息,在server.cpp中一秒打印一条信息,此时运行情况如下:
共享内存的特点
在结束掉上面两个进程之后再次运行server
:
此时会报错说文件已经存在了,也就是我们结束掉进程之后共享内存并没有自动销毁。
所以共享内存的生命周期是不随进程的,如果我们一直不释放,只有在关掉系统时消失,所以共享内存的生命周期是随OS的。
当然linux也有一些查看共享内存相关的命令,我们可以用ipcs -m
命令查看共享内存:
发现此时确实有一个共享内存,查看它的key和shmid信息也确实是我们刚刚创建的。其中几个属性还有owner,为创建共享内存的用户。perms就是permissions,权限的意思,正好也是我们创建共享内存时输入的权限0666。bytes就是共享内存的大小。nattach就是和共享内存挂接的进程的数量。
此时我们就可以用ipcrm -m $shmid
指令手动释放掉共享内存:
上面创建完共享内存之后的使用方式就跟使用malloc
开辟的空间似的。因为在进程的视角来看那就是自己空间的一部分,直接使用,不像管道似的还要先把要发送的数据存起来开然后向管道中写入,多了向管道中写入和从管道中读出两次拷贝。所以共享内存是所有进程间通信的方式中最快的。
我们还发现了,在运行client之前server端已经向显示器打印信息了,即使共享内存中没有信息。在client端关掉之后,server端就一直打印client最后发送的信息。所以共享内存是不会像管道一样能进行同步和互斥,也不会对数据有任何的保护。同步和互斥是通过信号量来完成的。
相关文章:

【Linux】进程间通信之共享内存
文章目录 引入共享内存的原理共享内存的相关接口shmget()shmat()shmdt()shmctl() 共享内存的简单使用共享内存的特点 引入 进程间通信,顾名思义就是一个进程和另一个进程之间进行对话,以此完成数据传输、资源共享、通知事件或进程控制等。 众所周知&am…...

文章解读与仿真程序复现思路——电网技术EI\CSCD\北大核心《基于条件风险价值的虚拟电厂参与能量及备用市场的双层随机优化》
本专栏栏目提供文章与程序复现思路,具体已有的论文与论文源程序可翻阅本博主免费的专栏栏目《论文与完整程序》 论文与完整源程序_电网论文源程序的博客-CSDN博客https://blog.csdn.net/liang674027206/category_12531414.html 这篇文章的标题涉及到以下几个关键点…...
前端架构: 脚手架通用框架封装之CommonJS和ESM混合开发兼容解决(教程五)
CommonJS 和 ESModule 混合开发 接上文,仍旧在 abc-cli 项目中参考:https://blog.csdn.net/Tyro_java/article/details/136433159现在要在脚手架项目中安装 chalk 依赖,因为在 abc-cli 项目几乎都是 CommonJS的实现而 chalk 这个依赖源码是基…...

基于主从模式的Reactor的仿muduo网络库
🌇个人主页:平凡的小苏 📚学习格言:命运给你一个低的起点,是想看你精彩的翻盘,而不是让你自甘堕落,脚下的路虽然难走,但我还能走,比起向阳而生,我更想尝试逆风…...

Linux服务器搭建超简易跳板机连接阿里云服务器
简介 想要规范内部连接阿里云云服务器的方式,但是最近懒病犯了,先搞一个简易式的跳板机过渡一下,顺便在出一个教程,其他以后再说! 配置方法 创建密钥 登录阿里云,找到云服务器ECS控制台,点击…...

Windows Server 各版本搭建文件服务器实现共享文件(03~19)
一、Windows Server 2003 打开服务器,点击左下角开始➡管理工具➡管理您的服务器➡添加或删除角色 点击下一步等待测试 勾选自定义配置,点击下一步 选择文件服务器,点击下一步 勾选设置默认磁盘空间,数据自己更改,最…...

ARM总结and复习
安装交叉编译工具链 a. 为什么安装 因为arm公司的指令集在不断迭代升级,指令集日益增多,而架构是基于指令集研发的,所以架构不一样,指令集也不一样 eg:arm架构使用的是arm指令集 x86架构使用的是x86指令集 而我们日常开发环境中linux的架构…...
非功能测试的定义、类型和示例
软件已从推动者转变为不同行业企业成功的核心支柱。因此,非功能测试活动成为人们关注的焦点。然而,许多技术和质量保证专业人员并没有意识到非功能测试的必要性。 他们必须了解什么是非功能测试以及为什么必须鼓励将其作为企业应用程序开发项目的实践。…...

Angular基础---HelloWorld---Day1
文章目录 1. 创建Angular 项目2.对Angular架构的最基本了解3.创建并引用新的组件(component)4.对Angular架构新的认识(多组件)5.组件中业务逻辑文件的编辑(ts文件)6.标签中属性的绑定(1) ID的绑定(2) class…...
k8s部署项目常见的问题及解决方案
在Kubernetes(k8s)部署项目中,确实存在一些常见问题和挑战。以下是这些问题及其相应的解决方案: 网络插件问题: 问题:网络插件配置不当或版本不兼容可能导致Pod间通信问题。解决方案:重新部署或…...
Redis实现乐观锁+秒杀场景demo
在Redis中,乐观锁通常是通过使用 WATCH、MULTI 、EXEC和DISCARD命令实现的。这种乐观锁机制允许客户端在执行事务期间监视一个或多个键,并且只有在事务执行期间没有其他客户端修改被监视的键时,才会执行事务。 应用场景: 库存控…...

阅读笔记 | Transformers in Time Series: A Survey
阅读论文: Wen, Qingsong, et al. “Transformers in time series: A survey.” arXiv preprint arXiv:2202.07125 (2022). 这篇综述主要对基于Transformer的时序建模方法进行介绍。论文首先简单介绍了Transformer的基本原理,包括位置编码、多头注意力机…...
WPF MVVM中List<>和ObservableCollection<>的区别与对比分析
在WPF MVVM(模型-视图-视图模型)架构中,数据绑定是实现UI与后端逻辑分离的关键特性。为了使UI能够响应后端数据的变化,通常需要用到特定的集合类型。在WPF中,最常见的两种集合类型是List< T>和ObservableCollect…...
python给企微发消息
方法一:webhook方式。使用群机器人给企微群发消息 import requestsdef qwxsendmessage(msg):urlhttps://qyapi.weixin.qq.com/cgi-bin/webhook/send?key6c598840-804a-4eb5-a999-a023313 #url换成自己群机器人的webhookurldata{msgtype:text,text:{content:msg}}…...
TCP/IP状态迁移
TCP(传输控制协议)是一种面向连接的流式控制协议,它定义了不同的状态以管理通信过程中的连接。TCP 状态迁移描述了 TCP 连接在不同状态之间的转换过程,常见的 TCP 状态包括 CLOSED、LISTEN、SYN_SENT、SYN_RECEIVED、ESTABLISHED、…...
C语言实现各类排序算法
排序算法是计算机科学中的一个重要概念,它是一种将一个无序的数列重新排列成有序的方法。常见的排序算法有: 选择排序(Selection Sort) 选择排序是一种简单直观的排序演算法。它的工作原理:首先在未排序序列中找到最小(大)元素,存放到排序序…...

Network LSA 结构简述
Network LSA主要用于描述一个区域内的网络拓扑结构,包括网络中的路由器和连接到这些路由器的网络。它记录了每个路由器的邻居关系、连接状态以及连接的度量值(如带宽、延迟等),以便计算最短路径和构建路由表。display ospf lsdb n…...

揭示IP风险画像的作用与价值
在当今数字化时代,互联网的快速发展为企业和个人带来了巨大的机遇,同时也带来了各种安全风险和威胁。随着网络攻击手段的不断升级和演变,传统的安全防御手段已经无法满足对抗复杂多变的网络威胁的需求。IP风险画像作为一种新型的网络安全解决…...
[python] dataclass 快速创建数据类
在Python中,dataclass是一种用于快速创建数据类的装饰器和工具。自Python 3.7起,通过标准库中的dataclasses模块引入。它的主要目的是简化定义类来仅存储数据的代码量。通常,这样的类包含多个初始化属性,但没有复杂的方法…...

opencv实现图像的融合
实现图像的融合并且输出一张jpg格式的照片。 先显示一个彩色图的照片 然后我以彩色方式读取1.png,以灰度图方式读取3.png这张图片,并且用两个窗口独立地去显示(我后来发现不能把灰度图和彩色图相融合) 然后实现两个融合 #include <opencv2/highgu…...

MPNet:旋转机械轻量化故障诊断模型详解python代码复现
目录 一、问题背景与挑战 二、MPNet核心架构 2.1 多分支特征融合模块(MBFM) 2.2 残差注意力金字塔模块(RAPM) 2.2.1 空间金字塔注意力(SPA) 2.2.2 金字塔残差块(PRBlock) 2.3 分类器设计 三、关键技术突破 3.1 多尺度特征融合 3.2 轻量化设计策略 3.3 抗噪声…...
synchronized 学习
学习源: https://www.bilibili.com/video/BV1aJ411V763?spm_id_from333.788.videopod.episodes&vd_source32e1c41a9370911ab06d12fbc36c4ebc 1.应用场景 不超卖,也要考虑性能问题(场景) 2.常见面试问题: sync出…...

简易版抽奖活动的设计技术方案
1.前言 本技术方案旨在设计一套完整且可靠的抽奖活动逻辑,确保抽奖活动能够公平、公正、公开地进行,同时满足高并发访问、数据安全存储与高效处理等需求,为用户提供流畅的抽奖体验,助力业务顺利开展。本方案将涵盖抽奖活动的整体架构设计、核心流程逻辑、关键功能实现以及…...
ssc377d修改flash分区大小
1、flash的分区默认分配16M、 / # df -h Filesystem Size Used Available Use% Mounted on /dev/root 1.9M 1.9M 0 100% / /dev/mtdblock4 3.0M...

基于uniapp+WebSocket实现聊天对话、消息监听、消息推送、聊天室等功能,多端兼容
基于 UniApp + WebSocket实现多端兼容的实时通讯系统,涵盖WebSocket连接建立、消息收发机制、多端兼容性配置、消息实时监听等功能,适配微信小程序、H5、Android、iOS等终端 目录 技术选型分析WebSocket协议优势UniApp跨平台特性WebSocket 基础实现连接管理消息收发连接…...

【机器视觉】单目测距——运动结构恢复
ps:图是随便找的,为了凑个封面 前言 在前面对光流法进行进一步改进,希望将2D光流推广至3D场景流时,发现2D转3D过程中存在尺度歧义问题,需要补全摄像头拍摄图像中缺失的深度信息,否则解空间不收敛…...
Auto-Coder使用GPT-4o完成:在用TabPFN这个模型构建一个预测未来3天涨跌的分类任务
通过akshare库,获取股票数据,并生成TabPFN这个模型 可以识别、处理的格式,写一个完整的预处理示例,并构建一个预测未来 3 天股价涨跌的分类任务 用TabPFN这个模型构建一个预测未来 3 天股价涨跌的分类任务,进行预测并输…...

376. Wiggle Subsequence
376. Wiggle Subsequence 代码 class Solution { public:int wiggleMaxLength(vector<int>& nums) {int n nums.size();int res 1;int prediff 0;int curdiff 0;for(int i 0;i < n-1;i){curdiff nums[i1] - nums[i];if( (prediff > 0 && curdif…...

多种风格导航菜单 HTML 实现(附源码)
下面我将为您展示 6 种不同风格的导航菜单实现,每种都包含完整 HTML、CSS 和 JavaScript 代码。 1. 简约水平导航栏 <!DOCTYPE html> <html lang"zh-CN"> <head><meta charset"UTF-8"><meta name"viewport&qu…...

SpringTask-03.入门案例
一.入门案例 启动类: package com.sky;import lombok.extern.slf4j.Slf4j; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cache.annotation.EnableCach…...