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

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

引用

CSDN

1.

https://m.blog.csdn.net/chenai886/article/details/145145919

在开发跨进程应用程序时，进程间通信（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. 释放共享内存：

4. QSharedMemory 常用函数详解

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

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. 进程退出：

7. 总结

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