paho-mqtt的类函数封装

Paho-MQTT是一个Python MQTT客户端库，用于连接到MQTT代理并发布/订阅消息。下面是一个基本的类函数封装示例，用于连接到MQTT代理并发布消息。

import paho.mqtt.client as mqtt

class MqttClient:
    def __init__(self, broker, port, username=None, password=None):
        self.broker = broker
        self.port = port
        self.username = username
        self.password = password
        self.client = mqtt.Client()
        self.client.username_pw_set(username, password)
        self.client.connect(broker, port)

    def publish(self, topic, message, qos=0, retain=False):
        self.client.publish(topic, message, qos=qos, retain=retain)

    def subscribe(self, topic, qos=0):
        self.client.subscribe(topic, qos=qos)

    def on_connect(self, client, userdata, flags, rc):
        print("Connected with result code " + str(rc))

    def on_message(self, client, userdata, msg):
        print(msg.topic + " " + str(msg.payload))

    def start(self):
        self.client.on_connect = self.on_connect
        self.client.on_message = self.on_message
        self.client.loop_forever()

在上面的代码中，我们定义了一个MqttClient类，该类具有以下功能：

- 初始化函数：使用传递的代理和端口号创建一个新的MQTT客户端，并使用用户名和密码设置身份验证。
- 发布函数：向指定主题发布消息。
- 订阅函数：订阅指定主题。
- 连接和消息回调函数：当客户端成功连接到代理并接收到新消息时，回调函数将被调用。
- 启动函数：启动MQTT客户端并循环以接收新消息。

使用此类，我们可以轻松连接到MQTT代理并发布/订阅消息。例如，要发布消息，请执行以下操作：

mqtt_client = MqttClient("localhost", 1883)
mqtt_client.publish("test/topic", "Hello, world!")

要订阅主题并接收新消息，请执行以下操作：

mqtt_client = MqttClient("localhost", 1883)
mqtt_client.subscribe("test/topic")
mqtt_client.start()