### ESP32 MicroPython MQTT 连接教程 要在ESP32上使用MicroPython连接到MQTT服务器，需要完成以下几个方面的配置： #### 1. 安装 `umqtt.simple` 或 `umqttsimple` 库 为了实现MQTT功能，需引入第三方库 `umqtt.simple` 或者更优化的版本 `umqttsimple.py`。这些库提供了轻量级的MQTT协议支持[^2]。 可以从以下链接下载适合的库文件并上传至ESP32设备： ```plaintext https://raw.githubusercontent.com/RuiSantosdotme/ESP-MicroPython/master/code/MQTT/umqttsimple.py ``` 通过工具如 Thonny IDE 将该 `.py` 文件复制到ESP32的文件系统中。 --- #### 2. 配置WiFi网络连接 在连接MQTT之前，必须先让ESP32接入Wi-Fi网络。以下是基本的WiFi连接代码示例： ```python import network def connect_wifi(ssid, password): wlan = network.WLAN(network.STA_IF) wlan.active(True) if not wlan.isconnected(): print("Connecting to WiFi...") wlan.connect(ssid, password) while not wlan.isconnected(): pass print(f"Connected! Network info: {wlan.ifconfig()}") # 替换为实际的SSID和密码 connect_wifi("your_ssid", "your_password") ``` 此部分确保ESP32已成功加入指定的无线局域网环境[^4]。 --- #### 3. 编写MQTT连接与消息发送代码 一旦WiFi设置完毕，就可以利用前述提到的 `umqttsimple` 库创建MQTT客户端实例并与远程代理（Broker）交互。下面是一个完整的示例程序展示如何订阅主题以及发布数据给特定主题： ```python from umqttsimple import MQTTClient import time import machine # 自定义函数用于处理收到的消息 def sub_cb(topic, msg): print((topic, msg)) # 初始化MQTT客户端对象 CLIENT_ID = 'esp32_client' BROKER_IP = 'mqtt.example.com' # 修改为目标MQTT Broker IP 地址或者域名 TOPIC_SUBSCRIBE = b'test/topic/sub' TOPIC_PUBLISH = b'test/topic/pub' client = MQTTClient(CLIENT_ID, BROKER_IP) try: client.set_callback(sub_cb) # 设置回调方法 client.connect() # 建立连接 client.subscribe(TOPIC_SUBSCRIBE) # 订阅某个主题 print(f'Subscribed to topic "{TOPIC_SUBSCRIBE.decode()}"') except Exception as e: print(f'MQTT connection error: {e}') while True: try: client.check_msg() # 检查是否有新消息到达 # 发布一条测试消息每隔两秒 message = f'Hello from ESP32 at {time.time()}'.encode() client.publish(TOPIC_PUBLISH, message) print(f'Published message: {message}') time.sleep(2) except OSError as err: print(err) restart_and_reconnect() def restart_and_reconnect(): print('Failed to connect to MQTT broker. Reconnecting...') time.sleep(5) machine.reset() ``` 上述脚本实现了周期性的向目标主题推送时间戳字符串的同时监听来自另一主题的信息反馈机制[^3]。 --- #### 注意事项 - **Broker地址**: 确认所使用的MQTT服务提供商及其对应的IP或DNS名称。 - **安全性考量**: 如果涉及敏感操作建议启用TLS加密传输层保护措施。 - **异常恢复逻辑**: 添加必要的错误捕获以便于应对断开重连等情况发生时能自动修复状态。 ---