使用gi.repository.Gst库，用Python编写实时视频流的录制和播放程序

使用gi.repository.Gst库可以方便地实现实时视频流的录制和播放。下面是一个包含使用例子的简单程序。

首先，我们需要导入gi.repository.Gst库，并初始化Gst:

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

接下来，我们定义一个录制视频流的函数record_video，该函数使用Gst Pipeline来进行录制。我们需要指定输入源和输出文件路径:

def record_video(input_src, output_file):
    pipeline = Gst.Pipeline()

    # 创建输入源
    source = Gst.ElementFactory.make("uridecodebin", "source")
    source.set_property("uri", input_src)

    # 创建编码器
    encoder = Gst.ElementFactory.make("x264enc", "encoder")

    # 创建文件输出
    muxer = Gst.ElementFactory.make("mp4mux", "muxer")
    filesink = Gst.ElementFactory.make("filesink", "filesink")
    filesink.set_property("location", output_file)

    # 将元素添加到pipeline中
    pipeline.add(source)
    pipeline.add(encoder)
    pipeline.add(muxer)
    pipeline.add(filesink)

    # 连接管道中的元素
    source.link(encoder)
    encoder.link(muxer)
    muxer.link(filesink)

    # 启动录制
    ret = pipeline.set_state(Gst.State.PLAYING)
    if ret == Gst.StateChangeReturn.FAILURE:
        print("Failed to start recording")
        return

    # 等待录制完成
    bus = pipeline.get_bus()
    msg = bus.timed_pop_filtered(Gst.CLOCK_TIME_NONE, Gst.MessageType.ERROR | Gst.MessageType.EOS)
    pipeline.set_state(Gst.State.NULL)

    if msg.type == Gst.MessageType.ERROR:
        print("Recording Error:", msg.parse_error())

接下来，我们定义一个播放视频流的函数play_video，该函数使用Gst Pipeline来进行播放。我们需要指定要播放的视频文件路径:

def play_video(file_path):
    pipeline = Gst.Pipeline()

    # 创建文件源
    source = Gst.ElementFactory.make("filesrc", "source")
    source.set_property("location", file_path)

    # 创建解码器
    decoder = Gst.ElementFactory.make("decodebin", "decoder")

    # 创建播放器
    sink = Gst.ElementFactory.make("autovideosink", "sink")

    # 将元素添加到pipeline中
    pipeline.add(source)
    pipeline.add(decoder)
    pipeline.add(sink)

    # 连接管道中的元素
    source.link(decoder)
    decoder.connect("pad-added", on_decoded_pad, sink)

    # 启动播放
    ret = pipeline.set_state(Gst.State.PLAYING)
    if ret == Gst.StateChangeReturn.FAILURE:
        print("Failed to start playing")
        return

    # 等待播放完成
    bus = pipeline.get_bus()
    msg = bus.timed_pop_filtered(Gst.CLOCK_TIME_NONE, Gst.MessageType.ERROR | Gst.MessageType.EOS)
    pipeline.set_state(Gst.State.NULL)

    if msg.type == Gst.MessageType.ERROR:
        print("Playing Error:", msg.parse_error())

def on_decoded_pad(decoder, pad, sink):
    sink_pad = sink.get_static_pad("sink")
    pad.link(sink_pad)

最后，我们可以使用以上两个函数来实现录制和播放视频流的功能，示例如下:

if __name__ == "__main__":
    input_src = "rtsp://example.com/live/stream"  # 输入源
    output_file = "output.mp4"  # 录制结果输出文件

    # 录制视频流
    record_video(input_src, output_file)

    # 播放录制的视频
    play_video(output_file)

在这个示例中，我们首先使用record_video函数录制一个使用rtsp协议的实时视频流，并将其保存成output.mp4文件。然后，我们使用play_video函数播放录制的视频文件。

通过使用gi.repository.Gst库，我们可以方便地实现实时视频流的录制和播放功能。上述示例仅仅是一个简单的演示，你可以根据自己的需求进行进一步的定制和扩展。