当前位置： 首页 > news >正文

GStreamer —— 2.3、Windows下Qt加载GStreamer库后运行 - “教程3:动态管道“（附：完整源码）

news 来源：原创 2025/6/26 16:09:45
运行效果（音频）

在这里插入图片描述

 

简介

     上一个教程演示了GStreamer 概念。本教程中的管在它设置为 playing 状态之前完全构建。这没关系。如果 我们没有采取进一步的行动，数据会到达 pipeline 的 pipeline 和 pipeline 将生成错误消息并停止。但 我们将采取进一步的行动…，它允许“动态”构建管道，如 信息变得可用，而不是拥有整体式管道 在应用程序开始时定义。您将掌握开始播放教程所需的知识。审查的要点 这将是：

          • 如何在链接元素时实现更精细的控制。

          • 如何收到有趣事件的通知，以便您及时做出反应。

          • 元素可以处于的各种状态。

 

GStreamer相关运行库
INCLUDEPATH += D:/Software/GStreamer/1.0/mingw_x86_64/include/gstreamer-1.0/gst
INCLUDEPATH += D:/Software/GStreamer/1.0/mingw_x86_64/include
INCLUDEPATH += D:/Software/GStreamer/1.0/mingw_x86_64/include/gstreamer-1.0
INCLUDEPATH += D:/Software/GStreamer/1.0/mingw_x86_64/include/glib-2.0
INCLUDEPATH += D:/Software/GStreamer/1.0/mingw_x86_64/lib/glib-2.0/include

LIBS += D:/Software/GStreamer/1.0/mingw_x86_64/lib/gstreamer-1.0.lib
LIBS += D:/Software/GStreamer/1.0/mingw_x86_64/lib/glib-2.0.lib
LIBS += D:/Software/GStreamer/1.0/mingw_x86_64/lib/gobject-2.0.lib

 

完整源码
#include <QCoreApplication>
#include <QDebug>

#include "gst.h"

/* 结构包含我们所有的信息，这样我们就可以将其传递给回调函数 */
typedef struct _CustomData
{
    GstElement *pipeline;
    GstElement *source;
    GstElement *convert;
    GstElement *resample;
    GstElement *sink;
} CustomData;

/* 附加信号处理器 */
static void pad_added_handler (GstElement *src, GstPad *pad, CustomData *data);

int main(int argc, char *argv[])
{
    /* 初始化GStreamer */
    gst_init (&argc, &argv);

    /* 创建元素 */
    CustomData data;
    data.source = gst_element_factory_make ("uridecodebin", "source");
    data.convert = gst_element_factory_make ("audioconvert", "convert");
    data.resample = gst_element_factory_make ("audioresample", "resample");
    data.sink = gst_element_factory_make ("autoaudiosink", "sink");

    /* 创建空管道 */
    data.pipeline = gst_pipeline_new ("test-pipeline");
    if (!data.pipeline || !data.source || !data.convert || !data.resample || !data.sink) { g_printerr ("Not all elements could be created.\n"); return -1; }

    /* 建造管道 */
    gst_bin_add_many (GST_BIN (data.pipeline), data.source, data.convert, data.resample, data.sink, NULL);
    if (!gst_element_link_many (data.convert, data.resample, data.sink, NULL))
    {
        g_printerr ("Elements could not be linked.\n");
        gst_object_unref (data.pipeline); return -1;
    }

    /* 设置播放的URI(需带有音频) */
    //g_object_set (data.source, "uri", "https://gstreamer.freedesktop.org/data/media/sintel_trailer-480p.webm", NULL);
    g_object_set (data.source, "uri", "rtsp://192.168.1.200", NULL);

    /* 连接到pad-add信号 */
    g_signal_connect (data.source, "pad-added", G_CALLBACK (pad_added_handler), &data);

    /* 开始播放 */
    GstStateChangeReturn ret = gst_element_set_state (data.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 (data.pipeline); return -1;
    }

    GstMessage *msg;
    gboolean terminate = FALSE;
    /* 从bus监听消息 */
    GstBus *bus = gst_element_get_bus (data.pipeline);
    do {
        // 从bus总线中获取下一个满足特定条件的消息
        msg = gst_bus_timed_pop_filtered (bus, GST_CLOCK_TIME_NONE, (GstMessageType)(GST_MESSAGE_STATE_CHANGED | 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);
                terminate = TRUE;
                break;
            case GST_MESSAGE_EOS:
                g_print ("End-Of-Stream reached.\n");
                terminate = TRUE;
                break;
            case GST_MESSAGE_STATE_CHANGED:
                /* 我们只对管道中的状态更改消息感兴趣 */
                if (GST_MESSAGE_SRC (msg) == GST_OBJECT (data.pipeline))
                {
                    GstState old_state, new_state, pending_state;
                    gst_message_parse_state_changed (msg, &old_state, &new_state, &pending_state);
                    g_print ("Pipeline state changed from %s to %s:\n", gst_element_state_get_name (old_state), gst_element_state_get_name (new_state));
                }
                break;
            default:
                /* 我们不应该来这里 */
                g_printerr ("Unexpected message received.\n");
                break;
            }
            gst_message_unref (msg);
        }
    } while (!terminate);

    /* Free resources */
    gst_object_unref (bus);
    gst_element_set_state (data.pipeline, GST_STATE_NULL);
    gst_object_unref (data.pipeline);
    return 0;
}

