通过配置系统对日志进行配置需要对日志里的类型进行片特化处理，这样在处理序列化与反序列话的时候才能识别yml文件中的log配置。
中间结构体定义
LogAppenderDefine结构体与LogDefine结构体分别为配置日志器与日志输出器作出的中间定义，这两个结构体是存储在ConfigVar的配置选项中的自定义类型，真正使得配置生效需要在回调函数中将结构体中的数据提取出来设置到loggerManager中去。对这两个结构体重载<与==操作符是因为在ConfigVar中使用LogDefine的set容器进行存储的，所以需要比较运算符<。
struct LogAppenderDefine {
int type = 0; //1 File, 2 Stdout
LogLevel::Level level = LogLevel::UNKNOW;
std::string formatter;
std::string file;
bool operator==(const LogAppenderDefine& oth) const {
return type == oth.type
&& level == oth.level
&& formatter == oth.formatter
&& file == oth.file;
}
};
struct LogDefine {
std::string name;
LogLevel::Level level = LogLevel::UNKNOW;
std::string formatter;
std::vector<LogAppenderDefine> appenders;
bool operator==(const LogDefine& oth) const {
return name == oth.name
&& level == oth.level
&& formatter == oth.formatter
&& appenders == appenders;
}
bool operator<(const LogDefine& oth) const {
return name < oth.name;
}
bool isValid() const {
return !name.empty();
}
};
自定义类型片特化
template<>
class LexicalCast<std::string, LogDefine> {
public:
LogDefine operator()(const std::string& v) {
YAML::Node n = YAML::Load(v);
LogDefine ld;
if(!n["name"].IsDefined()) {
std::cout << "log config error: name is null, " << n
<< std::endl;
throw std::logic_error("log config name is null");
}
ld.name = n["name"].as<std::string>();
ld.level = LogLevel::FromString(n["level"].IsDefined() ? n["level"].as<std::string>() : "");
if(n["formatter"].IsDefined()) {
ld.formatter = n["formatter"].as<std::string>();
}
if(n["appenders"].IsDefined()) {
//std::cout << "==" << ld.name << " = " << n["appenders"].size() << std::endl;
for(size_t x = 0; x < n["appenders"].size(); ++x) {
auto a = n["appenders"][x];
if(!a["type"].IsDefined()) {
std::cout << "log config error: appender type is null, " << a
<< std::endl;
continue;
}
std::string type = a["type"].as<std::string>();
LogAppenderDefine lad;
if(type == "FileLogAppender") {
lad.type = 1;
if(!a["file"].IsDefined()) {
std::cout << "log config error: fileappender file is null, " << a
<< std::endl;
continue;
}
lad.file = a["file"].as<std::string>();
if(a["formatter"].IsDefined()) {
lad.formatter = a["formatter"].as<std::string>();
}
} else if(type == "StdoutLogAppender") {
lad.type = 2;
if(a["formatter"].IsDefined()) {
lad.formatter = a["formatter"].as<std::string>();
}
} else {
std::cout << "log config error: appender type is invalid, " << a
<< std::endl;
continue;
}
ld.appenders.push_back(lad);
}
}
return ld;
}
};
template<>
class LexicalCast<LogDefine, std::string> {
public:
std::string operator()(const LogDefine& i) {
YAML::Node n;
n["name"] = i.name;
if(i.level != LogLevel::UNKNOW) {
n["level"] = LogLevel::ToString(i.level);
}
if(!i.formatter.empty()) {
n["formatter"] = i.formatter;
}
for(auto& a : i.appenders) {
YAML::Node na;
if(a.type == 1) {
na["type"] = "FileLogAppender";
na["file"] = a.file;
} else if(a.type == 2) {
na["type"] = "StdoutLogAppender";
}
if(a.level != LogLevel::UNKNOW) {
na["level"] = LogLevel::ToString(a.level);
}
if(!a.formatter.empty()) {
na["formatter"] = a.formatter;
}
n["appenders"].push_back(na);
}
std::stringstream ss;
ss << n;
return ss.str();
}
};
添加回调函数
在这一步中，首先使用LookUp在Config管理类中约定logs配置选项，接下来为logs配置选项添加回调函数。此处有一个奇妙的处理，在添加回调函数的时候，将回调函数添加写在了一个结构体的构造函数中，并直接定义此结构体类型的静态变量。这样就使得这个操作在main函数之前生效了。
sylar::ConfigVar<std::set<LogDefine> >::ptr g_log_defines =
sylar::Config::Lookup("logs", std::set<LogDefine>(), "logs config");
struct LogIniter {
LogIniter() {
g_log_defines->addListener([](const std::set<LogDefine>& old_value,
const std::set<LogDefine>& new_value){
SYLAR_LOG_INFO(SYLAR_LOG_ROOT()) << "on_logger_conf_changed";
for(auto& i : new_value) {
auto it = old_value.find(i);
std::cout<<"jiexissssssssss"<<std::endl;
sylar::Logger::ptr logger;
if(it == old_value.end()) {
//新增logger
logger = SYLAR_LOG_NAME(i.name);
} else {
if(!(i == *it)) {
//修改的logger
logger = SYLAR_LOG_NAME(i.name);
} else {
continue;
}
}
logger->setLevel(i.level);
//std::cout << "** " << i.name << " level=" << i.level
//<< " " << logger << std::endl;
if(!i.formatter.empty()) {
logger->setFormatter(i.formatter);
}
logger->clearAppenders();
for(auto& a : i.appenders) {
sylar::LogAppender::ptr ap;
if(a.type == 1) {
ap.reset(new FileLogAppender(a.file));
} else if(a.type == 2) {
// if(!sylar::EnvMgr::GetInstance()->has("d")) {
ap.reset(new StdoutLogAppender);
// } else {
// continue;
// }
}
ap->setLevel(a.level);
if(!a.formatter.empty()) {
LogFormatter::ptr fmt(new LogFormatter(a.formatter));
if(!fmt->isError()) {
ap->setFormatter(fmt);
} else {
std::cout << "log.name=" << i.name << " appender type=" << a.type
<< " formatter=" << a.formatter << " is invalid" << std::endl;
}
}
logger->addAppender(ap);
}
}
for(auto& i : old_value) {
auto it = new_value.find(i);
if(it == new_value.end()) {
//删除logger
auto logger = SYLAR_LOG_NAME(i.name);
logger->setLevel((LogLevel::Level)0);
logger->clearAppenders();
}
}
});
}
};
static LogIniter __log_init;toYamlString()
toYamlString函数是为了调试方便直接输出log的YAML::Node格式字符串
std::string LoggerManager::toYamlString() {
// MutexType::Lock lock(m_mutex);
YAML::Node node;
for(auto& i : m_loggers) {
node.push_back(YAML::Load(i.second->toYamlString()));
}
std::stringstream ss;
ss << node;
return ss.str();
}
std::string Logger::toYamlString() {
// MutexType::Lock lock(m_mutex);
YAML::Node node;
node["name"] = m_name;
if(m_level != LogLevel::UNKNOW) {
node["level"] = LogLevel::ToString(m_level);
}
if(m_formatter) {
node["formatter"] = m_formatter->getPattern();
}
for(auto& i : m_appenders) {
node["appenders"].push_back(YAML::Load(i->toYamlString()));
}
std::stringstream ss;
ss << node;
return ss.str();
}
std::string FileLogAppender::toYamlString() {
// MutexType::Lock lock(m_mutex);
YAML::Node node;
node["type"] = "FileLogAppender";
node["file"] = m_filename;
if(m_level != LogLevel::UNKNOW) {
node["level"] = LogLevel::ToString(m_level);
}
if(m_hasFormatter && m_formatter) {
node["formatter"] = m_formatter->getPattern();
}
std::stringstream ss;
ss << node;
return ss.str();
}
std::string StdoutLogAppender::toYamlString() {
// MutexType::Lock lock(m_mutex);
YAML::Node node;
node["type"] = "StdoutLogAppender";
if(m_level != LogLevel::UNKNOW) {
node["level"] = LogLevel::ToString(m_level);
}
if(m_hasFormatter && m_formatter) {
node["formatter"] = m_formatter->getPattern();
}
std::stringstream ss;
ss << node;
return ss.str();
}
京公网安备 11010502036488号