server/game2006
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2022-03-21 20:22:59 +08:00
parent 0f27c9f860
commit acffe3761b
2 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/gameserver/httpproxy.cc
View File

@ -68,17 +68,16 @@ std::string HttpProxy::HttpGet(a8::XParams param,
JsonDataMgr::Instance()->GetHttpProxyUrl(proxy_url); JsonDataMgr::Instance()->GetHttpProxyUrl(proxy_url);
f8::HttpClientPool::Instance()->HttpGet f8::HttpClientPool::Instance()->HttpGet
(a8::XParams() (a8::XParams()
.SetSender(request), .SetSender(request->req_id),
[] (a8::XParams& param, a8::XObject& data) [] (a8::XParams& param, a8::XObject& data)
{ {
HttpProxyRequest* req = (HttpProxyRequest*)(param.sender.GetUserData());
req->on_ok(req->param, data);
HttpProxy::Instance()->DestoryRequest(req);
}, },
[] (a8::XParams& param, const std::string& response) [] (a8::XParams& param, const std::string& response)
{ {
HttpProxyRequest* req = (HttpProxyRequest*)(param.sender.GetUserData()); HttpProxyRequest* req = HttpProxy::Instance()->GetRequest(param.sender.GetString());
if (req) {
req->on_error(req->param, response); req->on_error(req->param, response);
}
HttpProxy::Instance()->DestoryRequest(req); HttpProxy::Instance()->DestoryRequest(req);
}, },
proxy_url.c_str(), proxy_url.c_str(),
@ -94,6 +93,12 @@ std::string HttpProxy::CreateRequestId()
return request_prefix_ + a8::XValue(App::Instance()->NewUuid()).GetString(); return request_prefix_ + a8::XValue(App::Instance()->NewUuid()).GetString();
} }
HttpProxyRequest* HttpProxy::GetRequest(const std::string& req_id)
{
auto itr = request_hash_.find(req_id);
return itr != request_hash_.end() ? itr->second : nullptr;
}
void HttpProxy::DestoryRequest(HttpProxyRequest* request) void HttpProxy::DestoryRequest(HttpProxyRequest* request)
{ {
request_hash_.erase(request->req_id); request_hash_.erase(request->req_id);

3
server/gameserver/httpproxy.h
View File

@ -21,11 +21,12 @@ class HttpProxy : public a8::Singleton<HttpProxy>
const char* url, const char* url,
a8::XObject url_params a8::XObject url_params
); );
HttpProxyRequest* GetRequest(const std::string& req_id);
void DestoryRequest(HttpProxyRequest* request);
private: private:
std::string CreateRequestId(); std::string CreateRequestId();
void DestoryRequest(HttpProxyRequest* request);
private: private:
std::map<std::string, HttpProxyRequest*> request_hash_; std::map<std::string, HttpProxyRequest*> request_hash_;