QtRO(Qt Remote Objects)分布式对象远程通信

2023-12-23 16:20
文章标签 qt 对象 通信 分布式 远程 remote objects qtro

本文主要是介绍QtRO(Qt Remote Objects)分布式对象远程通信，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、什么是QtRO

Qt Remote Objects（QRO）是Qt提供的一种用于实现远程对象通信的机制。
QtRO支持两种类型的通信：RPC（远程过程调用）和LPC（本地进程通信）。

RPC（远程过程调用）包括以下几种类型：
基于HTTP协议的RPC：例如Dubbo、Thrift等。
基于二进制协议的RPC：例如GRPC、Hetty等。
基于TCP协议的RPC：例如RMI、Remoting等。

LPC包括基于共享内存的通信和基于消息传递的通信。
总的来说，QtRO类似于平时的socket通信、串口通信、信号槽通信。它最大的特点是集合了这些通信的功能，使得远端通信能与本机通信一样使用信号槽的方式来收发信息

最大的优点可以说是免去了平时自己创建client端和server端时需要每次创建通信线程，解析协议，分拣数据。这里不同的数据可以直接用不同的信号槽来完成，远端通信就像是同个软件中对象之间的通信一样方便。

二、使用QtRO编写服务端

2.1首先需要编写rep文件，rep文件中包含了通信之间定义的接口。具体说明见官方文档。

以下是我的文件interface.rep

class Interface
{SIGNAL(sigMessage(QString msg))   //发送文本SIGNAL(sigPixmap(QByteArray pix)) //发送图片SIGNAL(sigFile(QByteArray data,QString fname)) //发送文件SLOT(void onMessage(QString msg)) SLOT(void onPixmap(QByteArray pix))SLOT(void onFile(QByteArray data,QString fname))
}

2.2在pro文件中添加remoteobjects模块，添加rep文件

QT += remoteobjects

REPC_SOURCE += \interface.rep

2.3构建一次工程，在输出目录会找到rep_interface_source.h文件，把它复制到工程目录。在工程中新建一个CommonInterface类：

commoninterface.h

#ifndef COMMONINTERFACE_H
#define COMMONINTERFACE_H#include "rep_interface_source.h"
class CommonInterface : public CommonInterfaceSource
{Q_OBJECT
public:explicit CommonInterface(QObject *parent = nullptr);virtual void onMessage(QString msg) override;virtual void onPixmap(QByteArray pix) override;virtual void onFile(QByteArray data,QString fname) override;void sendMsg(const QString &msg);void sendPixmap(QByteArray pix);void sendFile(QByteArray data,QString fname);signals:void sigReceiveMsg(const QString &msg);void sigReceivePix(QByteArray pix);void sigReceiveFile(QByteArray data,QString fname);
};#endif // COMMONINTERFACE_H

commoninterface.cpp

#include "commoninterface.h"CommonInterface::CommonInterface(QObject *parent) : CommonInterfaceSource(parent)
{}void CommonInterface::onMessage(QString msg)
{emit sigReceiveMsg(msg);
}void CommonInterface::onPixmap(QByteArray pix)
{emit sigReceivePix(pix);
}void CommonInterface::onFile(QByteArray data,QString fname)
{emit sigReceiveFile(data,fname);
}void CommonInterface::sendMsg(const QString &msg)
{emit sigMessage(msg);
}void CommonInterface::sendPixmap(QByteArray pix)
{emit sigPixmap(pix);
}void CommonInterface::sendFile(QByteArray data,QString fname)
{emit sigFile(data,fname);
}

2.4主界面

主界面创建了三个按钮，分别用于发送文字、图片、文件。一个LineEdit(发送文字)、一个TextEdit(接收文字)、一个Label(接收图片)。

widget.h

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include "commoninterface.h"
#include <QRemoteObjectHost>
#include <QPixmap>
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();
private slots:void on_pushButton_clicked();void onReceiveMsg(const QString &msg);void on_pushButton_2_clicked();void onReceivePix(QByteArray pix);void on_pushButton_3_clicked();void onReceiveFile(QByteArray data,QString fname);private:Ui::Widget *ui;CommonInterface *m_pInterface = nullptr;QRemoteObjectHost *m_pHost = nullptr;void init();
};
#endif // WIDGET_H

