C/C++使用Windows的API实现共享内存以及同步

news2024/9/26 3:31:40

目录

  • 共享内存
  • 事件-Event
  • 实现思路
    • 创建方(服务端)
    • 连接方：
    • 进程同步：
  • windows的API
    • CreateFileMapping
    • MapViewOfFile
    • CreateEvent
    • WaitForSingleObject
    • CreateThread
    • OpenFileMapping
  • 通过共享内存实现进程间的交互
    • 服务端
    • 客户端
    • 结论

共享内存

共享内存指 (shared memory)在多处理器的计算机系统中，可以被不同中央处理器（CPU）访问的大容量内存。由于多个CPU需要快速访问存储器，这样就要对存储器进行缓存（Cache）。任何一个缓存的数据被更新后，由于其他处理器也可能要存取，共享内存就需要立即更新，否则不同的处理器可能用到不同的数据。共享内存是 Unix下的多进程之间的通信方法 ,这种方法通常用于一个程序的多进程间通信，实际上多个程序间也可以通过共享内存来传递信息。

事件-Event

Win 中最具弹性的同步机制就属 events 对象了。 Event 对象是一种核心对象，它的唯一目的就是成为激发状态或未激发状态。这两种状态全由程序来控制，不会成为 WaitForSingleObject() 函数的副作用。
Event 对象之所以有大用途，正是因为它们的状态完全在你掌控之下。Mutexes和semaphores就不一样了，它们的状态会因为诸如WaitForSingleObject() 之类的函数调用而变化。所以， 你可以精确告诉一个event 对象做什么事，以及什么时候去做。

实现思路

创建方(服务端)

  1. 首先创建共享内存CreateFileMapping(映射文件句柄，安全属性，访问权限，对象大小，共享内存大小，映射文件名)；（注意：映射文件名双方必须一致）
  2. 再将共享内存地址映射到本进程中MapViewOfFile(共享内存地址，访问权限，文件映射起始偏移的高32位，文件映射起始偏移的低32位， 映射文件的字节数.)
  3. 然后创建事件CreateEventW用于俩个进程间的同步，

连接方：

  1. 首先创建共享内存CreateFileMapping(映射文件句柄，安全属性，访问权限，对象大小，共享内存大小，映射文件名)；（注意：映射文件名双方必须一致）
  2. 再将共享内存地址映射到本进程中MapViewOfFile(共享内存地址，访问权限，文件映射起始偏移的高32位，文件映射起始偏移的低32位， 映射文件的字节数.)
  3. 然后创建同样数量的事件CreateEventW(此时的事件名称要与另一方一致)。这样在创建事件时系统就会发现这个事件已经被另一方创建过，就直接将创建好的句柄返回来。才可实现进程同步

进程同步：

例如 现有俩个事件g_EventRead和g_EventWrite；
初始状态g_EventRead和g_EventWrite事件的信号灯都是灭的。先启动创建方，然后启动连接方时，在初始化时将创建方的EventWrite事件的信号灯点亮，这样创建方获得数据就可以直接写入共享内存中并将g_EventRead灯点亮将g_EventWrite灯弄灭。然后连接方收到数据就可以读取共享内存中的数据，再将g_EventRead灯弄灭将g_EventWrite灯点亮。这样就实现了进程间的通讯。

windows的API

CreateFileMapping

创建共享内存

HANDLE WINAPI CreateFileMapping(
_In_HANDLE hFile,
_In_opt_LPSECURITY_ATTRIBUTES lpAttributes,
_In_DWORD flProtect,
_In_DWORD dwMaximumSizeHigh,
_In_DWORD dwMaximumSizeLow,
_In_opt_LPCTSTR lpName);

参数：

  1. _In_HANDLE 映射文件的句柄 NVALID_HANDLE_VALUE则创建一个进程间共享的对象
  2. _In_opt_LPSECURITY_ATTRIBUTES 安全属性
  3. _In_DWORD 保护方式
  4. _In_DWORD 对象的大小, 32位.
  5. _In_DWORD 共享内存大小 字节
  6. _In_opt_LPCTSTR 映射文件名，即共享内存的名称

MapViewOfFile

将共享内存映射到本地进程

LPVOID WINAPI MapViewOfFile(
__in HANDLE hFileMappingObject,
__in DWORD dwDesiredAccess,
__in DWORD dwFileOffsetHigh,
__in DWORD dwFileOffsetLow,
__in SIZE_T dwNumberOfBytesToMap
);

