当前位置： 首页 > article >正文

Qt/C++进程间通信：QSharedMemory 使用详解（附演示Demo）

article 2025/1/15 15:13:41

在开发跨进程应用程序时，进程间通信（IPC）是一个关键问题。Qt 框架提供了多种 IPC 技术，其中 QSharedMemory 是一种高效的共享内存方式，可以实现多个进程之间快速交换数据。本文将详细讲解 QSharedMemory 的概念、用法及其主要函数的用途，帮助开发者更好地理解和使用它。

1. 什么是 QSharedMemory？

QSharedMemory 是 Qt 中用于进程间共享内存的类。它允许多个进程共享一块内存区域，从而避免数据传输时的 IO 操作，提高通信速度。通过共享内存，多个进程可以直接读写这块内存，而无需经过文件或网络传递。

QSharedMemory 的核心特点

  1. 唯一键（Key）标识：

    • 每块共享内存通过唯一的键（字符串）标识。
    • 不同进程通过相同的键连接到共享内存。

  2. 线程安全性：

    • 提供锁机制（lock() 和 unlock()）以保护共享内存的读写。

  3. 跨平台支持：

    • Qt 的跨平台特性使 QSharedMemory 可以在不同操作系统上无缝使用。

2. QSharedMemory 的常用场景

  1. 实时数据共享：

    • 如传感器数据、实时日志等需要在多个进程间快速传递。

  2. 高性能需求：

    • 在频繁更新的大量数据（如图像处理、缓存共享）中，通过共享内存减少通信开销。

  3. 进程间消息传递：

    • 两个或多个应用程序之间的简单数据交换。

3. QSharedMemory 的工作流程

共享内存的基本使用可以分为以下几个步骤：

  1. 创建共享内存：

    • 第一个进程通过 create(size) 创建一块共享内存。
    • 分配的大小由数据的存储需求决定。

  2. 附加到共享内存：

    • 其他进程通过 attach() 方法连接到已有的共享内存。

  3. 数据读写：

    • 通过 lock() 和 unlock() 保证线程安全，获取内存指针后读写数据。

  4. 释放共享内存：

    • 调用 detach() 断开与共享内存的连接。

4. QSharedMemory 常用函数详解

以下是 QSharedMemory 类的常用函数及其作用：

函数名作用
构造函数创建 QSharedMemory 对象，指定唯一键标识共享内存。
create(size)创建指定大小的共享内存，如果共享内存已存在则返回失败。
attach()附加到已有的共享内存，连接成功后可以访问内存内容。
detach()断开与共享内存的连接，并释放资源（只有最后一个进程断开时共享内存才会被销毁）。
lock()锁定共享内存，防止其他进程或线程同时访问数据（用于数据同步）。
unlock()解锁共享内存，允许其他进程访问数据。
data() / constData()获取共享内存的指针，用于读写数据（data() 为可写指针，constData() 为只读指针）。
isAttached()检查当前进程是否已经连接到共享内存。
error() / errorString()获取最近一次操作的错误代码和描述，便于调试。

5. 使用示例：QSharedMemory 实现进程间通信

以下是一个完整的例子，展示如何通过 QSharedMemory 实现进程间的读写通信。

程序1：写入共享内存

程序1负责创建共享内存并向其中写入数据。

#include <QCoreApplication>
#include <QSharedMemory>
#include <QDebug>
#include <QTimer>
#include <QDateTime>

#define tc(a) QString::fromLocal8Bit(a)

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QSharedMemory sharedMemory("MySharedMemoryKey");

    // 创建共享内存，大小为 1024 字节
    if (!sharedMemory.create(1024)) {
        qDebug() << tc("无法创建共享内存:") << sharedMemory.errorString();
        return -1;
    }

    qDebug() << tc("共享内存已创建");

    // 定时写入动态数据
    QTimer timer;
    QObject::connect(&timer, &QTimer::timeout, [&]() {
        if (sharedMemory.lock()) {
            char *to = static_cast<char *>(sharedMemory.data());
            QString message = tc("程序1动态消息#") + QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss.zzz");
            QByteArray byteArray = message.toLocal8Bit();
            memcpy(to, byteArray.data(), byteArray.size() + 1); // 写入动态数据
            sharedMemory.unlock();
            qDebug() << tc("成功写入共享内存：") << message;
        } else {
            qDebug() << tc("无法锁定共享内存进行写入:") << sharedMemory.errorString();
        }
    });

    timer.start(1000); // 每秒更新一次

    return a.exec();
}

程序2：读取共享内存

程序2连接到共享内存，读取数据并解析时间戳。

#include <QCoreApplication>
#include <QSharedMemory>
#include <QDebug>
#include <QTimer>
#include <QDateTime>

