QT designer 实现MQTT话题订阅程序 多线程

要实现MQTT话题订阅程序并使用多线程，可以按照以下步骤进行：

1. 安装 paho-mqtt 库：使用 pip install paho-mqtt 命令来安装 paho-mqtt 库，该库提供了 Python 中 MQTT 协议的实现。

2. 创建 PyQt5 界面：使用 PyQt5 中的 Qt Designer 工具来创建用户界面。在界面中添加一个文本框和一个按钮，以便用户可以输入 MQTT 服务器地址和话题，并启动订阅程序。

3. 创建多线程模块：使用 Python 中的 threading 模块来创建多线程。在程序中创建一个线程，用于连接 MQTT 服务器并订阅特定的话题。使用另一个线程，用于更新界面上的消息文本框。

4. 编写程序代码：将界面和多线程模块结合起来，编写程序代码。当用户单击订阅按钮时，程序将启动一个新的线程来连接 MQTT 服务器并订阅话题。同时，程序将启动另一个线程来更新界面上的消息文本框。

下面是一个简单的示例程序，演示了如何使用 PyQt5 和 paho-mqtt 库来实现 MQTT 话题订阅程序：

import sys
import threading
from PyQt5.QtWidgets import QApplication, QMainWindow
from PyQt5.uic import loadUi
import paho.mqtt.client as mqtt

class MainWindow(QMainWindow):
    def __init__(self):
        super(MainWindow, self).__init__()
        loadUi('mainwindow.ui', self)
        self.connectButton.clicked.connect(self.connectToBroker)

    def connectToBroker(self):
        broker = self.brokerLineEdit.text()
        topic = self.topicLineEdit.text()

        self.client = mqtt.Client()
        self.client.connect(broker)
        self.client.subscribe(topic)
        
        self.startThread()

    def startThread(self):
        t1 = threading.Thread(target=self.updateMessage)
        t1.start()

    def updateMessage(self):
        while True:
            message = self.client.on_message()
            self.messageTextEdit.append(message)

if __name__ == '__main__':
    app = QApplication(sys.argv)
    window = MainWindow()
    window.show()
    sys.exit(app.exec_())

在这个程序中，我们创建了一个名为 `MainWindow` 的类，该类继承自 `QMainWindow`。在 `MainWindow` 类中，我们定义了一个 `connectToBroker` 方法，该方法获取用户输入的 MQTT 服务器地址和话题，并使用 paho-mqtt 库连接到 MQTT 服务器并订阅话题。

在 `connectToBroker` 方法中，我们还启动了一个名为 `startThread` 的方法。该方法创建一个新的线程，用于更新界面上的消息文本框。在 `updateMessage` 方法中，我们使用 `while` 循环来等待来自 MQTT 服务器的新消息，并将其追加到消息文本框中。

最后，在程序的主函数中，我们创建了一个 `QApplication` 对象，并创建一个 `MainWindow` 对象。我们调用 `show` 方法来显示主窗口，并调用 `app.exec_()` 方法来启动事件循环。