qt 连接mqtt代码

以下是使用Qt连接MQTT的示例代码：

#include <QCoreApplication>
#include <QtMqtt/QMqttClient>
#include <QtMqtt/QMqttSubscription>

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

    // 创建MQTT客户端实例
    QMqttClient mqttClient;

    // 连接到MQTT代理服务器
    mqttClient.setHostname("broker.hivemq.com");
    mqttClient.setPort(1883);

    mqttClient.connectToHost();

    // 订阅主题
    QMqttSubscription* subscription = mqttClient.subscribe("testtopic", 0);
    QObject::connect(subscription, &QMqttSubscription::messageReceived, [&](const QByteArray& message, const QMqttTopicName& topic){
        // 处理接收到的消息
        qDebug() << "Received message:" << message << "on topic:" << topic.name();
    });

    // 发布消息
    mqttClient.publish(QMqttTopicName("testtopic"), "Hello, world!");

    return a.exec();
}

在此示例中，我们创建了一个QMqttClient实例，并与一个MQTT代理服务器进行连接。然后，我们订阅了一个主题“testtopic”，并在收到新消息时打印出消息内容和主题名称。最后，我们通过publish函数发布了一条消息到主题“testtopic”。

请注意，此示例使用了QtMqtt模块。在运行此代码之前，您需要在项目文件（.pro文件）中添加以下行：

QT += mqtt