参数：

  1. hFileMappingObject 为CreateFileMapping()或OpenFileMapping()返回的文件映像对象句柄。
  2. dwDesiredAccess 映射对象的文件数据的访问方式，而且同样要与CreateFileMapping()函数所设置的保护属性相匹配。 可取以下值：
    1. FILE_MAP_ALL_ACCESS 等价于CreateFileMapping的 FILE_MAP_WRITE|FILE_MAP_READ. 文件映射对象被创建时必须指定PAGE_READWRITE 选项.
    2. FILE_MAP_COPY 可以读取和写入文件.写入操作会导致系统为该页面创建一份副本.在调用CreateFileMapping时必须传入PAGE_WRITECOPY保护属性.
    3. FILE_MAP_EXECUTE 可以将文件中的数据作为代码来执行.在调用CreateFileMapping时可以传入PAGE_EXECUTE_READWRITE或PAGE_EXECUTE_READ保护属性.
    4. FILE_MAP_READ 可以读取文件.在调用CreateFileMapping时可以传入PAGE_READONLY或PAGE_READWRITE保护属性.
    5. FILE_MAP_WRITE 可以读取和写入文件.在调用CreateFileMapping时必须传入PAGE_READWRITE保护属性.
  3. dwFileOffsetHigh 表示文件映射起始偏移的高32位.
  4. dwFileOffsetLow 表示文件映射起始偏移的低32位.(64KB对齐不是必须的)
  5. dwNumberOfBytes 指定映射文件的字节数.

CreateEvent

创建事件

HANDLE CreateEvent(
LPSECURITY_ATTRIBUTESlpEventAttributes,// 安全属性
BOOLbManualReset,// 复位方式
BOOLbInitialState,// 初始状态
LPCTSTRlpName // 对象名称
);

参数：
1. 安全属性 默认为NULL
2. 复位方式 (true-手工恢复， false-自动恢复)
3. 初始状态 (true-有信号，false-无信号)
4. 事件名称
返回值：

  1. 事件的句柄

WaitForSingleObject

在指定时间内等待事件的信号状态

DWORD WaitForSingleObject(

HANDLE hHandle,
DWORD dwMilliseconds
);

参数：

  1. hHandle 对象句柄。可以指定一系列的对象，如Event、Job、Memory resource notification、Mutex、Process、Semaphore、Thread、Waitable timer等。
  2. dwMilliseconds 定时时间间隔，单位为milliseconds（毫秒）

CreateThread

创建一个线程

HANDLE CreateThread(
LPSECURITY_ATTRIBUTES lpThreadAttributes,//SD
SIZE_T dwStackSize,//initialstacksize
LPTHREAD_START_ROUTINE lpStartAddress,//threadfunction
LPVOID lpParameter,//threadargument
DWORD dwCreationFlags,//creationoption
LPDWORD lpThreadId//threadidentifier
)

参数：

  1. lpThreadAttributes 指向SECURITY_ATTRIBUTES型态的结构的指针。在Windows 98中忽略该参数。在Windows NT中，NULL使用默认安全性，不可以被子线程继承，否则需要定义一个结构体将它的bInheritHandle成员初始化为TRUE
  2. dwStackSize，设置初始栈的大小，以字节为单位，如果为0，那么默认将使用与调用该函数的线程相同的栈空间大小。任何情况下，Windows根据需要动态延长堆栈的大小。
  3. lpStartAddress，指向线程函数的指针，形式：@函数名，函数名称没有限制，
  4. lpParameter：向线程函数传递的参数，是一个指向结构的指针，不需传递参数时，为NULL。
  5. dwCreationFlags ：线程标志,可取值如下
    （1）CREATE_SUSPENDED(0x00000004)：创建一个挂起的线程，
    （2）0：表示创建后立即激活。
    （3）STACK_SIZE_PARAM_IS_A_RESERVATION(0x00010000)：dwStackSize参数指定初始的保留堆栈 的大小，否则,dwStackSize指定提交的大小。
  6. lpThreadId:保存新线程的id。

OpenFileMapping

打开一个现成的文件映射对象的函数

HANDLE WINAPI OpenFileMapping(
    _In_ DWORD dwDesiredAccess,
    _In_ BOOL bInheritHandle,
    _In_ LPCWSTR lpName
    )

参数：

  1. dwDesiredAccess 访问方式
  2. bInheritHandle 继承标志句柄继承选项表示内核对象被子进程继承
  3. lpName 指定要打开的文件映射对象名称。

通过共享内存实现进程间的交互

服务端

#include <windows.h>
#include <iostream> 
using namespace std;

#define BUF_SIZE 4096

