如何在断开RTSP摄像头后自动关闭Gstreamer的autovideosink？

核心原因 #

断开摄像头连接后，rtspsrc会抛出网络错误，但默认不会主动向下游发送EOS（End-of-Stream）信号，导致autovideosink一直处于播放状态无法自动关闭。单纯设置超时属性不生效，通常是因为没有配合总线消息监听来处理错误事件。

解决步骤 #

1. 正确配置rtspsrc超时属性 #

设置rtspsrc的timeout（单位：纳秒）和tcp-timeout属性，确保无数据时触发错误信号。例如设置5秒超时：

rtspsrc location=rtsp://your-cam-addr timeout=5000000000 tcp-timeout=5000000000

2. 监听总线消息处理错误与EOS #

通过GStreamer总线捕获rtspsrc抛出的错误消息，在回调中主动发送EOS信号给管道，触发下游组件正常停止。

Python示例代码

import gi
gi.require_version('Gst', '1.0')
from gi.repository import Gst, GObject

Gst.init(None)

# 构建管道
pipeline = Gst.parse_launch(
    "rtspsrc location=rtsp://your-cam timeout=5000000000 ! "
    "rtph264depay ! h264parse ! avdec_h264 ! autovideosink"
)

# 监听总线消息
bus = pipeline.get_bus()
bus.add_signal_watch()

def on_bus_message(bus, message):
    msg_type = message.type
    if msg_type == Gst.MessageType.ERROR:
        err, debug = message.parse_error()
        print(f"RTSP连接错误: {err.message}")
        # 发送EOS信号让管道正常终止
        pipeline.send_event(Gst.Event.new_eos())
    elif msg_type == Gst.MessageType.EOS:
        print("管道已终止，关闭视频窗口")
        pipeline.set_state(Gst.State.NULL)
        # 退出主循环（如果需要）
        loop.quit()

bus.connect("message", on_bus_message)

# 启动管道
pipeline.set_state(Gst.State.PLAYING)

# 运行主循环
loop = GObject.MainLoop()
try:
    loop.run()
except KeyboardInterrupt:
    pass

# 清理资源
pipeline.set_state(Gst.State.NULL)

C语言示例代码

#include <gst/gst.h>

static gboolean bus_callback(GstBus *bus, GstMessage *msg, gpointer user_data) {
    GMainLoop *loop = (GMainLoop*)user_data;
    switch (GST_MESSAGE_TYPE(msg)) {
        case GST_MESSAGE_ERROR: {
            GError *err;
            gchar *debug_info;
            gst_message_parse_error(msg, &err, &debug_info);
            g_printerr("错误: %s\n", err->message);
            g_clear_error(&err);
            g_free(debug_info);
            // 发送EOS终止管道
            gst_element_send_event(GST_ELEMENT(user_data), gst_event_new_eos());
            break;
        }
        case GST_MESSAGE_EOS:
            g_print("管道已结束，关闭视频窗口\n");
            g_main_loop_quit(loop);
            break;
        default:
            break;
    }
    return TRUE;
}

int main(int argc, char *argv[]) {
    GstElement *pipeline;
    GstBus *bus;
    GMainLoop *loop;

    gst_init(&argc, &argv);
    loop = g_main_loop_new(NULL, FALSE);

    // 构建管道
    pipeline = gst_parse_launch(
        "rtspsrc location=rtsp://your-cam timeout=5000000000 ! "
        "rtph264depay ! h264parse ! avdec_h264 ! autovideosink",
        NULL
    );

    // 设置总线监听
    bus = gst_element_get_bus(pipeline);
    gst_bus_add_watch(bus, bus_callback, loop);
    gst_object_unref(bus);

    // 启动管道
    gst_element_set_state(pipeline, GST_STATE_PLAYING);
    g_main_loop_run(loop);

    // 清理资源
    gst_element_set_state(pipeline, GST_STATE_NULL);
    gst_object_unref(pipeline);
    g_main_loop_unref(loop);

    return 0;
}

3. 关键注意事项 #

• 超时单位必须是纳秒，如果设置成毫秒或秒会导致超时不触发。
• 必须发送EOS信号：仅停止管道状态可能无法让autovideosink正常释放窗口资源，发送EOS能让下游组件按流程关闭。
• 部分RTSP摄像头可能需要额外配置drop-on-latency或buffer-mode，确保断开后rtspsrc能快速检测到异常。

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