天楚锐齿

人工智能 云计算 大数据 物联网 IT 通信 嵌入式

QT qml下DBus的使用例子

Linux中使用DBus作为进程间通信是比较有效的方式，这种RPC方式跟队列比，可以省去处理进程间同步的步骤，QT也已经支持基于DBus的进程间通信，这里举个例子。

首先定义一个接口文件CallHelloItf.h：

#ifndef CALLHELLOITF_H
#define CALLHELLOITF_H
#include <QDebug>
#include <QObject>
class CallHelloItf :public QObject
{
    Q_OBJECT
    Q_CLASSINFO(“D-Bus Interface”, “ckx.dbus.CallHello”) //这里CallHello就是生成时的Adaptor类的前缀
public:
    CallHelloItf(){}
    ~CallHelloItf(){}
Q_SIGNALS: //信号函数，这些信号连接到Server实际处理函数中去。
    void Sig_SayBey();
    void Sig_SayHello();
    void Sig_SayAbout(QString, QString &);
public Q_SLOTS: //槽函数，由客户端proxy调用
    void SayHello()
    {
        qDebug() << “Hello D-Bus”;
        emit Sig_SayHello();  //发送信号到本接口
    }
    void SayBey()
    {
        qDebug() << “Bey D-Bus”;
        emit Sig_SayBey();
    }
    QString SayAbout(QString str)
    {
        qDebug() << “SayAbout D-Bus: str:”<<str;
        QString rtnStr;
        emit Sig_SayAbout(str, rtnStr);
        return rtnStr;
    }
};
#endif // CALLHELLOITF_H

然后用命令行由上面文件生成服务端和客户端代码：

$ Qt/Tools/QtDesignStudio/qt5_design_studio_reduced_version/bin/qdbuscpp2xml CallHelloItf.h -A -o CallHelloItf.xml
$ Qt/Tools/QtDesignStudio/qt5_design_studio_reduced_version/bin/qdbusxml2cpp CallHelloItf.xml -a CallHelloAdaptor
$ Qt/Tools/QtDesignStudio/qt5_design_studio_reduced_version/bin/qdbusxml2cpp CallHelloItf.xml -p CallHelloProxy

服务端代码的文件名为CallHelloAdaptor.cpp、CallHelloAdaptor.h。

客户端代码的文件名为CallHelloProxy.cpp、CallHelloProxy.h。
中间过渡的文件名为CallHelloItf.xml。
具体的内容不贴出来了，有兴趣的可以自己生成后打开看看。

DBus服务端项目：

用QT quick方式生成一个新项目，然后把上面生成的服务器代码CallHelloAdaptor.cpp、CallHelloAdaptor.h以及CallHelloItf.h都加入到服务端的工程里面。
在工程的pro文件中加入一行：
#DBus所需要的库
QT += dbus
增加一个Server类，server.h文件：
#ifndef SERVER_H
#define SERVER_H
#include <QObject>
#include <QDebug>
class Server : public QObject
{
    Q_OBJECT
public:
    explicit Server(QObject *parent = nullptr);
public Q_SLOTS: //槽函数
    void SayHello();
    void SayBey();
    void SayAbout(QString str, QString &rtnStr);
};
#endif // SERVER_H

server.cpp文件：

#include “server.h”
Server::Server(QObject *parent)
    : QObject{parent}
{
}
void Server::SayHello()
{
    qDebug() << “Server::SayHello”;
}
void Server::SayBey()
{
    qDebug() << “Server::SayBey”;
}
void Server::SayAbout(QString str, QString &rtnStr)
{
    qDebug() << “Server::SayAbout: str:” << str;
    rtnStr = “Server::SayAbout from server: BBB”;
}
main.cpp文件中加入几行：
#include <QGuiApplication>
#include <QQmlApplicationEngine>
#include <QDBusConnection>
#include <QObject>
#include “DBus/CallHelloItf.h”
#include “DBus/CallHelloAdaptor.h”
#include “server.h”
int main(int argc, char *argv[])
{
#if QT_VERSION < QT_VERSION_CHECK(6, 0, 0)
    QCoreApplication::setAttribute(Qt::AA_EnableHighDpiScaling);
#endif
    QGuiApplication app(argc, argv);
    QQmlApplicationEngine engine;
    const QUrl url(QStringLiteral(“qrc:/main.qml”));
    QObject::connect(&engine, &QQmlApplicationEngine::objectCreated,
                     &app, [url](QObject *obj, const QUrl &objUrl) {
        if (!obj && url == objUrl)
            QCoreApplication::exit(-1);
    }, Qt::QueuedConnection);
    engine.load(url);
    //Dbus 演示代码
    CallHelloItf *m_pCallHelloItf = new CallHelloItf(); //要记得delete
    CallHelloAdaptor *m_pCallHelloAdpator = new CallHelloAdaptor(m_pCallHelloItf); //要记得delete
    QDBusConnection session = QDBusConnection::sessionBus();
    //使用Tools/QtDesignStudio/qt5_design_studio_reduced_version/bin/qdbusviewer可以查看到该Service名字”ckx.dbus.CallHello”。
    session.registerService(“ckx.dbus.CallHello”);
    session.registerObject(“/”, m_pCallHelloItf);
    Server *server = new Server();
    //从Proxy客户端收到接口信号，交由Server的槽函数处理：
    QObject::connect(m_pCallHelloItf, SIGNAL(Sig_SayBey()), server, SLOT(SayBey()));
    QObject::connect(m_pCallHelloItf, SIGNAL(Sig_SayHello()), server, SLOT(SayHello()));
    QObject::connect(m_pCallHelloItf, SIGNAL(Sig_SayAbout(QString, QString &)), server, SLOT(SayAbout(QString, QString &)));
    return app.exec();
}
运行即可。

