GStreamer开发笔记（五）：gstreamer创建组件、管道和总线实现简单的播放器

雌鲳签 发表于 2025-6-9 10:31:35

前言

前面是自动构建管道。本篇实例化每个元素并将它们链接在一起来手动构建一个管道。
本篇创建管道分为：创建组件，连接组件，获取总线，阻塞提取需要的消息并处理。
Demo

管道图

我们创建了两个元素：videotestsrc和autovideosink。不创建过滤元件。因此，管道看起来如下：

连接源组件和接收组件程序

步骤一：初始化gst

步骤二：创建组件

使用gst_element_factory_make()创建新组件。第一个参数是要创建的元素类型（默认就有一些常见类型，可通过gstreamer工具获取所有可用类型的列表）。第二个参数是给这个特定实例起的名字。如果没有保留指针，为元素命名对于以后检索它们很有用（并且可以获得更有意义的调试输出）。但是，如果为名称传递NULL，GStreamer将为您提供一个唯一的名称。
代码创建了两个元素：videotestsrc和autovideosink。不创建过滤元件。因此，管道看起来如下：

[*]videotestsrc是一个源组件（它生成数据），用于创建测试视频模式。此元素可用于调试目的，通常在实际应用程序中找不到。
[*]autovideosink是一个接收组件（它消耗数据），它在窗口上显示它接收到的图像。根据操作系统的不同，存在几种具有不同功能的视频接收器。autovideosink会自动选择并实例化最佳的一个，因此不必担心细节，并且代码更加独立于平台。
步骤三：创建空管道

GStreamer中的所有元素通常必须包含在管道中才能使用，因为它负责一些时钟和消息传递功能。我们使用gst_pipeline_new()创建管道。
步骤四：管道连接组件，此处连接：源组件、接收组件

步骤五：修改源组件属性

步骤六：设置组件状态PALYING，开始播放

步骤七：获取bus总线，阻塞函数直至总线触发错误或流结束后继续

步骤八：处理返回消息

步骤九：释放资源

关键函数

gst_element_factory_make()

gst_element_factory_make 是 GStreamer 框架中的一个函数，用于创建 GStreamer 元素（Element）。GStreamer 是一个强大的多媒体框架，允许开发者构建媒体处理管道，而元素是这些管道的基本构建块。
GstElement* gst_element_factory_make(const gchar *factoryname, const gchar *name);

[*]参数一：要创建的元素的工厂名称。例如，如果想创建一个视频源元素，可以使用 “videotestsrc”
[*]参数二：为创建的元素指定一个名称。如果为NULL，GStreamer 会为该元素自动分配一个唯一的名称。
成功时：返回指向新创建元素的指针（GstElement*），失败时：返回NULL。
gst_pipeline_new()

gst_pipeline_new()是GStreamer框架中的一个函数，用于创建一个新的管道（Pipeline）。管道是 GStreamer 中用于连接和管理多个元素的核心结构，它定义了媒体数据从源到接收器的处理路径。
GstElement* gst_pipeline_new(const gchar *name);

[*]参数一：为创建的管道指定一个名称。如果为 NULL，GStreamer 会为管道自动分配一个唯一的名称。
成功时：返回指向新创建管道的指针（GstElement*），实际上是一个GstPipeline 类型的对象，但通常通过 GstElement 指针来引用。失败时：返回NULL。
gst_bin_add_many()

gst_bin_add_many()是GStreamer框架中的一个函数，用于将多个元素添加到一个GstBin（如GstPipeline）中。GstBin 是一个可以包含其他元素的容器，GstPipeline是GstBin的一种特殊类型，用于管理媒体处理流程。
guint gst_bin_add_many(GstBin *bin, GstElement *element_1, ..., NULL);

[*]参数一：指向目标 GstBin 的指针，通常是一个 GstPipeline。
[*]参数二（实际多个）：可变参数，GstElement* 类型，要添加到bin中的元素列表，可变参数允许一次添加多个元素，最后一个参数必须是 NULL，以指示参数列表的结束。
成功时：返回添加的元素数量（不包括最后的NULL）。失败时：如果任何元素无法添加，函数将返回 0，并且不会添加任何元素。
gst_element_link()

gst_element_link() 是 GStreamer 框架中的一个函数，用于将两个元素链接在一起，以便媒体数据可以在它们之间流动。在 GStreamer 管道中，元素通过“链接”来形成一个处理链，数据从源元素流向接收器元素，经过各种处理步骤。
gboolean gst_element_link(GstElement *src, GstElement *dest);

[*]参数一：指向源元素的指针，数据将从该元素流出。
[*]参数二：指向目标元素的指针，数据将流入该元素。
成功时：返回 TRUE。失败时：返回 FALSE。
Demo源码

#include <gst/gst.h>

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

// 步骤一：初始化gst
gst_init (&argc, &argv);

// 步骤二：创建组件
source = gst_element_factory_make("videotestsrc", "source");
sink = gst_element_factory_make("autovideosink", "sink");

// 步骤三：创建空管道
pipeline = gst_pipeline_new("test-pipeline");

if(!pipeline || !source || !sink)
{
   g_printerr("Not all elements could be created.\n");
   return -1;
}

// 步骤四：管道连接组件，此处连接：源组件、接收组件
gst_bin_add_many(GST_BIN(pipeline), source, sink, NULL);
if(gst_element_link(source, sink) != TRUE)
{
   g_printerr("Elements could not be linked.\n");
   gst_object_unref(pipeline);
   return -1;
}

// 步骤五：修改源组件属性
g_object_set(source, "pattern", 0, NULL);

// 步骤六：设置组件状态PALYING，开始播放
ret = gst_element_set_state(pipeline, GST_STATE_PLAYING);
if(ret == GST_STATE_CHANGE_FAILURE)
{
   g_printerr("Unable to set the pipeline to the playing state.\n");
   gst_object_unref(pipeline);
   return -1;
}

// 步骤七：获取bus总线，阻塞函数直至总线触发错误或流结束后继续
bus = gst_element_get_bus(pipeline);
msg = gst_bus_timed_pop_filtered(bus, GST_CLOCK_TIME_NONE, GST_MESSAGE_ERROR | GST_MESSAGE_EOS);

// 步骤八：处理返回消息
if(msg != NULL)
{
   GError *err;
   gchar *debug_info;

   switch(GST_MESSAGE_TYPE(msg))
   {
   case GST_MESSAGE_ERROR:
         gst_message_parse_error(msg, &err, &debug_info);
         g_printerr("Error received from element %s: %s\n",
                     GST_OBJECT_NAME(msg->src),
                     err->message);
         g_printerr("Debugging information: %s\n",
                     debug_info ? debug_info : "none");
         g_clear_error(&err);
         g_free(debug_info);
         break;
   case GST_MESSAGE_EOS:
         g_print("End-Of-Stream reached.\n");
         break;
   default:
         g_printerr("Unexpected message received.\n");
         break;
   }
   gst_message_unref(msg);
}

// 步骤九：释放资源
gst_object_unref(bus);
gst_element_set_state(pipeline, GST_STATE_NULL);
gst_object_unref(pipeline);
return 0;
} 工程模板v1.1.0

入坑

入坑一：无法连接g_type_check_instace_cast

问题

未定义库，无法连接
原因

这是gobject2.0库的
解决

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

页: [1]

程序园's Archiver

GStreamer开发笔记（五）：gstreamer创建组件、管道和总线实现简单的播放器