cxh/kunlang_video
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

无音频

Browse Source
This commit is contained in:
cxh 2025-11-26 09:44:56 +08:00
parent 9cfc4f2a8a
commit 364ee4c81a
1 changed files with 52 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
src/rtmp_manager.cpp
View File

@ -77,35 +77,61 @@ GstElement* RTMPManager::create_pipeline(const Camera& cam)
const std::string record_rtmp = "rtmp://127.0.0.1:2935/" + app + "/" + stream_name + "?vhost=record"; const std::string record_rtmp = "rtmp://127.0.0.1:2935/" + app + "/" + stream_name + "?vhost=record";
// 双路推流管线：一份流编码后 tee 分支分别送往两个 flvmux+rtmpsink // 双路推流管线：一份流编码后 tee 分支分别送往两个 flvmux+rtmpsink
std::string pipeline_str = // std::string pipeline_str =
"v4l2src name=src device=" + cam.device + // "v4l2src name=src device=" + cam.device +
" ! " // " ! "
"video/x-raw,format=NV12,width=" + // "video/x-raw,format=NV12,width=" +
std::to_string(width) + ",height=" + std::to_string(height) + ",framerate=" + std::to_string(fps) + // std::to_string(width) + ",height=" + std::to_string(height) + ",framerate=" + std::to_string(fps) +
"/1 ! " // "/1 ! "
"mpph264enc bps=" + // "mpph264enc bps=" +
std::to_string(bitrate) + " gop=" + std::to_string(fps) + // std::to_string(bitrate) + " gop=" + std::to_string(fps) +
" rc-mode=cbr ! " // " rc-mode=cbr ! "
"h264parse ! tee name=t " // "h264parse ! tee name=t "
// --- 分支1：低延时远控 SRS --- // // --- 分支1：低延时远控 SRS ---
"t. ! queue max-size-buffers=5 leaky=downstream ! " // "t. ! queue max-size-buffers=5 leaky=downstream ! "
"flvmux streamable=true name=mux_live " // "flvmux streamable=true name=mux_live "
"audiotestsrc wave=silence ! audioconvert ! audioresample ! voaacenc ! aacparse ! mux_live. " // "audiotestsrc wave=silence ! audioconvert ! audioresample ! voaacenc ! aacparse ! mux_live. "
"mux_live. ! rtmpsink location=\"" + // "mux_live. ! rtmpsink location=\"" +
live_rtmp + // live_rtmp +
"\" sync=false async=false " // "\" sync=false async=false "
// --- 分支2：录像 SRS --- // // --- 分支2：录像 SRS ---
"t. ! queue max-size-buffers=5 leaky=downstream ! " // "t. ! queue max-size-buffers=5 leaky=downstream ! "
"flvmux streamable=true name=mux_record " // "flvmux streamable=true name=mux_record "
"audiotestsrc wave=silence ! audioconvert ! audioresample ! voaacenc ! aacparse ! mux_record. " // "audiotestsrc wave=silence ! audioconvert ! audioresample ! voaacenc ! aacparse ! mux_record. "
"mux_record. ! rtmpsink location=\"" + // "mux_record. ! rtmpsink location=\"" +
record_rtmp + // record_rtmp +
"\" sync=false async=false " // "\" sync=false async=false "
// --- 可选第三分支：AI/检测 --- // // --- 可选第三分支：AI/检测 ---
"t. ! queue ! fakesink sync=false"; // "t. ! queue ! fakesink sync=false";
std::string pipeline_str = "v4l2src name=src device=" + cam.device +
" ! video/x-raw,format=NV12,width=" + std::to_string(width) +
",height=" + std::to_string(height) + ",framerate=" + std::to_string(fps) +
"/1 "
" ! mpph264enc bps=" +
std::to_string(bitrate) + " gop=" + std::to_string(fps) +
" rc-mode=cbr "
" ! h264parse ! tee name=t "
// ------ 分支1：live ------
"t. ! queue max-size-buffers=5 leaky=downstream "
" ! flvmux streamable=true name=mux_live "
" ! rtmpsink location=\"" +
live_rtmp +
"\" sync=false async=false "
// ------ 分支2：record ------
"t. ! queue max-size-buffers=5 leaky=downstream "
" ! flvmux streamable=true name=mux_record "
" ! rtmpsink location=\"" +
record_rtmp +
"\" sync=false async=false "
// ------ 分支3：AI ------
"t. ! queue ! fakesink sync=false";
GError* error = nullptr; GError* error = nullptr;
GstElement* pipeline = gst_parse_launch(pipeline_str.c_str(), &error); GstElement* pipeline = gst_parse_launch(pipeline_str.c_str(), &error);