如何通过Python GStreamer API正确终止并重启RTSP服务器实例？

我编写了一个基于FastAPI的Python API，用于控制GStreamer RTSP服务器，支持配置流的帧率、码率、分辨率等参数。目前存在两个关键问题：

• 执行停止流操作时，仅能阻止新连接，无法断开已建立的现有连接
• 修改配置参数后，必须重启整个FastAPI服务器才能加载新设置

当前停止流的逻辑仅调用loop.quit()，尝试过添加loop.get_context().unref()，但问题仍未解决。

现有完整代码 #

from threading import Thread
import json, os
import gi

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

from fastapi import FastAPI

app = FastAPI()
loop = GLib.MainLoop()

CONFIG_DEFAULTS = {
    'host': '127.0.0.1',
    'port': '8554',
    'mount': '/test',
    'width': '1280',
    'height': '800',
    'bitrate': '50000',
    'fps': '30'
}
CONFIGFILE = "config.cfg"


def load_config():
    with open(CONFIGFILE) as f:
        return json.load(f)


def save_config(config):
    with open(CONFIGFILE, 'w') as f:
        json.dump(config, f)
    return True


@app.on_event("startup")
async def startup_event():
    if not os.path.exists(CONFIGFILE):
        with open(CONFIGFILE, 'w') as f:
            json.dump(CONFIG_DEFAULTS, f)


@app.get("/get-fps")
def get_fps():
    config = load_config()
    return config['fps']


@app.get("/set-fps/{fps}")
def set_fps(fps: int):
    config = load_config()
    config['fps'] = fps
    save_config(config)
    return True

@app.get("/get-bitrate")
def get_bitrate():
    config = load_config()
    return config['bitrate']


@app.get("/set-bitrate/{bitrate}")
def set_bitrate(bitrate: int):
    config = load_config()
    config['bitrate'] = bitrate
    save_config(config)
    return True

@app.get("/get-resolution")
def get_resolution():
    config = load_config()
    return {
        'width': config['width'],
        'height': config['height'],
    }


@app.get("/set-resolution/{width}&{height}")
def set_resolution(width: int, height: int):
    config = load_config()
    config['width'] = width
    config['height'] = height
    save_config(config)
    return True

@app.get("/get-url")
def get_url():
    config = load_config()
    return config['host'] + ":" + config['port'] + config['mount']

@app.get("/start-stream")
def start_stream():

    Gst.init(None)
    config = load_config()
    server = GstRtspServer.RTSPServer()
    port = config['port']
    mount = config['mount']
    width = str(config['width'])
    height = str(config['height'])
    fps = str(config['fps'])
    bitrate = str(config['bitrate'])
    server.service = port
    mounts = server.get_mount_points()
    factory = GstRtspServer.RTSPMediaFactory()
    pipeline = "v4l2src device=/dev/video0 io-mode=2  ! " + \
                "image/jpeg,width="+width+",height="+height+",framerate="+fps+"/1 ! " + \
                "nvjpegdec ! " + \
                "video/x-raw ! " + \
                "omxh264enc bitrate="+bitrate+" control-rate=constant ! " + \
                "rtph264pay name=pay0 pt=96"

    factory.set_launch(pipeline)
    factory.set_shared(True)
    mounts.add_factory(mount, factory)
    server.attach()

    loop_thread = Thread(target=run_loop)
    loop_thread.start()
    return 'stream ready at rtsp://127.0.0.1:%s%s' % (port, mount)

def run_loop():
    global loop
    loop.run()

@app.get("/stop-stream")
def stop_stream():
    global loop
    loop.quit()
    return True

尝试过的无效停止逻辑 #

loop.quit()
    loop.get_context().unref()

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