如何使用GStreamer播放PCM数据数组

How to play a PCM data array with GStreamer

本文关键字：数据 数组 PCM 播放 何使用 GStreamer      更新时间：2023-10-16

我是gstreamer的新手，我可以简单地使用gst-launch来播放这样的PCM文件：

$ gst-launch-1.0 filesrc location=output.pcm ! audio/x-raw, format=S16LE, 
channels=1, rate=16000 ! autoaudiosink

但是在我的应用程序中，我得到的是一个带有 PCM 原始数据的字符数组。谷歌之后，我知道我应该使用 appsrc 作为源，但测试代码根本没有输出。

是否有任何示例代码可以告诉我如何播放这个包含一个通道 16K PCM 原始数据的字符数组？

这里附上了我的测试代码：

std::ifstream file("output.pcm");
char data[22120];
file.read(data, 22120);
file.close();
std::cout << "read success";
GstElement *m_pipeline;
GstElement *m_source;
GMainLoop *m_loop;
GstBuffer *m_last_buffer;
GstElement *m_sink;
GstCaps *audioCaps;
gst_init(NULL, NULL);
audioCaps = gst_caps_new_simple("audio/x-raw", "format", G_TYPE_STRING, "S16LE", "rate", G_TYPE_INT, 16000,
                                "channels", G_TYPE_INT, 1, nullptr);
if (audioCaps == nullptr)
{
    std::cout << "error" << std::endl;
    return 0;
}
m_source = gst_element_factory_make("appsrc", "source");
m_sink = gst_element_factory_make("autoaudiosink", "sink");
m_pipeline = gst_pipeline_new("audio-pipeline");
m_loop = g_main_loop_new(NULL, FALSE);
gst_bin_add_many(GST_BIN(m_pipeline), m_source, m_sink, NULL);
gst_element_link_many(m_source, m_sink, NULL);
gst_app_src_set_caps(GST_APP_SRC(m_source), audioCaps);
gst_caps_unref(audioCaps);
GstBuffer *buffer = gst_buffer_new_allocate(NULL, 22120, NULL);
gst_buffer_fill(buffer, 0, data, 22120);
gst_app_src_push_buffer(GST_APP_SRC(m_source), buffer);
gst_element_set_state(m_pipeline, GST_STATE_PLAYING);
g_main_loop_run(m_loop);
/* free resources */
gst_element_set_state(m_pipeline, GST_STATE_NULL);
gst_object_unref(m_pipeline);
第

1 步。要创建我自己的输入测试文件：

gst-launch-1.0 audiotestsrc num-buffers=10 ! audio/x-raw, channels=1, rate=16000, format=S16LE ! filesink location=out.raw

第 2 步。下面是一个示例应用程序：

#include <gst/gst.h>
#include <gst/app/gstappsrc.h>
#include <stdio.h>
int main()
{
    gst_init(NULL, NULL);
    GstElement* p = gst_parse_launch("appsrc name=src ! audio/x-raw, channels=1, rate=16000, format=S16LE ! autoaudiosink", NULL);
    GstElement* appsrc = gst_bin_get_by_name(GST_BIN(p), "src");
    GstBus* bus = gst_pipeline_get_bus(GST_PIPELINE(p));
    gst_element_set_state(p, GST_STATE_PLAYING);
    FILE* fp = fopen("out.raw", "rb");
    for (int i  = 0; i < 10; i++) {
            gchar buf[2048];
            fread(buf, 2048, 1, fp);
            GstBuffer *buffer = gst_buffer_new_allocate(NULL, 2048, NULL);
            gst_buffer_fill(buffer, 0, buf, 2048);
            gst_app_src_push_buffer(GST_APP_SRC(appsrc), buffer);
    }
    gst_app_src_end_of_stream(GST_APP_SRC(appsrc));
    gst_bus_timed_pop_filtered(bus, GST_CLOCK_TIME_NONE, GST_MESSAGE_EOS);
    gst_element_set_state(p, GST_STATE_NULL);
    gst_object_unref(bus);
    gst_object_unref(appsrc);
    gst_object_unref(p);
    fclose(fp);
}

它通过使用gst_parse_launch()简化了一些事情。完整的管道创建和上限设置。

进一步简化，创建的示例文件为 2048 字节 * 10 个块。您不需要知道原始块大小（只要它是样本对齐的 - 1 个通道和 16 位为 2 个字节）。我只是不想检查文件的 EOF。

基本上，我认为您应该在发送任何数据之前将管道置于 PLAY 状态。

相关文章：