HANDLE g_EventRead;		// 读信号灯
HANDLE g_EventWrite;	// 写信号灯
// 定义共享数据
char szBuffer[] = "LinXi07";
/* 读取con1串口的线程 */
DWORD __stdcall WriteThread(const LPVOID lp)
{
	while (true)
	{
		WaitForSingleObject(g_EventWrite, INFINITE); // 等待读数据的信号

		// 将数据拷贝到共享内存
		strcpy((char*)lp, szBuffer);
		cout << "服务发送成功!等待客户端接受：" << (char*)lp << endl;
		
		Sleep(1000);
		
		SetEvent(g_EventRead);
		ResetEvent(g_EventWrite);
	}
	return DWORD();
}

int main()
{

	// 创建共享文件句柄 
	HANDLE hMapFile = CreateFileMapping(
		INVALID_HANDLE_VALUE,   // 物理文件句柄  NVALID_HANDLE_VALUE  则创建一个进程间共享的对象
		NULL,   // 默认安全级别
		PAGE_READWRITE,   // 可读可写
		0,   // 高位文件大小
		BUF_SIZE,   // 低位文件大小
		L"ShareMemoryPDU"   // 映射文件名，即共享内存的名称
	);

	if (0 == hMapFile)
	{
		return 0;
	}

	// 映射缓存区视图 , 得到指向共享内存的指针
	// 将hFileMapping共享内存衍射到本进程的地址空间中
	LPVOID lpBase = MapViewOfFile(
		hMapFile,            // 共享内存的句柄
		FILE_MAP_ALL_ACCESS, // 可读写许可
		0,
		0,
		BUF_SIZE
	);

	if (0 == lpBase)
	{
		return 0;
	}

	g_EventRead = CreateEventW(NULL, TRUE, FALSE, TEXT("EventRead"));
	if (nullptr == g_EventRead)
	{
		return 0;
	}

	g_EventWrite = CreateEventW(NULL, TRUE, TRUE, TEXT("EventWrite"));
	if (nullptr == g_EventRead)
	{
		return 0;
	}

	HANDLE handle = CreateThread(NULL, 0, WriteThread, lpBase, 0, NULL);

	WaitForSingleObject(handle, INFINITE);
	
	// 解除文件映射
	UnmapViewOfFile(lpBase);
	
	// 关闭内存映射文件对象句柄
	CloseHandle(hMapFile);
	return 0;
}

客户端

#include <iostream>  
#include <windows.h>  
#include <string>
using namespace std;

#define BUF_SIZE 4096

HANDLE g_EventRead;		// 读信号灯
HANDLE g_EventWrite;	// 写信号灯


DWORD __stdcall ReadThread(const LPVOID lp)
{
	while (true)
	{
		WaitForSingleObject(g_EventRead, INFINITE); // 等待读数据的信号
	// 将数据拷贝到共享内存

	// 将共享内存数据拷贝出来
		char szBuffer[BUF_SIZE]{ 0 };
		
		strcpy_s(szBuffer, (char*)lp);
		
		std::cout << "客户数据读取成功！：" << szBuffer << endl;

		ResetEvent(g_EventRead); /* 将读取信号关闭  */
		SetEvent(g_EventWrite);
	}
}

int main()
{
	// 打开共享的文件对象
	HANDLE hMapFile = OpenFileMapping(FILE_MAP_ALL_ACCESS, NULL, L"ShareMemoryPDU");

	if (0 == hMapFile)
	{
		// 打开共享内存句柄失败
		std::cout << "打开共享失败！" << endl;
		return 0;
	}
	LPVOID lpBase = MapViewOfFile(hMapFile, FILE_MAP_ALL_ACCESS, 0, 0, 0);
	if (0 == lpBase)
	{
		return 0;
	}

	g_EventRead = CreateEventW(NULL, TRUE, FALSE, TEXT("EventRead"));
	if (nullptr == g_EventRead)
	{
		return 0;
	}

	g_EventWrite = CreateEventW(NULL, TRUE, TRUE, TEXT("EventWrite"));
	if (nullptr == g_EventRead)
	{
		return 0;
	}

	HANDLE handle = CreateThread(NULL, 0, ReadThread, lpBase, 0, NULL);
	if (0 == handle)
	{
		return 0;
	}
	
	WaitForSingleObject(handle, INFINITE);
	// 解除文件映射
	
	UnmapViewOfFile(lpBase);
	// 关闭内存映射文件对象句柄
	CloseHandle(hMapFile);


	return 0;
}

结论

单启动服务端，将只会发出一条，然后就一直处于等待状态
在这里插入图片描述

先启动服务端，再启动客户端。可以看到俩进程之间进行数据共享
在这里插入图片描述

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

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

