ESP32 基于 python语言 连接mqtt

首先需要安装 micropython，可以通过官方网站下载对应的固件：http://micropython.org/download#esp32。

将 ESP32 连接到电脑上，打开终端并进入串口模式。然后可以运行以下命令初始化 ESP32：

import network
sta_if = network.WLAN(network.STA_IF)
sta_if.active(True)
sta_if.connect('your_network_name', 'your_network_password')

此命令将 ESP32 连接到您的无线网络。可以通过 `sta_if.isconnected()` 检查连接是否成功。

接下来需要安装 umqtt.simple 库。可以通过以下命令安装：

import upip
upip.install('micropython-umqtt.simple')

然后使用以下代码将 ESP32 连接到 MQTT 服务器：

from umqtt.simple import MQTTClient
client = MQTTClient("esp32", "your_mqtt_broker_address")
client.connect()

替换 "your_mqtt_broker_address" 为您的 MQTT 服务器地址。然后，可以通过以下命令发布消息：

client.publish(b"topic", b"message")

其中，"topic" 是主题名称，"message" 是消息内容。

可以通过以下命令订阅主题：

def sub_cb(topic, msg):
    print((topic, msg))

client.set_callback(sub_cb)
client.subscribe(b"topic")

此命令将从 "topic" 订阅所有消息，并在接收消息时打印它们。

最后，您需要在主循环中运行以下命令：

while True:
    client.check_msg()

如果可以接收到新消息，则 `sub_cb` 回调函数将被调用。如果没有新消息，则 `client.check_msg()` 将使代码暂停一段时间，以便处理其他任务。