widget.cpp:

#include "widget.h"
#include "ui_widget.h"
#include <QFileDialog>
#include <QBuffer>
#include <QDebug>
Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);setWindowTitle("server");init();
}Widget::~Widget()
{delete ui;
}void Widget::on_pushButton_clicked()
{QString msg = ui->lineEdit->text();if(!msg.isEmpty()){m_pInterface->sendMsg(msg);}ui->textEdit->append(QString("Server:")+msg);ui->lineEdit->clear();
}void Widget::onReceiveMsg(const QString &msg)
{ui->textEdit->append(QString("Client:")+msg);
}void Widget::init()
{m_pHost = new QRemoteObjectHost(this);//m_pHost->setHostUrl(QUrl("tcp://192.168.137.100:8081"));m_pHost->setHostUrl(QUrl("local:interfaces"));m_pInterface = new CommonInterface(this);m_pHost->enableRemoting(m_pInterface);connect(m_pInterface,&CommonInterface::sigReceiveMsg,this,&Widget::onReceiveMsg);connect(m_pInterface,&CommonInterface::sigReceivePix,this,&Widget::onReceivePix);connect(m_pInterface,&CommonInterface::sigReceiveFile,this,&Widget::onReceiveFile);
}void Widget::on_pushButton_2_clicked()
{QString file = QFileDialog::getOpenFileName(this,"open","./","*.png *.jpg");if(file.isEmpty())return;QPixmap pix;pix.load(file,"png");if(pix.isNull())qDebug()<<"error";QByteArray ba;QBuffer bf(&ba);pix.save(&bf,"png");m_pInterface->sendPixmap(ba);
}void Widget::onReceivePix(QByteArray pix)
{ui->textEdit->append("收到图片");qDebug()<<pix.size();QPixmap p;p.loadFromData(pix);ui->label->setPixmap(p);
}void Widget::on_pushButton_3_clicked()
{QString file = QFileDialog::getOpenFileName(this,"open","./","*.*");if(file.isEmpty())return;QFile f(file);if(f.open(QIODevice::ReadOnly)){QByteArray ba = f.readAll();QFileInfo info(file);file = info.fileName();m_pInterface->sendFile(ba,file);f.close();}
}void Widget::onReceiveFile(QByteArray data,QString fname)
{ui->textEdit->append("收到文件："+fname);QFile file(fname);if(file.open(QIODevice::WriteOnly)){file.write(data);file.close();}
}

到此，服务端完成。

三、使用QtRO编写客户端

2.1rep文件是通用的，不用重复创建，这里直接添加到工程。

pro:

QT += remoteobjects

REPC_REPLICA += \interface.rep

注意！！！这里关键字变成了REPC_REPLICA和服务端的不一样！！所以到下一步以后生产的头文件名称也不一样！

2.2构建项目，在输出目录找到rep_interface_replica.h文件，放进工程。

2.3客户端中不需要再去创建CommonInterface类了，我们直接在主界面widget.h中编写。客户端和服务端的ui界面一样。

widget.h

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QRemoteObjectNode>
#include "rep_interface_replica.h"
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private slots:void on_pushButton_clicked();void onReceiveMsg(QString msg);void on_pushButton_2_clicked();void onReceivePix(QByteArray pix);void on_pushButton_3_clicked();void onReceiveFile(QByteArray ba,QString fname);private:Ui::Widget *ui;QRemoteObjectNode *m_pRemoteNode = nullptr;InterfaceReplica *m_pInterface = nullptr;void init();
};
#endif // WIDGET_H

widget.cpp

