NodeMCU ESP8266与Python建立Socket连接延迟过高问题优化咨询

你的问题根源非常明确：每次控制循环都创建并销毁TCP连接。TCP协议建立连接需要三次握手、断开需要四次挥手，这些额外的网络交互就是你看到的延迟来源——在实时遥控场景里，这种短连接模式完全不适用，必须改用**长连接（Persistent TCP Connection）**来消除连接开销。

下面是针对两端代码的具体修改方案：

一、Python端代码修改（改用长连接，保持持续通信） #

原来的代码每次循环都等待新连接、发指令就断开，我们改成只建立一次连接，之后复用这个连接发送指令，只有连接异常时才重新建立：

import socket
import time

# 初始化控制指令字典（这里假设你会在其他逻辑中更新这个字典）
dictionary = {'func': 'F', 'l': 0}
port = 1235  # 单端口足够，除非你需要控制多台独立设备

# 创建Socket并启动监听
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind(('0.0.0.0', port))
s.listen(1)
print(f"等待ESP8266连接到端口 {port}...")

# 建立初始长连接
client, addr = s.accept()
client.settimeout(30)  # 设置超时，避免连接挂死无响应
print(f"已与 {addr} 建立连接")

try:
    while True:
        then = time.time()
        # 获取最新的控制指令
        current_cmd = dictionary
        print(f"发送指令: {current_cmd['func']}")
        # 发送指令（用sendall确保完整发送）
        client.sendall(bytes(current_cmd['func'], encoding='utf8'))
        
        now = time.time()
        print(f"本次指令耗时: {now - then:.4f}秒")
        # 根据你的遥控频率调整延迟，避免指令发送过于频繁
        time.sleep(0.1)
except (socket.timeout, ConnectionResetError, BrokenPipeError):
    # 连接异常时自动重连
    print("连接断开，重新等待设备连接...")
    client.close()
    client, addr = s.accept()
    client.settimeout(30)
    print(f"重新与 {addr} 建立连接")
except KeyboardInterrupt:
    # 手动终止程序时清理资源
    print("程序终止")
    client.close()
    s.close()

Python端修改说明： #

• 移除了多端口逻辑（单端口足够支持单台机器人的长连接通信）
• 仅在程序启动时接受一次连接，后续所有指令都复用该连接
• 增加异常捕获，处理连接超时、断开等异常情况，实现自动重连
• 增加合理的循环延迟，避免指令发送过于频繁导致网络拥塞

二、NodeMCU ESP8266端代码修改（保持长连接，持续接收指令） #

原来的代码每次loop都重新连接、处理完就断开，我们改成只在连接失效时才重新连接，保持连接持续接收指令：

#include <Arduino.h>
#include <ESP8266WiFi.h>
#include <WiFiClient.h>

const uint16_t port = 1235;  // 与Python端端口保持一致
const char *host = "10.42.0.1";
WiFiClient client;

// 电机引脚定义（用有意义的变量名提升可读性）
const int MOTOR_POS = 0;
const int MOTOR_NEG = 2;

// 非阻塞电机控制变量
unsigned long motor_start_time = 0;
bool motor_running = false;

void setup() {
    pinMode(LED_BUILTIN, OUTPUT);
    pinMode(MOTOR_POS, OUTPUT);
    pinMode(MOTOR_NEG, OUTPUT);
    
    // 初始化引脚状态
    digitalWrite(LED_BUILTIN, LOW);
    digitalWrite(MOTOR_POS, LOW);
    digitalWrite(MOTOR_NEG, LOW);
    
    Serial.begin(9600);
    Serial.println("Connecting to WiFi...");
    
    WiFi.mode(WIFI_STA);
    WiFi.begin("Anthrax-Inspiron-5580", "x8XDXYnq");
    
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");
    }
    Serial.println("\nWiFi Connected!");
    digitalWrite(LED_BUILTIN, HIGH);
    
    // 建立初始服务器连接
    connect_to_server();
}

// 封装服务器连接逻辑，方便重连调用
void connect_to_server() {
    Serial.printf("Connecting to %s:%d...\n", host, port);
    while (!client.connect(host, port)) {
        Serial.println("Connection failed, retrying in 1s...");
        delay(1000);
    }
    Serial.println("Connected to server!");
}

void loop() {
    // 连接断开时自动重连
    if (!client.connected()) {
        connect_to_server();
    }
    
    // 持续读取服务器发送的指令
    while (client.available() > 0) {
        char cmd = client.read();
        Serial.printf("Received command: %c\n", cmd);
        
        // 启动电机（替代原来的阻塞delay）
        if (cmd == 'H') {
            digitalWrite(MOTOR_NEG, HIGH);
            digitalWrite(MOTOR_POS, LOW);
        } else {
            digitalWrite(MOTOR_POS, HIGH);
            digitalWrite(MOTOR_NEG, LOW);
        }
        motor_start_time = millis();
        motor_running = true;
    }
    
    // 非阻塞电机停止逻辑（7秒后自动停转）
    if (motor_running && millis() - motor_start_time >= 7000) {
        digitalWrite(MOTOR_POS, LOW);
        digitalWrite(MOTOR_NEG, LOW);
        motor_running = false;
        Serial.println("Motor stopped");
    }
}

ESP8266端修改说明： #

• 封装了connect_to_server()函数，简化重连逻辑
• 仅在连接失效时才重新建立连接，保持长连接状态
• 移除了原代码中主动断开连接的client.stop()调用
• 核心优化：用非阻塞的millis()替代delay(7000)，避免电机运行期间完全阻塞程序，导致无法接收新指令、错过边界控制信号

额外优化建议 #

1. 结构化指令格式：可以改用JSON或固定长度二进制格式传输指令，比如{"cmd":"H","duration":7000}，提升指令的扩展性和可靠性
2. 心跳机制：两端定期发送心跳包，检测连接是否正常，避免连接静默断开而未察觉
3. WiFi信号优化：确保ESP8266的WiFi信号稳定，弱信号会显著增加传输延迟
4. 缓冲区调整：可以适当调整Socket的发送/接收缓冲区大小，提升传输效率

内容的提问来源于stack exchange，提问作者Sahaj Mistry