Go语言使用GStreamer时appsink性能远低于filesink问题咨询

你遇到的性能差距是代码实现问题和GStreamer默认配置共同导致的，核心原因有三个：

• 重复IO开销：当前NewSampleFunc中每次触发都调用os.WriteFile，该函数会执行打开文件、覆盖写入、关闭文件的完整流程。WAV编码后的数据会拆分为多个GstBuffer分批到达sink，反复的系统调用开销远高于filesink保持单文件句柄流式写入的开销，同时重复覆盖写入还会导致最终输出的WAV文件不完整。
• 时钟同步配置差异：GStreamer所有sink组件默认开启sync属性，会按照音频的时钟速率消费数据，强制以实时播放速度处理，不适合转码场景。而filesink默认会关闭sync属性适配离线转码，这是最常见的性能差距来源。
• 跨语言调用开销：appsink的回调需要从GStreamer的C层跳转到Go层，每次拉取样本、拷贝字节都有额外开销，逐样本处理时会被放大；而filesink完全在C层处理数据，没有这类额外开销。

按照以下步骤修改代码即可将appsink的性能拉平到和filesink接近的水平：

1. 调整文件写入逻辑：在回调外提前打开一次文件，拿到持久化的文件句柄，每次回调仅追加写入字节，流结束时再关闭文件，避免重复的文件打开关闭开销。
2. 关闭appsink的时钟同步：获取到sink元素后设置sync属性为false，让转码流程尽可能快运行。
3. （可选）开启批量缓冲：设置appsink的buffer-list属性，批量接收多个样本后再一次性写入，进一步减少跨语言调用和IO次数。

func createPipeline() (*gst.Pipeline, error) {
    gst.Init(nil)

    pipeline, err := gst.NewPipelineFromString(
        "appsrc name=src ! decodebin ! audioresample ! audioconvert ! audio/x-raw,format=S16LE,rate=16000 ! wavenc ! appsink name=sink")
    if err != nil {
        return nil, err
    }

    srcElem, err := pipeline.GetElementByName("src")
    if err != nil {
        return nil, err
    }
    src := app.SrcFromElement(srcElem)
    src.SetCallbacks(&app.SourceCallbacks{
        NeedDataFunc: func(self *app.Source, _ uint) {
            bytes, _ := os.ReadFile("/tmp/a.mp3")
            buffer := gst.NewBufferFromBytes(bytes)
            self.PushBuffer(buffer)
            src.EndStream()
        },
    })

    sinkElem, err := pipeline.GetElementByName("sink")
    if err != nil {
        return nil, err
    }
    sink := app.SinkFromElement(sinkElem)
    // 关闭时钟同步，适配离线转码场景
    err = sink.Set("sync", false)
    if err != nil {
        return nil, err
    }

    // 提前打开输出文件，仅做一次初始化
    outFile, err := os.OpenFile("a.wav", os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0644)
    if err != nil {
        return nil, err
    }

    sink.SetCallbacks(&app.SinkCallbacks{
        NewSampleFunc: func(sink *app.Sink) gst.FlowReturn {
            sample := sink.PullSample()
            if sample == nil {
                // 流结束时关闭文件句柄
                _ = outFile.Close()
                return gst.FlowEOS
            }
            // 追加写入当前样本的字节数据
            buf := sample.GetBuffer()
            _, _ = outFile.Write(buf.Bytes())
            return gst.FlowOK
        },
    })

    return pipeline, nil
}

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