多线程创建4个子线程,子线程tcp收数据,接收到的数据类型为泛型数据T,将收到的数据通过Qvetor<T>发送给主线程,其中T是自定义类型。主线程收数据,收到的数据放入QMap<QString,QVctor<T>>中,根据不同的QString和T类型分类数据,比较同一个Map中数据的一致性,思考一下,请用qt写一段代码,代码包含.h和.cpp。

时间: 2024-02-13 22:05:16 浏览: 27
以下是我的实现,包括一个TCPClient类和一个主函数: TCPClient.h ```cpp #ifndef TCPCLIENT_H #define TCPCLIENT_H #include <QObject> #include <QTcpSocket> #include <QThread> #include <QVector> // 自定义类型 struct CustomData { int id; QString name; }; // TCP客户端类 class TCPClient : public QObject { Q_OBJECT public: explicit TCPClient(QObject *parent = nullptr); void start(const QString& host, quint16 port); signals: void dataReceived(const QString& key, const QVector<CustomData>& data); private slots: void readData(); private: QTcpSocket m_socket; }; #endif // TCPCLIENT_H ``` TCPClient.cpp ```cpp #include "TCPClient.h" TCPClient::TCPClient(QObject *parent) : QObject(parent) { connect(&m_socket, &QTcpSocket::readyRead, this, &TCPClient::readData); } // 启动客户端 void TCPClient::start(const QString& host, quint16 port) { m_socket.connectToHost(host, port); if (!m_socket.waitForConnected()) { qDebug() << "Error: " << m_socket.errorString(); return; } } // 读取数据 void TCPClient::readData() { // 读取key和数据 QByteArray rawKey, rawData; m_socket.read(2); quint16 keySize = *(reinterpret_cast<const quint16*>(rawKey.data())); rawKey.resize(keySize); m_socket.read(rawKey); m_socket.read(4); quint32 dataSize = *(reinterpret_cast<const quint32*>(rawData.data())); rawData.resize(dataSize); m_socket.read(rawData); // 解析数据 QString key = QString::fromUtf8(rawKey); QVector<CustomData> data; int pos = 0; while (pos < dataSize) { CustomData customData; memcpy(&customData, rawData.data() + pos, sizeof(CustomData)); pos += sizeof(CustomData); data.append(customData); } // 发送信号 emit dataReceived(key, data); } ``` main.cpp ```cpp #include <QCoreApplication> #include <QMap> #include <QVector> #include <QDebug> #include "TCPClient.h" int main(int argc, char *argv[]) { QCoreApplication a(argc, argv); // 创建TCP客户端 TCPClient client; client.start("localhost", 12345); // 数据统计 QMap<QString, QVector<CustomData>> dataMap; QObject::connect(&client, &TCPClient::dataReceived, [&dataMap](const QString& key, const QVector<CustomData>& data){ // 添加数据 if (!data.isEmpty()) { if (!dataMap.contains(key)) { dataMap.insert(key, QVector<CustomData>()); } dataMap[key].append(data); } // 比较数据 if (dataMap.contains("A") && dataMap.contains("B")) { QVector<CustomData>& dataA = dataMap["A"]; QVector<CustomData>& dataB = dataMap["B"]; for (const CustomData& data1 : dataA) { for (const CustomData& data2 : dataB) { if (data1.id == data2.id && data1.name == data2.name) { qDebug() << "Found matching data: " << data1.id << ", " << data1.name; } } } } }); return a.exec(); } ```

相关推荐

最新推荐

recommend-type

Python爬虫进阶之多线程爬取数据并保存到数据库

今天刚看完崔大佬的《python3网络爬虫开发实战》,顿时觉得...为了避免这种尴尬,以及我突然想写博客的心情,我决定还是为大家在进行一次简易爬虫展示,总体程序我会利用多线程的方式来充分利用CPU的空闲时间,其中我也
recommend-type

Java多线程--等待所有子线程执行完的五种方法.docx

Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程...
recommend-type

Java多线程--让主线程等待所有子线程执行完毕在执行

Java主线程等待所有子线程执行完毕在执行,其实在我们的工作中经常的用到,本篇文章就介绍了Java多线程--让主线程等待所有子线程执行完毕在执行,有需要的可以了解一下。
recommend-type

python进阶之多线程对同一个全局变量的处理方法

今天小编就为大家分享一篇python进阶之多线程对同一个全局变量的处理方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
recommend-type

C#子线程更新UI控件的方法实例总结

主要介绍了C#子线程更新UI控件的方法,在桌面应用程序中控制UI界面有着不错的实用价值,需要的朋友可以参考下
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构:Kafka与Hive集成

![实现实时数据湖架构:Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构,它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同,实时数据湖不依赖于预先定义的模式,而是采用灵活的架构,可以处理各种数据类型和格式。这种架构为企业提供了以下优势: - **实时洞察:**实时数据湖允许企业访问最新的数据,从而做出更明智的决策。 - **数据民主化:**实时数据湖使各种利益相关者都可
recommend-type

SPDK_NVMF_DISCOVERY_NQN是什么 有什么作用

SPDK_NVMF_DISCOVERY_NQN 是 SPDK (Storage Performance Development Kit) 中用于查询 NVMf (Non-Volatile Memory express over Fabrics) 存储设备名称的协议。NVMf 是一种基于网络的存储协议,可用于连接远程非易失性内存存储器。 SPDK_NVMF_DISCOVERY_NQN 的作用是让存储应用程序能够通过 SPDK 查询 NVMf 存储设备的名称,以便能够访问这些存储设备。通过查询 NVMf 存储设备名称,存储应用程序可以获取必要的信息,例如存储设备的IP地址、端口号、名称等,以便能
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。