QT开发（三十五）——QT进程间通讯

QT开发（三十五）——QT进程间通讯

    Qt 是一个跨平台的应用框架，其进程间通讯机制固然可使用所在平台的进程间通讯机制，如在Windows平台上的Message机制、共享内存、文件映射、管道、Socket等。其中，Qt对一些许多平台共有的IPC机制进行了封装。

1、TCP/IP

    其实就是经过网络模块实现的IPC。不过Qt对其进行了封装，并提供了两个层次的API，包括应用程序级的QNetworkAccessManager, QFtp等和底层的QTcpSocket, QTcpServer, QSslSocket等。

2、QShared Memory（共享内存）

    Qt提供的基于共享内存的IPC有QSharedMemory类和QSystemSemaphore类，QSharedMemory能够访问共享内存区域，以及多线程和进程的共享内存区域，而QSystemSemaphore类用于访问系统共享资源，以实现独立进程间的通讯。

一、QSharedMemory

    QSharedMemory读写内存时，可使用lock()实现同步。若是同步完成，必须使用unlock()为共享内存区域解锁。

    QSharedMemory可使用attach()访问共享内存，经过指定参数来设置共享内存的访问模式。若是使用的是QSharedMemory::ReadOnly模式，则只能经过只读模式访问共享内存，若是使用QSharedMemory::ReadWrite模式则能够经过读写模式访问共享内存。

    QSharedMemory拥有进程并提供能够返回共享内存区域指针的成员函数。在共享内存区域，成员函数constData()能够经过void 类型返回进程正在使用的内存区域指针。建立共享时，QSharedMemory能够以字节为单位分配共享内存区域，还能够经过第二个参数设置函数 attach()提供的模式。

    QSharedMemory能够设置特定共享内存的固定键。函数setNativeKey()能够设置共享内存对象的键，setNativeKey()函数使用从属平台的共享内存的键进行相关设置。使用函数setKey()能够设置独立于平台的键。函数setKey()建立与平台本地键（Native Key）映射的键。

    初始化QSharedMemory时，必须指定一个惟一的标识Key，进程的Key必须保持一致。可使用setKey来设置。

二、QSystemSemaphore

    QSystemSemaphore能够提供普通系统的信号量。信号量使用互斥体，而互斥体只可使用1次锁定（Block）。所以，QSemaphore类不能对有效资源使用多线程，而QSystemSemaphore类能够再多进程或多线程中实现。

    QSystemSemaphore与QSemaphore类不一样，能够访问多进程。这表示QSystemSemaphore是一个重量级的类。因 此，使用单一线程或进程时，建议使用QSemaphore。得到资源前，成员函数acquire()始终阻塞。函数release()用于释放资源，且该 函数能够设置参数。该函数的参数>1时，释放资源。

三、QSharedMemory编程流程

共享内存中数据提供方：

A、定义QSharedMemory shareMemory,并设置标志名shareMemory.setKey();

B、将共享内存与主进程分离 shareMemory.detach()；

C、建立共享内存 shareMemory.create()；

D、将共享内存上锁shareMemory.lock()；

E、将进程中要共享的数据拷贝到共享内存中；

F、将共享内存解锁shareMemory.unlock()；

共享内存中数据使用方：

A、定义QSharedMemory shareMemory,并设置与共享内存提供方一致的标志名shareMemory.setKey（）。

B、将共享内存上锁shareMemory.lock()；

C、将共享内存与主进程绑定shareMemory.attach()，使主进程能够访问共享内存的数据；

D、从共享内存中取数据；

E、使用完后将共享内存解锁shareMemory.unlock()，并将共享内存与进程分离shareMemory.detach()；

四、QSharedMemory使用实例

共享内存数据提供方代码：

Widget.h文件：

#ifndef WIDGET_H
#define WIDGET_H
#include <QtGui/QWidget>
#include <QSharedMemory>
class Widget : public QWidget
{
    Q_OBJECT
    
public:
    Widget(QWidget *parent = 0);
    ~Widget();
private:
    QSharedMemory sharememory;
private slots:
    void WriteShareMemory();
};
#endif // WIDGET_H

Widget.cpp文件：

#include "Widget.h"
#include <QBuffer>
#include <QDebug>
#include <QDataStream>
Widget::Widget(QWidget *parent)
    : QWidget(parent)
{
    sharememory.setKey("share");
    this->WriteShareMemory();
}
Widget::~Widget()
{
    
}
void Widget::WriteShareMemory()
{
    if(sharememory.isAttached())
    {
        sharememory.detach();
    }
    QBuffer buffer;
    QDataStream out(&buffer);
    buffer.open(QBuffer::ReadWrite);
    buffer.write("hello QT!");
    int size = buffer.size();
    if(!sharememory.create(size))
    {
        qDebug() << sharememory.errorString();
        return ;
    }
    sharememory.lock();
    char *dest = reinterpret_cast<char *>(sharememory.data());
    const char *source = reinterpret_cast<const char *>(buffer.data().data());
    memcpy(dest, source, qMin(size, sharememory.size()));
    sharememory.unlock();
}

