PYQT MQTT客户端订阅话题 多线程

下面是一个使用PyQt和paho-mqtt库实现MQTT客户端订阅多个话题的示例代码。

首先需要安装paho-mqtt库，可以使用以下命令进行安装：

pip install paho-mqtt

然后可以使用以下代码实现MQTT客户端：

import sys
from PyQt5.QtWidgets import QApplication, QWidget, QVBoxLayout, QHBoxLayout, QLineEdit, QPushButton, QTextEdit
import paho.mqtt.client as mqtt
import threading

class MQTTClient(QWidget):
    def __init__(self):
        super().__init__()
        self.initUI()

    def initUI(self):
        # 设置窗口大小和标题
        self.setGeometry(300, 300, 600, 400)
        self.setWindowTitle('MQTT Client')

        # 创建控件
        self.topicLineEdit = QLineEdit()
        self.subscribeButton = QPushButton('Subscribe')
        self.unsubscribeButton = QPushButton('Unsubscribe')
        self.clearButton = QPushButton('Clear')
        self.messageTextEdit = QTextEdit()

        # 创建布局
        topicLayout = QHBoxLayout()
        topicLayout.addWidget(self.topicLineEdit)
        topicLayout.addWidget(self.subscribeButton)
        topicLayout.addWidget(self.unsubscribeButton)
        topicLayout.addWidget(self.clearButton)

        mainLayout = QVBoxLayout()
        mainLayout.addLayout(topicLayout)
        mainLayout.addWidget(self.messageTextEdit)

        # 设置布局
        self.setLayout(mainLayout)

        # 创建MQTT客户端
        self.client = mqtt.Client()

        # 连接MQTT服务器
        self.client.connect('localhost', 1883, 60)

        # 绑定信号和槽
        self.subscribeButton.clicked.connect(self.subscribe)
        self.unsubscribeButton.clicked.connect(self.unsubscribe)
        self.clearButton.clicked.connect(self.clear)

        # 启动多线程
        self.thread = threading.Thread(target=self.client.loop_forever)
        self.thread.start()

    def subscribe(self):
        topic = self.topicLineEdit.text()
        self.client.subscribe(topic)
        self.messageTextEdit.append('Subscribed to topic: {}'.format(topic))

    def unsubscribe(self):
        topic = self.topicLineEdit.text()
        self.client.unsubscribe(topic)
        self.messageTextEdit.append('Unsubscribed from topic: {}'.format(topic))

    def clear(self):
        self.messageTextEdit.clear()

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

在该代码中，我们创建了一个继承自QWidget的MQTTClient类，在initUI方法中创建了窗口控件，并初始化了MQTT客户端。在subscribe方法中订阅了某个话题，在unsubscribe方法中取消订阅某个话题，在clear方法中清空消息文本框。启动多线程后，就可以在主线程中运行PyQt事件循环，而在子线程中运行MQTT客户端的消息循环。

注意，由于PyQt是单线程的，因此如果在主线程中运行MQTT客户端的消息循环，会导致PyQt事件循环无法响应，从而使窗口无法正常显示和响应。因此，我们需要在子线程中运行MQTT客户端的消息循环，以避免这种情况发生。