MQTT python连接话题

在 Python 中使用 paho-mqtt 库可以很方便地连接 MQTT 服务器并订阅/发布话题。

以下是一个简单的示例代码：

import paho.mqtt.client as mqtt

# 定义回调函数，处理连接成功事件
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 订阅话题
    client.subscribe("topic/test")

# 定义回调函数，处理收到消息事件
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

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

# 设置连接回调函数
client.on_connect = on_connect

# 设置收到消息回调函数
client.on_message = on_message

# 连接 MQTT 服务器
client.connect("broker.hivemq.com", 1883, 60)

# 开始循环处理消息
client.loop_forever()

在上面的代码中，我们首先定义了两个回调函数，分别处理连接成功和收到消息事件。然后创建了一个 MQTT 客户端实例，并设置连接和收到消息的回调函数。接着连接到 MQTT 服务器，订阅了 "topic/test" 话题，并启动了消息处理循环。

你可以将上述代码复制到你的 Python 环境中运行，然后在另一个终端窗口中使用 MQTT 客户端向 "topic/test" 话题发送消息，就可以看到该程序输出收到的消息了。