Main.cpp文件：

#include <QtGui/QApplication>
#include "Widget.h"
int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    Widget w;
    w.show();
    return a.exec();
}

共享内存数据使用方代码：

Widget.h文件：
#ifndef WIDGET_H
#define WIDGET_H
#include <QtGui/QWidget>
#include <QSharedMemory>
class Widget : public QWidget
{
    Q_OBJECT
    
public:
    Widget(QWidget *parent = 0);
    ~Widget();
private:
    QSharedMemory sharememory;
private slots:
    void ReadShareMemory();
};
#endif // WIDGET_H

Widget.cpp文件：

#include "Widget.h"
#include <QBuffer>
#include <QDebug>
#include <QDataStream>
Widget::Widget(QWidget *parent)
    : QWidget(parent)
{
    sharememory.setKey("share");
    this->ReadShareMemory();
}
Widget::~Widget()
{
    
}
void Widget::ReadShareMemory()
{
    if(!sharememory.attach())
    {
        qDebug() << "cann't attach sahrememory！";
    }
    QBuffer buffer;
    sharememory.lock();
    buffer.setData((char*)sharememory.constData(),sharememory.size());
    buffer.open(QBuffer::ReadWrite);
    buffer.readAll();
    sharememory.unlock();
    sharememory.detach();
    qDebug() << buffer.data().data();
}

Main.cpp文件：

#include <QtGui/QApplication>
#include "Widget.h"
int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    Widget w;
    w.show();
    
    return a.exec();
}

3、D-Bus

    D_BUS是一种低开销、低延迟的进程间通讯机制。Qt提供了QtDBus模块，QtDBus模块使用D-Bus协议，把信号与槽机制（Signal and Slot）扩展到进程级别，使得开发者能够在一个进程中发出信号，能够再其余进程定义槽来响应其余进程发出的信号。

    D-Bus是一种高级的进程间通讯机制，由freedesktop.org项目提供，使用GPL许可证发行。D-Bus最主要的用途是在Linux桌面环境为进程提供通讯，同时能将Linux桌面环境和Linux内核事件做为消息传递到进程。D-Bus的主要几率为总线，注册后的进程可经过总线接收或传递消息，进程也可注册后等待内核事件响应，例如等待网络状态的转变或者计算机发出关机指令。目前，D-Bus已被大多数Linux发行版所采用，开发者可以使用D-Bus实现各类复杂的进程间通讯任务。

    D-Bus是一个消息总线系统，其功能已涵盖进程间通讯的全部需求，并具有一些特殊的用途。D-Bus是三层架构的进程间通讯系统，其中包括：

    接口层：接口层由函数库libdbus提供，进程可经过libdbus库使用D-Bus的能力。

    总线层：总线层其实是由D-Bus总线守护进程提供的。在Linux系统启动时运行，负责进程间的消息路由和传递，其中包括Linux内核和Linux桌面环境的消息传递。

    包装层：包装层一系列基于特定应用程序框架的Wrapper库。

 

    在QT中的Dbus是使用的Dbus的包装层libdbus-qt.

    要查看Dbus总线上的服务和对象能够借助d-feet 和qdbusviewer

    要发送信号可使用dbus-send,要查看Dbus上的消息流可使用dbus-monitor

 

4、QCOP(Qt COmmunications Protocol )

    QCOP 是 Qt 内部的一种通讯协议，这种协议用于不一样的客户之间在同一地址空间内部或者不一样的进程之间的通讯。目前，这种机制还只在 Qt 的嵌入式版本中提供。

    为实现这种通讯机制，Qt 中包括了由 QObject 类继承而来的 QCopChannel 类，该类提供了诸如 send()、isRegistered() 等静态函数，它们能够在脱离对象的状况下使用。为了在 channel 中接收通讯数据，用户须要构造一个 QCopChannel 的子类并提供 receive() 函数的重载函数，或者利用 connect() 函数与接收到的信号相联系。值得一提的是，在 Qt 系统中，只提供了 QCOP 协议机制和用于接收消息的类，而如何发送消息则没有提供相应的类供用户使用。

    在基于 Qt 的桌面系统 Qtopia（QPE）中，则提供了相应的发送类：QCopEnvelope。用户能够经过该类利用 channel 向其余进程发送消息。该类将经过 QCopChannel 发送 QCop 消息的过程进行了封装，用户只须要调用该类中的相关函数就能够方便地实现进程之间的通讯。

5、QProcess

    跨平台类QProcess能够用于启动外部程序做为子进程，并与它们进行通讯。它提供了用于监测和控制该子进程状态的API。另外，QProcess为从QIODevice继承的子进程提供了输入/输出通道。

6、Session Management

    在Linux/X11平台上，Qt提供了会话管理的支持。会话容许事件传播到进程，例如，当检测到关机时。进程和应用程序能够执行任何须要的操做，例如：保存打开的文档。