前情回顾：

上一期已经讲解过了进程的相关概念以及进程间通信的实现原理，下面仅展示相关代码。

思路：

/* 本项目主要用于对同主机上以共享内存方式进行进程间通信的测试。
1.包含一个外部程序 publisherDemo.exe 以及 subscriberDemo.exe。
2.publisherDemo 主要功能是实现定时信息发布，并将信息发送到共享内存。
3.subscriberDemo 主要功能是实现访问指定共享内存，对publisherDemo.exe进程发布的信息进行捕获。
4.此外，本项目还利用信号量机制实现了进程间的同步发送与接收的功能。
*/

源码：

环境：Windows 64位 + QtCreator

Publisher.cpp

#include <QCoreApplication>
#include <Windows.h>
#include <iostream>
using namespace std;#define BUF_SIZE 4096HANDLE g_EventRead;		// 读信号灯
HANDLE g_EventWrite;	// 写信号灯
// 定义共享数据
char szBuffer[] = "Hello, shared memory!";
/* 读取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(int argc, char *argv[])
{QCoreApplication a(argc, argv);// 创建共享文件句柄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;return a.exec();
}

Subscriber.cpp

#include <QCoreApplication>
#include <iostream>
#include <Windows.h>
#include <string>
using namespace std;#define BUF_SIZE 4096HANDLE 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(int argc, char *argv[])
{QCoreApplication a(argc, argv);// 打开共享的文件对象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 a.exec();
}