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了。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/240395.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

智能优化算法应用:基于骑手优化算法3D无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用&#xff1a;基于骑手优化算法3D无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用&#xff1a;基于骑手优化算法3D无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.骑手优化算法4.实验参数设定5.算法结果6.…

跨平台应用程序开发软件,携RAD Studio 12新版上线

RAD Studio 是一款专为程序员而准备的跨平台应用程序开发软件&#xff0c;内置Delphi和CBuilder这两种开发工具&#xff0c;另外还提供了新的C功能&#xff0c;扩展了对ExtJS的RAD服务器支持&#xff0c;增强了对vcL的高dpi支持&#xff0c;提高了firemonk (FMX)的质量等等&…

C++结合OpenCV:掌握图像基础与处理

本文详细介绍了使用 OpenCV4 进行图像处理的基础知识和操作。内容包括图像的基础概念、色彩空间理解、以及如何在 C 中进行图像读取、显示和基础操作。 1.图像的基本概念与术语 图像表示 在计算机视觉中&#xff0c;图像通常表示为一个二维或三维的数组。二维数组表示灰度图像&…

vue3.0 通用管理页面封装

bmTable使用方法 <BmTable url"/project/list":columns"columns":formItem"formItem":formConfig"formConfig":isPagination"true"postData"postData"preData"preData"ref"bmTable">&…

[SQL]实验 视图和索引的应用

实验目的&#xff1a; [实验目的和要求] 1、掌握视图的创建、修改和重命名的方法 2、掌握视图中数据的操作 3、了解索引的作用 4、掌握索引的创建方法 实验步骤&#xff1a; 1、在销售管理数据库中&#xff0c;创建一个女职工视图&#xff0c;包括员工的编号、姓名、性别、雇佣…

JavaScript 数组去重 ES6 方法总结

JavaScript 数组去重 ES6 方法 方法一 new Set()生成出来的数据是Set数据结构&#xff0c;需要自行转换成对应结构 let array [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 2, 3, 3, 3, 9, 8, 9, s, o, o]; Array.from(new Set(array));方法二 let array [0, 1, 2, 3, 4, 5, 6, 7, 8,…

网站怎么才能做好SEO?网站SEO指引!!

在当今互联网的激烈竞争中&#xff0c;SEO&#xff08;搜索引擎优化&#xff09;已成为提升网站流量和吸引更多用户的关键手段。为了帮助您更好地掌握SEO网站优化技巧&#xff0c;本文将深入探讨以下几个方面&#xff1a; 一、关键词策略 关键词策略是SEO优化的基石。正确选择…

【WPF.NET开发】创建样式

本文内容 创建样式隐式应用样式显式应用样式以编程方式应用样式扩展样式TargetType 属性与 x:Key 属性之间的关系 使用 Windows Presentation Foundation (WPF)&#xff0c;可以使用自己的可重用样式自定义现有控件的外观。 可以对应用、窗口和页面全局应用样式&#xff0c;也…

linux同步文件到百度云盘

背景 由于个人项目预算有限&#xff0c;把mysql和应用程序都跑在同一台阿里云ECS机器上面&#xff0c;就在昨天(2023年12月21日) &#xff0c;服务器突然出现问题 进程全部挂掉了&#xff0c;服务器也无法重启&#xff0c;找工程师排查后发现是系统磁盘挂载出现了问题&#xf…

Ansible的脚本---Playbook剧本编写

playbook的组成部分 1、 tasks&#xff1a;任务 在目标主机上需要执行的操作。使用模块定义这些操作。每个任务都是一个模块的调用。 2、 variables&#xff1a;变量 用于存储和传递数据。类似于shell脚本中的变量。变量可以自定义。可以在playbook当中定义为全局变量&…

基于Vite+Vue3 给项目引入Axios