相关文章

数据结构和算法之图的遍历

数据结构和算法之图的遍历

6.2 图的遍历 6.2.1 图的遍历——DFS 遍历&#xff1a;把图里面每个顶点都访问一遍而且不能有重复的访问 深度优先搜索(DFS) 当访问完了一个节点所有的灯后&#xff0c;一定原路返回对应着堆栈的出栈入栈的一个行为 深度优先搜索的算法描述 void DFS(Vertex V)//从迷宫…
阅读更多...
Redis面试篇

Redis面试篇

文章目录1 Redis与Memcache的区别&#xff1f;2 Redis的单线程问题3 Redis的持久化方案由哪些&#xff1f;4 Redis的集群方式有哪些&#xff1f;5 Redis的常用数据类型有哪些&#xff1f;6 聊一下Redis事务机制7 Redis的Key过期策略参考资料&#xff1a;为什么需要内存回收&…
阅读更多...
SpringBoot+ElasticSearch 实现模糊查询，批量CRUD，排序，分页，高亮！

SpringBoot+ElasticSearch 实现模糊查询，批量CRUD，排序，分页，高亮！

一、导入elasticsearch依赖 在pom.xml里加入如下依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency>非常重要&#xff1a;检查依赖版本是否…
阅读更多...
【图像隐写】DWT数字水印嵌入+攻击+提取【含Matlab源码 1759期】

【图像隐写】DWT数字水印嵌入+攻击+提取【含Matlab源码 1759期】

⛄一、DWT数字水印简介 1 引言 数字水印技术发展迅速&#xff0c;出现了各种水印算法&#xff0c;最低有效位(Least Significant Bit,LSB)数字水印技术是最早的空域水印添加算法&#xff0c;它原理简单且易实现&#xff0c;但鲁棒性差。变换域水印算法大大提高了水印的鲁棒性&…
阅读更多...
【微信小程序】博客小程序，静态版本（三）设计和开发首页、个人关于页

【微信小程序】博客小程序，静态版本（三）设计和开发首页、个人关于页

【博客小程序】专栏 【微信小程序】博客小程序&#xff0c;静态版本&#xff08;一&#xff09;准备工作 【微信小程序】博客小程序&#xff0c;静态版本&#xff08;二&#xff09;引入 lin-ui 组件、设计和开发文章页 【微信小程序】博客小程序&#xff0c;静态版本&#…
阅读更多...
模型推荐丨政务大数据项目案例模型分享

模型推荐丨政务大数据项目案例模型分享

主要工具&#xff1a;Python 技术大类&#xff1a;自然语言处理 主要业务问题&#xff1a; 在社会治理上&#xff0c;政府部门一般通过群众的意见反馈、舆论情绪&#xff0c;掌握社会现状&#xff0c;做好舆情工作&#xff0c;以促进社会长治久安。微博作为有着大量活跃用户…
阅读更多...
13 Igress,集群进出流量的总管

13 Igress,集群进出流量的总管

文章目录1. 前言2. 为什么要有 Ingress?2.1 Service 的缺点2.2 (Ingress)怎么解决Service 的缺点&#xff1f;3. 为什么要有 Ingress Controller 和 IngressClass?3.1 为什么要有 Ingress Controller&#xff1f;3.1.1 Ingress Controller3.1.1 Ingress Controller 常见公司3…
阅读更多...
深入学习Linux内核（二）体系结构简析

深入学习Linux内核（二）体系结构简析

Linux内核体系结构简析 图1 Linux系统层次结构 最上面是用户&#xff08;或应用程序&#xff09;空间。这是用户应用程序执行的地方。用户空间之下是内核空间&#xff0c;Linux 内核正是位于这里。GNU C Library &#xff08;glibc&#xff09;也在这里。它提供了连接内核的系…
阅读更多...
Jitter

Jitter

1、Jitter定义 定义1&#xff08;SONET规范&#xff09; 抖动可以定义为数字信号在重要时点上偏离理想时间位置的短期变化。 Long term jitter 测量由参考点滞后相当数量的Cycle&#xff08;500~1000&#xff09;后时钟的抖动值。该抖动参数也是时钟稳定性的一个重要指标&a…
阅读更多...
如何清除电脑缓存？让电脑运行速度提升的有效方法

如何清除电脑缓存？让电脑运行速度提升的有效方法

