用PYTHON实现类，连接MQTT服务器并发送消息

你好！下面是用 Python 实现类来连接 MQTT 服务器并发送消息的示例代码。

首先，你需要安装 MQTT 库，这里建议使用 paho-mqtt 库。你可以使用如下命令来安装：

pipinstall paho-mqtt
1
2

然后，可以创建一个名为 MqttClient 的类，它具有连接到 MQTT 服务器、发送消息、和断开连接的方法。

import paho.mqtt.client as mqttclass MqttClient:
    def __init__(self, host, port, username, password):
        self.client = mqtt.Client()
        self.client.username_pw_set(username, password)
        self.client.connect(host, port)
 
    def publish(self, topic, payload, qos=0, retain=False):
        self.client.publish(topic, payload, qos, retain)
 
    def disconnect(self):
        self.client.disconnect()
1
2
3
4
5
6
7
8
9
10
11
12

要使用这个类，你可以创建一个 MqttClient 对象，并使用 publish 方法来发送消息。例如：

client = MqttClient("localhost", 1883, "username", "password")
client.publish("test/topic", "Hello, MQTT!")
client.disconnect()
1
2
3
4

希望这对你有帮助！