为每个新客户端提取 GStreamer 和 URI 查询参数

Dmi*_*yev 1 c++ streaming rtsp video-streaming gstreamer

我已经创建了 rtsp/h264/mjpeg 服务器。效果很好。但现在我必须查询每个新连接的客户端。例如,我必须从客户端查询获取请求的分辨率:rtsp://192.116.10.20:8554/stream?width=1920&height=1280

我尝试使用以下代码来做到这一点:

 ....
gulong clientConnectedConfigureId = g_signal_connect(m_server, "client-connected", (GCallback)ClientConnected, this);
 ....

static void ClientConnected(GstRTSPServer *gstrtspserver, GstRTSPClient *arg1, gpointer user_data)
    {
        GstRTSPConnection *connection = gst_rtsp_client_get_connection(arg1);

        if(!connection)
        {
            return;
        }

        GstRTSPUrl *uri = gst_rtsp_connection_get_url(connection);

        if(!uri)
        {
            return;
        }

        gchar *urlString = gst_rtsp_url_get_request_uri (uri);

        std::stringstream ssTemp;
        ssTemp << "ClientConnected - urlString = " << urlString;
        InternalLog::Debug(ssTemp.str());

        g_free(urlString); 
    }
Run Code Online (Sandbox Code Playgroud)

GstRTSPUrl 包含以下成员: //rtsp[u]://[user:passwd@]host[:port]/abspath[?query]

通过查询 rtsp://192.116.10.20:8554/stream?width=1920&height=1280 从 VLC 连接后,结果如下:

ClientConnected - urlString = rtsp://192.116.10.20:61099(null)

GstRTSPUrl 仅包含主机=192.116.10.20 和端口=61099。其他字段如“abspath”或“query”等于 NULL。

在 netstat 实用程序中,我看到端口 61099 是 VLC 应用程序的客户端端口。它连接到端口 8554。

如何接收客户端的 rtsp 查询,并将“query”填充为“width=1920&height=1280”?

Dmi*_*yev 6

我找到了解决方案

...
gulong clientConnectedConfigureId = g_signal_connect(m_server, "client-connected", (GCallback)ClientConnected, this);
...

static void ClientConnected(GstRTSPServer *gstrtspserver, GstRTSPClient *arg1, gpointer user_data)
{
    gulong describeConfigureId = g_signal_connect(arg1, "describe-request", (GCallback)DescribeRequest, user_data);

    //Do not forget about g_signal_handler_disconnect
}

void DescribeRequest(GstRTSPClient  *gstrtspclient, GstRTSPContext *arg1, gpointer user_data)
{
    gchar *urlString = gst_rtsp_url_get_request_uri(arg1->uri);

    std::stringstream ssTemp;
    ssTemp << "DescribeRequest - urlString = " << urlString;
    InternalLog::Debug(ssTemp.str());

    g_free(urlString);  
}
Run Code Online (Sandbox Code Playgroud)

如果您使用 gst_rtsp_media_factory_set_shared(m_factory, TRUE); 那么你必须重新定义方法default_gen_key。因为URL用作确定是否需要创建新媒体的关键。您可以使用以下代码来完成:

static gchar *
default_gen_key (GstRTSPMediaFactory * factory, const GstRTSPUrl * url)
{
  gchar *result =
      g_strdup_printf ("%u%s", url->port, url->abspath);

  return result;
}

...
m_factory = gst_rtsp_media_factory_new();
GstRTSPMediaFactoryClass *klass = GST_RTSP_MEDIA_FACTORY_GET_CLASS (m_factory);
klass->gen_key = default_gen_key;
gst_rtsp_media_factory_set_shared(m_factory, TRUE);
...
Run Code Online (Sandbox Code Playgroud)