基于ViteVue3 给项目引入Axios,方便与后端进行通信。 系列文章指路&#x1f449; 系列文章-基于Vue3创建前端项目并引入、配置常用的库和工具类 文章目录 安装依赖新建src/config/config.js 用于存放常用配置进行简单封装解决跨域问题调用尝试 安装依赖 npm install axios …

VisualVM监控远程服务SpringBoot

1.启动参数 java -jar \ -Djava.rmi.server.hostname192.168.14.11 \ -Dcom.sun.management.jmxremote \ -Dcom.sun.management.jmxremote.port2622 \ -Dcom.sun.management.jmxremote.sslfalse \ -Dcom.sun.management.jmxremote.access.file/usr/jmxremote.access \ -Dcom.s…

PIL/Pillow

Abstract PIL(Python Imaging Library)是一个用于图像处理的 Python 库。它提供了广泛的功能&#xff0c;包括图像加载、保存、调整大小、裁剪、旋转、滤镜应用等。 由于 PIL 的开发停止在 2009 年&#xff0c;因此推荐使用其后续的维护版本 Pillow。Pillow 是一个兼容 PIL 接…

Springboot启动异常 OgnlException: sqlSelect [java.lang.NoSuchMethodError

完整的日志如下&#xff1a; Invocation of init method failed; nested exception is org.mybatis.spring.MyBatisSystemException: nested exception is org.apache.ibatis.builder.BuilderException: Error evaluating expression ew ! null and ew.sqlSelect ! null. Cause…

不忍学弟学妹受苦受难!!!逐一讲解发动机原理实验报告(1)

固体火箭发动机侵蚀燃烧测试实验 经过了愉快迷糊——哦不瑟瑟发抖——哦不痛不欲生的两天&#xff0c;终于和小伙伴们协力完成了西北工业大学航天学院发动机原理实验报告。具体的实验指导书均可在本人博客资源站下载。 固体火箭发动机侵蚀燃烧测试实验&#xff0c;嗯哼—— 实…

MySQL 事务的ACID特性

MySQL事务是什么&#xff0c;它就是一组数据库的操作&#xff0c;是访问数据库的程序单元&#xff0c;事务中可能包含一个或者多个 SQL 语句。这些SQL 语句要么都执行、要么都不执行。我们知道&#xff0c;在MySQL 中&#xff0c;有不同的存储引擎&#xff0c;有的存储引擎比如…

c++学习笔记-提高篇-STL标准模板库3(stack容器、queue容器以及list容器)

目录 Stack容器 一、Stack容器介绍 二、stack常用接口 三、栈的示例 queue&#xff08;队列&#xff09;容器 一、queue容器介绍 二、queue常用接口 三、queue示例 list容器 一、list容器介绍 二、list常用接口及示例 &#xff08;一&#xff09;list构造函数 &am…

使用Swift Package Manager (SPM)实现xcframework分发

Swift Package Manager (SPM) 是苹果官方提供的用于管理 Swift 项目的依赖关系和构建过程的工具。它是一个集成在 Swift 编程语言中的包管理器&#xff0c;用于解决在开发过程中管理和构建包依赖项的需求。 1、上传xcframework.zip到服务端 压缩xcframeworks成一个zip包&…

【flink】状态清理策略(TTL)

flink的keyed state是有有效期(TTL)的&#xff0c;使用和说明在官网描述的篇幅也比较多&#xff0c;对于三种清理策略没有进行横向对比得很清晰。 全量快照清理(FULL_STATE_SCAN_SNAPSHOT)增量清理(INCREMENTAL_CLEANUP)rocksdb压缩清理(ROCKSDB_COMPACTION_FILTER) 注意&…

MySQL数据管理————外键

方式一&#xff1a;在创建表的时候&#xff0c;增加约束&#xff08;麻烦&#xff0c;比较复杂&#xff09; CREATE TABLE grade( gradeid INT(10) NOT NULL AUTO_INCREMENT COMMENT 年级id, gradename VARCHAR(50) NOT NULL COMMENT 年级名称, PRIMARY KEY(gradeid) )ENGINEI…