GStreamer技术咨询：如何在单端口接收并解复用多RTP流？

你的问题核心在于静态提前链接了尚未创建的Pad——rtpssrcdemux只会在收到新SSRC的RTP数据包时，才会动态生成对应的src_N Pad，而你在启动管道时就声明了demux.src_1，此时这个Pad根本不存在，GStreamer会因为无法完成链接而抛出streaming task paused, reason not-linked (-1)错误。

下面是具体的解决思路和实现方案：

核心原理：动态Pad链接 #

想要支持动态启停的多发送端，必须放弃静态声明所有可能的Pad，转而通过监听pad-added信号来处理新出现的流。当rtpssrcdemux检测到新的SSRC时，会触发pad-added信号，我们可以在这个信号的回调函数中，动态创建对应的解码输出分支并完成链接。

方案1：使用Python脚本实现灵活动态处理 #

如果想快速实现功能，GStreamer的Python绑定是最便捷的方式，以下是完整的示例代码：

import gi
gi.require_version('Gst', '1.0')
from gi.repository import Gst, GLib

# 初始化GStreamer
Gst.init(None)

def pad_added_callback(demux, new_pad, user_data):
    print(f"检测到新的流Pad: {new_pad.get_name()}")
    
    # 为新流创建解码输出分支
    depay = Gst.ElementFactory.make("rtpgstdepay", "depay")
    sink = Gst.ElementFactory.make("autoaudiosink", "sink")
    
    if not depay or not sink:
        print("无法创建所需元素")
        return
    
    # 将元素添加到管道
    user_data.add(depay, sink)
    depay.sync_state_with_parent()
    sink.sync_state_with_parent()
    
    # 链接新Pad到depay
    caps = new_pad.get_current_caps()
    if new_pad.link(depay.get_static_pad("sink")) != Gst.PadLinkReturn.OK:
        print("Pad链接失败")

def main():
    # 创建管道
    pipeline = Gst.Pipeline.new("multi-rtp-receiver")
    
    # 创建并配置udpsrc
    udpsrc = Gst.ElementFactory.make("udpsrc", "udpsrc")
    udpsrc.set_property("port", 5000)
    caps = Gst.Caps.from_string("application/x-rtp,media=application,clock-rate=90000,encoding-name=X-GST")
    udpsrc.set_property("caps", caps)
    
    # 创建rtpssrcdemux
    demux = Gst.ElementFactory.make("rtpssrcdemux", "demux")
    
    # 将元素添加到管道
    if not pipeline or not udpsrc or not demux:
        print("无法创建核心元素")
        return
    
    pipeline.add(udpsrc, demux)
    udpsrc.link(demux)
    
    # 监听pad-added信号
    demux.connect("pad-added", pad_added_callback, pipeline)
    
    # 启动管道
    pipeline.set_state(Gst.State.PLAYING)
    
    # 运行主循环
    loop = GLib.MainLoop()
    try:
        loop.run()
    except KeyboardInterrupt:
        pass
    
    # 清理资源
    pipeline.set_state(Gst.State.NULL)

if __name__ == "__main__":
    main()

方案2：使用gst-launch配合动态链接技巧（局限较多） #

如果你坚持想用gst-launch命令行，可以利用gst-launch的signal::pad-added信号绑定，但灵活性较差，示例如下：

gst-launch-1.0 -vvtcm udpsrc port=5000 caps="application/x-rtp,media=application,clock-rate=90000,encoding-name=X-GST" ! rtpssrcdemux name=demux

之后你可以通过GStreamer的调试工具（比如gst-inspect-1.0 rtpssrcdemux查看信号详情），结合外部脚本监听pad-added信号并动态添加解码分支，但这种方式远不如Python脚本直观可控。

额外注意事项 #

• 发送端SSRC必须唯一：确保每个发送端使用不同的ssrc参数（比如第一个用ssrc=1，第二个用ssrc=2），这样rtpssrcdemux才能正确区分不同的流。
• 调试技巧：添加--gst-debug=rtpssrcdemux:5参数来查看rtpssrcdemux的详细日志，确认它是否正确识别到了新的SSRC和创建了对应的Pad。
• 资源管理：如果发送端频繁启停，你可能需要在pad-removed信号的回调中清理对应的解码分支，避免资源泄漏。

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