Qt 官方提供了 **QtMqtt** 模块（`QMqttClient` 类），这是目前最推荐、最稳定的 MQTT 客户端实现

Qt MQTT 连接代码详解（Qt 5.9.9 ~ Qt 6.11 通用，适用于 Embedded-Integrated-Project）

Qt 官方提供了QtMqtt模块（QMqttClient类），这是目前最推荐、最稳定的 MQTT 客户端实现。项目Embedded-Integrated-Project的 Qt 上位机正是使用此模块实现与云服务器的 MQTT 通信（JSON 协议 + 设备 ChipID 主题）。

1. 项目配置（.pro 文件）

在你的Qt/Qt.pro（或主项目 .pro）中添加：

QT += core gui widgets network mqtt # 必须包含 mqtt 模块 # 推荐工业级优化 DEFINES += QT_NO_CAST_FROM_ASCII # 强制显式编码，配合 QByteArrayView CONFIG += c++17 # Qt 5.9.9 建议启用 # 如果是 Qt 6 项目（推荐升级） # QT += mqtt

注意：Qt 5.9.9 默认不包含 MQTT 模块，需要在 Qt 安装器中勾选 “Qt MQTT” 组件，或手动编译qtmqtt源码。

2. 完整封装类示例（推荐工业上位机写法）

创建一个MyMqttClient类，封装连接、重连、发布、订阅、协议解析等功能，适合直接复制到 Embedded-Integrated-Project 中使用。

头文件mymqttclient.h

#ifndefMYMQTTCLIENT_H#defineMYMQTTCLIENT_H#include<QMqttClient>#include<QMqttSubscription>#include<QJsonDocument>#include<QJsonObject>#include<QTimer>#include<QDebug>classMyMqttClient:publicQObject{Q_OBJECTpublic:explicitMyMqttClient(QObject*parent=nullptr);// 初始化参数（项目中常用）voidinit(constQString&host,quint16 port=1883,constQString&clientId=QString(),constQString&username=QString(),constQString&password=QString());voidconnectToBroker();// 连接voiddisconnectFromBroker();// 断开voidpublish(constQString&topic,constQJsonObject&json,intqos=0,boolretain=false);// 订阅示例（项目中设备 ChipID 主题）voidsubscribeDevice(constQString&chipId);signals:voidconnected();// 连接成功voiddisconnected();// 断开连接voidmessageReceived(constQString&topic,constQJsonObject&json);// JSON 消息privateslots:voidonConnected();voidonDisconnected();voidonMessageReceived(constQByteArray&message,constQMqttTopicName&topic);voidonStateChanged(QMqttClient::ClientState state);voidonErrorOccurred(QMqttClient::ClientError error);voidattemptReconnect();// 自动重连private:QMqttClient*m_client=nullptr;QTimer*m_reconnectTimer=nullptr;QString m_host;quint16 m_port=1883;QString m_clientId;QString m_username;QString m_password;intm_reconnectInterval=5000;// 重连间隔（ms）};#endif// MYMQTTCLIENT_H

源文件mymqttclient.cpp

