RK3588 MIPI 采集 OpenCV 处理硬件编码推流 WebRTC 低延迟播放

(保持此终端不关，另外打开新的终端)

第三步：核心 Python 脚本（rtsp 推流与处理）

新建一个 Python 脚本 stream.py。这段代码包含了降分辨率、防缓存延迟和调用 MPP 硬件编码的核心参数。

import cv2
import time

class FPSCounter:
    """FPS counter class"""
    def __init__(self, buffer_size=20):
        self.timestamps = []
        self.buffer_size = buffer_size

    def update(self):
        """Update FPS count"""
        current_time = time.time()
        self.timestamps.append(current_time)
        # Keep only recent timestamps
        if len(self.timestamps) > self.buffer_size:
            self.timestamps.pop(0)

    def get_fps(self):
        """Calculate current FPS"""
        if len(self.timestamps) < 2:
            return 0.0
        time_span = self.timestamps[-1] - self.timestamps[0]
        if time_span <= 0:
            return 0.0
        return (len(self.timestamps) - 1) / time_span

# 1. 配置读取摄像头的 GStreamer Pipeline (根据你的 MIPI 摄像头节点调整，这里假设是 /dev/video11)
# 强制设定分辨率和帧率，并转换为 BGR 格式给 OpenCV 处理
cap_pipeline = (
    "v4l2src device=/dev/video11 io-mode=2 ! "
    "video/x-raw, width=640, height=480, framerate=30/1, format=NV12 ! "
    "videoconvert ! video/x-raw, format=BGR ! "
    "appsink max-buffers=1 drop=true"
)

# 2. 配置推流的 GStreamer Pipeline
# appsrc 接收 OpenCV 的 BGR 图像，转为 NV12，交给 mpph264enc 硬编，然后推流给 MediaMTX
push_pipeline = (
    "appsrc is-live=true ! "
    "video/x-raw, format=BGR, width=640, height=480, framerate=30/1 ! "
    "videoconvert ! video/x-raw, format=NV12 ! "
    "mpph264enc bps=4000000 rc-mode=vbr ! "
    "h264parse ! "
    "rtspclientsink location=rtsp://127.0.0.1:8554/live protocols=tcp"
)

# 初始化视频读取
cap = cv2.VideoCapture(cap_pipeline, cv2.CAP_GSTREAMER)
if not cap.isOpened():
    print("错误：无法打开 MIPI 摄像头。请检查节点和 ISP 状态。")
    exit()

# 初始化视频推流器
out = cv2.VideoWriter(push_pipeline, cv2.CAP_GSTREAMER, 0, 30, (640, 480))
if not out.isOpened():
    print("错误：无法初始化 GStreamer 推流器。")
    exit()

print("成功启动采集和推流，按 'Ctrl+C' 停止。")
try:
    fps_counter = FPSCounter()
    while True:
        ret, frame = cap.read()
        if not ret:
            print("未能读取到画面")
            break

        # ==========================================
        # ★ 在这里加入你的 AI 推理代码 ★
        # ==========================================
        # 例如：
        # results = rknn_model.inference(frame)
        # frame = draw_bounding_boxes(frame, results)

        fps_counter.update()
        fps = fps_counter.get_fps()

        # 作为演示，我们在这里加上时间戳和 fps
        cv2.putText(frame, f"Time: {time.ctime()}", (30, 50), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 0, 255), 1)
        cv2.putText(frame, f"Fps: {fps}", (30, 100), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 0, 255), 1)

        # ==========================================
        # 将画好框的处理后图像，写入推流管道（由 mpp 硬件编码）
        out.write(frame)
except KeyboardInterrupt:
    print("停止推流...")
finally:
    cap.release()
    out.release()

运行脚本：python3 stream.py

第四步：如何在客户端观看与保存？

此时，你的 RK3588 已经变成了一个 IP 摄像头。假设你的板子局域网 IP 是 192.168.0.137。

1. 低延迟观看（网页直开） 直接在电脑/手机浏览器里输入：http://192.168.0.137:8889/live (这里的端口号在之前 MediaMTX 的输出中能看到)。利用 WebRTC 协议，延迟基本在百毫秒以内。

2. 在客户端无损录像（不需板端 CPU 占用） 想要在电脑上把刚才的监控视频存下来？只需要一行命令，直接将底层编好的 H.264 流封装成文件，完全不消耗客户端算力： 在电脑上安装 ffmpeg（windows / linux / mac 均可），运行：

ffmpeg -rtsp_transport tcp -i rtsp://192.168.0.137:8554/live -c copy -f mp4 record_video.mp4
# 注意这里的端口号选的是 8554（rtsp）

CPU 占用与延迟

以下是纯推流，基本没有图像处理的资源消耗。

延迟的话，体感上在 1 秒以内，没准确测过。所以实际上还有很大的优化空间。

避坑指南

分享几个过程中最容易卡住的问题：

1. 使用 gstreamer 无法打开摄像头
   • 原因：RK3588 的 V4L2 驱动在处理 MIPI 摄像头和 ISP 内存时，默认的 mmap 内存映射方式有时候在 GStreamer 中会引发异常（特别是在申请 buffer 时）
   • 解法：给 v4l2src 加上 io-mode=4（使用 DMABUF）或 io-mode=2（USERPTR）往往能瞬间解决问题。
2. MediaMTX 报错 invalid rtmp version (71)
   • 原因：进错端口了！用 HTTP 浏览器去访问了 1935 (RTMP) 或 8554 (RTSP) 端口。
   • 解法：浏览器观看必须要访问 8889 端口。
3. 推流成功了，但是画面全是'纯绿色'的
   • 原因：OpenCV 推入的画面分辨率和推流器配置的分辨率不匹配，导致内存错位；或者忘记启动 rkaiq ISP 服务导致画面全是空数据。
   • 解法：严格检查 cap_pipeline、cv2.VideoWriter 和 push_pipeline 三个地方的分辨率参数是否完全一致。
4. 延迟越来越大，跑久了像看回放
   • 原因：加入 AI 推理后处理速度跟不上采集速度，OpenCV 把旧画面全缓存在了内存里。
   • 解法：务必在读取管道末尾加上 appsink max-buffers=1 drop=true。

小贴士

我们直接传图像到 pc 端之所以会卡，只是因为图像没有经过压缩，网络传输速度不够。如果只是单纯想流畅的观看调试图像，可以直接用 opencv 自带的编码函数：

# 编码为 JPEG 格式
success, encoded_img = cv2.imencode(".jpg", img)

然后再通过 flask 之类的框架进行网络传输，好处是简单直接方便，只是性能不高。