ESP32-CAM 视频流传输实战：从局域网到外网接入

上传成功后，重启开发板，通过串口监视器查看 IP 地址，浏览器访问即可看到画面。

程序烧录

使用专用下载器

连接下载器后，点击编译验证，再点上传。确保工具选项中选择了正确的开发板和串口号。

使用 USB-TTL 转接器

若没有专用下载器，可用 CH340 等 USB-TTL 模块连接：

• VCC 接 5V
• GND 接 GND
• RXD 接 TXD
• TXD 接 RXD

注意：下载时需将 GPIO1 拉低至 GND，复位后再松开，进入 Boot 模式。

外网视频传输方案

局域网访问受限于内网 IP，若需外网查看，建议采用 TCP 透传方案：ESP32 作为客户端发送数据帧，服务器端接收并解码显示。

ESP32 端逻辑

核心思路是将图像分包发送，约定好起始标志 Frame Begin 和结束标志 Frame Over。

#include <Arduino.h>
#include <WiFi.h>
#include "esp_camera.h"

const char* ssid = "YOUR_WIFI_SSID";
const char* password = "YOUR_WIFI_PASSWORD";
const IPAddress serverIP(192, 168, 1, 104); // 服务器 IP
uint16_t serverPort = 18080;

WiFiClient client;

// 引脚定义略，参考上文
static camera_config_t camera_config = {
    .pin_pwdn = 32, .pin_reset = -1, .pin_xclk = 0,
    .pin_sscb_sda = 26, .pin_sscb_scl = 27,
    .pin_d7 = 35, .pin_d6 = 34, .pin_d5 = 39, .pin_d4 = 36,
    .pin_d3 = 21, .pin_d2 = 19, .pin_d1 = 18, .pin_d0 = 5,
    .pin_vsync = 25, .pin_href = 23, .pin_pclk = 22,
    .xclk_freq_hz = 20000000, .ledc_timer = LEDC_TIMER_0,
    .ledc_channel = LEDC_CHANNEL_0, .pixel_format = PIXFORMAT_JPEG,
    .frame_size = FRAMESIZE_QVGA, .jpeg_quality = 24, .fb_count = 1
};

void wifi_init() {
    WiFi.mode(WIFI_STA);
    WiFi.setSleep(false);
    WiFi.begin(ssid, password);
    while(WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");
    }
    Serial.println("WiFi Connected!");
}

esp_err_t camera_init() {
    esp_err_t err = esp_camera_init(&camera_config);
    if(err != ESP_OK) { Serial.println("Camera Init Failed"); return err; }
    Serial.println("Camera Init OK!");
    return ESP_OK;
}

void setup() {
    Serial.begin(115200);
    wifi_init();
    camera_init();
}

void loop() {
    if(client.connect(serverIP, serverPort)) {
        Serial.println("Connect Tcp Server Success!");
        while(true) {
            camera_fb_t * fb = esp_camera_fb_get();
            uint8_t* temp = fb->buf;
            if(!fb) {
                Serial.println("Camera Capture Failed");
            } else {
                client.print("Frame Begin");
                int leng = fb->len;
                int maxcache = 1430;
                int timess = leng / maxcache;
                int extra = leng % maxcache;
                
                for(int j = 0; j < timess; j++) {
                    client.write(fb->buf, maxcache);
                    fb->buf += maxcache;
                }
                client.write(fb->buf, extra);
                client.print("Frame Over");
                
                Serial.print("Send Frame Length: ");
                Serial.println(fb->len);
                
                esp_camera_fb_return(fb);
            }
            delay(20);
        }
    } else {
        Serial.println("Connect To Tcp Server Failed! After 10 Seconds Try Again!");
        delay(10000);
    }
}

Python 服务器端

服务器负责监听端口，接收分包数据，重组图片并显示。

import socket
import threading
import time
import numpy as np
import cv2

begin_data = b'Frame Begin'
end_data = b'Frame Over'

def handle_sock(sock, addr):
    temp_data = b''
    t1 = int(round(time.time() * 1000))
    while True:
        data = sock.recv(1430)
        if not data:
            break
        # 判断是否包含开始标志
        if data[0:len(begin_data)] == begin_data:
            data = data[len(begin_data):]
            # 循环接收直到遇到结束标志
            while data[-len(end_data):] != end_data:
                temp_data = temp_data + data
                data = sock.recv(1430)
            # 去除结束标志
            temp_data = temp_data + data[0:(len(data)-len(end_data))]
            
            receive_data = np.frombuffer(temp_data, dtype='uint8')
            r_img = cv2.imdecode(receive_data, cv2.IMREAD_COLOR)
            
            t2 = int(round(time.time() * 1000))
            fps = 1000 // (t2 - t1)
            cv2.putText(r_img, "FPS" + str(fps), (50, 50), cv2.FONT_HERSHEY_SIMPLEX, 1, (255, 0, 0), 2)
            cv2.imshow('server_frame', r_img)
            
            if cv2.waitKey(1) & 0xFF == ord('q'):
                break
            t1 = t2
            print("Received Data Size: " + str(len(temp_data)))
            temp_data = b''

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('192.168.1.104', 18080))
server.listen(5)
print('Listening on port 18080...')

while True:
    sock, addr = server.accept()
    client_thread = threading.Thread(target=handle_sock, args=(sock, addr))
    client_thread.start()

运行 Python 脚本前，请确保服务器 IP 与 ESP32 代码中的 serverIP 一致。这样就能突破内网限制，在任何有公网 IP 的地方查看监控画面了。