amass/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2024-11-22 19:00:01 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Ignore the http connection which calling kick_sessions http api

Browse Source
This commit is contained in:
xiongziliang 2023-12-17 18:13:51 +08:00
parent 189f787746
commit f1923f0076
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/WebApi.cpp
View File

@ -944,25 +944,29 @@ void installWebApi() {
//批量断开tcp连接，比如说可以断开rtsp、rtmp播放器等 //批量断开tcp连接，比如说可以断开rtsp、rtmp播放器等
//测试url http://127.0.0.1/index/api/kick_sessions?local_port=1935 //测试url http://127.0.0.1/index/api/kick_sessions?local_port=1935
api_regist("/index/api/kick_sessions",[](API_ARGS_MAP){ api_regist("/index/api/kick_sessions", [](API_ARGS_MAP) {
CHECK_SECRET(); CHECK_SECRET();
uint16_t local_port = allArgs["local_port"].as<uint16_t>(); uint16_t local_port = allArgs["local_port"].as<uint16_t>();
string peer_ip = allArgs["peer_ip"]; string peer_ip = allArgs["peer_ip"];
size_t count_hit = 0; size_t count_hit = 0;
list<Session::Ptr> session_list; list<Session::Ptr> session_list;
SessionMap::Instance().for_each_session([&](const string &id,const Session::Ptr &session){ SessionMap::Instance().for_each_session([&](const string &id, const Session::Ptr &session) {
if(local_port != 0 && local_port != session->get_local_port()){ if (local_port != 0 && local_port != session->get_local_port()) {
return; return;
} }
if(!peer_ip.empty() && peer_ip != session->get_peer_ip()){ if (!peer_ip.empty() && peer_ip != session->get_peer_ip()) {
return;
}
if (session->getIdentifier() == sender.getIdentifier()) {
// 忽略本http链接
return; return;
} }
session_list.emplace_back(session); session_list.emplace_back(session);
++count_hit; ++count_hit;
}); });
for(auto &session : session_list){ for (auto &session : session_list) {
session->safeShutdown(); session->safeShutdown();
} }
val["count_hit"] = (Json::UInt64)count_hit; val["count_hit"] = (Json::UInt64)count_hit;