python mqtt

# 导入paho-mqtt库，用于实现MQTT协议的客户端
import paho.mqtt.client as mqtt

# 当连接到MQTT代理时调用的回调函数
def on_connect(client, userdata, flags, rc):
    print(f"Connected with result code {rc}")
    # 订阅主题
    client.subscribe("test/topic")

# 当接收到消息时调用的回调函数
def on_message(client, userdata, msg):
    print(f"{msg.topic} {msg.payload.decode()}")

# 创建一个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()

解释说明：

1. 导入库：使用paho-mqtt库来实现MQTT协议的客户端。
2. 回调函数：
   • on_connect: 当客户端成功连接到MQTT代理时调用此函数，并订阅指定的主题。
   • on_message: 当客户端接收到消息时调用此函数，并打印消息的主题和内容。
3. 创建客户端实例：使用mqtt.Client()创建一个客户端实例。
4. 设置回调函数：将定义的回调函数绑定到客户端实例。
5. 连接到代理服务器：使用client.connect()方法连接到MQTT代理服务器（这里使用的是公共测试服务器broker.hivemq.com）。
6. 开始网络循环：使用client.loop_forever()进入一个无限循环，持续监听和处理消息。