随着时间的流逝&#xff0c;电脑保存太多缓存文件&#xff0c;电脑的运行速度会越来越慢&#xff0c;甚至无法启动。当出现这种情况时&#xff0c;我们就需要对电脑进行清理。那么如何清除电脑缓存&#xff1f;今天就来给大家分享几个方法&#xff0c;让你的电脑运行速度快起来…
阅读更多...
Spark SQL 与 Hive 的小文件调优

Spark SQL 与 Hive 的小文件调优

文章目录小文件危害表的缓存shuffle 分区数调整Spark SQL 客户端设置合并Hive 客户端处理小文件合并小文件危害 小文件会造成 nn 处理压力变大&#xff0c;大大降低了读取性能&#xff0c;整个 HDFS 文件系统访问缓慢&#xff0c;大量的小文件还会导致 nn 内存溢出&#xff0c…
阅读更多...
DataX使用、同步MySQL数据到HDFS案例

DataX使用、同步MySQL数据到HDFS案例

文章目录4. DataX使用4.1 DataX使用概述4.1.1 DataX任务提交命令4.1.2 DataX配置文件格式4.2 同步MySQL数据到HDFS案例4.2.1 MySQLReader之TableMode4.2.1.1 编写配置文件4.2.1.1.1 创建配置文件base_province.json4.2.1.1.2 配置文件内容如下4.2.1.2 配置文件说明4.2.1.2.1 Re…
阅读更多...
jdk 11 自带的HttpClient

jdk 11 自带的HttpClient

jdk 11 自带的HttpClient 文章目录jdk 11 自带的HttpClient步骤1&#xff1a;创建jdk HttpClient 对象步骤2&#xff1a;创建请求步骤3&#xff1a;使用client.sent()发送同步请求步骤4&#xff1a;处理响应下面是发送post请求&#xff0c;请求类型是json&#xff0c;使用clien…
阅读更多...
汇智动力《软件测试课程V8.0版本》正式发布！

汇智动力《软件测试课程V8.0版本》正式发布！

今年是汇智动力建校的第八个年头&#xff0c;这一路走来&#xff0c;我们始终抓住时代的机遇与发展同辉、与时代俱兴&#xff0c;助力千万学子圆梦互联网。时代在飞速发展&#xff0c;社会在不断进步&#xff0c;为了使汇智学子适应科技变化的需要&#xff0c;汇智动力《软件测…
阅读更多...
限量版Spring实战笔记与其在收藏里吃灰，不如大家一起学习，欸 大家一起卷！

限量版Spring实战笔记与其在收藏里吃灰，不如大家一起学习，欸 大家一起卷！

写在前面 作为一个java程序员&#xff0c;spring应该都不会陌生了吧&#xff1f; 对于大部分程序员来说&#xff0c;spring的入门&#xff0c;估计跑起一个框架&#xff0c;熟悉一下开发的流程&#xff0c;基本上就掌握spring框架的开发了。 随着开发年限的变大&#xff0c;我…
阅读更多...
解决Netty那些事儿之Reactor在Netty中的实现(创建篇)-下

解决Netty那些事儿之Reactor在Netty中的实现(创建篇)-下

接上文解决Netty那些事儿之Reactor在Netty中的实现(创建篇)-上 Netty对JDK NIO 原生Selector的优化 首先在NioEventLoop中有一个Selector优化开关DISABLE_KEY_SET_OPTIMIZATION,通过系统变量-D io.netty.noKeySetOptimization指定&#xff0c;默认是开启的&#xff0c;表示需…
阅读更多...
[附源码]计算机毕业设计疫情防控平台Springboot程序

[附源码]计算机毕业设计疫情防控平台Springboot程序

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
【OpenCV-Python】教程：3-14 Hough 圆变换

【OpenCV-Python】教程：3-14 Hough 圆变换

OpenCV Python Hough 圆变换 【目标】 学习用 Hough 变换检测圆cv2.HoughCircles() 【理论】 圆的数学表达式是 (x−xcenter)2(y−ycenter)2r2(x-x_{center})^2 (y-y_{center})^2 r^2 (x−xcenter​)2(y−ycenter​)2r2 其中 (xcenter,ycenter)(x_{center}, y_{center})…
阅读更多...
[附源码]计算机毕业设计志愿者服务平台Springboot程序

[附源码]计算机毕业设计志愿者服务平台Springboot程序

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
matlab测量计算信号的相似度

matlab测量计算信号的相似度

本示例说明如何测量信号相似度。最近我们被客户要求撰写关于计算信号的相似度的研究报告&#xff0c;包括一些图形和统计输出。 将回答以下问题&#xff1a;如何比较具有不同长度或不同采样率的信号&#xff1f;如何确定测量中是否存在信号或仅有噪声&#xff1f;有两个信号…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023