#include"mymqttclient.h"MyMqttClient::MyMqttClient(QObject*parent):QObject(parent){m_client=newQMqttClient(this);m_reconnectTimer=newQTimer(this);m_reconnectTimer->setSingleShot(true);// 信号槽连接（Qt 5/6 通用写法）connect(m_client,&QMqttClient::connected,this,&MyMqttClient::onConnected);connect(m_client,&QMqttClient::disconnected,this,&MyMqttClient::onDisconnected);connect(m_client,&QMqttClient::messageReceived,this,&MyMqttClient::onMessageReceived);connect(m_client,&QMqttClient::stateChanged,this,&MyMqttClient::onStateChanged);connect(m_client,&QMqttClient::errorOccurred,this,&MyMqttClient::onErrorOccurred);connect(m_reconnectTimer,&QTimer::timeout,this,&MyMqttClient::attemptReconnect);}voidMyMqttClient::init(constQString&host,quint16 port,constQString&clientId,constQString&username,constQString&password){m_host=host;m_port=port;m_clientId=clientId.isEmpty()?"QtClient_"+QString::number(QDateTime::currentMSecsSinceEpoch()):clientId;m_username=username;m_password=password;m_client->setHostname(m_host);m_client->setPort(m_port);m_client->setClientId(m_clientId);if(!m_username.isEmpty())m_client->setUsername(m_username);if(!m_password.isEmpty())m_client->setPassword(m_password);// 工业级推荐配置m_client->setKeepAlive(60);// 60 秒心跳（1.5 倍规则）m_client->setAutoKeepAlive(true);// 自动管理 PINGm_client->setCleanSession(true);// 清除会话（掉线后不保留）}voidMyMqttClient::connectToBroker(){if(m_client->state()==QMqttClient::Connected)return;m_client->connectToHost();qDebug()<<"MQTT 正在连接："<<m_host<<":"<<m_port;}voidMyMqttClient::disconnectFromBroker(){m_reconnectTimer->stop();m_client->disconnectFromHost();}voidMyMqttClient::onConnected(){qDebug()<<"MQTT 连接成功！ClientId:"<<m_client->clientId();emitconnected();// 项目中订阅设备主题// subscribeDevice("your_device_chipid");}voidMyMqttClient::onDisconnected(){qWarning()<<"MQTT 断开连接！";emitdisconnected();m_reconnectTimer->start(m_reconnectInterval);// 自动重连}voidMyMqttClient::onMessageReceived(constQByteArray&message,constQMqttTopicName&topic){// ★ 使用 QByteArrayView 零拷贝解析（性能关键）QByteArrayViewview(message);QJsonParseError error;QJsonDocument doc=QJsonDocument::fromJson(view.toByteArray(),&error);// view.toByteArray() 安全转换if(error.error==QJsonParseError::NoError){QJsonObject json=doc.object();qDebug()<<"收到 MQTT 消息 [Topic:"<<topic.name()<<"]"<<json;emitmessageReceived(topic.name(),json);}else{qWarning()<<"JSON 解析失败："<<error.errorString();}}voidMyMqttClient::onStateChanged(QMqttClient::ClientState state){qDebug()<<"MQTT 状态变化："<<state;}voidMyMqttClient::onErrorOccurred(QMqttClient::ClientError error){qWarning()<<"MQTT 错误："<<error;}voidMyMqttClient::attemptReconnect(){if(m_client->state()!=QMqttClient::Connected){qDebug()<<"MQTT 自动重连...";connectToBroker();}}voidMyMqttClient::publish(constQString&topic,constQJsonObject&json,intqos,boolretain){QByteArray payload=QJsonDocument(json).toJson(QJsonDocument::Compact);m_client->publish(QMqttTopicName(topic),payload,qos,retain);qDebug()<<"发布 MQTT 消息 [Topic:"<<topic<<"]"<<json;}voidMyMqttClient::subscribeDevice(constQString&chipId){QString topic="device/"+chipId+"/#";// 项目中常用通配符autosubscription=m_client->subscribe(QMqttTopicName(topic),1);// QoS 1if(subscription){qDebug()<<"已订阅设备主题："<<topic;}}

3. 使用方式（MainWindow 或主类中）

MyMqttClient*mqtt=newMyMqttClient(this);mqtt->init("your_server_ip",1883,"","user","pass");// 项目中通常无用户名密码connect(mqtt,&MyMqttClient::messageReceived,this,[](constQString&topic,constQJsonObject&json){// 处理项目 JSON 协议（控制指令、状态上报等）});mqtt->connectToBroker();

发布示例（下发控制指令）：

QJsonObject cmd;cmd["cmd"]="open_fan";cmd["value"]=100;mqtt->publish("device/your_chipid/cmd",cmd,1);

4. 关键信号/参数详解（工业重点）

5. 工业级进阶建议（结合项目）

• 自动重连：已封装在onDisconnected()中。
• SSL 加密（云服务器安全）：改用m_client->connectToHostEncrypted(sslConfig)。
• 多设备支持：维护QMap<QString, QMqttSubscription*>管理多个 ChipID 订阅。
• 协议解析：项目使用 JSON，推荐全部走QByteArrayView+QJsonDocument（零拷贝）。
• 日志：结合QsLog或qDebug()记录所有 MQTT 事件。
• Qt 6 迁移：代码几乎无需改动（QMqttClient API 高度稳定）。

在 Embedded-Integrated-Project 中的直接应用：
把上面的MyMqttClient替换掉项目原有的 MQTT 代码（通常在mainwindow.cpp或专用通信类中），即可获得更健壮的连接、重连和 JSON 处理能力。

需要我提供：

• 完整带 UI 的 MainWindow 示例？
• SSL 加密连接版本？
• 与项目中 JSON 协议完全匹配的解析代码？
• Qt 6.11 最新 CMake 版本？

随时告诉我，我继续给出可直接复制的代码！