企业网站内容如何备案,湖北省建设厅行政审批网站,出租网站空间,企业数字化建设公司功能#xff1a;将格式化完成后的日志消息字符串#xff0c;输出到指定的位置
扩展#xff1a;支持同时将日志落地到不同的位置
位置分类#xff1a;
1.标准输出
2.指定文件#xff08;时候进行日志分析#xff09;
3.滚动文件#xff08;文件按照时间/大小进行滚动…功能将格式化完成后的日志消息字符串输出到指定的位置
扩展支持同时将日志落地到不同的位置
位置分类
1.标准输出
2.指定文件时候进行日志分析
3.滚动文件文件按照时间/大小进行滚动切换
扩展支持落地方向的扩展 用户可以自己编写一个新的落地模块将日志进行其他方向的落地。 实现思想
1.抽象出一个落地基类
2.之后根据落地方向从基类派生出不同落地方向的子类
3.使用工厂模式进行创建与表示分离
标准输出
class StdoutSink :public LogSink{public:void log(const char* data,size_t len)override{std::cout.write(data,len);}};
输入到指定文件
class FileSink :public LogSink{public://传入文件路径并且打开文件FileSink(const std::string pathname):_pathname(pathname){//创建日志文件所在的目录util::File::createDirectory(util::File::path(pathname));//创建并打开日志文件_ofs.open(_pathname,std::ios::binary|std::ios::app);assert(_ofs.is_open());//判断文件是否打开}//将日志消息输入到文件里面void log(const char* data,size_t len)override{_ofs.write(data,len);assert(_ofs.good());}private:std::string _pathname;std::ofstream _ofs;};
以大小进行滚动
class RollBySizeSink :public LogSink{public://传入文件路径并且打开文件RollBySizeSink(const std::string basename,size_t max_size):_basename(basename),_max_fsize(max_size),_cur_fsize(0){std::string pathname createNewFile();//创建日志文件所在的目录util::File::createDirectory(util::File::path(pathname));//创建并打开日志文件_ofs.open(pathname,std::ios::binary|std::ios::app);assert(_ofs.is_open());//判断文件是否打开}//写入前判断文件大小超过了最大大小就要切换文件void log(const char* data,size_t len)override{if(_cur_fsize _max_fsize){std::string pathname createNewFile();_ofs.close();//关闭原来已经打开的文件。_ofs.open(pathname,std::ios::binary|std::ios::app);assert(_ofs.is_open());_cur_fsize 0;}_ofs.write(data,len);assert(_ofs.good());_cur_fsize len;}private:std::string createNewFile(){//获取系统时间以时间来构造文件扩展名time_t t util::Date::now();struct tm lt;localtime_r(t,lt);//将时间戳转换为有年月日的结构std::stringstream filename;filename _basename;filename lt.tm_year1900;filename lt.tm_mon1;filename lt.tm_mday;filename lt.tm_hour;filename lt.tm_min;filename lt.tm_sec;filename -;filename _name_count;filename .log;return filename.str();}//进行大小判断超过指定大小就要切换新文件private://基础文件名扩展文件名时间生成组成一个实际的当前输出文件名size_t _name_count0;std::string _basename;std::ofstream _ofs;size_t _max_fsize;//记录最大大小当前文件超过了这个大小就要切换文件size_t _cur_fsize;//记录当前文件已经写入的大小};
以时间进行滚动
enum class TimeGap{GAP_SECOND,GAP_MIUTE,GAP_HOUR,GAP_DAY,
};class RollByTimeSink :public bitlog::LogSink{public://传入文件路径并且打开文件RollByTimeSink(const std::string basename,TimeGap gap_type):_basename(basename){switch(gap_type){case TimeGap::GAP_SECOND:_gap_size 1;break;case TimeGap::GAP_MIUTE:_gap_size 60;break;case TimeGap::GAP_HOUR:_gap_size 3600;break;case TimeGap::GAP_DAY:_gap_size 3600*24;break;}_cur_gap _gap_size 1 ? bitlog::util::Date::now() : bitlog::util::Date::now() % _gap_size;std::string filename createNewFile();//创建日志文件所在的目录bitlog::util::File::createDirectory(bitlog::util::File::path(filename));//创建并打开日志文件_ofs.open(filename,std::ios::binary|std::ios::app);assert(_ofs.is_open());//判断文件是否打开}//写入前判断文件大小超过了最大大小就要切换文件void log(const char* data,size_t len)override{time_t cur bitlog::util::Date::now();if((cur%_gap_size)!_cur_gap){_ofs.close();std::string filename createNewFile();_ofs.open(filename,std::ios::binary|std::ios::app);assert(_ofs.is_open());}_ofs.write(data,len);assert(_ofs.good());}private:std::string createNewFile(){//获取系统时间以时间来构造文件扩展名time_t t bitlog::util::Date::now();struct tm lt;localtime_r(t,lt);//将时间戳转换为有年月日的结构std::stringstream filename;filename _basename;filename lt.tm_year1900;filename lt.tm_mon1;filename lt.tm_mday;filename lt.tm_hour;filename lt.tm_min;filename lt.tm_sec;filename .log;return filename.str();}//进行大小判断超过指定大小就要切换新文件private:std::string _basename;std::ofstream _ofs;size_t _cur_gap;//当前是第几个时间段size_t _gap_size;//时间段的大小};
使用简易工厂模式来创建
class SinkFactory{public:templatetypename SinkType,typename ...Argsstatic LogSink::ptr create(Args ...args){return std::make_sharedSinkType(std::forwardArgs(args)...);}};
