你有没有遇到过这样的场景设备已经部署在现场突然发现固件有个关键 bug 需要修复或者需要增加新功能但设备分布在各地不可能一个个手动烧录。这时候OTA空中升级就成了救命稻草。在 ESP32 生态中OTA 功能已经相当成熟但大多数教程都集中在 HTTP/HTTPS 方式。今天我要聊的是一个相对小众但很实用的方案TCP OTA 升级。与 HTTPS OTA 相比TCP OTA 的优势在于协议更轻量、控制更灵活特别适合内网环境或对安全性要求不是极端苛刻的场景。更重要的是TCP 连接让你可以完全掌控数据传输的每个环节从握手到分包从重传到校验。1. 为什么在 HTTPS OTA 之外还需要 TCP OTAESP-IDF 官方文档重点介绍了 HTTPS OTA这确实是生产环境的推荐方案。但 TCP OTA 在某些场景下有其独特价值。1.1 协议开销与灵活性差异HTTPS 在 HTTP 基础上增加了 TLS 加密层这带来了安全性但也增加了协议开销。每个请求都有完整的 HTTP 头部加上 TLS 握手和加密解密过程对资源有限的嵌入式设备来说是不小的负担。TCP 则是纯粹的字节流传输你可以自定义最简单的协议格式[固件大小(4字节)][固件数据(n字节)][校验和(4字节)]这种极简的协议意味着更少的内存占用和更快的传输速度。在局域网环境下安全性可能不是首要考虑因素此时 TCP 的轻量优势就体现出来了。1.2 控制粒度不同HTTPS OTA 使用 ESP-IDF 提供的esp_https_otaAPI虽然方便但封装层次较高。如果你想实现自定义的重试机制、进度显示、断点续传等高级功能就需要在框架限制内工作。TCP OTA 则完全不同——你就是协议的设计者。你可以决定如何分包固定大小包还是可变长度包如何确认每包确认还是批量确认如何重传超时重传还是选择性重传如何校验CRC32、MD5 还是 SHA256这种控制力在特殊应用场景中非常有用比如在信号不稳定的环境中需要更激进的重传策略。1.3 部署环境适应性HTTPS 需要证书验证这在公网环境下是必要的但在内网环境中可能显得繁琐。TCP OTA 可以快速搭建测试环境适合开发调试阶段使用。2. TCP OTA 的核心架构设计一个完整的 TCP OTA 系统需要客户端ESP32和服务器端配合工作。我们先从整体架构入手。2.1 客户端状态机设计ESP32 端的 OTA 过程可以抽象为有限状态机typedef enum { OTA_STATE_IDLE, // 空闲状态 OTA_STATE_CONNECTING, // 连接服务器 OTA_STATE_HANDSHAKE, // 协议握手 OTA_STATE_DOWNLOADING, // 下载固件 OTA_STATE_VALIDATING, // 校验固件 OTA_STATE_SWITCHING, // 切换分区 OTA_STATE_SUCCESS, // 升级成功 OTA_STATE_FAILED // 升级失败 } ota_state_t;每个状态都要有明确的进入条件、处理逻辑和退出条件。比如在DOWNLOADING状态需要处理数据接收、写入 Flash、进度更新等任务。2.2 服务器端职责划分服务器端通常运行在 PC 或云服务器上主要职责包括监听客户端连接请求验证客户端身份可选发送固件元数据大小、版本等分段发送固件数据处理客户端的确认和重传请求最终确认升级结果2.3 通信协议设计要点虽然协议可以完全自定义但有几个关键点需要考虑握手阶段需要交换基本信息// 客户端 - 服务器 typedef struct { uint32_t magic; // 魔数如 0x4F544131 (OTA1) uint32_t fw_size; // 当前固件大小 char version[16]; // 当前版本号 } ota_handshake_req_t; // 服务器 - 客户端 typedef struct { uint32_t magic; // 响应魔数 uint32_t new_fw_size; // 新固件大小 uint32_t packet_size; // 建议的包大小 char new_version[16]; // 新版本号 } ota_handshake_resp_t;数据传输阶段需要可靠的机制typedef struct { uint32_t seq_num; // 序列号 uint32_t data_len; // 数据长度 uint8_t data[]; // 可变长度数据 } ota_data_packet_t; typedef struct { uint32_t ack_seq; // 确认的序列号 uint32_t checksum; // 可选的数据校验 } ota_ack_packet_t;3. ESP32 端实现详解现在我们来深入 ESP32 端的代码实现这是整个系统的核心。3.1 网络连接管理首先需要建立 TCP 连接这里要注意错误处理和重连机制static esp_err_t tcp_connect_to_server(void) { struct sockaddr_in server_addr; int sockfd socket(AF_INET, SOCK_STREAM, 0); if (sockfd 0) { ESP_LOGE(TAG, Failed to create socket: errno %d, errno); return ESP_FAIL; } server_addr.sin_family AF_INET; server_addr.sin_port htons(CONFIG_OTA_SERVER_PORT); inet_pton(AF_INET, CONFIG_OTA_SERVER_IP, server_addr.sin_addr); if (connect(sockfd, (struct sockaddr*)server_addr, sizeof(server_addr)) ! 0) { ESP_LOGE(TAG, Socket connect failed: errno %d, errno); close(sockfd); return ESP_FAIL; } // 设置socket选项避免长时间等待 struct timeval timeout { .tv_sec 10, .tv_usec 0 }; setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, timeout, sizeof(timeout)); g_ota_ctx.sockfd sockfd; return ESP_OK; }3.2 Flash 分区操作OTA 的核心是操作 Flash 分区ESP-IDF 提供了完善的 APIstatic esp_err_t prepare_ota_partition(void) { // 查找下一个OTA分区非当前运行分区 const esp_partition_t* update_partition esp_ota_get_next_update_partition(NULL); if (update_partition NULL) { ESP_LOGE(TAG, Failed to find OTA update partition); return ESP_FAIL; } ESP_LOGI(TAG, Writing to partition subtype %d at offset 0x%x, update_partition-subtype, update_partition-address); // 擦除整个分区可选但建议执行 esp_err_t err esp_ota_begin(update_partition, OTA_SIZE_UNKNOWN, g_ota_ctx.update_handle); if (err ! ESP_OK) { ESP_LOGE(TAG, esp_ota_begin failed: 0x%x, err); return err; } g_ota_ctx.update_partition update_partition; return ESP_OK; }3.3 数据接收与写入这是最关键的环节需要处理网络接收和 Flash 写入的协调static esp_err_t receive_and_write_firmware(void) { uint8_t buffer[CONFIG_OTA_BUFFER_SIZE]; size_t total_received 0; uint32_t expected_size g_ota_ctx.expected_firmware_size; ESP_LOGI(TAG, Starting firmware download, expected size: %d bytes, expected_size); while (total_received expected_size) { // 计算本次需要接收的数据量 size_t remaining expected_size - total_received; size_t to_receive (remaining sizeof(buffer)) ? remaining : sizeof(buffer); // 从网络接收数据 ssize_t received recv(g_ota_ctx.sockfd, buffer, to_receive, 0); if (received 0) { if (errno EAGAIN || errno EWOULDBLOCK) { ESP_LOGW(TAG, Receive timeout, retrying...); vTaskDelay(pdMS_TO_TICKS(100)); continue; } ESP_LOGE(TAG, Network receive error: errno %d, errno); return ESP_FAIL; } if (received 0) { ESP_LOGE(TAG, Connection closed by server); return ESP_FAIL; } // 写入Flash esp_err_t err esp_ota_write(g_ota_ctx.update_handle, buffer, received); if (err ! ESP_OK) { ESP_LOGE(TAG, esp_ota_write failed: 0x%x, err); return err; } total_received received; // 更新进度每10%或至少每1MB报告一次 if (total_received % (expected_size / 10) 0 || total_received % (1024 * 1024) 0) { int progress (total_received * 100) / expected_size; ESP_LOGI(TAG, Download progress: %d%% (%d/%d bytes), progress, total_received, expected_size); } } g_ota_ctx.total_written total_received; return ESP_OK; }3.4 安全校验机制即使使用 TCP也要有基本的数据完整性校验static esp_err_t validate_firmware(void) { // 1. 大小校验 if (g_ota_ctx.total_written ! g_ota_ctx.expected_firmware_size) { ESP_LOGE(TAG, Size mismatch: expected %d, got %d, g_ota_ctx.expected_firmware_size, g_ota_ctx.total_written); return ESP_ERR_OTA_VALIDATE_FAILED; } // 2. 结束OTA过程并进行验证 esp_err_t err esp_ota_end(g_ota_ctx.update_handle); if (err ! ESP_OK) { if (err ESP_ERR_OTA_VALIDATE_FAILED) { ESP_LOGE(TAG, Image validation failed: image is corrupted); } else { ESP_LOGE(TAG, esp_ota_end failed: 0x%x, err); } return err; } // 3. 设置启动分区 err esp_ota_set_boot_partition(g_ota_ctx.update_partition); if (err ! ESP_OK) { ESP_LOGE(TAG, esp_ota_set_boot_partition failed: 0x%x, err); return err; } ESP_LOGI(TAG, Firmware validation successful, ready to reboot); return ESP_OK; }4. 服务器端实现策略服务器端可以用任何语言实现这里以 Python 为例说明关键逻辑。4.1 连接管理与协议处理import socket import struct import hashlib class OTAServer: def __init__(self, host0.0.0.0, port3232): self.host host self.port port self.firmware_path firmware.bin def handle_client(self, client_socket): try: # 读取握手请求 handshake_data client_socket.recv(24) if len(handshake_data) ! 24: print(Invalid handshake size) return magic, current_size, version struct.unpack(I20s, handshake_data) if magic ! 0x4F544131: # OTA1 print(Invalid magic number) return # 读取固件文件 with open(self.firmware_path, rb) as f: firmware_data f.read() # 发送握手响应 response struct.pack(III16s, 0x4F544132, # OTA2 len(firmware_data), 4096, # 包大小 b1.0.0) # 版本号 client_socket.send(response) # 分段发送固件 packet_size 4096 sequence 0 for i in range(0, len(firmware_data), packet_size): chunk firmware_data[i:i packet_size] packet_header struct.pack(II, sequence, len(chunk)) client_socket.send(packet_header chunk) # 等待确认 ack_data client_socket.recv(8) if len(ack_data) ! 8: print(Ack timeout) return ack_seq, struct.unpack(I, ack_data[:4]) if ack_seq ! sequence: print(fSequence mismatch: expected {sequence}, got {ack_seq}) return sequence 1 print(fSent packet {sequence}, progress: {i len(chunk)}/{len(firmware_data)}) print(Firmware transfer completed) except Exception as e: print(fError handling client: {e}) finally: client_socket.close()4.2 流量控制与错误恢复在实际部署中还需要考虑更复杂的控制逻辑def send_with_retry(self, client_socket, data, max_retries3): 带重传的数据发送 for attempt in range(max_retries): try: client_socket.send(data) # 设置超时等待确认 client_socket.settimeout(5.0) ack client_socket.recv(4) if ack bACK: return True elif ack bNAK: print(fReceived NAK, retrying... ({attempt 1}/{max_retries})) continue except socket.timeout: print(fTimeout, retrying... ({attempt 1}/{max_retries})) continue print(Max retries exceeded) return False5. 生产环境的关键考量把 TCP OTA 用于实际项目时有几个关键点需要特别注意。5.1 可靠性设计断点续传是必须的。可以在协议中增加偏移量字段typedef struct { uint32_t magic; uint32_t resume_offset; // 续传偏移量 uint32_t total_size; } ota_resume_req_t;看门狗处理也很重要OTA 过程可能耗时较长需要合理喂狗static void ota_task(void* pvParameter) { // 配置看门狗超时时间较长 esp_task_wdt_config_t wdt_config { .timeout_ms 30000, // 30秒 .idle_core_mask 0, .trigger_panic true }; esp_task_wdt_reconfigure(wdt_config); while (1) { esp_task_wdt_reset(); // 定期喂狗 // OTA 处理逻辑... } }5.2 安全增强虽然 TCP 本身不加密但可以增加应用层安全措施简单身份验证// 握手时交换设备ID和令牌 typedef struct { uint32_t magic; char device_id[32]; char auth_token[32]; // ...其他字段 } ota_auth_req_t;数据校验除了 TCP 的校验和可以增加应用层校验// 每个数据包包含CRC32校验 typedef struct { uint32_t seq_num; uint32_t data_len; uint32_t crc32; uint8_t data[]; } ota_secure_packet_t;5.3 资源管理与监控内存使用监控OTA 过程内存使用较大需要监控static void check_memory_usage(void) { multi_heap_info_t info; heap_caps_get_info(info, MALLOC_CAP_8BIT); ESP_LOGI(TAG, Free memory: %d bytes, largest free block: %d bytes, info.total_free_bytes, info.largest_free_block); if (info.largest_free_block MIN_REQUIRED_MEMORY) { ESP_LOGW(TAG, Low memory condition detected); } }进度持久化将升级进度保存到 NVS防止意外重启后重头开始static esp_err_t save_ota_progress(uint32_t offset, uint32_t total_size) { nvs_handle_t handle; esp_err_t err nvs_open(ota_storage, NVS_READWRITE, handle); if (err ! ESP_OK) return err; err nvs_set_u32(handle, ota_offset, offset); if (err ESP_OK) { err nvs_set_u32(handle, ota_total, total_size); } nvs_commit(handle); nvs_close(handle); return err; }6. 调试与问题排查OTA 升级失败时需要有清晰的排查路径。6.1 常见问题分类连接类问题服务器地址/端口错误防火墙阻挡网络不稳定数据完整性问题Flash 写入错误网络包丢失校验和不匹配资源相关问题内存不足Flash 空间不够看门狗超时6.2 日志策略建立分级的日志系统便于问题定位#define OTA_DEBUG_LEVEL 2 // 0错误, 1信息, 2调试, 3详细 #define OTA_LOG(level, format, ...) do { \ if (level OTA_DEBUG_LEVEL) { \ ESP_LOGI(TAG, format, ##__VA_ARGS__); \ } \ } while(0) // 使用示例 OTA_LOG(3, Received packet %d, size %d, seq_num, data_len);6.3 恢复机制升级失败时要有安全的回退方案static esp_err_t rollback_if_needed(void) { if (esp_ota_get_boot_partition() ! esp_ota_get_running_partition()) { ESP_LOGW(TAG, Boot partition differs from running partition, attempting rollback); esp_err_t err esp_ota_set_boot_partition(esp_ota_get_running_partition()); if (err ESP_OK) { ESP_LOGI(TAG, Rollback successful); } else { ESP_LOGE(TAG, Rollback failed: 0x%x, err); } return err; } return ESP_OK; }TCP OTA 升级虽然不像 HTTPS OTA 那样开箱即用但它提供的灵活性和控制力在特定场景下非常有价值。关键在于理解每个环节的工作原理建立完善的错误处理机制并在实际部署前进行充分测试。从简单的内网工具到复杂的生产系统TCP OTA 都可以根据需求进行定制。这种自己掌握每一个字节的体验正是嵌入式开发的魅力所在。
