如何使用Gstreamer和C++将Open CV帧写入RTSP流？

#include <gst/gst.h>
#include <opencv2/opencv.hpp>

gst_init(NULL, NULL);

GstElement *pipeline = gst_pipeline_new("pipeline");

GstElement *source = gst_element_factory_make("appsrc", "source");
GstElement *encoder = gst_element_factory_make("x264enc", "encoder");
GstElement *rtspSink = gst_element_factory_make("rtspclientsink", "rtspSink");

g_object_set(G_OBJECT(rtspSink), "location", "rtsp://<IP_ADDRESS>:<PORT>/stream", NULL);

gst_bin_add_many(GST_BIN(pipeline), source, encoder, rtspSink, NULL);

gst_element_link_many(source, encoder, rtspSink, NULL);

g_object_set(G_OBJECT(source), "caps",
    gst_caps_new_simple("video/x-raw",
        "format", G_TYPE_STRING, "BGR",
        "width", G_TYPE_INT, width,
        "height", G_TYPE_INT, height,
        "framerate", GST_TYPE_FRACTION, fps, 1,
        NULL), NULL);

while (true) {
    // 从摄像头或视频文件中读取帧
    cv::Mat frame;
    // ...

    // 将OpenCV帧转换为Gstreamer的buffer
    GstBuffer *buffer = gst_buffer_new_wrapped(frame.data, frame.total() * frame.elemSize(), 0, frame.total() * frame.elemSize());

    // 将buffer推送到appsrc元素
    GstFlowReturn ret;
    g_signal_emit_by_name(source, "push-buffer", buffer, &ret);

    // 处理推送结果
    if (ret != GST_FLOW_OK) {
        // 处理错误
        break;
    }

    // 释放buffer
    gst_buffer_unref(buffer);
}

gst_element_set_state(pipeline, GST_STATE_NULL);
gst_object_unref(GST_OBJECT(pipeline));