如何使用gstreamer播放原始数据？

#include <gst/gst.h>

typedef struct {
    GstElement *pipeline;
    GstElement *appsrc;
} CustomData;

static void prepare_buffer(GstElement *appsrc, guint size, CustomData *data) {
    // 准备数据，将数据提供给appsrc元素
    // 数据可以从文件、网络等来源获取，这里以一个数组为例
    gsize len;
    guchar *buffer = malloc(size);

    // 填充buffer...

    // 将数据提交给appsrc元素
    GstBuffer *gstBuffer = gst_buffer_new_wrapped(buffer, len);
    g_signal_emit_by_name(appsrc, "push-buffer", gstBuffer, NULL);
}

static void on_need_data(GstElement *appsrc, guint unused_size, CustomData *data) {
    // 当gstreamer需要数据时，调用此回调函数
    prepare_buffer(appsrc, unused_size, data);
}

int main(int argc, char *argv[]) {
    CustomData data;
    GstBus *bus;
    GstMessage *msg;
    GstStateChangeReturn ret;

    gst_init(&argc, &argv);

    // 创建pipeline
    data.pipeline = gst_pipeline_new("audio-player");

    // 创建appsrc元素
    data.appsrc = gst_element_factory_make("appsrc", "audio-source");

    // 创建decodebin元素
    GstElement *decodebin = gst_element_factory_make("decodebin", "decodebin");

    // 添加元素到pipeline
    gst_bin_add_many(GST_BIN(data.pipeline), data.appsrc, decodebin, NULL);

    // 连接appsrc和decodebin元素
    gst_element_link(data.appsrc, decodebin);

    // 设置appsrc元素的回调函数
    g_signal_connect(data.appsrc, "need-data", G_CALLBACK(on_need_data), &data);

    // 启动pipeline
    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;
    }

    // 进入消息循环
    bus = gst_element_get_bus(data.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:
                // 不处理其他消息
                break;
        }
        gst_message_unref(msg);
    }

    // 停止pipeline
    gst_element_set_state(data.pipeline, GST_STATE_NULL);
    gst_object_unref(data.pipeline);
    return 0;
}