THENG
/
ZLMediaKit
mirror of https://gitcode.com/gh_mirrors/zlme/ZLMediaKit.git
6
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

优化rtmp播放器url解析逻辑

This commit is contained in:
xia-chu 2023-10-27 17:52:44 +08:00
parent be46a37d3a
commit 1b95ed1c97
2 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/Rtmp/RtmpPlayer.cpp
View File

@ -52,17 +52,18 @@ void RtmpPlayer::teardown() {
void RtmpPlayer::play(const string &url) { void RtmpPlayer::play(const string &url) {
teardown(); teardown();
string host_url = findSubString(url.data(), "://", "/"); auto schema = findSubString(url.data(), nullptr, "://");
{ auto host_url = findSubString(url.data(), "://", "/");
auto pos = url.find_last_of('/'); _app = findSubString(url.data(), (host_url + "/").data(), "/");
if (pos != string::npos) { _stream_id = findSubString(url.data(), (host_url + "/" + _app + "/").data(), NULL);
_stream_id = url.substr(pos + 1); auto app_second = findSubString(_stream_id.data(), nullptr, "/");
} if (!app_second.empty() && app_second.find('?') == std::string::npos) {
// _stream_id存在多级；不包含'?', 说明分割符'/'不是url参数的一部分
_app += "/" + app_second;
_stream_id.erase(0, app_second.size() + 1);
} }
_app = findSubString(url.data(), (host_url + "/").data(), ("/" + _stream_id).data()); _tc_url = schema + "://" + host_url + "/" + _app;
_tc_url = string("rtmp://") + host_url + "/" + _app; if (_app.empty() || _stream_id.empty()) {
if (!_app.size() || !_stream_id.size()) {
onPlayResult_l(SockException(Err_other, "rtmp url非法"), false); onPlayResult_l(SockException(Err_other, "rtmp url非法"), false);
return; return;
} }

2
src/Rtmp/RtmpPusher.cpp
View File

@ -73,7 +73,7 @@ void RtmpPusher::publish(const string &url) {
if (!app_second.empty() && app_second.find('?') == std::string::npos) { if (!app_second.empty() && app_second.find('?') == std::string::npos) {
// _stream_id存在多级；不包含'?', 说明分割符'/'不是url参数的一部分 // _stream_id存在多级；不包含'?', 说明分割符'/'不是url参数的一部分
_app += "/" + app_second; _app += "/" + app_second;
_stream_id.erase(0, app_second.size()); _stream_id.erase(0, app_second.size() + 1);
} }
_tc_url = schema + "://" + host_url + "/" + _app; _tc_url = schema + "://" + host_url + "/" + _app;
if (_app.empty() || _stream_id.empty()) { if (_app.empty() || _stream_id.empty()) {