### Python与ESP32通过MQTT协议控制多LED灯 使用Python和ESP32通过MQTT协议实现多LED灯的控制，包括单个LED开关功能和流水灯效果，需要以下几个关键步骤：配置ESP32作为MQTT客户端、设置Python作为MQTT服务器或客户端、编写相应的逻辑代码。以下为具体实现方法。 #### 1. 硬件连接 ESP32开发板上连接多个LED灯，每个LED灯通过GPIO引脚控制[^1]。例如，可以将LED灯分别连接到GPIO 2、GPIO 4、GPIO 5等引脚，并确保每个LED灯都有独立的GPIO控制。 #### 2. ESP32端代码实现 ESP32需要作为MQTT客户端，订阅和发布消息以控制LED灯的状态。以下是ESP32端的代码示例： ```cpp #include <WiFi.h> #include <PubSubClient.h> // WiFi 和 MQTT 配置 const char* ssid = "你的WiFi名称"; const char* password = "你的WiFi密码"; const char* mqtt_server = "你的MQTT代理地址"; WiFiClient espClient; PubSubClient client(espClient); void setup_wifi() { delay(10); Serial.println(); Serial.print("Connecting to "); Serial.println(ssid); WiFi.begin(ssid, password); while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.print("."); } Serial.println(""); Serial.println("WiFi connected"); Serial.println("IP address: "); Serial.println(WiFi.localIP()); } void reconnect() { while (!client.connected()) { Serial.print("Attempting MQTT connection..."); if (client.connect("ESP32Client")) { Serial.println("connected"); // 订阅主题 client.subscribe("led/control"); } else { Serial.print("failed, rc="); Serial.print(client.state()); Serial.println(" try again in 5 seconds"); delay(5000); } } } void callback(char* topic, byte* payload, unsigned int length) { String message = ""; for (int i = 0; i < length; i++) { message += (char)payload[i]; } if (message == "on") { digitalWrite(2, HIGH); // 打开GPIO 2上的LED } else if (message == "off") { digitalWrite(2, LOW); // 关闭GPIO 2上的LED } } void setup() { Serial.begin(115200); setup_wifi(); client.setServer(mqtt_server, 1883); client.setCallback(callback); pinMode(2, OUTPUT); // 设置GPIO 2为输出模式 pinMode(4, OUTPUT); // 设置GPIO 4为输出模式 pinMode(5, OUTPUT); // 设置GPIO 5为输出模式 } void loop() { if (!client.connected()) { reconnect(); } client.loop(); } ``` #### 3. Python端代码实现 Python端可以作为MQTT客户端或服务器，用于发送控制命令。以下是Python端的代码示例： ```python import paho.mqtt.client as mqtt # MQTT 配置 broker_address = "你的MQTT代理地址" topic = "led/control" # MQTT 连接回调函数 def on_connect(client, userdata, flags, rc): print(f"Connected with result code {rc}") # 初始化MQTT客户端 client = mqtt.Client() client.on_connect = on_connect # 连接到MQTT代理 client.connect(broker_address, 1883, 60) # 单个LED开关功能 def control_led(state): client.publish(topic, state) # 流水灯效果 def running_light_effect(): states = ["on", "off"] gpios = ["gpio2", "gpio4", "gpio5"] # 假设GPIO映射为这些主题 for gpio in gpios: for state in states: client.publish(f"led/{gpio}", state) time.sleep(0.5) control_led("on") # 打开LED running_light_effect() # 启动流水灯效果 ``` #### 4. 功能说明 - **单个LED开关功能**：通过发布`on`或`off`消息到指定的主题（如`led/control`），可以控制单个LED灯的开关状态[^2]。 - **流水灯效果**：通过循环发布不同的GPIO状态，实现流水灯的效果。每个LED灯依次点亮并熄灭，形成流动的视觉效果[^3]。 #### 5. 注意事项 - 确保ESP32和Python端使用的MQTT代理地址一致。 - GPIO引脚编号需要根据实际硬件连接进行调整。 - 如果使用云MQTT代理，需注意网络稳定性及安全性。