/* 此函数将由添加了hanle的信号调用 */
/*
	当source element最后获得足够的数据时，它就会自动生成source pad，并且触令“pad-added”信号。这样回调就会被调用了;
	
	static void pad_added handler (GstElement *src, GstPad *new_pad, CustomData *data)说明: 
		src是触发这个信号的GstElement。在这个例子中就是uridecodebin，也是我们唯一注册的信号。
		new_pad是加到src上的pad。通常来说，是我们需要连接的pad。
		data指针是跟随信号一起过来的参数,在这个例子中传递的是CustomData指针。
*/
static void pad_added_handler (GstElement *src, GstPad *new_pad, CustomData *data)
{
    GstPad *sink_pad = gst_element_get_static_pad (data->convert, "sink");
    g_print ("Received new pad '%s' from '%s':", GST_PAD_NAME (new_pad), GST_ELEMENT_NAME (src));

    /* 如果我们的转换器已经链接，我们在这里什么也不用做 */
    if (gst_pad_is_linked (sink_pad)) { g_print ("We are already linked. Ignoring.\n"); goto exit; }

    /* 检查新pad的类型 */
    GstCaps *new_pad_caps = gst_pad_get_current_caps (new_pad);
    GstStructure *new_pad_struct = gst_caps_get_structure (new_pad_caps, 0);
    const gchar *new_pad_type = gst_structure_get_name (new_pad_struct);
    if (!g_str_has_prefix (new_pad_type, "audio/x-raw")) {  g_print ("It has type '%s' which is not raw audio. Ignoring.\n", new_pad_type); goto exit;  }

    /* 尝试链接 */
    GstPadLinkReturn ret = gst_pad_link (new_pad, sink_pad);
    if (GST_PAD_LINK_FAILED (ret))
    {
        g_print ("Type is '%s' but link failed.\n", new_pad_type);
    }
    else
    {
        g_print ("Link succeeded (type '%s').\n", new_pad_type);
    }

exit:
    /* 如果我们有新pad的caps，请不要参考 */
    if (new_pad_caps != NULL){gst_caps_unref (new_pad_caps);}

    /* 减小引用计数sink_pad */
    gst_object_unref (sink_pad);
}

 

关注

笔者 - jxd

相关文章：

  • 水资源论证网站建设百度收录平台
  • 网站建设现状分析关键词排名方法
  • 二级域名做很多网站新闻投稿
  • 旅游网站需求分析武汉seo网站排名优化公司
  • 成都今日疫情增加seo网站推广批发
  • .东莞网站建设百度网盘提取码入口
  • Redis7——进阶篇（三）
  • LLM实践——DeepSeek技术报告学习（含实现逻辑梳理）
  • 腾讯云物联网平台（IoT Explorer）设备端使用
  • 【练习】【链表】力扣热题100 141. 环形链表
  • 汽车免拆诊断案例 | 2023款丰田雷凌汽油版车行驶中偶尔出现通信故障
  • 八、Redis 过期策略与淘汰机制：深入解析与优化实践
  • C语言-指针
  • android_viewtracker 原理
  • Vue的简单入门 三
  • Qt 坐标体系：逻辑坐标与物理坐标的区别与实践
  • SCI期刊推荐 | 免版面费 | 计算机领域：信息系统、软件工程、自动化和控制
  • Scala 中 val 和对象内部状态的关系
  • 如何搭建本地LLM的应用和开发
  • VBA信息获取与处理第五节:如何在单个工作表中查找某个给定值
  • 通往 AI 之路：Python 机器学习入门-机器学习基本概念
  • C/C++ 内存管理
  • 马斯克：AI游戏前景无限
  • 大模型+知识图谱：重塑企业制度标准管理
  • C++方向的面经
  • Self-Supervised Prompt Optimization