【计算机网络通信 MQTT】使用Qt调用 qmqttclient 库进行 MQTT 通信

flos chen

发布于 2026-01-23 15:20:43

1680

以下是一个使用 qmqttclient 库进行 MQTT 通信的 Qt 代码示例：

#include <QCoreApplication>
#include <QDebug>
#include <QMqttClient>


int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);


    // 创建 MQTT 客户端对象
    QMqttClient client;


    // 设置 MQTT 服务器地址和端口
    client.setHostname("localhost");
    client.setPort(1883);


    // 连接到 MQTT 服务器
    client.connectToHost();


    // 当客户端连接成功时，触发 connected 信号
    QObject::connect(&client, &QMqttClient::connected, [&]() {
        qDebug() << "Connected to MQTT server";


        // 订阅主题
        QString topic = "test/topic";
        client.subscribe(topic);
        qDebug() << "Subscribed to topic:" << topic;


        // 当收到消息时，触发 messageReceived 信号
        QObject::connect(&client, &QMqttClient::messageReceived, [&](const QByteArray &message, const QMqttTopicName &topic) {
            qDebug() << "Received message on topic" << topic.name() << ":" << message;
        });


        // 发布消息
        QString payload = "Hello, MQTT!";
        QMqttTopicName pubTopic("test/topic");
        client.publish(pubTopic, payload.toUtf8());
        qDebug() << "Published message:" << payload;
    });


    // 当客户端连接断开时，触发 disconnected 信号
    QObject::connect(&client, &QMqttClient::disconnected, [&]() {
        qDebug() << "Disconnected from MQTT server";
    });


    return a.exec();
}

代码解释

头文件导入：
- QCoreApplication 是 Qt 核心应用程序类，是 Qt 应用程序的基础。
- QDebug 用于输出调试信息。
- QMqttClient 是 Qt 提供的 MQTT 客户端类，用于实现 MQTT 通信。
创建 MQTT 客户端对象：
- QMqttClient client; 创建一个 MQTT 客户端对象，用于后续的 MQTT 操作。
设置 MQTT 服务器信息：
- client.setHostname("localhost"); 设置 MQTT 服务器的主机名。
- client.setPort(1883); 设置 MQTT 服务器的端口号，通常 MQTT 的默认端口是 1883。
连接到 MQTT 服务器：
- client.connectToHost(); 发起连接到 MQTT 服务器的操作。
连接成功后的操作：
- 使用 QObject::connect 连接 connected 信号，当客户端成功连接到 MQTT 服务器时，会触发该信号。在信号的槽函数中：
  - 打印连接成功的消息。
  - 订阅主题 "test/topic"，使用 client.subscribe(topic);。
  - 连接 messageReceived 信号，当收到消息时，会触发该信号。在信号的槽函数中，打印收到的消息和消息所在的主题。
  - 发布消息 "Hello, MQTT!" 到主题 "test/topic"，使用 client.publish(pubTopic, payload.toUtf8());。
连接断开后的操作：
- 使用 QObject::connect 连接 disconnected 信号，当客户端断开连接时，会触发该信号。在信号的槽函数中，打印断开连接的消息。