ZLMediaKit/server/WebApi.cpp

1940 lines
74 KiB
C++
Raw Normal View History

2022-07-15 20:01:00 +08:00
/*
2023-12-09 16:23:51 +08:00
* Copyright (c) 2016-present The ZLMediaKit project authors. All Rights Reserved.
2019-06-11 09:25:54 +08:00
*
2023-12-09 16:23:51 +08:00
* This file is part of ZLMediaKit(https://github.com/ZLMediaKit/ZLMediaKit).
2019-06-11 09:25:54 +08:00
*
2023-12-09 16:23:51 +08:00
* Use of this source code is governed by MIT-like license that can be found in the
2020-04-04 20:30:09 +08:00
* LICENSE file in the root of the source tree. All contributing project authors
* may be found in the AUTHORS file in the root of the source tree.
2019-06-11 09:25:54 +08:00
*/
2020-06-10 10:33:48 +08:00
#include <sys/stat.h>
2020-12-06 22:36:44 +08:00
#include <math.h>
2019-05-20 11:22:59 +08:00
#include <signal.h>
#ifdef _WIN32
#include <io.h>
#include <iostream>
#include <tchar.h>
#endif // _WIN32
2019-05-20 11:22:59 +08:00
#include <functional>
#include <unordered_map>
#include <regex>
#include "Util/MD5.h"
2019-05-20 11:22:59 +08:00
#include "Util/util.h"
#include "Util/File.h"
2019-05-20 11:22:59 +08:00
#include "Util/logger.h"
#include "Util/onceToken.h"
#include "Util/NoticeCenter.h"
#include "Network/TcpServer.h"
#include "Network/UdpServer.h"
#include "Thread/WorkThreadPool.h"
2019-05-21 09:26:24 +08:00
#ifdef ENABLE_MYSQL
2019-05-20 11:22:59 +08:00
#include "Util/SqlPool.h"
2019-05-21 09:26:24 +08:00
#endif //ENABLE_MYSQL
#include "WebApi.h"
#include "WebHook.h"
#include "FFmpegSource.h"
2019-05-20 11:22:59 +08:00
#include "Common/config.h"
#include "Common/MediaSource.h"
#include "Http/HttpSession.h"
#include "Http/HttpRequester.h"
2019-05-20 16:26:04 +08:00
#include "Player/PlayerProxy.h"
2021-06-16 19:40:08 +08:00
#include "Pusher/PusherProxy.h"
2019-12-05 19:53:55 +08:00
#include "Rtp/RtpSelector.h"
#include "Record/MP4Reader.h"
#if defined(ENABLE_RTPPROXY)
#include "Rtp/RtpServer.h"
#endif
2021-03-24 16:52:41 +08:00
#ifdef ENABLE_WEBRTC
#include "../webrtc/WebRtcPlayer.h"
#include "../webrtc/WebRtcPusher.h"
#include "../webrtc/WebRtcEchoTest.h"
2021-03-24 16:52:41 +08:00
#endif
2022-08-12 18:09:44 +08:00
#if defined(ENABLE_VERSION)
#include "version.h"
#endif
using namespace std;
using namespace Json;
2019-05-20 11:22:59 +08:00
using namespace toolkit;
using namespace mediakit;
namespace API {
#define API_FIELD "api."
const string kApiDebug = API_FIELD"apiDebug";
const string kSecret = API_FIELD"secret";
const string kSnapRoot = API_FIELD"snapRoot";
2020-06-10 10:33:48 +08:00
const string kDefaultSnap = API_FIELD"defaultSnap";
const string kDownloadRoot = API_FIELD"downloadRoot";
2019-05-20 17:12:00 +08:00
2019-05-20 11:22:59 +08:00
static onceToken token([]() {
2019-05-20 16:26:04 +08:00
mINI::Instance()[kApiDebug] = "1";
2019-05-20 17:12:00 +08:00
mINI::Instance()[kSecret] = "035c73f7-bb6b-4889-a715-d9eb2d1925cc";
mINI::Instance()[kSnapRoot] = "./www/snap/";
2020-06-10 10:33:48 +08:00
mINI::Instance()[kDefaultSnap] = "./www/logo.png";
mINI::Instance()[kDownloadRoot] = "./www";
2019-05-20 11:22:59 +08:00
});
}//namespace API
2020-12-27 22:14:59 +08:00
using HttpApi = function<void(const Parser &parser, const HttpSession::HttpResponseInvoker &invoker, SockInfo &sender)>;
2020-01-17 11:44:20 +08:00
//http api列表
2023-12-02 14:56:59 +08:00
static map<string, HttpApi, StrCaseCompare> s_map_api;
2020-01-17 11:44:20 +08:00
static void responseApi(const Json::Value &res, const HttpSession::HttpResponseInvoker &invoker){
GET_CONFIG(string, charSet, Http::kCharSet);
HttpSession::KeyValue headerOut;
headerOut["Content-Type"] = string("application/json; charset=") + charSet;
invoker(200, headerOut, res.toStyledString());
};
static void responseApi(int code, const string &msg, const HttpSession::HttpResponseInvoker &invoker){
Json::Value res;
res["code"] = code;
res["msg"] = msg;
responseApi(res, invoker);
}
static ApiArgsType getAllArgs(const Parser &parser);
2020-12-27 22:14:59 +08:00
static HttpApi toApi(const function<void(API_ARGS_MAP_ASYNC)> &cb) {
return [cb](const Parser &parser, const HttpSession::HttpResponseInvoker &invoker, SockInfo &sender) {
GET_CONFIG(string, charSet, Http::kCharSet);
HttpSession::KeyValue headerOut;
headerOut["Content-Type"] = string("application/json; charset=") + charSet;
Json::Value val;
val["code"] = API::Success;
2020-12-27 22:14:59 +08:00
//参数解析成map
auto args = getAllArgs(parser);
2021-08-12 16:07:31 +08:00
cb(sender, headerOut, HttpAllArgs<decltype(args)>(parser, args), val, invoker);
};
}
2020-12-27 22:14:59 +08:00
static HttpApi toApi(const function<void(API_ARGS_MAP)> &cb) {
return toApi([cb](API_ARGS_MAP_ASYNC) {
cb(API_ARGS_VALUE);
invoker(200, headerOut, val.toStyledString());
2020-01-17 11:44:20 +08:00
});
}
2020-12-27 22:14:59 +08:00
static HttpApi toApi(const function<void(API_ARGS_JSON_ASYNC)> &cb) {
return [cb](const Parser &parser, const HttpSession::HttpResponseInvoker &invoker, SockInfo &sender) {
GET_CONFIG(string, charSet, Http::kCharSet);
HttpSession::KeyValue headerOut;
headerOut["Content-Type"] = string("application/json; charset=") + charSet;
2021-08-12 16:07:31 +08:00
Json::Value val;
val["code"] = API::Success;
2020-12-27 22:14:59 +08:00
if (parser["Content-Type"].find("application/json") == string::npos) {
throw InvalidArgsException("该接口只支持json格式的请求");
}
//参数解析成json对象然后处理
2021-08-12 16:07:31 +08:00
Json::Value args;
2020-12-27 22:14:59 +08:00
Json::Reader reader;
2023-06-10 11:04:52 +08:00
reader.parse(parser.content(), args);
2020-12-27 22:14:59 +08:00
2021-08-12 16:07:31 +08:00
cb(sender, headerOut, HttpAllArgs<decltype(args)>(parser, args), val, invoker);
2020-12-27 22:14:59 +08:00
};
}
static HttpApi toApi(const function<void(API_ARGS_JSON)> &cb) {
return toApi([cb](API_ARGS_JSON_ASYNC) {
2021-08-12 16:07:31 +08:00
cb(API_ARGS_VALUE);
invoker(200, headerOut, val.toStyledString());
2020-12-27 22:14:59 +08:00
});
}
2021-03-31 17:15:26 +08:00
static HttpApi toApi(const function<void(API_ARGS_STRING_ASYNC)> &cb) {
return [cb](const Parser &parser, const HttpSession::HttpResponseInvoker &invoker, SockInfo &sender) {
GET_CONFIG(string, charSet, Http::kCharSet);
HttpSession::KeyValue headerOut;
headerOut["Content-Type"] = string("application/json; charset=") + charSet;
Json::Value val;
val["code"] = API::Success;
2023-06-10 11:04:52 +08:00
cb(sender, headerOut, HttpAllArgs<string>(parser, (string &)parser.content()), val, invoker);
2021-03-31 17:15:26 +08:00
};
}
static HttpApi toApi(const function<void(API_ARGS_STRING)> &cb) {
return toApi([cb](API_ARGS_STRING_ASYNC) {
cb(API_ARGS_VALUE);
invoker(200, headerOut, val.toStyledString());
});
}
2020-12-27 22:14:59 +08:00
void api_regist(const string &api_path, const function<void(API_ARGS_MAP)> &func) {
s_map_api.emplace(api_path, toApi(func));
}
void api_regist(const string &api_path, const function<void(API_ARGS_MAP_ASYNC)> &func) {
s_map_api.emplace(api_path, toApi(func));
}
void api_regist(const string &api_path, const function<void(API_ARGS_JSON)> &func) {
s_map_api.emplace(api_path, toApi(func));
2020-01-17 11:44:20 +08:00
}
2019-05-20 11:22:59 +08:00
2020-12-27 22:14:59 +08:00
void api_regist(const string &api_path, const function<void(API_ARGS_JSON_ASYNC)> &func) {
s_map_api.emplace(api_path, toApi(func));
}
2021-03-31 17:15:26 +08:00
void api_regist(const string &api_path, const function<void(API_ARGS_STRING)> &func){
s_map_api.emplace(api_path, toApi(func));
}
void api_regist(const string &api_path, const function<void(API_ARGS_STRING_ASYNC)> &func){
s_map_api.emplace(api_path, toApi(func));
}
2019-05-20 11:22:59 +08:00
//获取HTTP请求中url参数、content参数
2019-05-20 16:26:04 +08:00
static ApiArgsType getAllArgs(const Parser &parser) {
ApiArgsType allArgs;
2019-12-29 10:49:04 +08:00
if (parser["Content-Type"].find("application/x-www-form-urlencoded") == 0) {
2023-06-10 11:04:52 +08:00
auto contentArgs = parser.parseArgs(parser.content());
2019-05-20 11:22:59 +08:00
for (auto &pr : contentArgs) {
allArgs[pr.first] = HttpSession::urlDecodeComponent(pr.second);
2019-05-20 11:22:59 +08:00
}
2019-12-29 10:49:04 +08:00
} else if (parser["Content-Type"].find("application/json") == 0) {
2019-05-20 16:26:04 +08:00
try {
2023-06-10 11:04:52 +08:00
stringstream ss(parser.content());
2019-05-20 16:26:04 +08:00
Value jsonArgs;
ss >> jsonArgs;
auto keys = jsonArgs.getMemberNames();
2019-12-29 10:49:04 +08:00
for (auto key = keys.begin(); key != keys.end(); ++key) {
2019-05-20 16:26:04 +08:00
allArgs[*key] = jsonArgs[*key].asString();
}
2019-12-29 10:49:04 +08:00
} catch (std::exception &ex) {
2019-05-20 16:26:04 +08:00
WarnL << ex.what();
2019-05-20 11:22:59 +08:00
}
2019-12-29 10:49:04 +08:00
} else if (!parser["Content-Type"].empty()) {
2019-05-20 16:26:04 +08:00
WarnL << "invalid Content-Type:" << parser["Content-Type"];
2019-05-20 11:22:59 +08:00
}
2019-05-20 16:26:04 +08:00
2019-12-29 10:49:04 +08:00
for (auto &pr : parser.getUrlArgs()) {
allArgs[pr.first] = pr.second;
2019-05-20 16:26:04 +08:00
}
2020-09-21 14:32:56 +08:00
return allArgs;
2019-05-20 11:22:59 +08:00
}
2021-02-21 21:28:17 +08:00
extern uint64_t getTotalMemUsage();
extern uint64_t getTotalMemBlock();
2021-12-27 17:40:15 +08:00
extern uint64_t getThisThreadMemUsage();
extern uint64_t getThisThreadMemBlock();
extern std::vector<size_t> getBlockTypeSize();
extern uint64_t getTotalMemBlockByType(int type);
extern uint64_t getThisThreadMemBlockByType(int type) ;
2021-02-21 21:28:17 +08:00
static void *web_api_tag = nullptr;
2019-05-20 11:22:59 +08:00
static inline void addHttpListener(){
2019-05-28 17:14:36 +08:00
GET_CONFIG(bool, api_debug, API::kApiDebug);
2019-05-20 11:22:59 +08:00
//注册监听kBroadcastHttpRequest事件
NoticeCenter::Instance().addListener(&web_api_tag, Broadcast::kBroadcastHttpRequest, [](BroadcastHttpRequestArgs) {
2023-06-10 11:04:52 +08:00
auto it = s_map_api.find(parser.url());
2019-05-20 11:22:59 +08:00
if (it == s_map_api.end()) {
return;
}
//该api已被消费
consumed = true;
2019-05-20 17:34:39 +08:00
if(api_debug){
2021-08-12 21:02:07 +08:00
auto newInvoker = [invoker, parser](int code, const HttpSession::KeyValue &headerOut, const HttpBody::Ptr &body) {
2019-10-28 17:23:16 +08:00
//body默认为空
2021-01-19 16:05:38 +08:00
ssize_t size = 0;
2019-10-28 17:23:16 +08:00
if (body && body->remainSize()) {
//有body获取body大小
size = body->remainSize();
}
2019-05-20 17:34:39 +08:00
2023-07-02 12:45:07 +08:00
LogContextCapture log(getLogger(), toolkit::LDebug, __FILE__, "http api debug", __LINE__);
2023-06-10 11:04:52 +08:00
log << "\r\n# request:\r\n" << parser.method() << " " << parser.fullUrl() << "\r\n";
2021-08-12 21:02:07 +08:00
log << "# header:\r\n";
for (auto &pr : parser.getHeader()) {
log << pr.first << " : " << pr.second << "\r\n";
}
2023-06-10 11:04:52 +08:00
auto &content = parser.content();
2021-08-12 21:02:07 +08:00
log << "# content:\r\n" << (content.size() > 4 * 1024 ? content.substr(0, 4 * 1024) : content) << "\r\n";
2021-08-23 11:00:20 +08:00
if (size > 0 && size < 4 * 1024) {
2021-08-12 21:02:07 +08:00
auto response = body->readData(size);
log << "# response:\r\n" << response->data() << "\r\n";
invoker(code, headerOut, response);
} else {
2021-08-12 21:02:07 +08:00
log << "# response size:" << size << "\r\n";
invoker(code, headerOut, body);
2019-10-28 17:23:16 +08:00
}
2019-05-20 17:34:39 +08:00
};
((HttpSession::HttpResponseInvoker &) invoker) = newInvoker;
2019-05-20 17:34:39 +08:00
}
2019-05-20 11:22:59 +08:00
2019-05-20 17:34:39 +08:00
try {
it->second(parser, invoker, sender);
} catch (ApiRetException &ex) {
responseApi(ex.code(), ex.what(), invoker);
2019-05-21 09:26:24 +08:00
}
#ifdef ENABLE_MYSQL
catch(SqlException &ex){
responseApi(API::SqlFailed, StrPrinter << "操作数据库失败:" << ex.what() << ":" << ex.getSql(), invoker);
2019-05-21 09:26:24 +08:00
}
#endif// ENABLE_MYSQL
catch (std::exception &ex) {
responseApi(API::Exception, ex.what(), invoker);
2019-05-20 17:34:39 +08:00
}
2019-05-20 11:22:59 +08:00
});
}
template <typename Type>
class ServiceController {
public:
using Pointer = std::shared_ptr<Type>;
std::unordered_map<std::string, Pointer> _map;
mutable std::recursive_mutex _mtx;
void clear() {
decltype(_map) copy;
{
std::lock_guard<std::recursive_mutex> lck(_mtx);
copy.swap(_map);
}
}
size_t erase(const std::string &key) {
std::lock_guard<std::recursive_mutex> lck(_mtx);
return _map.erase(key);
}
Pointer find(const std::string &key) const {
std::lock_guard<std::recursive_mutex> lck(_mtx);
auto it = _map.find(key);
if (it == _map.end()) {
return nullptr;
}
return it->second;
}
template<class ..._Args>
Pointer make(const std::string &key, _Args&& ...__args) {
// assert(!find(key));
auto server = std::make_shared<Type>(std::forward<_Args>(__args)...);
std::lock_guard<std::recursive_mutex> lck(_mtx);
auto it = _map.emplace(key, server);
assert(it.second);
return server;
}
template<class ..._Args>
Pointer makeWithAction(const std::string &key, function<void(Pointer)> action, _Args&& ...__args) {
// assert(!find(key));
auto server = std::make_shared<Type>(std::forward<_Args>(__args)...);
action(server);
std::lock_guard<std::recursive_mutex> lck(_mtx);
auto it = _map.emplace(key, server);
assert(it.second);
return server;
}
};
//拉流代理器列表
static ServiceController<PlayerProxy> s_player_proxy;
2021-06-16 19:40:08 +08:00
//推流代理器列表
static ServiceController<PusherProxy> s_pusher_proxy;
2021-06-16 19:40:08 +08:00
//FFmpeg拉流代理器列表
static ServiceController<FFmpegSource> s_ffmpeg_src;
2019-06-06 18:28:33 +08:00
#if defined(ENABLE_RTPPROXY)
//rtp服务器列表
static ServiceController<RtpServer> s_rtp_server;
#endif
static inline string getProxyKey(const string &vhost, const string &app, const string &stream) {
return vhost + "/" + app + "/" + stream;
}
static inline string getPusherKey(const string &schema, const string &vhost, const string &app, const string &stream,
const string &dst_url) {
return schema + "/" + vhost + "/" + app + "/" + stream + "/" + MD5(dst_url).hexdigest();
}
static void fillSockInfo(Value& val, SockInfo* info) {
val["peer_ip"] = info->get_peer_ip();
val["peer_port"] = info->get_peer_port();
val["local_port"] = info->get_local_port();
val["local_ip"] = info->get_local_ip();
val["identifier"] = info->getIdentifier();
}
void dumpMediaTuple(const MediaTuple &tuple, Json::Value& item) {
item[VHOST_KEY] = tuple.vhost;
item["app"] = tuple.app;
item["stream"] = tuple.stream;
}
2021-04-08 17:34:13 +08:00
Value makeMediaSourceJson(MediaSource &media){
Value item;
item["schema"] = media.getSchema();
dumpMediaTuple(media.getMediaTuple(), item);
2021-04-08 17:34:13 +08:00
item["createStamp"] = (Json::UInt64) media.getCreateStamp();
item["aliveSecond"] = (Json::UInt64) media.getAliveSecond();
item["bytesSpeed"] = media.getBytesSpeed();
item["readerCount"] = media.readerCount();
item["totalReaderCount"] = media.totalReaderCount();
item["originType"] = (int) media.getOriginType();
item["originTypeStr"] = getOriginTypeString(media.getOriginType());
item["originUrl"] = media.getOriginUrl();
item["isRecordingMP4"] = media.isRecording(Recorder::type_mp4);
item["isRecordingHLS"] = media.isRecording(Recorder::type_hls);
2021-04-08 17:34:13 +08:00
auto originSock = media.getOriginSock();
if (originSock) {
fillSockInfo(item["originSock"], originSock.get());
2021-04-08 17:34:13 +08:00
} else {
item["originSock"] = Json::nullValue;
}
2022-06-11 14:40:14 +08:00
//getLossRate有线程安全问题使用getMediaInfo接口才能获取丢包率getMediaList接口将忽略丢包率
auto current_thread = false;
try { current_thread = media.getOwnerPoller()->isCurrentThread();} catch (...) {}
float last_loss = -1;
for(auto &track : media.getTracks(false)){
2021-04-08 17:34:13 +08:00
Value obj;
auto codec_type = track->getTrackType();
obj["codec_id"] = track->getCodecId();
obj["codec_id_name"] = track->getCodecName();
obj["ready"] = track->ready();
obj["codec_type"] = codec_type;
2022-06-11 14:45:56 +08:00
if (current_thread) {
//rtp推流只有一个统计器但是可能有多个track如果短时间多次获取间隔丢包率第二次会获取为-1
auto loss = media.getLossRate(codec_type);
if (loss == -1) {
loss = last_loss;
} else {
last_loss = loss;
}
obj["loss"] = loss;
2022-06-11 14:45:56 +08:00
}
obj["frames"] = track->getFrames();
obj["duration"] = track->getDuration();
2021-04-08 17:34:13 +08:00
switch(codec_type){
case TrackAudio : {
auto audio_track = dynamic_pointer_cast<AudioTrack>(track);
obj["sample_rate"] = audio_track->getAudioSampleRate();
obj["channels"] = audio_track->getAudioChannel();
obj["sample_bit"] = audio_track->getAudioSampleBit();
break;
}
case TrackVideo : {
auto video_track = dynamic_pointer_cast<VideoTrack>(track);
obj["width"] = video_track->getVideoWidth();
obj["height"] = video_track->getVideoHeight();
obj["key_frames"] = video_track->getVideoKeyFrames();
int gop_size = video_track->getVideoGopSize();
int gop_interval_ms = video_track->getVideoGopInterval();
float fps = video_track->getVideoFps();
2023-03-23 18:14:28 +08:00
if (fps <= 1 && gop_interval_ms) {
fps = gop_size * 1000.0 / gop_interval_ms;
}
obj["fps"] = round(fps);
obj["gop_size"] = gop_size;
obj["gop_interval_ms"] = gop_interval_ms;
2021-04-08 17:34:13 +08:00
break;
}
default:
break;
}
item["tracks"].append(obj);
}
return item;
}
2022-07-24 22:30:59 +08:00
#if defined(ENABLE_RTPPROXY)
uint16_t openRtpServer(uint16_t local_port, const string &stream_id, int tcp_mode, const string &local_ip, bool re_use_port, uint32_t ssrc, int only_track, bool multiplex) {
if (s_rtp_server.find(stream_id)) {
2022-06-22 10:31:53 +08:00
//为了防止RtpProcess所有权限混乱的问题不允许重复添加相同的stream_id
return 0;
}
auto server = s_rtp_server.makeWithAction(stream_id, [&](RtpServer::Ptr server) {
server->start(local_port, stream_id, (RtpServer::TcpMode)tcp_mode, local_ip.c_str(), re_use_port, ssrc, only_track, multiplex);
});
2022-06-22 10:31:53 +08:00
server->setOnDetach([stream_id]() {
//设置rtp超时移除事件
s_rtp_server.erase(stream_id);
2022-10-30 21:36:35 +08:00
});
2022-06-22 10:31:53 +08:00
//回复json
return server->getPort();
}
2022-07-24 22:30:59 +08:00
#endif
2022-06-22 10:31:53 +08:00
2021-12-27 17:40:15 +08:00
void getStatisticJson(const function<void(Value &val)> &cb) {
auto obj = std::make_shared<Value>(objectValue);
auto &val = *obj;
val["MediaSource"] = (Json::UInt64)(ObjectStatistic<MediaSource>::count());
val["MultiMediaSourceMuxer"] = (Json::UInt64)(ObjectStatistic<MultiMediaSourceMuxer>::count());
val["TcpServer"] = (Json::UInt64)(ObjectStatistic<TcpServer>::count());
val["TcpSession"] = (Json::UInt64)(ObjectStatistic<TcpSession>::count());
val["UdpServer"] = (Json::UInt64)(ObjectStatistic<UdpServer>::count());
val["UdpSession"] = (Json::UInt64)(ObjectStatistic<UdpSession>::count());
val["TcpClient"] = (Json::UInt64)(ObjectStatistic<TcpClient>::count());
val["Socket"] = (Json::UInt64)(ObjectStatistic<Socket>::count());
val["FrameImp"] = (Json::UInt64)(ObjectStatistic<FrameImp>::count());
val["Frame"] = (Json::UInt64)(ObjectStatistic<Frame>::count());
val["Buffer"] = (Json::UInt64)(ObjectStatistic<Buffer>::count());
val["BufferRaw"] = (Json::UInt64)(ObjectStatistic<BufferRaw>::count());
val["BufferLikeString"] = (Json::UInt64)(ObjectStatistic<BufferLikeString>::count());
val["BufferList"] = (Json::UInt64)(ObjectStatistic<BufferList>::count());
val["RtpPacket"] = (Json::UInt64)(ObjectStatistic<RtpPacket>::count());
val["RtmpPacket"] = (Json::UInt64)(ObjectStatistic<RtmpPacket>::count());
#ifdef ENABLE_MEM_DEBUG
auto bytes = getTotalMemUsage();
val["totalMemUsage"] = (Json::UInt64) bytes;
val["totalMemUsageMB"] = (int) (bytes / 1024 / 1024);
val["totalMemBlock"] = (Json::UInt64) getTotalMemBlock();
static auto block_type_size = getBlockTypeSize();
{
int i = 0;
string str;
size_t last = 0;
for (auto sz : block_type_size) {
str.append(to_string(last) + "~" + to_string(sz) + ":" + to_string(getTotalMemBlockByType(i++)) + ";");
last = sz;
}
str.pop_back();
val["totalMemBlockTypeCount"] = str;
}
2021-12-27 17:40:15 +08:00
auto thread_size = EventPollerPool::Instance().getExecutorSize() + WorkThreadPool::Instance().getExecutorSize();
std::shared_ptr<vector<Value> > thread_mem_info = std::make_shared<vector<Value> >(thread_size);
shared_ptr<void> finished(nullptr, [thread_mem_info, cb, obj](void *) {
2021-12-27 17:40:15 +08:00
for (auto &val : *thread_mem_info) {
(*obj)["threadMem"].append(val);
}
//触发回调
cb(*obj);
});
auto pos = 0;
auto lam0 = [&](TaskExecutor &executor) {
2021-12-27 17:40:15 +08:00
auto &val = (*thread_mem_info)[pos++];
executor.async([finished, &val]() {
2021-12-27 17:40:15 +08:00
auto bytes = getThisThreadMemUsage();
val["threadName"] = getThreadName();
val["threadMemUsage"] = (Json::UInt64) bytes;
val["threadMemUsageMB"] = (Json::UInt64) (bytes / 1024 / 1024);
val["threadMemBlock"] = (Json::UInt64) getThisThreadMemBlock();
{
int i = 0;
string str;
size_t last = 0;
for (auto sz : block_type_size) {
str.append(to_string(last) + "~" + to_string(sz) + ":" + to_string(getThisThreadMemBlockByType(i++)) + ";");
last = sz;
}
str.pop_back();
val["threadMemBlockTypeCount"] = str;
}
2021-12-27 17:40:15 +08:00
});
};
auto lam1 = [lam0](const TaskExecutor::Ptr &executor) {
lam0(*executor);
};
EventPollerPool::Instance().for_each(lam1);
WorkThreadPool::Instance().for_each(lam1);
2021-12-27 17:40:15 +08:00
#else
cb(*obj);
#endif
}
2022-01-12 16:45:47 +08:00
void addStreamProxy(const string &vhost, const string &app, const string &stream, const string &url, int retry_count,
const ProtocolOption &option, int rtp_type, float timeout_sec, const mINI &args,
2022-01-12 16:45:47 +08:00
const function<void(const SockException &ex, const string &key)> &cb) {
auto key = getProxyKey(vhost, app, stream);
if (s_player_proxy.find(key)) {
2022-01-12 16:45:47 +08:00
//已经在拉流了
cb(SockException(Err_other, "This stream already exists"), key);
2022-01-12 16:45:47 +08:00
return;
}
//添加拉流代理
auto player = s_player_proxy.make(key, vhost, app, stream, option, retry_count);
2022-01-12 16:45:47 +08:00
// 先透传参数
player->mINI::operator=(args);
2022-01-12 16:45:47 +08:00
//指定RTP over TCP(播放rtsp时有效)
(*player)[Client::kRtpType] = rtp_type;
2022-01-12 16:45:47 +08:00
if (timeout_sec > 0.1f) {
2022-01-12 16:45:47 +08:00
//播放握手超时时间
(*player)[Client::kTimeoutMS] = timeout_sec * 1000;
2022-01-12 16:45:47 +08:00
}
//开始播放,如果播放失败或者播放中止,将会自动重试若干次,默认一直重试
player->setPlayCallbackOnce([cb, key](const SockException &ex) {
if (ex) {
s_player_proxy.erase(key);
2022-01-12 16:45:47 +08:00
}
cb(ex, key);
});
//被主动关闭拉流
player->setOnClose([key](const SockException &ex) {
s_player_proxy.erase(key);
2022-01-12 16:45:47 +08:00
});
player->play(url);
};
void addStreamPusherProxy(const string &schema,
const string &vhost,
const string &app,
const string &stream,
const string &url,
int retry_count,
int rtp_type,
float timeout_sec,
const function<void(const SockException &ex, const string &key)> &cb) {
auto key = getPusherKey(schema, vhost, app, stream, url);
auto src = MediaSource::find(schema, vhost, app, stream);
if (!src) {
cb(SockException(Err_other, "can not find the source stream"), key);
return;
}
if (s_pusher_proxy.find(key)) {
//已经在推流了
cb(SockException(Err_success), key);
return;
}
//添加推流代理
auto pusher = s_pusher_proxy.make(key, src, retry_count);
//指定RTP over TCP(播放rtsp时有效)
pusher->emplace(Client::kRtpType, rtp_type);
if (timeout_sec > 0.1f) {
//推流握手超时时间
pusher->emplace(Client::kTimeoutMS, timeout_sec * 1000);
}
//开始推流,如果推流失败或者推流中止,将会自动重试若干次,默认一直重试
pusher->setPushCallbackOnce([cb, key, url](const SockException &ex) {
if (ex) {
WarnL << "Push " << url << " failed, key: " << key << ", err: " << ex;
s_pusher_proxy.erase(key);
}
cb(ex, key);
});
//被主动关闭推流
pusher->setOnClose([key, url](const SockException &ex) {
WarnL << "Push " << url << " failed, key: " << key << ", err: " << ex;
s_pusher_proxy.erase(key);
});
pusher->publish(url);
}
template <typename Type>
2022-03-12 15:18:12 +08:00
static void getArgsValue(const HttpAllArgs<ApiArgsType> &allArgs, const string &key, Type &value) {
auto val = allArgs[key];
2022-03-12 15:18:12 +08:00
if (!val.empty()) {
value = (Type)val;
}
}
/**
* api接口
* api都支持GET和POST两种方式
* POST方式参数支持application/json和application/x-www-form-urlencoded方式
*/
2019-05-20 11:22:59 +08:00
void installWebApi() {
addHttpListener();
2019-05-28 17:14:36 +08:00
GET_CONFIG(string,api_secret,API::kSecret);
2019-05-20 17:12:00 +08:00
//获取线程负载
//测试url http://127.0.0.1/index/api/getThreadsLoad
api_regist("/index/api/getThreadsLoad", [](API_ARGS_MAP_ASYNC) {
CHECK_SECRET();
2019-05-20 11:22:59 +08:00
EventPollerPool::Instance().getExecutorDelay([invoker, headerOut](const vector<int> &vecDelay) {
Value val;
auto vec = EventPollerPool::Instance().getExecutorLoad();
2019-05-28 09:38:15 +08:00
int i = API::Success;
2019-05-20 11:22:59 +08:00
for (auto load : vec) {
Value obj(objectValue);
obj["load"] = load;
2019-10-24 11:21:55 +08:00
obj["delay"] = vecDelay[i++];
val["data"].append(obj);
}
val["code"] = API::Success;
invoker(200, headerOut, val.toStyledString());
2019-10-24 11:21:55 +08:00
});
});
//获取后台工作线程负载
//测试url http://127.0.0.1/index/api/getWorkThreadsLoad
api_regist("/index/api/getWorkThreadsLoad", [](API_ARGS_MAP_ASYNC) {
CHECK_SECRET();
2019-10-24 11:21:55 +08:00
WorkThreadPool::Instance().getExecutorDelay([invoker, headerOut](const vector<int> &vecDelay) {
Value val;
auto vec = WorkThreadPool::Instance().getExecutorLoad();
int i = 0;
for (auto load : vec) {
Value obj(objectValue);
obj["load"] = load;
2019-05-20 11:22:59 +08:00
obj["delay"] = vecDelay[i++];
val["data"].append(obj);
}
val["code"] = API::Success;
invoker(200, headerOut, val.toStyledString());
2019-05-20 11:22:59 +08:00
});
});
//获取服务器配置
//测试url http://127.0.0.1/index/api/getServerConfig
2020-12-27 22:14:59 +08:00
api_regist("/index/api/getServerConfig",[](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 11:22:59 +08:00
Value obj;
for (auto &pr : mINI::Instance()) {
obj[pr.first] = (string &) pr.second;
}
val["data"].append(obj);
});
//设置服务器配置
//测试url(比如关闭http api调试) http://127.0.0.1/index/api/setServerConfig?api.apiDebug=0
//你也可以通过http post方式传参可以通过application/x-www-form-urlencoded或application/json方式传参
2020-12-27 22:14:59 +08:00
api_regist("/index/api/setServerConfig",[](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 11:22:59 +08:00
auto &ini = mINI::Instance();
2019-05-28 09:38:15 +08:00
int changed = API::Success;
2021-08-12 16:07:31 +08:00
for (auto &pr : allArgs.getArgs()) {
2019-05-20 11:22:59 +08:00
if (ini.find(pr.first) == ini.end()) {
#if 1
2019-05-20 11:22:59 +08:00
//没有这个key
continue;
#else
// 新增配置选项,为了动态添加多个ffmpeg cmd 模板
ini[pr.first] = pr.second;
// 防止changed变化
continue;
#endif
2019-05-20 11:22:59 +08:00
}
if (pr.first == FFmpeg::kBin) {
WarnL << "Configuration named " << FFmpeg::kBin << " is not allowed to be set by setServerConfig api.";
continue;
}
2019-05-20 11:22:59 +08:00
if (ini[pr.first] == pr.second) {
continue;
}
ini[pr.first] = pr.second;
//替换成功
++changed;
}
if (changed > 0) {
NOTICE_EMIT(BroadcastReloadConfigArgs, Broadcast::kBroadcastReloadConfig);
ini.dumpFile(g_ini_file);
2019-05-20 11:22:59 +08:00
}
val["changed"] = changed;
});
2020-12-27 22:14:59 +08:00
static auto s_get_api_list = [](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 11:22:59 +08:00
for(auto &pr : s_map_api){
val["data"].append(pr.first);
}
2020-01-17 11:44:20 +08:00
};
//获取服务器api列表
//测试url http://127.0.0.1/index/api/getApiList
2020-12-27 22:14:59 +08:00
api_regist("/index/api/getApiList",[](API_ARGS_MAP){
s_get_api_list(API_ARGS_VALUE);
2020-01-17 11:44:20 +08:00
});
//获取服务器api列表
//测试url http://127.0.0.1/index/
2020-12-27 22:14:59 +08:00
api_regist("/index/",[](API_ARGS_MAP){
s_get_api_list(API_ARGS_VALUE);
2019-05-20 11:22:59 +08:00
});
2019-06-15 17:07:10 +08:00
#if !defined(_WIN32)
//重启服务器,只有Daemon方式才能重启否则是直接关闭
//测试url http://127.0.0.1/index/api/restartServer
2020-12-27 22:14:59 +08:00
api_regist("/index/api/restartServer",[](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 11:22:59 +08:00
EventPollerPool::Instance().getPoller()->doDelayTask(1000,[](){
//尝试正常退出
::kill(getpid(), SIGINT);
//3秒后强制退出
EventPollerPool::Instance().getPoller()->doDelayTask(3000,[](){
exit(0);
return 0;
});
return 0;
});
2023-12-02 15:02:00 +08:00
val["msg"] = "MediaServer will reboot in on 1 second";
2019-05-20 11:22:59 +08:00
});
#else
//增加Windows下的重启代码
api_regist("/index/api/restartServer", [](API_ARGS_MAP) {
CHECK_SECRET();
//创建重启批处理脚本文件
FILE *pf;
errno_t err = ::_wfopen_s(&pf, L"RestartServer.cmd", L"w"); //“w”如果该文件存在其内容将被覆盖
if (err == 0) {
char szExeName[1024];
char drive[_MAX_DRIVE] = { 0 };
char dir[_MAX_DIR] = { 0 };
char fname[_MAX_FNAME] = { 0 };
char ext[_MAX_EXT] = { 0 };
char exeName[_MAX_FNAME] = { 0 };
GetModuleFileNameA(NULL, szExeName, 1024); //获取进程的全路径
_splitpath(szExeName, drive, dir, fname, ext);
strcpy(exeName, fname);
strcat(exeName, ext);
fprintf(pf, "@echo off\ntaskkill /f /im %s\nstart \"\" \"%s\"\ndel %%0", exeName, szExeName);
fclose(pf);
// 1秒后执行创建的批处理脚本
EventPollerPool::Instance().getPoller()->doDelayTask(1000, []() {
STARTUPINFO si;
PROCESS_INFORMATION pi;
ZeroMemory(&si, sizeof si);
ZeroMemory(&pi, sizeof pi);
si.cb = sizeof si;
si.dwFlags = STARTF_USESHOWWINDOW;
si.wShowWindow = SW_HIDE;
TCHAR winSysDir[1024];
ZeroMemory(winSysDir, sizeof winSysDir);
GetSystemDirectory(winSysDir, 1024);
TCHAR appName[1024];
ZeroMemory(appName, sizeof appName);
_stprintf(appName, "%s\\cmd.exe", winSysDir);
BOOL bRet = CreateProcess(appName, " /c RestartServer.cmd", NULL, NULL, FALSE, 0, NULL, NULL, &si, &pi);
if (bRet == FALSE) {
int err = GetLastError();
cout << endl << "无法执行重启操作,错误代码:" << err << endl;
}
WaitForSingleObject(pi.hProcess, INFINITE);
CloseHandle(pi.hProcess);
CloseHandle(pi.hThread);
return 0;
});
val["msg"] = "服务器将在一秒后自动重启";
} else {
val["msg"] = "创建重启脚本文件失败";
val["code"] = API::OtherFailed;
}
});
2019-06-15 17:07:10 +08:00
#endif//#if !defined(_WIN32)
2019-05-20 11:22:59 +08:00
//获取流列表,可选筛选参数
//测试url0(获取所有流) http://127.0.0.1/index/api/getMediaList
//测试url1(获取虚拟主机为"__defaultVost__"的流) http://127.0.0.1/index/api/getMediaList?vhost=__defaultVost__
//测试url2(获取rtsp类型的流) http://127.0.0.1/index/api/getMediaList?schema=rtsp
2020-12-27 22:14:59 +08:00
api_regist("/index/api/getMediaList",[](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 11:22:59 +08:00
//获取所有MediaSource列表
2021-06-30 21:06:29 +08:00
MediaSource::for_each_media([&](const MediaSource::Ptr &media) {
2021-04-08 17:34:13 +08:00
val["data"].append(makeMediaSourceJson(*media));
2021-06-30 21:06:29 +08:00
}, allArgs["schema"], allArgs["vhost"], allArgs["app"], allArgs["stream"]);
2019-05-20 11:22:59 +08:00
});
//测试url http://127.0.0.1/index/api/isMediaOnline?schema=rtsp&vhost=__defaultVhost__&app=live&stream=obs
2020-12-27 22:14:59 +08:00
api_regist("/index/api/isMediaOnline",[](API_ARGS_MAP){
CHECK_SECRET();
CHECK_ARGS("schema","vhost","app","stream");
2020-05-26 10:11:58 +08:00
val["online"] = (bool) (MediaSource::find(allArgs["schema"],allArgs["vhost"],allArgs["app"],allArgs["stream"]));
});
//获取媒体流播放器列表
//测试url http://127.0.0.1/index/api/getMediaPlayerList?schema=rtsp&vhost=__defaultVhost__&app=live&stream=obs
api_regist("/index/api/getMediaPlayerList",[](API_ARGS_MAP_ASYNC){
CHECK_SECRET();
CHECK_ARGS("schema", "vhost", "app", "stream");
auto src = MediaSource::find(allArgs["schema"], allArgs["vhost"], allArgs["app"], allArgs["stream"]);
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
src->getPlayerList(
[=](const std::list<toolkit::Any> &info_list) mutable {
val["code"] = API::Success;
auto &data = val["data"];
data = Value(arrayValue);
for (auto &info : info_list) {
auto &obj = info.get<Value>();
data.append(std::move(obj));
}
invoker(200, headerOut, val.toStyledString());
},
[](toolkit::Any &&info) -> toolkit::Any {
auto obj = std::make_shared<Value>();
auto &sock = info.get<SockInfo>();
fillSockInfo(*obj, &sock);
(*obj)["typeid"] = toolkit::demangle(typeid(sock).name());
toolkit::Any ret;
ret.set(obj);
return ret;
});
});
api_regist("/index/api/broadcastMessage", [](API_ARGS_MAP) {
CHECK_SECRET();
CHECK_ARGS("schema", "vhost", "app", "stream", "msg");
auto src = MediaSource::find(allArgs["schema"], allArgs["vhost"], allArgs["app"], allArgs["stream"]);
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
Any any;
Buffer::Ptr buffer = std::make_shared<BufferLikeString>(allArgs["msg"]);
any.set(std::move(buffer));
src->broadcastMessage(any);
});
//测试url http://127.0.0.1/index/api/getMediaInfo?schema=rtsp&vhost=__defaultVhost__&app=live&stream=obs
api_regist("/index/api/getMediaInfo",[](API_ARGS_MAP_ASYNC){
CHECK_SECRET();
CHECK_ARGS("schema","vhost","app","stream");
2020-05-26 10:11:58 +08:00
auto src = MediaSource::find(allArgs["schema"],allArgs["vhost"],allArgs["app"],allArgs["stream"]);
if(!src){
throw ApiRetException("can not find the stream", API::NotFound);
}
src->getOwnerPoller()->async([=]() mutable {
auto val = makeMediaSourceJson(*src);
val["code"] = API::Success;
invoker(200, headerOut, val.toStyledString());
});
});
2019-05-27 14:14:42 +08:00
//主动关断流,包括关断拉流、推流
2019-05-27 18:39:43 +08:00
//测试url http://127.0.0.1/index/api/close_stream?schema=rtsp&vhost=__defaultVhost__&app=live&stream=obs&force=1
api_regist("/index/api/close_stream",[](API_ARGS_MAP_ASYNC){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 16:53:29 +08:00
CHECK_ARGS("schema","vhost","app","stream");
2019-05-20 11:22:59 +08:00
//踢掉推流器
auto src = MediaSource::find(allArgs["schema"],
allArgs["vhost"],
allArgs["app"],
allArgs["stream"]);
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
bool force = allArgs["force"].as<bool>();
src->getOwnerPoller()->async([=]() mutable {
bool flag = src->close(force);
val["result"] = flag ? 0 : -1;
2019-05-27 14:15:21 +08:00
val["msg"] = flag ? "success" : "close failed";
val["code"] = flag ? API::Success : API::OtherFailed;
invoker(200, headerOut, val.toStyledString());
});
2019-05-20 11:22:59 +08:00
});
2019-11-18 10:46:59 +08:00
//批量主动关断流,包括关断拉流、推流
//测试url http://127.0.0.1/index/api/close_streams?schema=rtsp&vhost=__defaultVhost__&app=live&stream=obs&force=1
2020-12-27 22:14:59 +08:00
api_regist("/index/api/close_streams",[](API_ARGS_MAP){
2019-11-18 10:46:59 +08:00
CHECK_SECRET();
//筛选命中个数
int count_hit = 0;
int count_closed = 0;
2019-11-19 10:55:44 +08:00
list<MediaSource::Ptr> media_list;
2021-06-30 21:06:29 +08:00
MediaSource::for_each_media([&](const MediaSource::Ptr &media) {
2019-11-18 10:46:59 +08:00
++count_hit;
2019-11-19 10:55:44 +08:00
media_list.emplace_back(media);
2021-06-30 21:06:29 +08:00
}, allArgs["schema"], allArgs["vhost"], allArgs["app"], allArgs["stream"]);
2019-11-19 10:55:44 +08:00
bool force = allArgs["force"].as<bool>();
for (auto &media : media_list) {
if (media->close(force)) {
2019-11-18 10:46:59 +08:00
++count_closed;
}
2019-11-19 10:55:44 +08:00
}
2019-11-18 10:46:59 +08:00
val["count_hit"] = count_hit;
val["count_closed"] = count_closed;
});
//获取所有Session列表信息
//可以根据本地端口和远端ip来筛选
//测试url(筛选某端口下的tcp会话) http://127.0.0.1/index/api/getAllSession?local_port=1935
2020-12-27 22:14:59 +08:00
api_regist("/index/api/getAllSession",[](API_ARGS_MAP){
CHECK_SECRET();
Value jsession;
uint16_t local_port = allArgs["local_port"].as<uint16_t>();
2021-08-12 16:07:31 +08:00
string peer_ip = allArgs["peer_ip"];
2021-06-08 11:29:32 +08:00
SessionMap::Instance().for_each_session([&](const string &id,const Session::Ptr &session){
2019-11-18 16:16:56 +08:00
if(local_port != 0 && local_port != session->get_local_port()){
return;
}
if(!peer_ip.empty() && peer_ip != session->get_peer_ip()){
return;
}
fillSockInfo(jsession, session.get());
jsession["id"] = id;
jsession["typeid"] = toolkit::demangle(typeid(*session).name());
val["data"].append(jsession);
});
});
//断开tcp连接比如说可以断开rtsp、rtmp播放器等
//测试url http://127.0.0.1/index/api/kick_session?id=123456
2020-12-27 22:14:59 +08:00
api_regist("/index/api/kick_session",[](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
2019-05-20 16:53:29 +08:00
CHECK_ARGS("id");
2019-05-20 11:22:59 +08:00
//踢掉tcp会话
2019-05-28 09:38:15 +08:00
auto session = SessionMap::Instance().get(allArgs["id"]);
2019-05-20 11:22:59 +08:00
if(!session){
throw ApiRetException("can not find the target",API::OtherFailed);
2019-05-20 11:22:59 +08:00
}
session->safeShutdown();
});
2019-11-18 16:34:39 +08:00
//批量断开tcp连接比如说可以断开rtsp、rtmp播放器等
//测试url http://127.0.0.1/index/api/kick_sessions?local_port=1935
api_regist("/index/api/kick_sessions", [](API_ARGS_MAP) {
2019-11-18 16:34:39 +08:00
CHECK_SECRET();
uint16_t local_port = allArgs["local_port"].as<uint16_t>();
2021-08-12 16:07:31 +08:00
string peer_ip = allArgs["peer_ip"];
size_t count_hit = 0;
2019-11-18 16:34:39 +08:00
2021-06-08 11:29:32 +08:00
list<Session::Ptr> session_list;
SessionMap::Instance().for_each_session([&](const string &id, const Session::Ptr &session) {
if (local_port != 0 && local_port != session->get_local_port()) {
2019-11-18 16:34:39 +08:00
return;
}
if (!peer_ip.empty() && peer_ip != session->get_peer_ip()) {
return;
}
if (session->getIdentifier() == sender.getIdentifier()) {
// 忽略本http链接
2019-11-18 16:34:39 +08:00
return;
}
2019-11-19 10:55:44 +08:00
session_list.emplace_back(session);
2019-11-18 16:34:39 +08:00
++count_hit;
});
2019-11-19 10:55:44 +08:00
for (auto &session : session_list) {
2019-11-19 10:55:44 +08:00
session->safeShutdown();
}
2019-11-18 16:34:39 +08:00
val["count_hit"] = (Json::UInt64)count_hit;
});
2021-06-16 19:40:08 +08:00
//动态添加rtsp/rtmp推流代理
//测试url http://127.0.0.1/index/api/addStreamPusherProxy?schema=rtmp&vhost=__defaultVhost__&app=proxy&stream=0&dst_url=rtmp://127.0.0.1/live/obs
api_regist("/index/api/addStreamPusherProxy", [](API_ARGS_MAP_ASYNC) {
CHECK_SECRET();
2021-06-17 10:12:34 +08:00
CHECK_ARGS("schema", "vhost", "app", "stream", "dst_url");
auto dst_url = allArgs["dst_url"];
2023-04-01 23:54:11 +08:00
auto retry_count = allArgs["retry_count"].empty() ? -1 : allArgs["retry_count"].as<int>();
2021-06-16 19:40:08 +08:00
addStreamPusherProxy(allArgs["schema"],
allArgs["vhost"],
allArgs["app"],
allArgs["stream"],
2021-06-17 10:12:34 +08:00
allArgs["dst_url"],
2023-03-22 15:52:56 +08:00
retry_count,
allArgs["rtp_type"],
allArgs["timeout_sec"],
2021-06-17 10:12:34 +08:00
[invoker, val, headerOut, dst_url](const SockException &ex, const string &key) mutable {
if (ex) {
val["code"] = API::OtherFailed;
val["msg"] = ex.what();
} else {
val["data"]["key"] = key;
InfoL << "Publish success, please play with player:" << dst_url;
2021-06-16 19:40:08 +08:00
}
invoker(200, headerOut, val.toStyledString());
});
});
//关闭推流代理
//测试url http://127.0.0.1/index/api/delStreamPusherProxy?key=__defaultVhost__/proxy/0
2021-06-17 10:12:34 +08:00
api_regist("/index/api/delStreamPusherProxy", [](API_ARGS_MAP) {
2021-06-16 19:40:08 +08:00
CHECK_SECRET();
CHECK_ARGS("key");
val["data"]["flag"] = s_pusher_proxy.erase(allArgs["key"]) == 1;
2021-06-16 19:40:08 +08:00
});
2019-05-27 23:07:12 +08:00
//动态添加rtsp/rtmp拉流代理
2019-07-22 11:38:32 +08:00
//测试url http://127.0.0.1/index/api/addStreamProxy?vhost=__defaultVhost__&app=proxy&enable_rtsp=1&enable_rtmp=1&stream=0&url=rtmp://127.0.0.1/live/obs
2020-12-27 22:14:59 +08:00
api_regist("/index/api/addStreamProxy",[](API_ARGS_MAP_ASYNC){
2019-05-27 23:07:12 +08:00
CHECK_SECRET();
2020-09-20 09:26:00 +08:00
CHECK_ARGS("vhost","app","stream","url");
mINI args;
for (auto &pr : allArgs.getArgs()) {
args.emplace(pr.first, pr.second);
}
2022-09-16 23:30:55 +08:00
ProtocolOption option(allArgs);
2023-03-22 15:52:56 +08:00
auto retry_count = allArgs["retry_count"].empty()? -1: allArgs["retry_count"].as<int>();
2019-05-27 23:07:12 +08:00
addStreamProxy(allArgs["vhost"],
allArgs["app"],
allArgs["stream"],
allArgs["url"],
2023-03-22 15:52:56 +08:00
retry_count,
option,
2019-05-27 23:07:12 +08:00
allArgs["rtp_type"],
2021-04-30 18:01:48 +08:00
allArgs["timeout_sec"],
args,
2021-03-14 10:29:17 +08:00
[invoker,val,headerOut](const SockException &ex,const string &key) mutable{
if (ex) {
val["code"] = API::OtherFailed;
val["msg"] = ex.what();
} else {
val["data"]["key"] = key;
2019-05-27 23:07:12 +08:00
}
invoker(200, headerOut, val.toStyledString());
2019-05-27 23:07:12 +08:00
});
2019-05-20 16:26:04 +08:00
});
//关闭拉流代理
//测试url http://127.0.0.1/index/api/delStreamProxy?key=__defaultVhost__/proxy/0
2020-12-27 22:14:59 +08:00
api_regist("/index/api/delStreamProxy",[](API_ARGS_MAP){
2019-05-20 17:12:00 +08:00
CHECK_SECRET();
CHECK_ARGS("key");
val["data"]["flag"] = s_player_proxy.erase(allArgs["key"]) == 1;
2019-05-20 16:26:04 +08:00
});
2021-01-23 09:42:15 +08:00
static auto addFFmpegSource = [](const string &ffmpeg_cmd_key,
const string &src_url,
2019-06-06 18:28:33 +08:00
const string &dst_url,
int timeout_ms,
bool enable_hls,
bool enable_mp4,
const function<void(const SockException &ex, const string &key)> &cb) {
2019-06-06 18:28:33 +08:00
auto key = MD5(dst_url).hexdigest();
if (s_ffmpeg_src.find(key)) {
2019-06-06 18:28:33 +08:00
//已经在拉流了
cb(SockException(Err_success), key);
2019-06-06 18:28:33 +08:00
return;
}
auto ffmpeg = s_ffmpeg_src.make(key);
2019-06-06 18:28:33 +08:00
ffmpeg->setOnClose([key]() {
s_ffmpeg_src.erase(key);
2019-06-06 18:28:33 +08:00
});
2021-01-17 20:15:08 +08:00
ffmpeg->setupRecordFlag(enable_hls, enable_mp4);
2021-01-23 09:42:15 +08:00
ffmpeg->play(ffmpeg_cmd_key, src_url, dst_url, timeout_ms, [cb, key](const SockException &ex) {
if (ex) {
s_ffmpeg_src.erase(key);
2019-06-06 18:28:33 +08:00
}
cb(ex, key);
2019-06-06 18:28:33 +08:00
});
};
//动态添加rtsp/rtmp拉流代理
//测试url http://127.0.0.1/index/api/addFFmpegSource?src_url=http://live.hkstv.hk.lxdns.com/live/hks2/playlist.m3u8&dst_url=rtmp://127.0.0.1/live/hks2&timeout_ms=10000
2020-12-27 22:14:59 +08:00
api_regist("/index/api/addFFmpegSource",[](API_ARGS_MAP_ASYNC){
2019-06-06 18:28:33 +08:00
CHECK_SECRET();
CHECK_ARGS("src_url","dst_url","timeout_ms");
auto src_url = allArgs["src_url"];
auto dst_url = allArgs["dst_url"];
int timeout_ms = allArgs["timeout_ms"];
auto enable_hls = allArgs["enable_hls"].as<int>();
auto enable_mp4 = allArgs["enable_mp4"].as<int>();
2019-06-06 18:28:33 +08:00
2021-01-23 09:42:15 +08:00
addFFmpegSource(allArgs["ffmpeg_cmd_key"], src_url, dst_url, timeout_ms, enable_hls, enable_mp4,
2021-03-14 10:29:17 +08:00
[invoker, val, headerOut](const SockException &ex, const string &key) mutable{
if (ex) {
2021-03-14 10:29:17 +08:00
val["code"] = API::OtherFailed;
val["msg"] = ex.what();
} else {
2021-03-14 10:29:17 +08:00
val["data"]["key"] = key;
2019-06-06 18:28:33 +08:00
}
invoker(200, headerOut, val.toStyledString());
2019-06-06 18:28:33 +08:00
});
});
2020-12-27 21:48:04 +08:00
//关闭拉流代理
//测试url http://127.0.0.1/index/api/delFFmepgSource?key=key
2020-12-27 22:14:59 +08:00
api_regist("/index/api/delFFmpegSource",[](API_ARGS_MAP){
2019-06-06 18:28:33 +08:00
CHECK_SECRET();
CHECK_ARGS("key");
val["data"]["flag"] = s_ffmpeg_src.erase(allArgs["key"]) == 1;
2019-06-06 18:28:33 +08:00
});
2019-05-20 16:26:04 +08:00
2019-10-28 17:23:16 +08:00
//新增http api下载可执行程序文件接口
//测试url http://127.0.0.1/index/api/downloadBin
2020-12-27 22:14:59 +08:00
api_regist("/index/api/downloadBin",[](API_ARGS_MAP_ASYNC){
2019-10-28 17:23:16 +08:00
CHECK_SECRET();
2021-08-12 16:07:31 +08:00
invoker.responseFile(allArgs.getParser().getHeader(),StrCaseMap(),exePath());
2019-10-28 17:23:16 +08:00
});
2019-12-06 11:54:10 +08:00
#if defined(ENABLE_RTPPROXY)
2020-12-27 22:14:59 +08:00
api_regist("/index/api/getRtpInfo",[](API_ARGS_MAP){
2019-12-05 19:53:55 +08:00
CHECK_SECRET();
CHECK_ARGS("stream_id");
auto process = RtpSelector::Instance().getProcess(allArgs["stream_id"], false);
if (!process) {
2019-12-05 19:53:55 +08:00
val["exist"] = false;
return;
}
val["exist"] = true;
fillSockInfo(val, process.get());
2019-12-05 19:53:55 +08:00
});
2020-12-27 22:14:59 +08:00
api_regist("/index/api/openRtpServer",[](API_ARGS_MAP){
CHECK_SECRET();
CHECK_ARGS("port", "stream_id");
auto stream_id = allArgs["stream_id"];
auto tcp_mode = allArgs["tcp_mode"].as<int>();
if (allArgs["enable_tcp"].as<int>() && !tcp_mode) {
//兼容老版本请求新版本去除enable_tcp参数并新增tcp_mode参数
tcp_mode = 1;
}
auto only_track = allArgs["only_track"].as<int>();
if (allArgs["only_audio"].as<bool>()) {
// 兼容老版本请求新版本去除only_audio参数并新增only_track参数
only_track = 1;
}
std::string local_ip = "::";
if (!allArgs["local_ip"].empty()) {
local_ip = allArgs["local_ip"];
}
auto port = openRtpServer(allArgs["port"], stream_id, tcp_mode, local_ip, allArgs["re_use_port"].as<bool>(),
allArgs["ssrc"].as<uint32_t>(), only_track);
if (port == 0) {
throw InvalidArgsException("该stream_id已存在");
}
//回复json
2022-06-22 10:31:53 +08:00
val["port"] = port;
});
api_regist("/index/api/openRtpServerMultiplex", [](API_ARGS_MAP) {
CHECK_SECRET();
CHECK_ARGS("port", "stream_id");
auto stream_id = allArgs["stream_id"];
auto tcp_mode = allArgs["tcp_mode"].as<int>();
if (allArgs["enable_tcp"].as<int>() && !tcp_mode) {
// 兼容老版本请求新版本去除enable_tcp参数并新增tcp_mode参数
tcp_mode = 1;
}
auto only_track = allArgs["only_track"].as<int>();
if (allArgs["only_audio"].as<bool>()) {
// 兼容老版本请求新版本去除only_audio参数并新增only_track参数
only_track = 1;
}
std::string local_ip = "::";
if (!allArgs["local_ip"].empty()) {
local_ip = allArgs["local_ip"];
}
auto port = openRtpServer(allArgs["port"], stream_id, tcp_mode, local_ip, true, 0, only_track,true);
if (port == 0) {
throw InvalidArgsException("该stream_id已存在");
}
// 回复json
val["port"] = port;
});
api_regist("/index/api/connectRtpServer", [](API_ARGS_MAP_ASYNC) {
CHECK_SECRET();
CHECK_ARGS("stream_id", "dst_url", "dst_port");
auto cb = [val, headerOut, invoker](const SockException &ex) mutable {
if (ex) {
val["code"] = API::OtherFailed;
val["msg"] = ex.what();
}
invoker(200, headerOut, val.toStyledString());
};
auto server = s_rtp_server.find(allArgs["stream_id"]);
if (!server) {
cb(SockException(Err_other, "未找到rtp服务"));
return;
}
server->connectToServer(allArgs["dst_url"], allArgs["dst_port"], cb);
});
2020-12-27 22:14:59 +08:00
api_regist("/index/api/closeRtpServer",[](API_ARGS_MAP){
CHECK_SECRET();
CHECK_ARGS("stream_id");
if(s_rtp_server.erase(allArgs["stream_id"]) == 0){
val["hit"] = 0;
return;
}
val["hit"] = 1;
});
api_regist("/index/api/updateRtpServerSSRC",[](API_ARGS_MAP){
CHECK_SECRET();
CHECK_ARGS("stream_id", "ssrc");
auto server = s_rtp_server.find(allArgs["stream_id"]);
if (!server) {
throw ApiRetException("RtpServer not found by stream_id", API::NotFound);
}
server->updateSSRC(allArgs["ssrc"]);
});
2020-12-27 22:14:59 +08:00
api_regist("/index/api/listRtpServer",[](API_ARGS_MAP){
2020-07-02 22:26:38 +08:00
CHECK_SECRET();
std::lock_guard<std::recursive_mutex> lck(s_rtp_server._mtx);
for (auto &pr : s_rtp_server._map) {
Value obj;
obj["stream_id"] = pr.first;
obj["port"] = pr.second->getPort();
val["data"].append(obj);
2020-07-02 22:26:38 +08:00
}
});
2020-12-27 22:14:59 +08:00
api_regist("/index/api/startSendRtp",[](API_ARGS_MAP_ASYNC){
2020-09-06 17:56:05 +08:00
CHECK_SECRET();
CHECK_ARGS("vhost", "app", "stream", "ssrc", "dst_url", "dst_port", "is_udp");
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"], allArgs["from_mp4"].as<int>());
2021-08-12 16:07:31 +08:00
if (!src) {
throw ApiRetException("can not find the source stream", API::NotFound);
2020-09-06 17:56:05 +08:00
}
auto type = allArgs["type"].as<int>();
if (!allArgs["use_ps"].empty()) {
// 兼容之前的use_ps参数
type = allArgs["use_ps"].as<int>();
}
2022-04-03 18:25:36 +08:00
MediaSourceEvent::SendRtpArgs args;
args.passive = false;
2022-04-03 18:25:36 +08:00
args.dst_url = allArgs["dst_url"];
args.dst_port = allArgs["dst_port"];
args.ssrc_multi_send = allArgs["ssrc_multi_send"].empty() ? false : allArgs["ssrc_multi_send"].as<bool>();
2022-04-03 18:25:36 +08:00
args.ssrc = allArgs["ssrc"];
args.is_udp = allArgs["is_udp"];
args.src_port = allArgs["src_port"];
args.pt = allArgs["pt"].empty() ? 96 : allArgs["pt"].as<int>();
args.type = (MediaSourceEvent::SendRtpArgs::Type)type;
args.only_audio = allArgs["only_audio"].as<bool>();
args.udp_rtcp_timeout = allArgs["udp_rtcp_timeout"];
args.recv_stream_id = allArgs["recv_stream_id"];
TraceL << "startSendRtp, pt " << int(args.pt) << " rtp type " << type << " audio " << args.only_audio;
2022-04-03 18:25:36 +08:00
src->getOwnerPoller()->async([=]() mutable {
src->startSendRtp(args, [val, headerOut, invoker](uint16_t local_port, const SockException &ex) mutable {
if (ex) {
val["code"] = API::OtherFailed;
val["msg"] = ex.what();
}
val["local_port"] = local_port;
invoker(200, headerOut, val.toStyledString());
});
2022-04-03 18:25:36 +08:00
});
2020-09-06 17:56:05 +08:00
});
api_regist("/index/api/startSendRtpPassive",[](API_ARGS_MAP_ASYNC){
CHECK_SECRET();
CHECK_ARGS("vhost", "app", "stream", "ssrc");
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"], allArgs["from_mp4"].as<int>());
if (!src) {
throw ApiRetException("can not find the source stream", API::NotFound);
}
auto type = allArgs["type"].as<int>();
if (!allArgs["use_ps"].empty()) {
// 兼容之前的use_ps参数
type = allArgs["use_ps"].as<int>();
}
MediaSourceEvent::SendRtpArgs args;
args.passive = true;
args.ssrc = allArgs["ssrc"];
args.is_udp = false;
args.src_port = allArgs["src_port"];
args.pt = allArgs["pt"].empty() ? 96 : allArgs["pt"].as<int>();
args.type = (MediaSourceEvent::SendRtpArgs::Type)type;
args.only_audio = allArgs["only_audio"].as<bool>();
args.recv_stream_id = allArgs["recv_stream_id"];
//tcp被动服务器等待链接超时时间
args.tcp_passive_close_delay_ms = allArgs["close_delay_ms"];
TraceL << "startSendRtpPassive, pt " << int(args.pt) << " rtp type " << type << " audio " << args.only_audio;
src->getOwnerPoller()->async([=]() mutable {
src->startSendRtp(args, [val, headerOut, invoker](uint16_t local_port, const SockException &ex) mutable {
if (ex) {
val["code"] = API::OtherFailed;
val["msg"] = ex.what();
}
val["local_port"] = local_port;
invoker(200, headerOut, val.toStyledString());
});
});
});
api_regist("/index/api/stopSendRtp",[](API_ARGS_MAP_ASYNC){
2020-09-06 17:56:05 +08:00
CHECK_SECRET();
CHECK_ARGS("vhost", "app", "stream");
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"]);
2020-09-06 17:56:05 +08:00
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
2020-09-06 17:56:05 +08:00
}
src->getOwnerPoller()->async([=]() mutable {
// ssrc如果为空关闭全部
if (!src->stopSendRtp(allArgs["ssrc"])) {
val["code"] = API::OtherFailed;
val["msg"] = "stopSendRtp failed";
invoker(200, headerOut, val.toStyledString());
return;
}
invoker(200, headerOut, val.toStyledString());
});
2020-09-06 17:56:05 +08:00
});
2020-12-27 22:14:59 +08:00
api_regist("/index/api/pauseRtpCheck", [](API_ARGS_MAP) {
CHECK_SECRET();
CHECK_ARGS("stream_id");
//只是暂停流的检查流媒体服务器做为流负载服务收流就转发RTSP/RTMP有自己暂停协议
auto rtp_process = RtpSelector::Instance().getProcess(allArgs["stream_id"], false);
if (rtp_process) {
rtp_process->setStopCheckRtp(true);
} else {
val["code"] = API::NotFound;
}
});
2020-12-27 22:14:59 +08:00
api_regist("/index/api/resumeRtpCheck", [](API_ARGS_MAP) {
CHECK_SECRET();
CHECK_ARGS("stream_id");
auto rtp_process = RtpSelector::Instance().getProcess(allArgs["stream_id"], false);
if (rtp_process) {
rtp_process->setStopCheckRtp(false);
} else {
val["code"] = API::NotFound;
}
});
2020-09-06 17:56:05 +08:00
2019-12-06 11:54:10 +08:00
#endif//ENABLE_RTPPROXY
2019-12-05 19:53:55 +08:00
2020-04-05 09:26:29 +08:00
// 开始录制hls或MP4
api_regist("/index/api/startRecord",[](API_ARGS_MAP_ASYNC){
2020-04-05 09:26:29 +08:00
CHECK_SECRET();
CHECK_ARGS("type","vhost","app","stream");
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"] );
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
src->getOwnerPoller()->async([=]() mutable {
auto result = src->setupRecord((Recorder::type)allArgs["type"].as<int>(), true, allArgs["customized_path"], allArgs["max_second"].as<size_t>());
val["result"] = result;
val["code"] = result ? API::Success : API::OtherFailed;
val["msg"] = result ? "success" : "start record failed";
invoker(200, headerOut, val.toStyledString());
});
2020-04-05 09:26:29 +08:00
});
2023-04-01 23:54:11 +08:00
2021-10-25 15:13:21 +08:00
//设置录像流播放速度
api_regist("/index/api/setRecordSpeed", [](API_ARGS_MAP_ASYNC) {
2021-10-25 15:13:21 +08:00
CHECK_SECRET();
CHECK_ARGS("schema", "vhost", "app", "stream", "speed");
auto src = MediaSource::find(allArgs["schema"],
allArgs["vhost"],
allArgs["app"],
allArgs["stream"]);
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
auto speed = allArgs["speed"].as<float>();
src->getOwnerPoller()->async([=]() mutable {
bool flag = src->speed(speed);
2021-10-25 15:13:21 +08:00
val["result"] = flag ? 0 : -1;
val["msg"] = flag ? "success" : "set failed";
val["code"] = flag ? API::Success : API::OtherFailed;
invoker(200, headerOut, val.toStyledString());
});
2021-10-25 15:13:21 +08:00
});
api_regist("/index/api/seekRecordStamp", [](API_ARGS_MAP_ASYNC) {
2021-10-25 15:13:21 +08:00
CHECK_SECRET();
CHECK_ARGS("schema", "vhost", "app", "stream", "stamp");
auto src = MediaSource::find(allArgs["schema"],
allArgs["vhost"],
allArgs["app"],
allArgs["stream"]);
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
auto stamp = allArgs["stamp"].as<size_t>();
src->getOwnerPoller()->async([=]() mutable {
bool flag = src->seekTo(stamp);
2021-10-25 15:13:21 +08:00
val["result"] = flag ? 0 : -1;
val["msg"] = flag ? "success" : "seek failed";
val["code"] = flag ? API::Success : API::OtherFailed;
invoker(200, headerOut, val.toStyledString());
});
2021-10-25 15:13:21 +08:00
});
2020-04-05 09:26:29 +08:00
// 停止录制hls或MP4
api_regist("/index/api/stopRecord",[](API_ARGS_MAP_ASYNC){
2020-04-05 09:26:29 +08:00
CHECK_SECRET();
CHECK_ARGS("type","vhost","app","stream");
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"] );
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
auto type = (Recorder::type)allArgs["type"].as<int>();
src->getOwnerPoller()->async([=]() mutable {
auto result = src->setupRecord(type, false, "", 0);
val["result"] = result;
val["code"] = result ? API::Success : API::OtherFailed;
val["msg"] = result ? "success" : "stop record failed";
invoker(200, headerOut, val.toStyledString());
});
2020-04-05 09:26:29 +08:00
});
// 获取hls或MP4录制状态
api_regist("/index/api/isRecording",[](API_ARGS_MAP_ASYNC){
2020-04-05 09:26:29 +08:00
CHECK_SECRET();
CHECK_ARGS("type","vhost","app","stream");
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"]);
if (!src) {
throw ApiRetException("can not find the stream", API::NotFound);
}
auto type = (Recorder::type)allArgs["type"].as<int>();
src->getOwnerPoller()->async([=]() mutable {
val["status"] = src->isRecording(type);
invoker(200, headerOut, val.toStyledString());
});
2020-04-05 09:26:29 +08:00
});
2023-04-01 23:54:11 +08:00
api_regist("/index/api/getProxyPusherInfo", [](API_ARGS_MAP_ASYNC) {
CHECK_SECRET();
CHECK_ARGS("key");
auto pusher = s_pusher_proxy.find(allArgs["key"]);
if (!pusher) {
throw ApiRetException("can not find pusher", API::NotFound);
}
val["data"]["status"] = pusher->getStatus();
val["data"]["liveSecs"] = pusher->getLiveSecs();
val["data"]["rePublishCount"] = pusher->getRePublishCount();
invoker(200, headerOut, val.toStyledString());
});
api_regist("/index/api/getProxyInfo", [](API_ARGS_MAP_ASYNC) {
CHECK_SECRET();
CHECK_ARGS("key");
auto proxy = s_player_proxy.find(allArgs["key"]);
if (!proxy) {
throw ApiRetException("can not find the proxy", API::NotFound);
}
val["data"]["status"] = proxy->getStatus();
val["data"]["liveSecs"] = proxy->getLiveSecs();
val["data"]["rePullCount"] = proxy->getRePullCount();
invoker(200, headerOut, val.toStyledString());
});
// 删除录像文件夹
// http://127.0.0.1/index/api/deleteRecordDirectroy?vhost=__defaultVhost__&app=live&stream=ss&period=2020-01-01
api_regist("/index/api/deleteRecordDirectory", [](API_ARGS_MAP) {
CHECK_SECRET();
CHECK_ARGS("vhost", "app", "stream", "period");
2023-05-25 16:23:24 +08:00
auto tuple = MediaTuple{allArgs["vhost"], allArgs["app"], allArgs["stream"]};
auto record_path = Recorder::getRecordPath(Recorder::type_mp4, tuple, allArgs["customized_path"]);
auto period = allArgs["period"];
record_path = record_path + period + "/";
auto name = allArgs["name"];
if (!name.empty()) {
record_path += name;
}
bool recording = false;
{
auto src = MediaSource::find(allArgs["vhost"], allArgs["app"], allArgs["stream"]);
if (src && src->isRecording(Recorder::type_mp4)) {
recording = true;
}
}
val["path"] = record_path;
if (!recording) {
val["code"] = File::delete_file(record_path, true);
return;
}
File::scanDir(record_path, [](const string &path, bool is_dir) {
if (is_dir) {
return true;
}
if (path.find("/.") == std::string::npos) {
2023-12-02 19:49:28 +08:00
File::delete_file(path);
} else {
TraceL << "Ignore tmp mp4 file: " << path;
}
return true;
}, true, true);
File::deleteEmptyDir(record_path);
});
2023-04-01 23:54:11 +08:00
2020-03-20 11:51:24 +08:00
//获取录像文件夹列表或mp4文件列表
2023-12-02 14:56:59 +08:00
//http://127.0.0.1/index/api/getMP4RecordFile?vhost=__defaultVhost__&app=live&stream=ss&period=2020-01
api_regist("/index/api/getMP4RecordFile", [](API_ARGS_MAP){
2020-02-01 23:26:33 +08:00
CHECK_SECRET();
CHECK_ARGS("vhost", "app", "stream");
2023-05-25 16:23:24 +08:00
auto tuple = MediaTuple{allArgs["vhost"], allArgs["app"], allArgs["stream"]};
auto record_path = Recorder::getRecordPath(Recorder::type_mp4, tuple, allArgs["customized_path"]);
2020-02-01 23:26:33 +08:00
auto period = allArgs["period"];
//判断是获取mp4文件列表还是获取文件夹列表
bool search_mp4 = period.size() == sizeof("2020-02-01") - 1;
if (search_mp4) {
record_path = record_path + period + "/";
}
Json::Value paths(arrayValue);
//这是筛选日期,获取文件夹列表
File::scanDir(record_path, [&](const string &path, bool isDir) {
auto pos = path.rfind('/');
2020-02-01 23:26:33 +08:00
if (pos != string::npos) {
string relative_path = path.substr(pos + 1);
if (search_mp4) {
if (!isDir) {
//我们只收集mp4文件对文件夹不感兴趣
paths.append(relative_path);
}
} else if (isDir && relative_path.find(period) == 0) {
//匹配到对应日期的文件夹
paths.append(relative_path);
}
}
return true;
}, false);
2020-01-19 14:54:31 +08:00
2020-02-01 23:26:33 +08:00
val["data"]["rootPath"] = record_path;
val["data"]["paths"] = paths;
2020-03-20 11:51:24 +08:00
});
2020-01-19 14:54:31 +08:00
2020-06-10 10:50:37 +08:00
static auto responseSnap = [](const string &snap_path,
const HttpSession::KeyValue &headerIn,
const HttpSession::HttpResponseInvoker &invoker,
const string &err_msg = "") {
static bool s_snap_success_once = false;
2020-06-10 10:50:37 +08:00
StrCaseMap headerOut;
GET_CONFIG(string, defaultSnap, API::kDefaultSnap);
2023-12-02 19:49:28 +08:00
if (!File::fileSize(snap_path)) {
if (!err_msg.empty() && (!s_snap_success_once || defaultSnap.empty())) {
//重来没截图成功过或者默认截图图片为空那么直接返回FFmpeg错误日志
headerOut["Content-Type"] = HttpFileManager::getContentType(".txt");
invoker.responseFile(headerIn, headerOut, err_msg, false, false);
return;
}
//截图成功过一次,那么认为配置无错误,截图失败时,返回预设默认图片
const_cast<string &>(snap_path) = File::absolutePath("", defaultSnap);
2020-06-10 10:50:37 +08:00
headerOut["Content-Type"] = HttpFileManager::getContentType(snap_path.data());
} else {
s_snap_success_once = true;
2020-06-10 10:50:37 +08:00
//之前生成的截图文件我们默认为jpeg格式
headerOut["Content-Type"] = HttpFileManager::getContentType(".jpeg");
}
//返回图片给http客户端
invoker.responseFile(headerIn, headerOut, snap_path);
};
//获取截图缓存或者实时截图
//http://127.0.0.1/index/api/getSnap?url=rtmp://127.0.0.1/record/robot.mp4&timeout_sec=10&expire_sec=3
2020-12-27 22:14:59 +08:00
api_regist("/index/api/getSnap", [](API_ARGS_MAP_ASYNC){
CHECK_SECRET();
CHECK_ARGS("url", "timeout_sec", "expire_sec");
2020-06-10 10:50:37 +08:00
GET_CONFIG(string, snap_root, API::kSnapRoot);
2020-09-26 10:07:22 +08:00
bool have_old_snap = false, res_old_snap = false;
int expire_sec = allArgs["expire_sec"];
2020-05-09 09:29:45 +08:00
auto scan_path = File::absolutePath(MD5(allArgs["url"]).hexdigest(), snap_root) + "/";
2020-09-26 10:07:22 +08:00
string new_snap = StrPrinter << scan_path << time(NULL) << ".jpeg";
2020-05-09 09:29:45 +08:00
File::scanDir(scan_path, [&](const string &path, bool isDir) {
2020-09-26 10:07:22 +08:00
if (isDir || !end_with(path, ".jpeg")) {
//忽略文件夹或其他类型的文件
2020-05-09 09:29:45 +08:00
return true;
}
2020-05-09 09:29:45 +08:00
//找到截图
auto tm = findSubString(path.data() + scan_path.size(), nullptr, ".jpeg");
2020-05-09 09:29:45 +08:00
if (atoll(tm.data()) + expire_sec < time(NULL)) {
2020-09-26 10:07:22 +08:00
//截图已经过期,改名,以便再次请求时,可以返回老截图
rename(path.data(), new_snap.data());
have_old_snap = true;
2020-05-09 09:29:45 +08:00
return true;
}
2020-09-26 10:07:22 +08:00
//截图存在,且未过期,那么返回之
res_old_snap = true;
2021-08-12 16:07:31 +08:00
responseSnap(path, allArgs.getParser().getHeader(), invoker);
2020-09-26 10:07:22 +08:00
//中断遍历
2020-05-09 09:29:45 +08:00
return false;
});
2020-09-26 10:07:22 +08:00
if (res_old_snap) {
//已经回复了旧的截图
2020-06-10 10:33:48 +08:00
return;
}
//无截图或者截图已经过期
2020-09-26 10:07:22 +08:00
if (!have_old_snap) {
//无过期截图,生成一个空文件,目的是顺便创建文件夹路径
//同时防止在FFmpeg生成截图途中不停的尝试调用该api多次启动FFmpeg进程
2023-12-02 19:49:28 +08:00
auto file = File::create_file(new_snap, "wb");
2020-09-26 10:07:22 +08:00
if (file) {
fclose(file);
}
2020-05-09 09:39:36 +08:00
}
2020-09-26 10:07:22 +08:00
//启动FFmpeg进程开始截图生成临时文件截图成功后替换为正式文件
auto new_snap_tmp = new_snap + ".tmp";
FFmpegSnap::makeSnap(allArgs["url"], new_snap_tmp, allArgs["timeout_sec"], [invoker, allArgs, new_snap, new_snap_tmp](bool success, const string &err_msg) {
2020-09-26 10:07:22 +08:00
if (!success) {
//生成截图失败,可能残留空文件
2023-12-02 19:49:28 +08:00
File::delete_file(new_snap_tmp);
2020-09-26 10:07:22 +08:00
} else {
//临时文件改成正式文件
2023-12-02 19:49:28 +08:00
File::delete_file(new_snap);
2020-09-26 10:07:22 +08:00
rename(new_snap_tmp.data(), new_snap.data());
}
responseSnap(new_snap, allArgs.getParser().getHeader(), invoker, err_msg);
});
});
2021-12-27 17:40:15 +08:00
api_regist("/index/api/getStatistic",[](API_ARGS_MAP_ASYNC){
2021-01-23 09:44:37 +08:00
CHECK_SECRET();
2021-12-27 17:40:15 +08:00
getStatisticJson([headerOut, val, invoker](const Value &data) mutable{
val["data"] = data;
invoker(200, headerOut, val.toStyledString());
});
2021-01-23 09:44:37 +08:00
});
2021-03-24 16:52:41 +08:00
#ifdef ENABLE_WEBRTC
2021-10-19 15:23:12 +08:00
class WebRtcArgsImp : public WebRtcArgs {
public:
WebRtcArgsImp(const HttpAllArgs<string> &args, std::string session_id)
: _args(args)
, _session_id(std::move(session_id)) {}
2021-10-19 15:23:12 +08:00
~WebRtcArgsImp() override = default;
variant operator[](const string &key) const override {
if (key == "url") {
return getUrl();
2021-04-04 23:20:10 +08:00
}
2021-10-19 15:23:12 +08:00
return _args[key];
2021-04-04 23:20:10 +08:00
}
2021-10-19 15:23:12 +08:00
private:
string getUrl() const{
auto &allArgs = _args;
CHECK_ARGS("app", "stream");
2023-12-02 16:31:40 +08:00
return StrPrinter << "rtc://" << _args["Host"] << "/" << _args["app"] << "/"
2023-06-10 11:04:52 +08:00
<< _args["stream"] << "?" << _args.getParser().params() + "&session=" + _session_id;
2021-04-04 23:20:10 +08:00
}
2021-10-19 15:23:12 +08:00
private:
HttpAllArgs<string> _args;
std::string _session_id;
2021-10-19 15:23:12 +08:00
};
2021-10-19 15:23:12 +08:00
api_regist("/index/api/webrtc",[](API_ARGS_STRING_ASYNC){
CHECK_ARGS("type");
auto type = allArgs["type"];
auto offer = allArgs.getArgs();
CHECK(!offer.empty(), "http body(webrtc offer sdp) is empty");
std::string host = allArgs.getParser()["Host"];
std::string localIp = host.substr(0, host.find(':'));
auto isVaildIP = [](std::string ip)-> bool {
int a,b,c,d;
return sscanf(ip.c_str(),"%d.%d.%d.%d", &a, &b, &c, &d) == 4;
};
if (!isVaildIP(localIp) || localIp=="127.0.0.1") {
localIp = "";
}
2021-10-19 15:23:12 +08:00
auto args = std::make_shared<WebRtcArgsImp>(allArgs, sender.getIdentifier());
WebRtcPluginManager::Instance().getAnswerSdp(static_cast<Session&>(sender), type, *args, [invoker, val, offer, headerOut, localIp](const WebRtcInterface &exchanger) mutable {
2021-10-19 15:23:12 +08:00
//设置返回类型
headerOut["Content-Type"] = HttpFileManager::getContentType(".json");
//设置跨域
headerOut["Access-Control-Allow-Origin"] = "*";
try {
setLocalIp(exchanger,localIp);
2023-04-21 20:23:26 +08:00
val["sdp"] = exchangeSdp(exchanger, offer);
2021-10-19 15:23:12 +08:00
val["id"] = exchanger.getIdentifier();
val["type"] = "answer";
invoker(200, headerOut, val.toStyledString());
} catch (std::exception &ex) {
val["code"] = API::Exception;
val["msg"] = ex.what();
invoker(200, headerOut, val.toStyledString());
}
});
2021-03-24 16:52:41 +08:00
});
static constexpr char delete_webrtc_url [] = "/index/api/delete_webrtc";
static auto whip_whep_func = [](const char *type, API_ARGS_STRING_ASYNC) {
auto offer = allArgs.getArgs();
CHECK(!offer.empty(), "http body(webrtc offer sdp) is empty");
auto &session = static_cast<Session&>(sender);
auto location = std::string("http") + (session.overSsl() ? "s" : "") + "://" + allArgs["host"] + delete_webrtc_url;
auto args = std::make_shared<WebRtcArgsImp>(allArgs, sender.getIdentifier());
WebRtcPluginManager::Instance().getAnswerSdp(session, type, *args,
[invoker, offer, headerOut, location](const WebRtcInterface &exchanger) mutable {
// 设置跨域
headerOut["Access-Control-Allow-Origin"] = "*";
try {
// 设置返回类型
headerOut["Content-Type"] = "application/sdp";
headerOut["Location"] = location + "?id=" + exchanger.getIdentifier() + "&token=" + exchanger.deleteRandStr();
2023-04-21 20:23:26 +08:00
invoker(201, headerOut, exchangeSdp(exchanger, offer));
} catch (std::exception &ex) {
headerOut["Content-Type"] = "text/plain";
invoker(406, headerOut, ex.what());
}
});
};
api_regist("/index/api/whip", [](API_ARGS_STRING_ASYNC) { whip_whep_func("push", API_ARGS_VALUE, invoker); });
api_regist("/index/api/whep", [](API_ARGS_STRING_ASYNC) { whip_whep_func("play", API_ARGS_VALUE, invoker); });
api_regist(delete_webrtc_url, [](API_ARGS_MAP_ASYNC) {
CHECK_ARGS("id", "token");
2023-06-10 11:04:52 +08:00
CHECK(allArgs.getParser().method() == "DELETE", "http method is not DELETE: " + allArgs.getParser().method());
auto obj = WebRtcTransportManager::Instance().getItem(allArgs["id"]);
if (!obj) {
invoker(404, headerOut, "id not found");
return;
}
if (obj->deleteRandStr() != allArgs["token"]) {
invoker(401, headerOut, "token incorrect");
return;
}
obj->safeShutdown(SockException(Err_shutdown, "deleted by http api"));
invoker(200, headerOut, "");
});
2021-03-24 16:52:41 +08:00
#endif
2022-08-12 18:09:44 +08:00
#if defined(ENABLE_VERSION)
api_regist("/index/api/version",[](API_ARGS_MAP_ASYNC){
CHECK_SECRET();
Value ver;
ver["buildTime"] = BUILD_TIME;
ver["branchName"] = BRANCH_NAME;
ver["commitHash"] = COMMIT_HASH;
val["data"] = ver;
invoker(200, headerOut, val.toStyledString());
});
#endif
api_regist("/index/api/loadMP4File", [](API_ARGS_MAP) {
CHECK_SECRET();
CHECK_ARGS("vhost", "app", "stream", "file_path");
ProtocolOption option;
2023-12-09 22:34:22 +08:00
// mp4支持多track
option.max_track = 16;
// 默认解复用mp4不生成mp4
option.enable_mp4 = false;
// 但是如果参数明确指定开启mp4, 那么也允许之
option.load(allArgs);
// 强制无人观看时自动关闭
option.auto_close = true;
auto reader = std::make_shared<MP4Reader>(allArgs["vhost"], allArgs["app"], allArgs["stream"], allArgs["file_path"], option);
// sample_ms设置为0从配置文件加载file_repeat可以指定如果配置文件也指定循环解复用那么强制开启
reader->startReadMP4(0, true, allArgs["file_repeat"]);
});
GET_CONFIG_FUNC(std::set<std::string>, download_roots, API::kDownloadRoot, [](const string &str) -> std::set<std::string> {
std::set<std::string> ret;
auto vec = toolkit::split(str, ";");
for (auto &item : vec) {
auto root = File::absolutePath("", item, true);
ret.emplace(std::move(root));
}
return ret;
});
api_regist("/index/api/downloadFile", [](API_ARGS_MAP_ASYNC) {
CHECK_ARGS("file_path");
auto file_path = allArgs["file_path"];
if (file_path.find("..") != std::string::npos) {
invoker(401, StrCaseMap{}, "You can not access parent directory");
return;
}
bool safe = false;
for (auto &root : download_roots) {
if (start_with(file_path, root)) {
safe = true;
break;
}
}
if (!safe) {
invoker(401, StrCaseMap{}, "You can not download files outside the root directory");
return;
}
// 通过on_http_access完成文件下载鉴权请务必确认访问鉴权url参数以及访问文件路径是否合法
HttpSession::HttpAccessPathInvoker file_invoker = [allArgs, invoker](const string &err_msg, const string &cookie_path_in, int life_second) mutable {
if (!err_msg.empty()) {
invoker(401, StrCaseMap{}, err_msg);
} else {
StrCaseMap res_header;
auto save_name = allArgs["save_name"];
if (!save_name.empty()) {
res_header.emplace("Content-Disposition", "attachment;filename=\"" + save_name + "\"");
}
invoker.responseFile(allArgs.getParser().getHeader(), res_header, allArgs["file_path"]);
}
};
bool flag = NOTICE_EMIT(BroadcastHttpAccessArgs, Broadcast::kBroadcastHttpAccess, allArgs.getParser(), file_path, false, file_invoker, sender);
if (!flag) {
// 文件下载鉴权事件无人监听,不允许下载
invoker(401, StrCaseMap {}, "None http access event listener");
}
});
}
2019-05-20 16:26:04 +08:00
void unInstallWebApi(){
s_player_proxy.clear();
s_ffmpeg_src.clear();
s_pusher_proxy.clear();
#if defined(ENABLE_RTPPROXY)
s_rtp_server.clear();
#endif
NoticeCenter::Instance().delListener(&web_api_tag);
2021-10-25 15:13:21 +08:00
}