#define tc(a) QString::fromLocal8Bit(a)

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QSharedMemory sharedMemory("MySharedMemoryKey");

    // 连接到已有的共享内存
    if (!sharedMemory.attach()) {
        qDebug() << tc("无法连接到共享内存:") << sharedMemory.errorString();
        return -1;
    }

    qDebug() << tc("成功连接到共享内存");

    // 定时读取数据
    QTimer timer;
    QObject::connect(&timer, &QTimer::timeout, [&]() {
        if (sharedMemory.lock()) {
            const char *from = static_cast<const char *>(sharedMemory.constData());
            QString data = QString::fromLocal8Bit(from);
            sharedMemory.unlock();

            // 解析时间戳
            QString timeStampString = data.split("#").at(1);
            QDateTime messageTime = QDateTime::fromString(timeStampString, "yyyy-MM-dd hh:mm:ss.zzz");

            // 当前时间
            QDateTime currentTime = QDateTime::currentDateTime();

            qDebug() << tc("从共享内存读取到的数据：") << data;

            // 如果时间戳解析成功，计算时间差
            if (messageTime.isValid()) {
                qint64 timeDifference = messageTime.msecsTo(currentTime); // 时间差（毫秒）
                qDebug() << tc("接收到的时间：") << messageTime.toString("yyyy-MM-dd hh:mm:ss.zzz");
                qDebug() << tc("当前时间：") << currentTime.toString("yyyy-MM-dd hh:mm:ss.zzz");
                qDebug() << tc("时间差（毫秒）：") << timeDifference;
            } else {
                qDebug() << tc("无法解析时间戳！");
            }
        } else {
            qDebug() << tc("无法锁定共享内存进行读取:") << sharedMemory.errorString();
        }
    });

    timer.start(1000); // 每秒读取一次

    return a.exec();
}

6. 注意事项

  1. 共享内存大小：

    • 创建共享内存时，指定的大小必须足够大以存储所有数据。

  2. 锁机制：

    • 在操作共享内存前，必须调用 lock() 进行锁定，以避免数据竞争。
    • 使用完成后，必须调用 unlock() 解锁。

  3. 错误处理：

    • 使用 error() 和 errorString() 检查共享内存的状态。

  4. 进程退出：

    • 调用 detach() 确保释放共享内存资源。

7. 总结

QSharedMemory 是一种高效的进程间通信方式，适用于需要快速传递数据的场景。通过本文的讲解，您应该能够掌握 QSharedMemory 的核心功能及其应用。无论是共享日志、实时数据，还是跨进程消息传递，QSharedMemory 都是一个值得考虑的解决方案。


http://www.kler.cn/a/503747.html

相关文章：

  • 【绝对无坑】Mongodb获取集合的字段以及数据类型信息
  • 【C语言】字符串函数详解
  • STM32入门教程-示例程序（按键控制LED光敏传感器控制蜂鸣器）
  • JAVA：利用 RabbitMQ 死信队列实现支付超时场景的技术指南
  • Linux下部署Redis（本地部署超详细）
  • 【STM32-学习笔记-6-】DMA
  • 刷题记录 回溯算法-10：93. 复原 IP 地址
  • 如何高效使用Adobe软件的组件功能
  • OpenCV实现彩色图像的直方图均衡化
  • riscv架构下linux4.15实现early打印
  • 《零基础Go语言算法实战》【题目 4-2】使用 Go 语言实现一个模拟栈数据结构操作的类 FrequencyStack
  • 智能制造智慧工业4.0大数据平台建设综合解决方案（PPT原件）
  • element-ui动态设置tabel的columns时,切换columns数据表格抖动
  • 30分钟内搭建一个全能轻量级springboot 3.4 + 脚手架 ＜1＞ 5分钟快速创建一个springboot web项目
  • MATLAB学习笔记-table
  • C++实现设计模式---代理模式 (Proxy)
  • 【Uniapp-Vue3】vite.config中安装插件unplugin-auto-import自动导入vue和uniapp
  • nginx的可视化配置工具nginxWebUI的使用
  • 2.0 机器学习任务攻略
  • JAVA之单例模式
  • 【2024年华为OD机试】 (B卷,100分)- 矩形相交的面积（Java JS PythonC/C++）
  • 【MacOS】恢复打开系统设置的安全性的允许以下来源的应用程序的“任何来源”
  • 掌控 JMeter 测试节奏：Once Only Controller 让关键操作 “一步到位”
  • FPGA EDA软件的位流验证
  • 【深度学习】神经网络灾难性遗忘（Catastrophic Forgetting，CF）问题
  • 深入理解ASP.NET Core 管道的工作原理