### 如何使用 MicroPython 连接到 MQTT 服务器 要实现通过 MicroPython 将设备连接至 MQTT 服务器的功能，可以参考以下方法和示例代码。 #### 准备工作 为了成功运行基于 MicroPython 的 MQTT 客户端程序，需先导入 `umqttsimple.py` 库文件。此库提供了必要的功能来处理 MQTT 协议中的订阅、发布操作等功能[^1]。如果尚未安装该库，则应按照相关文档说明完成配置过程。 #### 示例代码展示 下面提供了一段完整的 Python 程序用于演示如何利用 ESP32 和 MicroPython 向指定主题发送消息给远程 MQTT Broker： ```python import time from umqtt.simple import MQTTClient # 导入MQTT客户端类 def connect_and_subscribe(): server = "mqtt.example.com" # 替换为实际使用的Broker地址 client_id = b'esp32_client' topic_sub = b'test/topic' def sub_cb(topic, msg): # 订阅回调函数定义 print((topic, msg)) client = MQTTClient(client_id, server) client.set_callback(sub_cb) client.connect() client.subscribe(topic_sub) print('Connected to %s MQTT broker, subscribed to %s topic' % (server, topic_sub)) return client def restart_and_reconnect(): global client print('Failed to connect to MQTT broker. Reconnecting...') time.sleep(5) machine.reset() try: client = connect_and_subscribe() except OSError as e: restart_and_reconnect() while True: try: new_message = False while not new_message: # 循环等待新消息到来 client.check_msg() # 非阻塞方式接收消息 time.sleep_ms(10) message_to_send = 'Hello from ESP32!' client.publish(b'test/response', bytes(message_to_send, 'utf-8')) print(f'Sent `{message_to_send}`') time.sleep(5) # 发送频率控制 except Exception as err: restart_and_reconnect() ``` 上述脚本实现了基本的 MQTT 功能，包括建立与代理之间的连接以及周期性地向特定主题推送字符串形式的消息[^3]。 #### 注意事项 当执行以上代码前，请确认已正确设置好开发板及其联网参数；另外还需注意调整其中涉及的具体变量值（如服务器域名），使其匹配目标环境需求[^2]。