首页 资讯中心 文章详情

C++/Qt + Mqtt协议 实现客户端订阅/发布功能

发布时间：2026/7/28 1:28:15
C++/Qt + Mqtt协议 实现客户端订阅/发布功能 目录一、UI 构建setupUI二、信号槽绑定setupConnections三、连接/断开 BrokeronConnectClicked四、 订阅主题onSubscribeClicked五、取消订阅onUnsubscribeClicked六、发布普通消息onPublishClicked七、发布保留消息onPublishRetainClicked八、连接状态变化处理onStateChanged九、连接成功处理onConnected十、断开连接处理onDisconnected十一、 接收消息处理onMessageReceived十二、消息发送确认onMessageSent十三、错误处理onErrorChanged一、UI 构建setupUIvoid MainWindow::setupUI() { // --- 中央部件和主布局 --- QWidget *central new QWidget(this); setCentralWidget(central); QVBoxLayout *mainLayout new QVBoxLayout(central); // 1. 连接配置区域 m_groupConnect new QGroupBox(tr(连接配置), this); QFormLayout *formLayout new QFormLayout(m_groupConnect); // Broker 地址默认 localhost m_editHost new QLineEdit(127.0.0.1, this); formLayout-addRow(tr(Broker 地址:), m_editHost); // 端口号MQTT 默认 1883 m_spinPort new QSpinBox(this); m_spinPort-setRange(1, 65535); m_spinPort-setValue(1883); formLayout-addRow(tr(端口:), m_spinPort); // 客户端 IDMQTT 协议要求每个客户端有唯一 ID // QUuid 生成一个全局唯一标识符避免多客户端冲突 m_editClientId new QLineEdit(QUuid::createUuid().toString(QUuid::WithoutBraces), this); formLayout-addRow(tr(客户端 ID:), m_editClientId); // 用户名和密码可选用于 Broker 认证 m_editUsername new QLineEdit(this); m_editUsername-setPlaceholderText(可选); formLayout-addRow(tr(用户名:), m_editUsername); m_editPassword new QLineEdit(this); m_editPassword-setPlaceholderText(可选); m_editPassword-setEchoMode(QLineEdit::Password); formLayout-addRow(tr(密码:), m_editPassword); // QoS 等级选择 // QoS 0: 最多一次发完不管可能丢 // QoS 1: 至少一次保证收到可能重复 // QoS 2: 恰好一次保证收到且不重复开销最大 m_comboQos new QComboBox(this); m_comboQos-addItem(QoS 0 - 最多一次, 0); m_comboQos-addItem(QoS 1 - 至少一次, 1); m_comboQos-addItem(QoS 2 - 恰好一次, 2); formLayout-addRow(tr(QoS 等级:), m_comboQos); // 连接/断开按钮 状态标签 QHBoxLayout *connBtnLayout new QHBoxLayout(); m_btnConnect new QPushButton(tr(连接), this); m_btnConnect-setMinimumWidth(100); connBtnLayout-addWidget(m_btnConnect); m_labelStatus new QLabel(tr(状态: 未连接), this); m_labelStatus-setStyleSheet(color: red; font-weight: bold;); connBtnLayout-addWidget(m_labelStatus); connBtnLayout-addStretch(); formLayout-addRow(connBtnLayout); mainLayout-addWidget(m_groupConnect); // 2. 订阅区域 m_groupSubscribe new QGroupBox(tr(订阅主题), this); QHBoxLayout *subLayout new QHBoxLayout(m_groupSubscribe); m_editSubTopic new QLineEdit(test/topic, this); m_editSubTopic-setPlaceholderText(输入主题名如 sensor/temp); subLayout-addWidget(m_editSubTopic); m_btnSubscribe new QPushButton(tr(订阅), this); subLayout-addWidget(m_btnSubscribe); m_btnUnsubscribe new QPushButton(tr(取消订阅), this); subLayout-addWidget(m_btnUnsubscribe); mainLayout-addWidget(m_groupSubscribe); // 3. 发布区域 m_groupPublish new QGroupBox(tr(发布消息), this); QHBoxLayout *pubLayout new QHBoxLayout(m_groupPublish); m_editPubTopic new QLineEdit(test/topic, this); m_editPubTopic-setPlaceholderText(发布主题); pubLayout-addWidget(m_editPubTopic, 2); m_editMessage new QLineEdit(Hello MQTT, this); m_editMessage-setPlaceholderText(消息内容); pubLayout-addWidget(m_editMessage, 3); m_btnPublish new QPushButton(tr(发布), this); pubLayout-addWidget(m_btnPublish); m_btnPubRetain new QPushButton(tr(发布(保留)), this); m_btnPubRetain-setToolTip(保留消息Broker 会保存最后一条新订阅者立即收到); pubLayout-addWidget(m_btnPubRetain); mainLayout-addWidget(m_groupPublish); // 4. 消息日志区域 QGroupBox *logGroup new QGroupBox(tr(消息日志), this); QVBoxLayout *logLayout new QVBoxLayout(logGroup); m_logText new QTextEdit(this); m_logText-setReadOnly(true); // 只读不允许用户编辑 logLayout-addWidget(m_logText); mainLayout-addWidget(logGroup, 1); // 日志区域占剩余空间 // 窗口基本设置 setWindowTitle(tr(MQTT 学习 Demo - QtMqtt)); resize(700, 650); }二、信号槽绑定setupConnectionsvoid MainWindow::setupConnections() { // --- 按钮点击信号 --- connect(m_btnConnect, QPushButton::clicked, this, MainWindow::onConnectClicked); connect(m_btnSubscribe, QPushButton::clicked, this, MainWindow::onSubscribeClicked); //订阅 connect(m_btnUnsubscribe, QPushButton::clicked, this, MainWindow::onUnsubscribeClicked); //取消订阅 connect(m_btnPublish, QPushButton::clicked, this, MainWindow::onPublishClicked); //发布普通消息 connect(m_btnPubRetain, QPushButton::clicked, this, MainWindow::onPublishRetainClicked); // 发布保留消息 // --- QMqttClient 核心信号重点学习这些 --- // 1. stateChanged: 连接状态变化时触发 // ClientState 枚举值: Disconnected0, Connecting1, Connected2 connect(m_client, QMqttClient::stateChanged, this, MainWindow::onStateChanged); // 2. connected: 成功连接到 Broker 时触发 connect(m_client, QMqttClient::connected, this, MainWindow::onConnected); // 3. disconnected: 与 Broker 断开连接时触发 connect(m_client, QMqttClient::disconnected, this, MainWindow::onDisconnected); // 4. messageReceived: 收到订阅主题的消息时触发 // 参数: QByteArray 消息内容, QMqttTopicName 主题名 connect(m_client, QMqttClient::messageReceived, this, MainWindow::onMessageReceived); // 5. messageSent: 消息成功发布到 Broker 时触发 // 参数: qint32 消息 ID connect(m_client, QMqttClient::messageSent, this, MainWindow::onMessageSent); // 6. errorChanged: 发生错误时触发 connect(m_client, QMqttClient::errorChanged, this, MainWindow::onErrorChanged); }三、连接/断开 BrokeronConnectClickedvoid MainWindow::onConnectClicked() { if (m_client-state() QMqttClient::Connected) { // 已连接 → 执行断开 m_client-disconnectFromHost(); return; } // --- 配置连接参数 --- m_client-setHostname(m_editHost-text()); m_client-setPort(m_spinPort-value()); m_client-setClientId(m_editClientId-text()); // 设置认证信息如果填了用户名和密码 if (!m_editUsername-text().isEmpty()) { m_client-setUsername(m_editUsername-text()); } if (!m_editPassword-text().isEmpty()) { m_client-setPassword(m_editPassword-text()); } // 设置 Keep Alive心跳间隔单位秒 // 客户端必须在此时间内至少发送一次消息或 PING 请求否则 Broker 会认为客户端已死并断开连接 // 默认 60 秒设为 30 秒更保险 m_client-setKeepAlive(30); /* * 什么是遗嘱消息 遗嘱消息是 MQTT 客户端在连接 Broker 时提前“立下遗嘱”指定一个主题和一条消息。如果该客户端异常断开例如网络故障、电源掉电、程序崩溃等而不是主动发送 DISCONNECT 报文 Broker 就会自动将这条遗嘱消息发布到指定的主题上通知其他订阅者。 类比一个人客户端在进入危险环境前提前写好遗书遗嘱消息交给公证人Broker并说明如果自己意外死亡异常断开就把遗书公布给指定的人订阅者。 */ // 配置遗嘱消息Last Will // 作用当客户端异常断开时Broker 自动发布这条消息通知其他客户端 m_client-setWillTopic(client/status);//设置遗嘱消息的发布主题。当客户端异常断开时Broker 会向 client/status 这个主题发布一条消息。 m_client-setWillMessage(客户端离线); m_client-setWillQoS(1); m_client-setWillRetain(true); // 标记为保留消息。Broker 会永久保存这条消息后续新订阅 client/status 主题的客户端立即收到这条离线通知而不需要等待下一次事件发生。 appendLog(正在连接到 Broker m_editHost-text() : QString::number(m_spinPort-value()) ...); // 发起连接异步操作结果通过 connected/disconnected 信号通知 m_client-connectToHost(); }四、 订阅主题onSubscribeClickedvoid MainWindow::onSubscribeClicked() { QString topic m_editSubTopic-text().trimmed(); if (topic.isEmpty()) { QMessageBox::warning(this, tr(警告), tr(请输入要订阅的主题名)); return; } // 获取用户选择的 QoS 等级 int qos m_comboQos-currentData().toInt(); // QMqttClient::subscribe() 返回 QMqttSubscription 对象 // 可通过它监控订阅状态如是否成功、QoS 协商结果等 /*MQTT 主题过滤器 可以包含通配符 单层通配符匹配任意一个层级。 #多层通配符匹配任意多个层级必须放在最后。 当你构造 QMqttTopicFilter(topic) 时如果传入的 topic 不包含通配符它就是一个精确的主题过滤器只匹配该主题本身如果包含通配符它会匹配所有符合条件的主题。*/ QMqttSubscription *sub m_client-subscribe(QMqttTopicFilter(topic), qos); // QMqttClient::subscribe()订阅方法返回订阅对象 // 可选监听订阅状态变化 connect(sub, QMqttSubscription::stateChanged, this, [this, topic](QMqttSubscription::SubscriptionState state) { if (state QMqttSubscription::Subscribed) { appendLog(✓ 订阅成功: topic); } else if (state QMqttSubscription::Unsubscribed) { appendLog(✗ 已取消订阅: topic); } }); appendLog(正在订阅主题: topic (QoS QString::number(qos) )); }五、取消订阅onUnsubscribeClickedvoid MainWindow::onUnsubscribeClicked() { QString topic m_editSubTopic-text().trimmed(); if (topic.isEmpty()) { QMessageBox::warning(this, tr(警告), tr(请输入要取消订阅的主题名)); return; } // QMqttClient::unsubscribe() 取消对指定主题的订阅 m_client-unsubscribe(QMqttTopicFilter(topic)); appendLog(正在取消订阅: topic); }六、发布普通消息onPublishClickedvoid MainWindow::onPublishClicked() { QString topic m_editPubTopic-text().trimmed(); QString message m_editMessage-text().trimmed(); if (topic.isEmpty() || message.isEmpty()) { QMessageBox::warning(this, tr(警告), tr(请输入主题和消息内容)); return; } int qos m_comboQos-currentData().toInt(); // QMqttClient::publish() 发布消息 // 参数: 主题名, 消息内容, QoS 等级, 是否保留默认false // 返回值: qint32 消息 ID可用于跟踪发布状态 qint32 msgId m_client-publish( QMqttTopicName(topic), // 主题 message.toUtf8(), // 消息体转为 UTF-8 字节 qos // QoS 等级 ); appendLog(发布消息 - 主题: topic , QoS: QString::number(qos) , ID: QString::number(msgId)); }七、发布保留消息onPublishRetainClickedvoid MainWindow::onPublishRetainClicked() { QString topic m_editPubTopic-text().trimmed(); QString message m_editMessage-text().trimmed(); if (topic.isEmpty() || message.isEmpty()) { QMessageBox::warning(this, tr(警告), tr(请输入主题和消息内容)); return; } int qos m_comboQos-currentData().toInt(); // 保留消息Broker 会保存这条消息后续订阅该主题的新客户端会立即收到 // 典型用途设备状态、配置信息等最新值 qint32 msgId m_client-publish( QMqttTopicName(topic), message.toUtf8(), qos, true // retain true标记为保留消息 ); appendLog(发布保留消息 - 主题: topic , ID: QString::number(msgId)); }八、连接状态变化处理onStateChangedvoid MainWindow::onStateChanged(QMqttClient::ClientState state) { // 根据当前状态更新 UI 显示 QString stateText; switch (state) { case QMqttClient::Disconnected: stateText 未连接; break; case QMqttClient::Connecting: stateText 正在连接...; break; case QMqttClient::Connected: stateText 已连接; break; } m_labelStatus-setText(状态: stateText); // 连接中显示黄色已连接显示绿色未连接显示红色 if (state QMqttClient::Connected) { m_labelStatus-setStyleSheet(color: green; font-weight: bold;); } else if (state QMqttClient::Connecting) { m_labelStatus-setStyleSheet(color: orange; font-weight: bold;); } else { m_labelStatus-setStyleSheet(color: red; font-weight: bold;); } }九、连接成功处理onConnectedvoid MainWindow::onConnected() { appendLog( 已连接到 Broker ); m_btnConnect-setText(断开); // 连接成功后可以发布一条上线通知 m_client-publish(QMqttTopicName(client/status), 客户端在线, 1, true); }十、断开连接处理onDisconnectedvoid MainWindow::onDisconnected() { appendLog( 与 Broker 断开连接 ); m_btnConnect-setText(连接); }十一、 接收消息处理onMessageReceivedvoid MainWindow::onMessageReceived(const QByteArray message, const QMqttTopicName topic) { // 收到消息时的核心处理逻辑 // topic.name() → 获取主题名字符串 // message → 获取消息内容QByteArray可转 QString QString timeStr QDateTime::currentDateTime().toString(HH:mm:ss); appendLog([ timeStr ] 收到消息 ← 主题: topic.name() | 内容: QString::fromUtf8(message)); }十二、消息发送确认onMessageSentvoid MainWindow::onMessageSent(qint32 id) { // 消息成功发布到 Broker 后触发 // 注意QoS 0 时可能不会触发此信号因为不需要确认 appendLog(消息发送确认 ✓ (ID: QString::number(id) )); }十三、错误处理onErrorChangedvoid MainWindow::onErrorChanged(QMqttClient::ClientError error) { // 错误处理根据错误码判断问题类型 QString errorText; switch (error) { case QMqttClient::NoError: return; // 无错误忽略 // --- 协议层错误MQTT 协议返回 --- case QMqttClient::InvalidProtocolVersion: errorText 协议版本不支持; break; case QMqttClient::IdRejected: errorText 客户端 ID 被拒绝可能太长或格式不对; break; case QMqttClient::ServerUnavailable: errorText Broker 不可用; break; case QMqttClient::BadUsernameOrPassword: errorText 用户名或密码错误; break; case QMqttClient::NotAuthorized: errorText 认证失败无权限; break; // --- 传输层错误网络问题 --- case QMqttClient::TransportInvalid: errorText 传输层错误网络断开/连接失败; break; case QMqttClient::ProtocolViolation: errorText 协议违规消息格式不正确; break; case QMqttClient::UnknownError: errorText 未知错误; break; case QMqttClient::Mqtt5SpecificError: errorText MQTT 5.0 特有错误; break; default: errorText 未知错误码: QString::number(error); break; } appendLog(⚠ 错误: errorText); }

相关新闻

千笔AI：深度学习驱动的学术写作智能辅助平台

千笔AI：深度学习驱动的学术写作智能辅助平台

2026/7/28 1:28:15

1. 项目概述：学术写作的智能化革命千笔AI作为一款面向学术论文写作的智能辅助平台，正在改变传统学术研究的范式。这个平台的核心价值在于通过深度学习技术，为研究者提供从选题到发表的全程智能化支持。不同于市面上常见的论文查重或格式调整工…

AI降重工具技术解析与本科生论文应用指南

AI降重工具技术解析与本科生论文应用指南

2026/7/28 3:11:42

1. 项目概述：AI降重工具的市场需求与核心价值在学术写作领域，AI生成内容的检测与降重已成为刚需。特别是对于本科生群体，论文查重率直接关系到毕业资格。传统改写工具往往存在语义失真、格式混乱等问题，而新兴的AI降重工具通过深度…

BERT模型核心技术解析与实践应用指南

BERT模型核心技术解析与实践应用指南

2026/7/28 3:11:42

1. BERT模型概述BERT（Bidirectional Encoder Representations from Transformers）是2018年由Google提出的革命性自然语言处理模型。作为Transformer架构的重要应用，它彻底改变了传统语言模型的训练方式。与以往的单向语言模型不同&#xff0c…

北京市2026年第二批专精特新中小企业资质申报全解析

北京市2026年第二批专精特新中小企业资质申报全解析

2026/7/28 3:11:42

一、政策背景本次申报依据《优质中小企业梯度培育管理办法》（工信部企业〔2026〕2号）开展。值得注意的是，自2026年4月1日起，专精特新中小企业申报已按新政策执行，原《优质中小企业梯度培育管理暂行办法》（工…

C语言在操作系统开发中的核心优势与实战指南

C语言在操作系统开发中的核心优势与实战指南

2026/7/28 3:11:42

在操作系统开发领域，每隔几年就会出现关于“C语言是否过时”的讨论。随着Rust、Go等现代语言的兴起，许多开发者开始质疑这门诞生于上世纪70年代的语言是否还能胜任现代系统编程。然而，无论是Linux内核的持续演进，还是新兴的嵌入式实时操作系统，C语言依然是无可争议的基石。…

智能课程开发指南：从目标设定到效果评估

智能课程开发指南：从目标设定到效果评估

2026/7/28 3:11:42

1. 项目概述 "Agent 30 课程开发指南 - 第9课"这个标题让我想起了十年前我刚入行教育科技领域时开发的第一套智能课程体系。这类课程开发指南通常面向教育科技从业者、企业内训师或在线教育创业者，旨在提供一套可复用的课程开发方法论。 第9课作为系列课…

解决Git克隆失败：OpenClaw等大型AI项目的完整克隆指南

解决Git克隆失败：OpenClaw等大型AI项目的完整克隆指南

2026/7/28 3:10:42

在本地部署和运行开源 AI 项目时，很多开发者会遇到从 GitHub 克隆仓库速度慢甚至失败的问题。OpenClaw 作为一个新兴的 AI 项目，其仓库包含大量模型文件和历史提交记录，直接使用git clone命令可能会因为网络环境或仓库体积过大而中断。1. 理解…

告别臃肿！3步让你的暗影精灵笔记本重获新生

告别臃肿！3步让你的暗影精灵笔记本重获新生

2026/7/28 0:00:46

告别臃肿！3步让你的暗影精灵笔记本重获新生 【免费下载链接】OmenSuperHub Control Omen laptop performance, fan speeds, and keyboard lighting, and unlock power limits. 项目地址: https://gitcode.com/gh_mirrors/om/OmenSuperHub 你是否也曾为官方Om…

AI短剧创作系统：从剧本生成到视频合成的全流程解析

AI短剧创作系统：从剧本生成到视频合成的全流程解析

2026/7/27 21:55:32

1. 项目背景与核心价值去年参与的一个短剧项目让我深刻体会到传统创作流程的痛点：编剧团队花了三周打磨剧本，角色设计反复修改了七版，最后成片时又因为演员档期问题不得不临时调整分镜。这种低效的创作模式在快节奏的内容行业越来越难以为继。…

数据分析师必学MySQL：从零构建电商销售分析实战

数据分析师必学MySQL：从零构建电商销售分析实战

2026/7/27 1:16:55

你是不是也遇到过这样的困惑：想学数据分析，看了很多Python、R语言的教程，结果发现第一步就被卡住了——数据从哪里来？怎么存？怎么查？怎么保证数据准确？很多数据分析教程都默认你已经有了一个干净…

HS2-HF Patch：3步实现HoneySelect2完美汉化与MOD整合

HS2-HF Patch：3步实现HoneySelect2完美汉化与MOD整合

2026/7/27 3:25:51

HS2-HF Patch：3步实现HoneySelect2完美汉化与MOD整合 【免费下载链接】HS2-HF_Patch Automatically translate, uncensor and update HoneySelect2! 项目地址: https://gitcode.com/gh_mirrors/hs/HS2-HF_Patch HS2-HF Patch是专为HoneySelect2玩家设计的一站…