2019-05-20 11:22:59 +08:00
|
|
|
|
/*
|
|
|
|
|
* MIT License
|
|
|
|
|
*
|
|
|
|
|
* Copyright (c) 2016-2019 xiongziliang <771730766@qq.com>
|
|
|
|
|
*
|
|
|
|
|
* This file is part of ZLMediaKit(https://github.com/xiongziliang/ZLMediaKit).
|
|
|
|
|
*
|
|
|
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
|
|
|
* of this software and associated documentation files (the "Software"), to deal
|
|
|
|
|
* in the Software without restriction, including without limitation the rights
|
|
|
|
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
|
|
|
* copies of the Software, and to permit persons to whom the Software is
|
|
|
|
|
* furnished to do so, subject to the following conditions:
|
|
|
|
|
*
|
|
|
|
|
* The above copyright notice and this permission notice shall be included in all
|
|
|
|
|
* copies or substantial portions of the Software.
|
|
|
|
|
*
|
|
|
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
|
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
|
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
|
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
|
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
|
|
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
|
|
|
* SOFTWARE.
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
#include <map>
|
|
|
|
|
#include <signal.h>
|
|
|
|
|
#include <iostream>
|
|
|
|
|
#include "Util/MD5.h"
|
|
|
|
|
#include "Util/File.h"
|
|
|
|
|
#include "Util/logger.h"
|
|
|
|
|
#include "Util/SSLBox.h"
|
|
|
|
|
#include "Util/onceToken.h"
|
|
|
|
|
#include "Util/CMD.h"
|
|
|
|
|
#include "Network/TcpServer.h"
|
|
|
|
|
#include "Poller/EventPoller.h"
|
|
|
|
|
#include "Common/config.h"
|
|
|
|
|
#include "Rtsp/UDPServer.h"
|
|
|
|
|
#include "Rtsp/RtspSession.h"
|
2019-12-06 11:54:10 +08:00
|
|
|
|
#include "Rtp/RtpSession.h"
|
2019-05-20 11:22:59 +08:00
|
|
|
|
#include "Rtmp/RtmpSession.h"
|
|
|
|
|
#include "Shell/ShellSession.h"
|
|
|
|
|
#include "Http/WebSocketSession.h"
|
2019-12-06 11:54:10 +08:00
|
|
|
|
#include "Rtp/UdpRecver.h"
|
2019-06-06 18:28:33 +08:00
|
|
|
|
#include "WebApi.h"
|
2019-06-24 14:58:56 +08:00
|
|
|
|
#include "WebHook.h"
|
2019-05-20 11:22:59 +08:00
|
|
|
|
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#if !defined(_WIN32)
|
|
|
|
|
#include "System.h"
|
|
|
|
|
#endif//!defined(_WIN32)
|
|
|
|
|
|
2019-05-20 11:22:59 +08:00
|
|
|
|
using namespace std;
|
|
|
|
|
using namespace toolkit;
|
|
|
|
|
using namespace mediakit;
|
|
|
|
|
|
|
|
|
|
namespace mediakit {
|
|
|
|
|
////////////HTTP配置///////////
|
|
|
|
|
namespace Http {
|
|
|
|
|
#define HTTP_FIELD "http."
|
2019-06-19 10:32:54 +08:00
|
|
|
|
const string kPort = HTTP_FIELD"port";
|
|
|
|
|
const string kSSLPort = HTTP_FIELD"sslport";
|
2019-05-20 11:22:59 +08:00
|
|
|
|
onceToken token1([](){
|
2019-12-06 11:54:10 +08:00
|
|
|
|
mINI::Instance()[kPort] = 80;
|
|
|
|
|
mINI::Instance()[kSSLPort] = 443;
|
2019-05-20 11:22:59 +08:00
|
|
|
|
},nullptr);
|
|
|
|
|
}//namespace Http
|
|
|
|
|
|
|
|
|
|
////////////SHELL配置///////////
|
|
|
|
|
namespace Shell {
|
|
|
|
|
#define SHELL_FIELD "shell."
|
2019-06-19 10:32:54 +08:00
|
|
|
|
const string kPort = SHELL_FIELD"port";
|
2019-05-20 11:22:59 +08:00
|
|
|
|
onceToken token1([](){
|
2019-12-06 11:54:10 +08:00
|
|
|
|
mINI::Instance()[kPort] = 9000;
|
2019-05-20 11:22:59 +08:00
|
|
|
|
},nullptr);
|
|
|
|
|
} //namespace Shell
|
|
|
|
|
|
|
|
|
|
////////////RTSP服务器配置///////////
|
|
|
|
|
namespace Rtsp {
|
|
|
|
|
#define RTSP_FIELD "rtsp."
|
2019-06-19 10:32:54 +08:00
|
|
|
|
const string kPort = RTSP_FIELD"port";
|
|
|
|
|
const string kSSLPort = RTSP_FIELD"sslport";
|
2019-05-20 11:22:59 +08:00
|
|
|
|
onceToken token1([](){
|
2019-12-06 11:54:10 +08:00
|
|
|
|
mINI::Instance()[kPort] = 554;
|
|
|
|
|
mINI::Instance()[kSSLPort] = 332;
|
2019-05-20 11:22:59 +08:00
|
|
|
|
},nullptr);
|
|
|
|
|
|
|
|
|
|
} //namespace Rtsp
|
|
|
|
|
|
|
|
|
|
////////////RTMP服务器配置///////////
|
|
|
|
|
namespace Rtmp {
|
|
|
|
|
#define RTMP_FIELD "rtmp."
|
2019-06-19 10:32:54 +08:00
|
|
|
|
const string kPort = RTMP_FIELD"port";
|
2019-05-20 11:22:59 +08:00
|
|
|
|
onceToken token1([](){
|
2019-12-06 11:54:10 +08:00
|
|
|
|
mINI::Instance()[kPort] = 1935;
|
2019-05-20 11:22:59 +08:00
|
|
|
|
},nullptr);
|
|
|
|
|
} //namespace RTMP
|
2019-12-06 11:54:10 +08:00
|
|
|
|
|
|
|
|
|
////////////Rtp代理相关配置///////////
|
|
|
|
|
namespace RtpProxy {
|
|
|
|
|
#define RTP_PROXY_FIELD "rtp_proxy."
|
|
|
|
|
const string kPort = RTP_PROXY_FIELD"port";
|
|
|
|
|
onceToken token1([](){
|
|
|
|
|
mINI::Instance()[kPort] = 10000;
|
|
|
|
|
},nullptr);
|
|
|
|
|
} //namespace RtpProxy
|
|
|
|
|
|
2019-05-20 11:22:59 +08:00
|
|
|
|
} // namespace mediakit
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class CMD_main : public CMD {
|
|
|
|
|
public:
|
|
|
|
|
CMD_main() {
|
|
|
|
|
_parser.reset(new OptionParser(nullptr));
|
|
|
|
|
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#if !defined(_WIN32)
|
2019-05-20 11:22:59 +08:00
|
|
|
|
(*_parser) << Option('d',/*该选项简称,如果是\x00则说明无简称*/
|
|
|
|
|
"daemon",/*该选项全称,每个选项必须有全称;不得为null或空字符串*/
|
|
|
|
|
Option::ArgNone,/*该选项后面必须跟值*/
|
|
|
|
|
nullptr,/*该选项默认值*/
|
|
|
|
|
false,/*该选项是否必须赋值,如果没有默认值且为ArgRequired时用户必须提供该参数否则将抛异常*/
|
|
|
|
|
"是否以Daemon方式启动",/*该选项说明文字*/
|
|
|
|
|
nullptr);
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#endif//!defined(_WIN32)
|
2019-05-20 11:22:59 +08:00
|
|
|
|
|
|
|
|
|
(*_parser) << Option('l',/*该选项简称,如果是\x00则说明无简称*/
|
|
|
|
|
"level",/*该选项全称,每个选项必须有全称;不得为null或空字符串*/
|
|
|
|
|
Option::ArgRequired,/*该选项后面必须跟值*/
|
|
|
|
|
to_string(LTrace).data(),/*该选项默认值*/
|
|
|
|
|
false,/*该选项是否必须赋值,如果没有默认值且为ArgRequired时用户必须提供该参数否则将抛异常*/
|
|
|
|
|
"日志等级,LTrace~LError(0~4)",/*该选项说明文字*/
|
|
|
|
|
nullptr);
|
|
|
|
|
|
2019-08-06 22:51:40 +08:00
|
|
|
|
(*_parser) << Option('m',/*该选项简称,如果是\x00则说明无简称*/
|
|
|
|
|
"max_day",/*该选项全称,每个选项必须有全称;不得为null或空字符串*/
|
|
|
|
|
Option::ArgRequired,/*该选项后面必须跟值*/
|
|
|
|
|
"7",/*该选项默认值*/
|
|
|
|
|
false,/*该选项是否必须赋值,如果没有默认值且为ArgRequired时用户必须提供该参数否则将抛异常*/
|
2019-08-06 22:56:09 +08:00
|
|
|
|
"日志最多保存天数",/*该选项说明文字*/
|
2019-08-06 22:51:40 +08:00
|
|
|
|
nullptr);
|
|
|
|
|
|
2019-05-20 11:22:59 +08:00
|
|
|
|
(*_parser) << Option('c',/*该选项简称,如果是\x00则说明无简称*/
|
|
|
|
|
"config",/*该选项全称,每个选项必须有全称;不得为null或空字符串*/
|
|
|
|
|
Option::ArgRequired,/*该选项后面必须跟值*/
|
|
|
|
|
(exeDir() + "config.ini").data(),/*该选项默认值*/
|
|
|
|
|
false,/*该选项是否必须赋值,如果没有默认值且为ArgRequired时用户必须提供该参数否则将抛异常*/
|
|
|
|
|
"配置文件路径",/*该选项说明文字*/
|
|
|
|
|
nullptr);
|
|
|
|
|
|
|
|
|
|
(*_parser) << Option('s',/*该选项简称,如果是\x00则说明无简称*/
|
|
|
|
|
"ssl",/*该选项全称,每个选项必须有全称;不得为null或空字符串*/
|
|
|
|
|
Option::ArgRequired,/*该选项后面必须跟值*/
|
|
|
|
|
(exeDir() + "ssl.p12").data(),/*该选项默认值*/
|
|
|
|
|
false,/*该选项是否必须赋值,如果没有默认值且为ArgRequired时用户必须提供该参数否则将抛异常*/
|
2019-11-08 15:20:54 +08:00
|
|
|
|
"ssl证书文件或文件夹,支持p12/pem类型",/*该选项说明文字*/
|
2019-05-20 11:22:59 +08:00
|
|
|
|
nullptr);
|
|
|
|
|
|
|
|
|
|
(*_parser) << Option('t',/*该选项简称,如果是\x00则说明无简称*/
|
|
|
|
|
"threads",/*该选项全称,每个选项必须有全称;不得为null或空字符串*/
|
|
|
|
|
Option::ArgRequired,/*该选项后面必须跟值*/
|
|
|
|
|
to_string(thread::hardware_concurrency()).data(),/*该选项默认值*/
|
|
|
|
|
false,/*该选项是否必须赋值,如果没有默认值且为ArgRequired时用户必须提供该参数否则将抛异常*/
|
|
|
|
|
"启动事件触发线程数",/*该选项说明文字*/
|
|
|
|
|
nullptr);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
virtual ~CMD_main() {}
|
|
|
|
|
virtual const char *description() const {
|
|
|
|
|
return "主程序命令参数";
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#if !defined(_WIN32)
|
2019-05-20 11:22:59 +08:00
|
|
|
|
static void inline listen_shell_input(){
|
|
|
|
|
cout << "> 欢迎进入命令模式,你可以输入\"help\"命令获取帮助" << endl;
|
|
|
|
|
cout << "> " << std::flush;
|
2019-05-20 22:22:05 +08:00
|
|
|
|
|
|
|
|
|
signal(SIGTTOU,SIG_IGN);
|
|
|
|
|
signal(SIGTTIN,SIG_IGN);
|
2019-06-15 17:07:10 +08:00
|
|
|
|
|
2019-05-20 11:22:59 +08:00
|
|
|
|
SockUtil::setNoBlocked(STDIN_FILENO);
|
|
|
|
|
auto oninput = [](int event) {
|
|
|
|
|
if (event & Event_Read) {
|
|
|
|
|
char buf[1024];
|
|
|
|
|
int n = read(STDIN_FILENO, buf, sizeof(buf));
|
|
|
|
|
if (n > 0) {
|
|
|
|
|
buf[n] = '\0';
|
|
|
|
|
try {
|
|
|
|
|
CMDRegister::Instance()(buf);
|
|
|
|
|
cout << "> " << std::flush;
|
|
|
|
|
} catch (ExitException &ex) {
|
|
|
|
|
InfoL << "ExitException";
|
|
|
|
|
kill(getpid(), SIGINT);
|
|
|
|
|
} catch (std::exception &ex) {
|
|
|
|
|
cout << ex.what() << endl;
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
DebugL << get_uv_errmsg();
|
|
|
|
|
EventPollerPool::Instance().getFirstPoller()->delEvent(STDIN_FILENO);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (event & Event_Error) {
|
|
|
|
|
WarnL << "Event_Error";
|
|
|
|
|
EventPollerPool::Instance().getFirstPoller()->delEvent(STDIN_FILENO);
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
EventPollerPool::Instance().getFirstPoller()->addEvent(STDIN_FILENO, Event_Read | Event_Error | Event_LT,oninput);
|
|
|
|
|
}
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#endif//!defined(_WIN32)
|
|
|
|
|
|
2019-11-04 09:21:11 +08:00
|
|
|
|
//全局变量,在WebApi中用于保存配置文件用
|
|
|
|
|
string g_ini_file;
|
2019-09-24 15:21:20 +08:00
|
|
|
|
|
|
|
|
|
int start_main(int argc,char *argv[]) {
|
2019-05-20 16:26:04 +08:00
|
|
|
|
{
|
|
|
|
|
CMD_main cmd_main;
|
|
|
|
|
try {
|
|
|
|
|
cmd_main.operator()(argc, argv);
|
|
|
|
|
} catch (std::exception &ex) {
|
|
|
|
|
cout << ex.what() << endl;
|
|
|
|
|
return -1;
|
|
|
|
|
}
|
2019-05-20 11:22:59 +08:00
|
|
|
|
|
2019-05-20 16:26:04 +08:00
|
|
|
|
bool bDaemon = cmd_main.hasKey("daemon");
|
|
|
|
|
LogLevel logLevel = (LogLevel) cmd_main["level"].as<int>();
|
|
|
|
|
logLevel = MIN(MAX(logLevel, LTrace), LError);
|
2019-11-04 09:21:11 +08:00
|
|
|
|
g_ini_file = cmd_main["config"];
|
2019-05-20 16:26:04 +08:00
|
|
|
|
string ssl_file = cmd_main["ssl"];
|
|
|
|
|
int threads = cmd_main["threads"];
|
2019-05-20 11:22:59 +08:00
|
|
|
|
|
2019-05-20 16:26:04 +08:00
|
|
|
|
//设置日志
|
|
|
|
|
Logger::Instance().add(std::make_shared<ConsoleChannel>("ConsoleChannel", logLevel));
|
2019-09-24 15:21:20 +08:00
|
|
|
|
#ifndef ANDROID
|
2019-08-06 22:51:40 +08:00
|
|
|
|
auto fileChannel = std::make_shared<FileChannel>("FileChannel", exeDir() + "log/", logLevel);
|
|
|
|
|
//日志最多保存天数
|
|
|
|
|
fileChannel->setMaxDay(cmd_main["max_day"]);
|
|
|
|
|
Logger::Instance().add(fileChannel);
|
2019-09-24 15:21:20 +08:00
|
|
|
|
#endif//
|
2019-05-20 11:22:59 +08:00
|
|
|
|
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#if !defined(_WIN32)
|
2019-11-29 11:27:54 +08:00
|
|
|
|
pid_t pid = getpid();
|
2019-05-20 16:26:04 +08:00
|
|
|
|
if (bDaemon) {
|
|
|
|
|
//启动守护进程
|
|
|
|
|
System::startDaemon();
|
|
|
|
|
}
|
2019-05-20 16:34:46 +08:00
|
|
|
|
//开启崩溃捕获等
|
|
|
|
|
System::systemSetup();
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#endif//!defined(_WIN32)
|
2019-05-20 16:34:46 +08:00
|
|
|
|
|
2019-05-20 16:26:04 +08:00
|
|
|
|
//启动异步日志线程
|
|
|
|
|
Logger::Instance().setWriter(std::make_shared<AsyncLogWriter>());
|
|
|
|
|
//加载配置文件,如果配置文件不存在就创建一个
|
2019-11-04 09:21:11 +08:00
|
|
|
|
loadIniConfig(g_ini_file.data());
|
2019-05-20 16:26:04 +08:00
|
|
|
|
|
2019-11-08 15:20:54 +08:00
|
|
|
|
if(!File::is_dir(ssl_file.data())){
|
|
|
|
|
//不是文件夹,加载证书,证书包含公钥和私钥
|
|
|
|
|
SSL_Initor::Instance().loadCertificate(ssl_file.data());
|
|
|
|
|
}else{
|
|
|
|
|
//加载文件夹下的所有证书
|
|
|
|
|
File::scanDir(ssl_file,[](const string &path, bool isDir){
|
|
|
|
|
if(!isDir){
|
2019-11-08 15:26:46 +08:00
|
|
|
|
//最后的一个证书会当做默认证书(客户端ssl握手时未指定主机)
|
2019-11-08 15:20:54 +08:00
|
|
|
|
SSL_Initor::Instance().loadCertificate(path.data());
|
|
|
|
|
}
|
|
|
|
|
return true;
|
|
|
|
|
});
|
|
|
|
|
}
|
2019-05-20 16:26:04 +08:00
|
|
|
|
|
|
|
|
|
uint16_t shellPort = mINI::Instance()[Shell::kPort];
|
|
|
|
|
uint16_t rtspPort = mINI::Instance()[Rtsp::kPort];
|
|
|
|
|
uint16_t rtspsPort = mINI::Instance()[Rtsp::kSSLPort];
|
|
|
|
|
uint16_t rtmpPort = mINI::Instance()[Rtmp::kPort];
|
|
|
|
|
uint16_t httpPort = mINI::Instance()[Http::kPort];
|
|
|
|
|
uint16_t httpsPort = mINI::Instance()[Http::kSSLPort];
|
2019-12-06 11:54:10 +08:00
|
|
|
|
uint16_t rtp_proxy = mINI::Instance()[RtpProxy::kPort];
|
2019-05-20 16:26:04 +08:00
|
|
|
|
|
2019-05-20 16:34:46 +08:00
|
|
|
|
//设置poller线程数,该函数必须在使用ZLToolKit网络相关对象之前调用才能生效
|
2019-05-20 16:26:04 +08:00
|
|
|
|
EventPollerPool::setPoolSize(threads);
|
|
|
|
|
|
|
|
|
|
//简单的telnet服务器,可用于服务器调试,但是不能使用23端口,否则telnet上了莫名其妙的现象
|
|
|
|
|
//测试方法:telnet 127.0.0.1 9000
|
|
|
|
|
TcpServer::Ptr shellSrv(new TcpServer());
|
|
|
|
|
TcpServer::Ptr rtspSrv(new TcpServer());
|
|
|
|
|
TcpServer::Ptr rtmpSrv(new TcpServer());
|
|
|
|
|
TcpServer::Ptr httpSrv(new TcpServer());
|
|
|
|
|
//如果支持ssl,还可以开启https服务器
|
|
|
|
|
TcpServer::Ptr httpsSrv(new TcpServer());
|
|
|
|
|
//支持ssl加密的rtsp服务器,可用于诸如亚马逊echo show这样的设备访问
|
|
|
|
|
TcpServer::Ptr rtspSSLSrv(new TcpServer());
|
2019-11-29 11:27:54 +08:00
|
|
|
|
|
2019-12-06 11:54:10 +08:00
|
|
|
|
#if defined(ENABLE_RTPPROXY)
|
|
|
|
|
UdpRecver recver;
|
|
|
|
|
TcpServer::Ptr tcpRtpServer(new TcpServer());
|
|
|
|
|
#endif//defined(ENABLE_RTPPROXY)
|
|
|
|
|
|
2019-11-29 11:27:54 +08:00
|
|
|
|
try {
|
|
|
|
|
//rtsp服务器,端口默认554
|
|
|
|
|
rtspSrv->start<RtspSession>(rtspPort);//默认554
|
|
|
|
|
//rtsps服务器,端口默认322
|
|
|
|
|
rtspSSLSrv->start<RtspSessionWithSSL>(rtspsPort);
|
|
|
|
|
//rtmp服务器,端口默认1935
|
|
|
|
|
rtmpSrv->start<RtmpSession>(rtmpPort);
|
|
|
|
|
//http服务器,端口默认80
|
|
|
|
|
httpSrv->start<HttpSession>(httpPort);
|
|
|
|
|
//https服务器,端口默认443
|
|
|
|
|
httpsSrv->start<HttpsSession>(httpsPort);
|
|
|
|
|
//telnet远程调试服务器
|
|
|
|
|
shellSrv->start<ShellSession>(shellPort);
|
2019-12-06 11:54:10 +08:00
|
|
|
|
|
|
|
|
|
#if defined(ENABLE_RTPPROXY)
|
|
|
|
|
//创建rtp udp服务器
|
|
|
|
|
recver.initSock(rtp_proxy);
|
|
|
|
|
//创建rtp tcp服务器
|
|
|
|
|
tcpRtpServer->start<RtpSession>(rtp_proxy);
|
|
|
|
|
#endif//defined(ENABLE_RTPPROXY)
|
|
|
|
|
|
2019-11-29 11:27:54 +08:00
|
|
|
|
}catch (std::exception &ex){
|
|
|
|
|
WarnL << "端口占用或无权限:" << ex.what() << endl;
|
|
|
|
|
ErrorL << "程序启动失败,请修改配置文件中端口号后重试!" << endl;
|
|
|
|
|
sleep(1);
|
|
|
|
|
#if !defined(_WIN32)
|
|
|
|
|
if(pid != getpid()){
|
|
|
|
|
kill(pid,SIGINT);
|
|
|
|
|
}
|
|
|
|
|
#endif
|
|
|
|
|
return -1;
|
|
|
|
|
}
|
2019-05-20 16:26:04 +08:00
|
|
|
|
|
|
|
|
|
installWebApi();
|
|
|
|
|
InfoL << "已启动http api 接口";
|
|
|
|
|
installWebHook();
|
|
|
|
|
InfoL << "已启动http hook 接口";
|
|
|
|
|
|
2019-09-24 15:21:20 +08:00
|
|
|
|
#if !defined(_WIN32) && !defined(ANDROID)
|
2019-05-20 16:26:04 +08:00
|
|
|
|
if (!bDaemon) {
|
|
|
|
|
//交互式shell输入
|
|
|
|
|
listen_shell_input();
|
|
|
|
|
}
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#endif
|
2019-05-20 11:22:59 +08:00
|
|
|
|
|
2019-05-20 16:26:04 +08:00
|
|
|
|
//设置退出信号处理函数
|
|
|
|
|
static semaphore sem;
|
|
|
|
|
signal(SIGINT, [](int) {
|
|
|
|
|
InfoL << "SIGINT:exit";
|
2019-05-20 17:03:04 +08:00
|
|
|
|
signal(SIGINT, SIG_IGN);// 设置退出信号
|
2019-05-20 16:26:04 +08:00
|
|
|
|
sem.post();
|
|
|
|
|
});// 设置退出信号
|
2019-06-15 17:07:10 +08:00
|
|
|
|
|
|
|
|
|
#if !defined(_WIN32)
|
2019-11-04 09:21:11 +08:00
|
|
|
|
signal(SIGHUP, [](int) { mediakit::loadIniConfig(g_ini_file.data()); });
|
2019-06-15 17:07:10 +08:00
|
|
|
|
#endif
|
2019-05-20 16:26:04 +08:00
|
|
|
|
sem.wait();
|
|
|
|
|
}
|
2019-05-20 17:03:04 +08:00
|
|
|
|
unInstallWebApi();
|
|
|
|
|
unInstallWebHook();
|
2019-12-04 19:15:48 +08:00
|
|
|
|
Recorder::stopAll();
|
2019-05-28 09:50:05 +08:00
|
|
|
|
//休眠1秒再退出,防止资源释放顺序错误
|
2019-05-20 17:03:04 +08:00
|
|
|
|
InfoL << "程序退出中,请等待...";
|
2019-05-28 09:50:05 +08:00
|
|
|
|
sleep(1);
|
2019-05-20 17:03:04 +08:00
|
|
|
|
InfoL << "程序退出完毕!";
|
2019-05-20 11:22:59 +08:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
2019-09-24 15:21:20 +08:00
|
|
|
|
#ifndef DISABLE_MAIN
|
|
|
|
|
int main(int argc,char *argv[]) {
|
|
|
|
|
return start_main(argc,argv);
|
|
|
|
|
}
|
|
|
|
|
#endif //DISABLE_MAIN
|
|
|
|
|
|
|
|
|
|
|