publish/payserver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加db重连机制

Browse Source
This commit is contained in:
aozhiwei 2019-03-30 13:47:26 +08:00
parent 14d941779d
commit f125016c57
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
server/payserver/ordermgr.cc
View File

@ -75,17 +75,19 @@ void OrderMgr::Update()
{ {
if (a8::XGetTickCount() - last_ping_db_tick_ > 1000 * 60 * 5) { if (a8::XGetTickCount() - last_ping_db_tick_ > 1000 * 60 * 5) {
last_ping_db_tick_ = a8::XGetTickCount(); last_ping_db_tick_ = a8::XGetTickCount();
#if 0
if (query_->ExecQuery("SELECT 1;", {}) <= 0) { if (query_->ExecQuery("SELECT 1;", {}) <= 0) {
g_udplog->Warning("mysql disconnect", {}); a8::UdpLog::Instance()->Warning("mysql disconnect", {});
if (mysql_conn_.Connect()) { if (mysql_conn_->Connect(JsonDataMgr::Instance()->GetMysqlConf()->At("host")->AsXValue(),
DumpMysqlInfo(query_); JsonDataMgr::Instance()->GetMysqlConf()->At("port")->AsXValue(),
g_udplog->Info("mysql reconnect successed", {}); JsonDataMgr::Instance()->GetMysqlConf()->At("user")->AsXValue(),
JsonDataMgr::Instance()->GetMysqlConf()->At("passwd")->AsXValue(),
"paydb")) {
f8::InitMysqlConnection(query_);
a8::UdpLog::Instance()->Info("mysql reconnect successed", {});
} else { } else {
g_udplog->Info("mysql reconnect failed", {}); a8::UdpLog::Instance()->Info("mysql reconnect failed", {});
} }
} }
#endif
} }
#if 0 #if 0
ProcessOrderMsg(); ProcessOrderMsg();