使用GStreamer播放AVI视频 自定义GstElement管线报错如何修复

核心问题原因 #

你当前的代码缺少完整的媒体处理链路，且参数配置、运行逻辑存在错误，具体问题如下：

• 管线元素链路缺失：filesrc仅负责读取本地文件的二进制数据，没有解复用、解码环节，无法直接将MP4封装的压缩数据输出到视频渲染器autovideosink
• filesrc参数配置错误：filesrc不支持file://协议头，location属性需要直接传入本地绝对路径
• 缺少GStreamer主循环：设置播放状态后程序直接退出，没有处理管线的生命周期消息，无法正常完成播放流程
• 静态链接逻辑不兼容动态Pad：解复用、解码类元素的输出Pad是动态生成的，不能用gst_element_link_many做静态链接

修复方案 #

推荐使用decodebin自动处理解复用、解码逻辑，通过监听pad-added信号完成动态链接，同时添加GStreamer总线消息循环处理播放事件。

修复后的代码如下：

#include <iostream>
#include <gst/gst.h>

// 动态Pad链接回调
static void pad_added_handler(GstElement *src, GstPad *new_pad, gpointer user_data) {
    GstElement *sink = (GstElement *)user_data;
    GstPad *sink_pad = gst_element_get_static_pad(sink, "sink");

    // 如果sink的Pad已经链接，直接返回
    if (gst_pad_is_linked(sink_pad)) {
        g_object_unref(sink_pad);
        return;
    }

    // 检查Pad的能力，只链接视频流
    GstCaps *caps = gst_pad_get_current_caps(new_pad);
    const gchar *media_type = gst_structure_get_name(gst_caps_get_structure(caps, 0));
    if (g_str_has_prefix(media_type, "video/")) {
        GstFlowReturn ret = gst_pad_link(new_pad, sink_pad);
        if (ret != GST_FLOW_OK) {
            g_warning("动态Pad链接失败");
        }
    }

    gst_caps_unref(caps);
    g_object_unref(sink_pad);
}

int main(int argc, char *argv[]) {
    GstElement *pipeline, *source, *decodebin, *sink;
    GstBus *bus;
    GstMessage *msg;

    gst_init(&argc, &argv);

    // 创建所有元素
    pipeline = gst_pipeline_new("my-pipeline");
    source = gst_element_factory_make("filesrc", "file-source");
    decodebin = gst_element_factory_make("decodebin", "decoder");
    sink = gst_element_factory_make("autovideosink", "sink");

    if (!pipeline || !source || !decodebin || !sink) {
        g_error("元素创建失败，请检查GStreamer插件安装是否完整");
        return -1;
    }

    // 配置文件路径，去掉file://前缀
    g_object_set(G_OBJECT(source), "location", "D:/workspace/rocket.mp4", NULL);

    // 把所有元素加入管线
    gst_bin_add_many(GST_BIN(pipeline), source, decodebin, sink, NULL);

    // 先静态链接filesrc和decodebin
    if (!gst_element_link(source, decodebin)) {
        g_warning("source和decodebin链接失败");
        gst_object_unref(pipeline);
        return -1;
    }

    // 监听decodebin的pad-added信号，动态链接到videosink
    g_signal_connect(decodebin, "pad-added", G_CALLBACK(pad_added_handler), sink);

    // 启动管线
    auto ret = gst_element_set_state(pipeline, GST_STATE_PLAYING);
    if (ret == GST_STATE_CHANGE_FAILURE) {
        g_printerr("无法将管线设置为PLAYING状态");
        gst_object_unref(pipeline);
        return -1;
    }

    // 监听总线消息，等待播放结束或者错误
    bus = gst_element_get_bus(pipeline);
    msg = gst_bus_timed_pop_filtered(bus, GST_CLOCK_TIME_NONE, (GstMessageType)(GST_MESSAGE_ERROR | GST_MESSAGE_EOS));

    // 资源释放
    if (msg != NULL) {
        gst_message_unref(msg);
    }
    gst_object_unref(bus);
    gst_element_set_state(pipeline, GST_STATE_NULL);
    gst_object_unref(pipeline);

    return 0;
}

额外注意事项 #

• 请确保你的系统已经安装了GStreamer的相关插件：gstreamer1.0-plugins-base、gstreamer1.0-plugins-good、gstreamer1.0-plugins-bad、gstreamer1.0-plugins-ugly，保证MP4格式的解复用、解码组件可用。
• 如果需要同时播放音频，可在管线中添加autoaudiosink，在pad_added_handler中判断音频流后链接到对应sink即可。

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