Mqtt Python

### Python中使用MQTT进行消息传递

#### 安装依赖库
为了能够在Python环境中使用MQTT协议，需安装`paho-mqtt`库。该库提供了简单的API接口用于连接到MQTT代理并执行发布/订阅操作。

pip install paho-mqtt

#### 连接到MQTT Broker
建立与MQTT代理之间的TCP/IP网络连接是第一步，在此过程中可以指定要使用的主机地址以及端口号。对于本例而言，选择了由EMQX提供的公共测试Broker[^3]。

import paho.mqtt.client as mqtt

client = mqtt.Client()
broker_address = "broker.emqx.io"
port = 1883
client.connect(broker_address, port)

#### 发布消息至特定主题
一旦成功建立了连接，则可以通过调用publish方法向指定的主题发送消息。这里的消息体通常是字符串形式的数据，而topic则是接收者用来过滤感兴趣的内容的关键字[^2]。

topic = "/test/topic"
message = "Hello from MQTT client!"
result = client.publish(topic, message)

if result.rc == mqtt.MQTT_ERR_SUCCESS:
    print(f"Message published to {topic}")
else:
    print("Failed to publish message.")

#### 订阅来自某个主题的消息
除了作为生产者外，还可以让程序扮演消费者的角色——监听某些话题上的更新。这涉及到subscribe()函数的应用，并定义相应的回调处理逻辑以便于接收到新信息时触发相应动作。

def on_message(client, userdata, msg):
    print(f"Received message '{msg.payload.decode()}' on topic '{msg.topic}'")

client.on_message = on_message
client.subscribe("/test/#")  # 使用通配符订阅多个子主题下的所有消息
client.loop_start()

try:
    while True:
        pass
except KeyboardInterrupt:
    client.disconnect()
    client.loop_stop()

上述代码片段展示了基本的MQTT客户端配置过程及其核心功能实现方式。值得注意的是，实际项目开发当中可能还需要考虑诸如异常捕获、重试机制等因素以提高系统的健壮性和稳定性[^1]。