### 使用 Python 实现 MQTT 协议的消息发送与接收 为了实现 Python 中的 MQTT 消息收发功能，可以利用 `paho-mqtt` 库来简化操作。下面展示一段完整的代码示例，用于说明如何建立客户端连接、订阅主题、发布消息以及处理收到的信息。 #### 安装依赖库 首先需要安装 paho-mqtt 库，可以通过 pip 工具轻松完成此过程[^3]： ```bash pip install paho-mqtt ``` #### 示例代码：MQTT 发布者(Publisher) ```python import paho.mqtt.client as mqtt class MQTTPublisher: def __init__(self, broker_address="localhost", port=1883, topic="test/topic"): self.broker_address = broker_address self.port = port self.topic = topic # 初始化客户端实例 self.client = mqtt.Client() # 设置回调函数，在连接成功时触发 self.client.on_connect = lambda client, userdata, flags, rc: \ print(f"Connected with result code {rc}") def connect(self): try: # 尝试连接至指定的代理服务器 self.client.connect(self.broker_address, self.port) # 启动网络循环以维持会话状态 self.client.loop_start() while not self.client.is_connected(): pass # 等待直到连接成功 return True except Exception as e: print(e) return False def publish(self, message): if self.client.is_connected(): # 如果当前处于已连接状态，则尝试发布一条新消息 res = self.client.publish(topic=self.topic, payload=message) if res.rc != mqtt.MQTT_ERR_SUCCESS: print("Failed to send message.") def disconnect(self): # 停止网络循环并安全断开连接 self.client.disconnect() self.client.loop_stop(force=True) if __name__ == "__main__": publisher = MQTTPublisher(broker_address='broker.hivemq.com', port=1883, topic='my/test') success = publisher.connect() if success: publisher.publish('Hello World!') publisher.disconnect() ``` 这段程序定义了一个名为 `MQTTPublisher` 的类，它封装了创建 MQTT 连接所需的功能，并提供了简单的接口来进行消息发布的操作[^4]。 #### 示例代码：MQTT 订阅者(Subscriber) ```python import time import paho.mqtt.client as mqtt def on_message(client, userdata, msg): """当有新的消息到达时调用""" print(f"{msg.topic}: {str(msg.payload.decode())}") client = mqtt.Client() client.on_message = on_message try: client.connect('broker.hivemq.com', 1883, 60) except ConnectionRefusedError: print("无法连接到 Broker") client.subscribe('my/test') client.loop_start() # 开始监听来自服务端的数据包 time.sleep(5) # 维持脚本运行一段时间以便能够接收到可能到来的消息 client.loop_stop() # 结束监听 client.disconnect() # 断开与Broker之间的链接 ``` 上述例子展示了怎样构建一个简易版的 MQTT 订阅器，它可以监听特定的主题并将任何接收到的新消息打印出来[^1]。