Skip to content

Z
ZLMediaKit
Commit 1c89c609 by xiongziliang
Options

fixed #51

parent ee8edb8b
正在显示 包含 45 行增加 和 43 行删除
tests/test_httpApi.cpp
...@@ -56,49 +56,50 @@ onceToken token1([](){ ...@@ -56,49 +56,50 @@ onceToken token1([](){
}//namespace Http }//namespace Http
} // namespace mediakit } // namespace mediakit
void initEventListener(){
static onceToken s_token([](){ static onceToken s_token([](){
NoticeCenter::Instance().addListener(nullptr,Broadcast::kBroadcastHttpRequest,[](BroadcastHttpRequestArgs){ NoticeCenter::Instance().addListener(nullptr,Broadcast::kBroadcastHttpRequest,[](BroadcastHttpRequestArgs){
//const Parser &parser,HttpSession::HttpResponseInvoker &invoker,bool &consumed //const Parser &parser,HttpSession::HttpResponseInvoker &invoker,bool &consumed
if(strstr(parser.Url().data(),"/api/") != parser.Url().data()){ if(strstr(parser.Url().data(),"/api/") != parser.Url().data()){
return; return;
} }
//url以"/api/起始，说明是http api" //url以"/api/起始，说明是http api"
consumed = true;//该http请求已被消费 consumed = true;//该http请求已被消费
_StrPrinter printer; _StrPrinter printer;
////////////////method//////////////////// ////////////////method////////////////////
printer << "\r\nmethod:\r\n\t" << parser.Method(); printer << "\r\nmethod:\r\n\t" << parser.Method();
////////////////url///////////////// ////////////////url/////////////////
printer << "\r\nurl:\r\n\t" << parser.Url(); printer << "\r\nurl:\r\n\t" << parser.Url();
////////////////protocol///////////////// ////////////////protocol/////////////////
printer << "\r\nprotocol:\r\n\t" << parser.Tail(); printer << "\r\nprotocol:\r\n\t" << parser.Tail();
///////////////args////////////////// ///////////////args//////////////////
printer << "\r\nargs:\r\n"; printer << "\r\nargs:\r\n";
for(auto &pr : parser.getUrlArgs()){ for(auto &pr : parser.getUrlArgs()){
printer << "\t" << pr.first << " : " << pr.second << "\r\n"; printer << "\t" << pr.first << " : " << pr.second << "\r\n";
} }
///////////////header////////////////// ///////////////header//////////////////
printer << "\r\nheader:\r\n"; printer << "\r\nheader:\r\n";
for(auto &pr : parser.getValues()){ for(auto &pr : parser.getValues()){
printer << "\t" << pr.first << " : " << pr.second << "\r\n"; printer << "\t" << pr.first << " : " << pr.second << "\r\n";
} }
////////////////content///////////////// ////////////////content/////////////////
printer << "\r\ncontent:\r\n" << parser.Content(); printer << "\r\ncontent:\r\n" << parser.Content();
auto contentOut = printer << endl; auto contentOut = printer << endl;
////////////////我们测算异步回复，当然你也可以同步回复///////////////// ////////////////我们测算异步回复，当然你也可以同步回复/////////////////
EventPollerPool::Instance().getPoller()->async([invoker,contentOut](){ EventPollerPool::Instance().getPoller()->async([invoker,contentOut](){
HttpSession::KeyValue headerOut; HttpSession::KeyValue headerOut;
//你可以自定义header,如果跟默认header重名，则会覆盖之 //你可以自定义header,如果跟默认header重名，则会覆盖之
//默认header有:Server,Connection,Date,Content-Type,Content-Length //默认header有:Server,Connection,Date,Content-Type,Content-Length
//请勿覆盖Connection、Content-Length键 //请勿覆盖Connection、Content-Length键
//键名覆盖时不区分大小写 //键名覆盖时不区分大小写
headerOut["TestHeader"] = "HeaderValue"; headerOut["TestHeader"] = "HeaderValue";
invoker("200 OK",headerOut,contentOut); invoker("200 OK",headerOut,contentOut);
}); });
}); });
}, nullptr); }, nullptr);
}
int main(int argc,char *argv[]){ int main(int argc,char *argv[]){
//设置退出信号处理函数 //设置退出信号处理函数
...@@ -111,6 +112,7 @@ int main(int argc,char *argv[]){ ...@@ -111,6 +112,7 @@ int main(int argc,char *argv[]){
//加载配置文件，如果配置文件不存在就创建一个 //加载配置文件，如果配置文件不存在就创建一个
loadIniConfig(); loadIniConfig();
initEventListener();
//加载证书，证书包含公钥和私钥 //加载证书，证书包含公钥和私钥
SSL_Initor::Instance().loadCertificate((exeDir() + "ssl.p12").data()); SSL_Initor::Instance().loadCertificate((exeDir() + "ssl.p12").data());
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论