|
|
@@ -54,6 +54,17 @@ struct Init_Setting
|
|
|
DBSetting.PoolSize = config.get("db.pool_size",30);
|
|
|
DBSetting.Port = config.get("db.port",3306);
|
|
|
if(!_mysql_init(DBSetting))
|
|
|
+ {
|
|
|
+ std_info("连接DB[%s:%s] 失败，采集服务器无法启动!",DBSetting.Host.c_str(),DBSetting.User.c_str());
|
|
|
+ exit(0);
|
|
|
+ }
|
|
|
+
|
|
|
+ std::string url=config.get("service.websocket_url","ws://127.0.0.1:8086");
|
|
|
+ int32_t send_interval =config.get("service.interval_send_json_postion",1);
|
|
|
+ std_info("json_interval:%d",send_interval);
|
|
|
+ std::vector<std::string> url_list;
|
|
|
+ url_list.push_back(url);
|
|
|
+ if(!wsClientMgr_init(url_list,send_interval))
|
|
|
{
|
|
|
std_info("连接DB[%s:%s] 失败，采集服务器无法启动!",DBSetting.Host.c_str(),DBSetting.User.c_str());
|
|
|
exit(0);
|
|
|
@@ -97,6 +108,7 @@ struct Init_Setting
|
|
|
ip.driving_face_alarm = Handle_ThreeRates_Event_Callback;
|
|
|
three_rates::get_instance()->init(ip,dbs);
|
|
|
three_rates::get_instance()->start();
|
|
|
+ std_info("加载三率模块成功");
|
|
|
}
|
|
|
|
|
|
bool _mysql_init(YADB::_DB_POOL_SETTING_ &dps)
|
chensongchao