6

我正在使用 gstreamer 通过网络传输音频。我的目标看似简单：将传入流预缓冲到某个时间/字节阈值，然后开始播放。我可能忽略了 gstreamer 的一个非常简单的功能，但到目前为止，我还没有找到一种方法来做到这一点。

我的（简化的）管道如下所示udpsrc -> alsasink：到目前为止，我为实现目标所做的所有尝试都是在两者之间使用队列元素：

  1. 在两者之间添加一个队列元素。
  2. 使用该min-threshold-time物业。这实际上可行，但问题是，它使所有传入数据在队列中花费指定的最短时间，而不仅仅是开始，这不是我想要的。
  3. 为了解决前面的问题，我尝试让队列在数据第一次进入音频接收器时通知我的代码，认为这是取消我之前设置的 min-time 属性的时间，从而实现“预缓冲”行为。

这是我尝试过的代码的大致等价物：

def remove_thresh(pad, info, queue):
    pad.remove_data_probe(probe_id)
    queue.set_property("min-threshold-time", 0)

queue.set_property("min-threshold-time", delay)
queue.set_property("max-size-time", delay * 2)
probe_id = audiosink.get_pad("sink").add_data_probe(remove_thresh, queue)

这不起作用有两个原因：

  1. 我的回调比delay我提供的变量更早地被调用。
  2. 调用它后，存储在队列中的所有数据都将丢失。播放开始时就好像队列根本不存在一样。

我认为我对这件事的工作原理有一个根本的误解。有谁知道我做错了什么，或者可以提供（可能）更好的方法来做到这一点？我在这里使用 python，但欢迎使用任何语言的任何解决方案。

谢谢。

4

2 回答 2

3

缓冲已经在 GStreamer 中实现。某些元素，如队列，能够构建此缓冲区并发布有关缓冲区级别（队列状态）的总线消息。

如果缓冲区级别不够高（通常是低于 100% 时），想要拥有更多网络弹性的应用程序应该监听这些消息并暂停播放。

因此，您所要做的就是在队列缓冲时将管道设置为PAUSED状态。在您的情况下，您只想缓冲一次，因此请为此使用任何逻辑（可能设置标志变量以仅在第一次暂停管道）。

  1. 将队列的“max-size-bytes”属性设置为您想要的值。
  2. 要么监听“溢出”信号以在缓冲区满时通知你，要么使用 gst_message_parse_buffering () 来查找缓冲级别。
  3. 缓冲区已满后，将管道设置为PLAYING状态，然后忽略所有进一步的缓冲消息。

最后，对于完整的流式传输示例，您可以参考本教程：https ://gstreamer.freedesktop.org/documentation/tutorials/basic/streaming.html 代码是 C 语言，但演练应该可以帮助您。

于 2013-04-22T04:35:27.173 回答
0

我在使用不同的管道（appsrc）时遇到了与您完全相同的问题，并且在花了几天时间试图找到一个优雅的解决方案（并最终得到与您发布的非常相似的代码）之后......我所做的只是切换标志is-live和False缓冲自动工作。（不需要min-threshold-time或其他任何东西）

希望这可以帮助。

于 2013-08-01T16:10:06.953 回答