#include "widget.h"
#include "ui_widget.h"
#include <QBuffer>
#include <QFileDialog>
#include <QDebug>
Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);setWindowTitle("Client");init();
}Widget::~Widget()
{delete ui;
}void Widget::on_pushButton_clicked()
{QString msg = ui->lineEdit->text();if(!msg.isEmpty()){m_pInterface->onMessage(msg);}ui->textEdit->append("Client:"+msg);ui->lineEdit->clear();
}void Widget::onReceiveMsg(QString msg)
{ui->textEdit->append("Server:"+msg);
}void Widget::init()
{m_pRemoteNode = new QRemoteObjectNode(this);m_pRemoteNode->connectToNode(QUrl("local:interfaces"));m_pInterface = m_pRemoteNode->acquire<CommonInterfaceReplica>();connect(m_pInterface,&CommonInterfaceReplica::sigMessage,this,&Widget::onReceiveMsg);connect(m_pInterface,&CommonInterfaceReplica::sigPixmap,this,&Widget::onReceivePix);connect(m_pInterface,&CommonInterfaceReplica::sigFile,this,&Widget::onReceiveFile);
}void Widget::on_pushButton_2_clicked()
{QString file = QFileDialog::getOpenFileName(this,"open","./","*.png *.jpg");if(file.isEmpty())return;QPixmap pix;pix.load(file,"png");if(pix.isNull())qDebug()<<"error";QByteArray ba;QBuffer bf(&ba);pix.save(&bf,"png");m_pInterface->onPixmap(ba);
}void Widget::onReceivePix(QByteArray pix)
{ui->textEdit->append("收到图片");qDebug()<<pix.size();QPixmap p;p.loadFromData(pix);ui->label->setPixmap(p);
}void Widget::on_pushButton_3_clicked()
{QString file = QFileDialog::getOpenFileName(this,"open","./","*.*");if(file.isEmpty())return;QFile f(file);if(f.open(QIODevice::ReadOnly)){QByteArray ba = f.readAll();QFileInfo info(file);file = info.fileName();m_pInterface->onFile(ba,file);f.close();}
}void Widget::onReceiveFile(QByteArray data,QString fname)
{ui->textEdit->append("收到文件："+fname);QFile file(fname);if(file.open(QIODevice::WriteOnly)){file.write(data);file.close();}
}

到此，客户端和服务端都完成了，他们之间可以互相收发文字、图片、文件。

四、QtRO支持的参数类型

4.1 从2.1中我们可以知道，QtRO可以收发的数据类型由rep文件中定义的信号和槽决定的，那是不是可以定义任何数据类型，实现任何数据类型的收发呢？显然不是的，QRO允许发送的信号参数类型包括以下几种：

1.基本数据类型：如int、bool、char、float、double等。
2.Qt的核心类：如QString、QList、QMap等。
3.Qt的自定义类：只要这些类实现了序列化功能，就可以作为信号参数。

因此我的图片收发用的是QByteArray，而不是直接用QPixmap。

上述代码中连接方式是本机内通信，若要拓展为远端通信，可以把URL设置为如下格式：

m_pHost->setHostUrl(QUrl("tcp://192.168.137.100:8081"));

五、适合使用QtRO的场合

只有在服务端和客户端均用Qt开发的时候，适合使用QtRO方式。使用QtRO使得接口定义和实现更加方便。当已经有服务端程序，仅用Qt编写客户端时，就无法使用QtRO了。

这篇关于QtRO(Qt Remote Objects)分布式对象远程通信的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/528654。

相关文章

java如何分布式锁实现和选型

java如何分布式锁实现和选型

《java如何分布式锁实现和选型》文章介绍了分布式锁的重要性以及在分布式系统中常见的问题和需求,它详细阐述了如何使用分布式锁来确保数据的一致性和系统的高可用性,文章还提供了基于数据库、Redis和Zo... 目录引言：分布式锁的重要性与分布式系统中的常见问题和需求分布式锁的重要性分布式系统中常见的问题和需求
阅读更多...
基于Qt开发一个简单的OFD阅读器

基于Qt开发一个简单的OFD阅读器