用qdbusviewer可以查看注册到系统中的DBus服务：

注意：DBus目前在win上不支持，要到linux下执行以上server代码，并且确保linux上运行有dbus-daemon这个DBus服务进程。
$ sudo Qt/Tools/QtDesignStudio/qt5_design_studio_reduced_version/bin/qdbusviewer
从窗口左侧可以看到名字为“ckx.dbus.CallHello”的服务，点击后右侧可以看到该服务下的信号和方法。

客户端实现：

用QT quick方式生成一个新项目，然后把上面生成的客户端代码CallHelloProxy.cpp、CallHelloProxy.h都加入到服务端的工程里面。
在工程的pro文件中加入一行：
#DBus所需要的库
QT += dbus
加入Client类，client.h文件：
#ifndef CLIENT_H
#define CLIENT_H
#include <QObject>
#include “DBus/CallHelloProxy.h”
class Client : public QObject
{
    Q_OBJECT
public:
    explicit Client(QObject *parent = nullptr);
    ~Client();
public Q_SLOTS: //槽函数,由qml来调用
    void SayHello();
    void SayBey();
    void SayAbout();
public:
    ckx::dbus::CallHello *m_pCkxDbusCallHello;
};
#endif // CLIENT_H
client.cpp文件：
#include <QDebug>
#include “DBus/CallHelloProxy.h”
#include “client.h”
Client::~Client()
{
    delete m_pCkxDbusCallHello;
}
Client::Client(QObject *parent)
    : QObject{parent}
{
    m_pCkxDbusCallHello = new ckx::dbus::CallHello(“ckx.dbus.CallHello”, “/”,
           QDBusConnection::sessionBus(), this);
}
void Client::SayHello()
{
    qDebug() << “Client::SayHello”;
    m_pCkxDbusCallHello ->SayHello();
}
void Client::SayBey()
{
    qDebug() << “Client::SayBey”;
    m_pCkxDbusCallHello ->SayBey();
}
void Client::SayAbout()
{
    qDebug() << “Client::SayAbout”;
    QString strCont = “D-Bus from client: AAA”;
    QDBusPendingReply<QString> reply = m_pCkxDbusCallHello->SayAbout(strCont);
    reply.waitForFinished();
    qDebug() << reply.value();
}
在main.cpp中增加几行：
#include <QGuiApplication>
#include <QQmlApplicationEngine>
#include <QQmlContext>
#include “DBus/CallHelloProxy.h”
#include “client.h”
int main(int argc, char *argv[])
{
#if QT_VERSION < QT_VERSION_CHECK(6, 0, 0)
    QCoreApplication::setAttribute(Qt::AA_EnableHighDpiScaling);
#endif
    QGuiApplication app(argc, argv);
    QQmlApplicationEngine engine;
    Client *m_pClient = new Client(); //new出来的在堆中分配，就不会被qt提前自动释放，但是必须自己释放
    engine.rootContext()->setContextProperty(“CLIENT”, m_pClient);
    const QUrl url(QStringLiteral(“qrc:/main.qml”));
    QObject::connect(&engine, &QQmlApplicationEngine::objectCreated,
                     &app, [url](QObject *obj, const QUrl &objUrl) {
        if (!obj && url == objUrl)
            QCoreApplication::exit(-1);
    }, Qt::QueuedConnection);
    engine.load(url);
    return app.exec();
}
在main.qml中增加几个按钮：

import QtQuick 2.15
import QtQuick.Window 2.15
import QtQuick.Controls 2.15

Window {
width: 640
height: 480
visible: true
title: qsTr(“Hello World”)

Row{
Button{
id: btnSayBey
text: “SayBey”
}
Button{
id: btnSayHello
text: “SayHello”
}
Button{
id: btnSayAbout
text: “SayAbout”
}
}

//组件加载完成执行
Component.onCompleted: {
//关联信号与信号处理函数的方式同QML中的类型
//Qml对象的信号关联到Cpp的槽函数
    console.log(‘main: btnSayBey.onClicked.connect(CLIENT.SayBey)’);
    btnSayBey.onClicked.connect(CLIENT.SayBey);
    console.log(‘main: btnSayHello.onClicked.connect(CLIENT.SayHello)’);
    btnSayHello.onClicked.connect(CLIENT.SayHello);
    console.log(‘main: btnSayAbout.onClicked.connect(CLIENT.SayAbout)’);
    btnSayAbout.onClicked.connect(CLIENT.SayAbout);
}
}

运行（保持服务端也在运行），各个点击三个按钮，可以从服务端和客户端console的log中看到访问过程。
1,480次阅读

发表回复