qtmqtt 在子线程中使用

在Qt中，使用QtMqtt需要确保不在非GUI线程上执行界面相关的操作。如果你需要在子线程中使用QtMqtt，你应该避免在子线程中直接进行界面更新。相反，你可以通过信号和槽机制安全地从子线程发送数据到主线程，并在主线程进行UI更新。

以下是一个简单的例子，展示了如何在子线程中使用QtMqtt，并通过信号发送数据到主线程进行处理：

#include <QThread>
#include <QMqttClient>
#include <QMqttSubscription>
 
class MqttClientThread : public QThread {
    Q_OBJECT
public:
    MqttClientThread(QMqttClient *client) : m_client(client) {
        connect(m_client, &QMqttClient::received, this, &MqttClientThread::onMessageReceived);
    }
 
    void run() override {
        m_client->connectToHost();
        exec();
    }
 
signals:
    void messageReceived(const QByteArray &topic, const QByteArray &payload);
 
private slots:
    void onMessageReceived(const QMqttMessage &message) {
        emit messageReceived(message.topic(), message.payload());
    }
 
private:
    QMqttClient *m_client;
};
 
class MqttClient : public QObject {
    Q_OBJECT
public:
    MqttClient(QMqttClient *client, QObject *parent = nullptr)
        : QObject(parent), m_clientThread(client) {
        connect(&m_clientThread, &MqttClientThread::messageReceived, this, &MqttClient::handleMessage);
        m_clientThread.start();
    }
 
public slots:
    void handleMessage(const QByteArray &topic, const QByteArray &payload) {
        // 处理接收到的消息，在主线程安全地更新UI
    }
 
private:
    MqttClientThread m_clientThread;
};

在这个例子中，MqttClientThread 类继承自 QThread，并在其 run() 方法中启动MQTT客户端的连接。客户端连接在一个独立的线程中，这样UI线程（主线程）不会被阻塞。当客户端接收到消息时，通过信号 messageReceived 发送消息到主线程处理。MqttClient 类接收这个信号，并在其槽函数 handleMessage 中处理接收到的消息，在这里可以安全地更新UI。

请注意，这个例子只是展示了如何在Qt中使用信号和槽来安全地在子线程和主线程之间传递数据。在实际应用中，你需要根据自己的应用程序需求和MQTT客户端的具体使用情况来调整代码。