《基于Qt开发一个简单的OFD阅读器》这篇文章主要为大家详细介绍了如何使用Qt框架开发一个功能强大且性能优异的OFD阅读器,文中的示例代码讲解详细,有需要的小伙伴可以参考一下... 目录摘要引言一、OFD文件格式解析二、文档结构解析三、页面渲染四、用户交互五、性能优化六、示例代码七、未来发展方向八、结论摘要
阅读更多...
Golang使用etcd构建分布式锁的示例分享

Golang使用etcd构建分布式锁的示例分享

《Golang使用etcd构建分布式锁的示例分享》在本教程中,我们将学习如何使用Go和etcd构建分布式锁系统,分布式锁系统对于管理对分布式系统中共享资源的并发访问至关重要,它有助于维护一致性,防止竞... 目录引言环境准备新建Go项目实现加锁和解锁功能测试分布式锁重构实现失败重试总结引言我们将使用Go作
阅读更多...
Redis分布式锁使用及说明

Redis分布式锁使用及说明

《Redis分布式锁使用及说明》本文总结了Redis和Zookeeper在高可用性和高一致性场景下的应用,并详细介绍了Redis的分布式锁实现方式,包括使用Lua脚本和续期机制,最后,提到了RedLo... 目录Redis分布式锁加锁方式怎么会解错锁？举个小案例吧解锁方式续期总结Redis分布式锁如果追求
阅读更多...
java中VO PO DTO POJO BO DO对象的应用场景及使用方式

java中VO PO DTO POJO BO DO对象的应用场景及使用方式

《java中VOPODTOPOJOBODO对象的应用场景及使用方式》文章介绍了Java开发中常用的几种对象类型及其应用场景,包括VO、PO、DTO、POJO、BO和DO等,并通过示例说明了它... 目录Java中VO PO DTO POJO BO DO对象的应用VO (View Object) - 视图对象
阅读更多...
python与QT联合的详细步骤记录

python与QT联合的详细步骤记录

《python与QT联合的详细步骤记录》：本文主要介绍python与QT联合的详细步骤,文章还展示了如何在Python中调用QT的.ui文件来实现GUI界面,并介绍了多窗口的应用,文中通过代码介绍... 目录一、文章简介二、安装pyqt5三、GUI页面设计四、python的使用python文件创建pytho
阅读更多...
Python实现局域网远程控制电脑

Python实现局域网远程控制电脑

《Python实现局域网远程控制电脑》这篇文章主要为大家详细介绍了如何利用Python编写一个工具,可以实现远程控制局域网电脑关机,重启,注销等功能,感兴趣的小伙伴可以参考一下... 目录1.简介2. 运行效果3. 1.0版本相关源码服务端server.py客户端client.py4. 2.0版本相关源码1
阅读更多...
vue如何监听对象或者数组某个属性的变化详解

vue如何监听对象或者数组某个属性的变化详解

《vue如何监听对象或者数组某个属性的变化详解》这篇文章主要给大家介绍了关于vue如何监听对象或者数组某个属性的变化,在Vue.js中可以通过watch监听属性变化并动态修改其他属性的值,watch通... 目录前言用watch监听深度监听使用计算属性watch和计算属性的区别在vue 3中使用watchE
阅读更多...
Java将时间戳转换为Date对象的方法小结

Java将时间戳转换为Date对象的方法小结

《Java将时间戳转换为Date对象的方法小结》在Java编程中,处理日期和时间是一个常见需求,特别是在处理网络通信或者数据库操作时,本文主要为大家整理了Java中将时间戳转换为Date对象的方法... 目录1. 理解时间戳2. Date 类的构造函数3. 转换示例4. 处理可能的异常5. 考虑时区问题6.
阅读更多...
QT实现TCP客户端自动连接

QT实现TCP客户端自动连接

《QT实现TCP客户端自动连接》这篇文章主要为大家详细介绍了QT中一个TCP客户端自动连接的测试模型,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录版本 1:没有取消按钮 测试效果测试代码版本 2:有取消按钮测试效果测试代码版本 1:没有取消按钮 测试效果缺陷：无法手动停
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2