2017-01-18 16:19:06 +08:00
/**
* Tencent is pleased to support the open source community by making Tars available.
*
* Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
*
* Licensed under the BSD 3-Clause License (the "License"); you may not use this file except
* in compliance with the License. You may obtain a copy of the License at
*
* https://opensource.org/licenses/BSD-3-Clause
*
* Unless required by applicable law or agreed to in writing, software distributed
* under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
* CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
*/
# ifndef _CONFIG_IMP_H_
# define _CONFIG_IMP_H_
# include "util/tc_common.h"
# include "util/tc_config.h"
# include "util/tc_mysql.h"
# include "servant/ConfigF.h"
using namespace tars ;
enum Level
{
eLevelApp = 1 ,
eLevelAllServer ,
eLevelIpServer
} ;
struct ServerKey
{
string application ;
string serverName ;
string nodeName ;
string filename ;
} ;
inline bool operator < ( const ServerKey & l , const ServerKey & r )
{
if ( l . application ! = r . application ) return ( l . application < r . application ) ;
if ( l . serverName ! = r . serverName ) return ( l . serverName < r . serverName ) ;
if ( l . nodeName ! = r . nodeName ) return ( l . nodeName < r . nodeName ) ;
if ( l . filename ! = r . filename ) return ( l . filename < r . filename ) ;
return false ;
}
class ConfigImp : public Config
{
public :
/**
*
*/
ConfigImp ( ) { } ;
/**
*
*/
~ ConfigImp ( ) { } ;
/**
* 初始化
*
* @return int
*/
virtual void initialize ( ) ;
/**
* 退出
*/
virtual void destroy ( ) { } ;
/**
* 获取配置文件列表
* param app :应用
* param server: server名
* param vf: 配置文件名
*
* return : 配置文件内容
*/
virtual int ListConfig ( const string & app , const string & server , vector < string > & vf , tars : : TarsCurrentPtr current ) ;
/**
* 加载配置文件
* param app :应用
* param server: server名
* param filename: 配置文件名
*
* return : 配置文件内容
*/
virtual int loadConfig ( const std : : string & app , const std : : string & server , const std : : string & filename , string & config , tars : : TarsCurrentPtr current ) ;
/**
* 根据ip获取配置
* @param appServerName
* @param filename
* @param host
* @param config
*
* @return int
*/
virtual int loadConfigByHost ( const string & appServerName , const string & filename , const string & host , string & config , tars : : TarsCurrentPtr current ) ;
/**
*
* @param appServerName
* @param filename
* @param host
* @param current
*
* @return int
*/
virtual int checkConfig ( const string & appServerName , const string & filename , const string & host , string & result , tars : : TarsCurrentPtr current ) ;
/**
* 获取配置文件列表
* param configInfo ConfigInfo
* param vf: 配置文件名
*
* return : 配置文件内容
*/
virtual int ListConfigByInfo ( const ConfigInfo & configInfo , vector < string > & vf , tars : : TarsCurrentPtr current ) ;
/**
* 加载配置文件
* param configInfo ConfigInfo
* param config: 配置文件内容
*
* return :
*/
virtual int loadConfigByInfo ( const ConfigInfo & configInfo , string & config , tars : : TarsCurrentPtr current ) ;
/**
*
* @param configInfo ConfigInfo
*
* @return int
*/
virtual int checkConfigByInfo ( const ConfigInfo & configInfo , string & result , tars : : TarsCurrentPtr current ) ;
2017-02-23 19:11:26 +08:00
/**
* 获取服务的所有配置文件列表，
* @param configInfo 支持拉取应用配置列表，服务配置列表，机器配置列表
* @param[out] vf 获取到的文件名称列表
* @return int 0: 成功, -1:失败
**/
virtual int ListAllConfigByInfo ( const tars : : GetConfigListInfo & configInfo , vector < std : : string > & vf , tars : : TarsCurrentPtr current ) ;
2017-01-18 16:19:06 +08:00
protected :
/**
* 加载本server的配置文件
*/
void loadconf ( ) ;
private :
/**
*
* 查询configId对应的配置
*
* @param iConfigId
* @param sConfig
*
* @return int 0，
* 2,表示set应用配置
*/
int loadConfigByPK ( int iConfigId , string & sConfig ) ;
/**
*
* 查询configId对应的配置信息，
*
* @param iConfigId
* @param setdivision set分组信息
* @param sConfig
*
* @return int 0，
*
*/
int loadRefConfigByPK ( int iConfigId , const string & setdivision , string & sConfig ) ;
/**
*
* 获取iConfigId对应的引用id列表
*
* @param iConfigId
* @param referenceIds
*
* @return int
*/
int getReferenceIds ( int iConfigId , vector < int > & referenceIds ) ;
/**
* 获取应用级公共配置
* @param appName 应用名称
* @param fileName 文件名称
* @out param 获取到的配置文件内容
*
* @return int
*/
int loadAppConfig ( const std : : string & appName , const std : : string & fileName , string & config , tars : : TarsCurrentPtr current ) ;
/**
* 获取应用级公共配置
* @param configInfo ConfigInfo
* @out param 获取到的配置文件内容
*
* @return int
*/
int loadAppConfigByInfo ( const ConfigInfo & configInfo , string & config , tars : : TarsCurrentPtr current ) ;
/**
* 根据ip获取配置
* @param configInfo ConfigInfo； ，
* @param config
*
* @return int
*/
int loadConfigByHost ( const ConfigInfo & configInfo , string & config , tars : : TarsCurrentPtr current ) ;
/**
* 获取set分组信息
* @out param sSetName set名称
* @out param sSetArea set地区名称
* @out param sSetGroup set分组名称
* @param sSetDivision set信息:sSetName.sSetArea.sSetGroup格式
*
* @return bool set信息正确则返回true
*/
bool getSetInfo ( string & sSetName , string & sSetArea , string & sSetGroup , const string & sSetDivision ) ;
/**
* 合并两个配置文件,如果有冲突项,则sHighConf优先级比sLowConf高
*
* @param sLowConf 应用名称
* @param sHighConf 应用名称
*
* @ return string 合并的结果
*/
string mergeConfig ( const string & sLowConf , const string & sHighConf ) ;
/**
* 通过对app+server + ip + file进行限制加载配置文件的频率
*
*/
bool IsLimited ( const std : : string & app , const std : : string & server , const std : : string & sIp , const string & sFile ) ;
protected :
TC_Mysql _mysqlConfig ;
static map < ServerKey , pair < time_t , int > > _loadConfigLimited ;
//时间间隔
int _interval ;
///每分钟限制个数
int _limitInterval ;
} ;
# endif
