Python MQTT 程序示例：连接、订阅和接收消息

以下是一个简单的 Python MQTT 程序示例：

import paho.mqtt.client as mqtt

# MQTT 代理服务器地址和端口号
broker_address = 'broker.hivemq.com'
port = 1883

# MQTT 订阅的主题
topic = 'test/topic'

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

# 连接 MQTT 代理服务器
client.connect(broker_address, port)

# 定义消息处理函数
def on_message(client, userdata, message):
    print('接收到消息：' + message.payload.decode() + '，主题：' + message.topic)

# 订阅主题，并设置消息处理函数
client.subscribe(topic)
client.on_message = on_message

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

这个程序连接到一个公共的 MQTT 代理服务器（'broker.hivemq.com'），订阅一个主题（'test/topic'），并在接收到消息时打印出来。程序会一直运行，等待接收 MQTT 消息。