添加mk_rtp_server_start接口

api/include/common.h

@@ -103,6 +103,13 @@ API_EXPORT uint16_t API_CALL mk_rtsp_server_start(uint16_t port, int ssl);
 API_EXPORT uint16_t API_CALL mk_rtmp_server_start(uint16_t port, int ssl);
 
 /**
+ * 创建rtp服务器
+ * @param port rtp监听端口(包括udp/tcp)
+ * @return 0:失败,非0:端口号
+ */
+API_EXPORT uint16_t API_CALL mk_rtp_server_start(uint16_t port);
+
+/**
  * 打印日志
  * @param level 日志级别,支持0~4
  * @param file __FILE__

api/include/httpdownloader.h

@@ -65,7 +65,6 @@ API_EXPORT void API_CALL mk_http_downloader_release(mk_http_downloader ctx);
  */
 API_EXPORT void API_CALL mk_http_downloader_start(mk_http_downloader ctx, const char *url, const char *file, on_mk_download_complete cb, void *user_data);
 
-
 #ifdef __cplusplus
 }
 #endif

api/include/proxyplayer.h

@@ -53,7 +53,6 @@ API_EXPORT mk_proxy_player API_CALL mk_proxy_player_create(const char *vhost, co
  */
 API_EXPORT void API_CALL mk_proxy_player_release(mk_proxy_player ctx);
 
-
 /**
  * 设置代理播放器配置选项
  * @param ctx 代理播放器指针

api/source/common.cpp

@@ -43,6 +43,13 @@ static TcpServer::Ptr rtsp_server[2];
 static TcpServer::Ptr rtmp_server[2];
 static TcpServer::Ptr http_server[2];
 
+#ifdef ENABLE_RTPPROXY
+#include "Rtp/UdpRecver.h"
+#include "Rtp/RtpSession.h"
+static std::shared_ptr<UdpRecver> udpRtpServer;
+static TcpServer::Ptr tcpRtpServer(new TcpServer());
+#endif
+
 //////////////////////////environment init///////////////////////////
 API_EXPORT void API_CALL mk_env_init(const config *cfg) {
     assert(cfg);
@@ -129,6 +136,28 @@ API_EXPORT uint16_t API_CALL mk_rtmp_server_start(uint16_t port, int ssl) {
     }
 }
 
+API_EXPORT uint16_t API_CALL mk_rtp_server_start(uint16_t port){
+#ifdef ENABLE_RTPPROXY
+    try {
+        //创建rtp tcp服务器
+        tcpRtpServer->start<RtpSession>(port);
+        auto ret = tcpRtpServer->getPort();
+        udpRtpServer = std::make_shared<UdpRecver>();
+        //创建rtp udp服务器
+        udpRtpServer->initSock(port);
+        return ret;
+    } catch (std::exception &ex) {
+        tcpRtpServer.reset();
+        udpRtpServer.reset();
+        WarnL << ex.what();
+        return 0;
+    }
+#else
+    WarnL << "未启用该功能!";
+    return 0;
+#endif
+}
+
 API_EXPORT void API_CALL mk_log_printf(int level, const char *file, const char *function, int line, const char *fmt, ...) {
     assert(file && function && fmt);
     LogContextCapturer info(Logger::Instance(), (LogLevel) level, file, function, line);