学步园

    首先谈谈日志生成机制，以下所谈内容适用运行于Unix操作系统的应用程序；

一、日志生成规则
  1、可以限制单个日志文件的最大文件大小（一般32M~64M）。
  2、日志系统应能够分级显式，为4个级别：ERROR、WARN、MESSAGE（或INFO）、DEBUG；ERROR优先级别最高，DEBUG优先级别最低；优先级别比配置输出级别低的日志信息不输出（假设配置输出级别为ERROR，则WARN、MESSAGE、DEBUG级别的日志均不会输出）。不同级别的日志信息均在同一个文件内输出。
  3、可控制输出到控制台或文件或两者都输出。
  4、具备自动清理功能开关，可以自动删除过期的日志文件，过期时间可以配置（如6个月，则系统定期清理6个月前的日志）。

日志输出级别原则：
 DEBUG信息包括：收发socket包的二进制或文本信息、关键点的打印信息、SQL语句信息等调式信息。
 MESSAGE信息包括：程序正常启动、链路连接、能体现完整业务流程的所有消息包（如各个接口的收发消息包、消息包在内部的流转过程）
 WARN信息包括：不影响业务逻辑的异常，如客户端重复登陆，数据库重连等信息。
 ERROR信息包括：影响业务正常开展的严重错误，如程序退出，数据库链路异常、用户数据格式非法等。

二、日志输出规则
日志文件输出路径：
  $HOME/logs/<项目名称（可选）>/模块名称/年/月/日/文件名_时_分_秒.log

日志输出内容格式：
  [时间] [级别] <日志输出位置（可选）> <进程或线程号（可选）> ：日志内容

实现代码如下：

1、 ffcs_logger.cpp

/*==================================================================================================<br /> * 项目名称: 日志库<br /> * 功能: 提供函数,实现格式日志打印,可选择打印屏幕,文件或两者均有,支持自动清理日志功能<br /> * 作者: huangjf<br /> * 联系: huangjf@ffcs.cn<br /> * 最近修改: 2010-8-31<br /> * 版本: v1.1.3<br /> ==================================================================================================*/</p> <p>#include <stdio.h><br /> #include <stdarg.h><br /> #include <sys/timeb.h></p> <p>#include <ace/OS.h><br /> #include <ace/OS_NS_stdio.h><br /> #include <ace/OS_NS_stdlib.h><br /> #include <ace/OS_NS_string.h><br /> #include <ace/OS_NS_unistd.h><br /> #include <ace/OS_NS_sys_stat.h><br /> #include <ace/os_include/os_unistd.h><br /> #include <ace/os_include/sys/os_stat.h><br /> #include <ace/os_include/os_time.h><br /> #include <ace/Time_Value.h><br /> #include <ace/FILE_Addr.h><br /> #include <ace/Addr.h><br /> #include <ace/Message_Block.h><br /> #include <ace/Configuration.h><br /> #include <ace/Configuration_Import_Export.h></p> <p>#include "ffcs_logger.h"</p> <p>static void * pthr_cleaner_process(void * arg);</p> <p>/*-----------------------------------------------------------------------<br /> * name: 初始化日志系统参数<br /> * input: fdir -- 日志文件根目录<br /> * _media -- 日志媒体<br /> * _level -- 日志级别<br /> * _cleaner_switch -- 日志清理开关<br /> * _saved_month -- 日志保存月数<br /> * output: NONE<br /> * return: NONE<br /> *-----------------------------------------------------------------------*/<br /> void Logger::init_logger(const char * _fdir, unsigned int _media, unsigned int _level, int _cleaner_switch, int _saved_month)<br /> {<br /> this->media_ = _media;<br /> this->level_ = _level;<br /> this->cleaner_switch_ = _cleaner_switch;<br /> this->saved_month_ = _saved_month;</p> <p> ACE_OS::strncpy(this->parentdir_, _fdir, sizeof(this->parentdir_));<br /> if (ACE_OS::strlen(this->parentdir_) <= 0)<br /> ACE_OS::sprintf(this->parentdir_, "%s", FFCS_LOG_FILEDIR);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 初始化日志系统<br /> * 每次系统调用此日志类时 需要调用此函数初始化日志系统<br /> * input: NONE<br /> * output: NONE<br /> * return: -1 -- 失败<br /> * 1 -- 成功<br /> *-----------------------------------------------------------------------*/<br /> int Logger::open_logger()<br /> {<br /> ACE_OS::memset(this->filedir_, 0x00, sizeof(this->filedir_));<br /> ACE_OS::memset(this->filename_, 0x00, sizeof(this->filename_));<br /> ACE_OS::memset(this->fullpath_, 0x00, sizeof(this->fullpath_));</p> <p> /*创建根目录*/<br /> if (ACE_OS::strlen(this->parentdir_) <= 0)<br /> ACE_OS::sprintf(this->parentdir_, "%s", FFCS_LOG_FILEDIR);<br /> if (this->mkdir(this->parentdir_) < 0)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) 创建根目录：'%s' 失败/n"), this->parentdir_), -1);<br /> }<br /> if (this->parentdir_[ACE_OS::strlen(this->parentdir_)-1] != '/')<br /> {<br /> ACE_OS::sprintf(this->parentdir_, "%s/", this->parentdir_);<br /> }</p> <p> /*检测日志目录，同时初始化this->filedir_*/<br /> this->check_subdir(this->parentdir_);</p> <p> this->create_filename(this->filename_);</p> <p> ACE_OS::sprintf(this->fullpath_, "%s%s", this->filedir_, this->filename_);</p> <p> if (this->fp_conn_.connect(this->fp_, ACE_FILE_Addr(ACE_TEXT(this->fullpath_)), 0, ACE_Addr::sap_any, 0, O_RDWR|O_APPEND|O_CREAT, ACE_DEFAULT_FILE_PERMS) == -1)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("%p/n to %s"), ACE_TEXT("open"), this->fullpath_), -1);<br /> }<br /> else<br /> {<br /> chmod(this->fullpath_, S_IRWXU|S_IRWXG|S_IRWXO); /*开放权限*/<br /> }</p> <p> /*启动日志系统*/<br /> this->active_ = true;</p> <p> /*启动日志处理线程*/<br /> if (this->activate() == -1)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) Logger activate failed/n")), -1);<br /> }</p> <p> /*启动日志清理线程*/<br /> if (ACE_Thread_Manager::instance()->spawn_n(1,<br /> (ACE_THR_FUNC)pthr_cleaner_process,/*Execute task one*/<br /> this, /*arguments*/<br /> THR_NEW_LWP | THR_JOINABLE | THR_INHERIT_SCHED, /*New Light Weight Process*/<br /> ACE_DEFAULT_THREAD_PRIORITY,<br /> FFCS_LOG_GRP_ID)==-1) /*Group ID*/<br /> ACE_ERROR((LM_ERROR, "Failure to spawn first group of threads: %p /n"));</p> <p> return 1;<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 关闭日志系统<br /> * input: NONE<br /> * output: NONE<br /> * return: NONE<br /> *-----------------------------------------------------------------------*/<br /> void Logger::close_logger()<br /> {<br /> this->active_ = false;</p> <p> ACE_Thread_Manager::instance()->cancel_grp(FFCS_LOG_GRP_ID);<br /> ACE_Thread_Manager::instance()->wait_grp(FFCS_LOG_GRP_ID);</p> <p> this->msg_queue()->close();<br /> this->wait();</p> <p> this->fp_.close();<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 载入配置文件<br /> * input: _config_filename -- 日志文件路径<br /> * output: NONE<br /> * return: -1 -- 失败<br /> * 1 -- 成功<br /> *-----------------------------------------------------------------------*/<br /> int Logger::load_config(const char * _config_filename)<br /> {<br /> ACE_TString str;<br /> long num;</p> <p> ACE_Configuration_Heap config;<br /> if (config.open() == -1)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) %p/n"), ACE_TEXT("config.open()")), -1);<br /> }</p> <p> ACE_Ini_ImpExp config_importer(config);<br /> if (config_importer.import_config(ACE_TEXT(_config_filename)) == -1)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) %p/n"), _config_filename), -1);<br /> }</p> <p> ACE_Configuration_Section_Key status_section;<br /> if (config.open_section (config.root_section(), ACE_TEXT(FFCS_LOG_CONF_SECTION), 0, status_section) == -1)<br /> {<br /> ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT("(%P|%t) %p/n"), ACE_TEXT ("Can't open [LOGGER] section")), -1);<br /> }</p> <p> /*日志输出根路径*/<br /> if (config.get_string_value(status_section, ACE_TEXT(FFCS_LOG_CONF_LOGFILEDIR), str) != -1)<br /> {<br /> if (str.length()>0 && str.c_str()[str.length()-1]!='/')<br /> {<br /> str.append("/", 1);<br /> }<br /> if (ACE_OS::strlen(this->parentdir_)>0 && this->parentdir_[ACE_OS::strlen(this->parentdir_)-1]!='/')<br /> {<br /> ACE_OS::strcat(this->parentdir_, "/");<br /> }<br /> if (ACE_OS::strcmp(str.c_str(), this->parentdir_) != 0)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) [%s]->'%s' is updated (%s)->(%s)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGFILEDIR, this->parentdir_, str.c_str()));<br /> ACE_OS::memset(this->parentdir_, 0x00, sizeof(this->parentdir_));<br /> ACE_OS::strncpy(this->parentdir_, str.c_str(), sizeof(this->parentdir_));<br /> }<br /> str.clear();<br /> }<br /> else<br /> {<br /> ACE_OS::memset(this->parentdir_, 0x00, sizeof(this->parentdir_));<br /> ACE_OS::strncpy(this->parentdir_, "log", sizeof(this->parentdir_));<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' does not exist, default value is (%s)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGFILEDIR, this->parentdir_));<br /> }</p> <p> /*日志输出媒体 0：屏幕 1：文件 2：屏幕+文件*/<br /> if (config.get_string_value(status_section, ACE_TEXT(FFCS_LOG_CONF_LOGMEDIA), str) != -1)<br /> {<br /> try<br /> {<br /> num = ACE_OS::strtol(str.c_str(), NULL, 10);<br /> if (num != this->media_)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) [%s]->'%s' is updated (%d)->(%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGMEDIA, this->media_, num));<br /> this->media_ = num;<br /> }<br /> }<br /> catch (...)<br /> {<br /> this->media_ = 2;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' is catch exception, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGMEDIA, this->media_));<br /> }<br /> num = 0;<br /> }<br /> else<br /> {<br /> this->media_ = 2;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' does not exist, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGMEDIA, this->media_));<br /> }</p> <p> /*日志打印级别 0：ERROR 1：WARN 2：MESSAGE 3：DEBUG*/<br /> if (config.get_string_value(status_section, ACE_TEXT(FFCS_LOG_CONF_LOGLEVEL), str) != -1)<br /> {<br /> try<br /> {<br /> num = ACE_OS::strtol(str.c_str(), NULL, 10);<br /> if (num != this->level_)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) [%s]->'%s' is updated (%d)->(%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGLEVEL, this->level_, num));<br /> this->level_ = num;<br /> }<br /> }<br /> catch (...)<br /> {<br /> this->level_ = 3;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' is catch exception, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGLEVEL, this->level_));<br /> }<br /> num = 0;<br /> }<br /> else<br /> {<br /> this->level_ = 3;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' does not exist, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGLEVEL, this->level_));<br /> }</p> <p> /*日志清理开关 1：开，0：关*/<br /> if (config.get_string_value(status_section, ACE_TEXT(FFCS_LOG_CONF_LOGCLEANER), str) != -1)<br /> {<br /> try<br /> {<br /> num = ACE_OS::strtol(str.c_str(), NULL, 10);<br /> if (num != this->cleaner_switch_)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) [%s]->'%s' is updated (%d)->(%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGCLEANER, this->cleaner_switch_, num));<br /> this->cleaner_switch_ = num;<br /> }<br /> }<br /> catch (...)<br /> {<br /> this->cleaner_switch_ = 0;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' is catch exception, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGCLEANER, this->cleaner_switch_));<br /> }<br /> num = 0;<br /> }<br /> else<br /> {<br /> this->cleaner_switch_ = 0;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' does not exist, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGCLEANER, this->cleaner_switch_));<br /> }</p> <p> /*日志保存月数，日志清理开时有效 0：表示不删除*/<br /> if (config.get_string_value(status_section, ACE_TEXT(FFCS_LOG_CONF_LOGSAVEDMONTH), str) != -1)<br /> {<br /> try<br /> {<br /> num = ACE_OS::strtol(str.c_str(), NULL, 10);<br /> if (num != this->saved_month_)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) [%s]->'%s' is updated (%d)->(%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGSAVEDMONTH, this->saved_month_, num));<br /> this->saved_month_ = num;<br /> }<br /> }<br /> catch (...)<br /> {<br /> this->saved_month_ = 0;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' is catch exception, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGSAVEDMONTH, this->saved_month_));<br /> }<br /> num = 0;<br /> }<br /> else<br /> {<br /> this->saved_month_ = 0;<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) [%s]->'%s' does not exist, default value is (%d)/n"), FFCS_LOG_CONF_SECTION, FFCS_LOG_CONF_LOGSAVEDMONTH, this->saved_month_));<br /> }</p> <p> return 1;<br /> }</p> <p>/**********************************************************************************************************************************/</p> <p>/*-----------------------------------------------------------------------<br /> * name: 建立目录<br /> * input: _fdir -- 目录<br /> * output:<br /> * return: >0 -- 新建目录<br /> * =0 -- 目录已存在<br /> * <0 -- 创建失败<br /> *-----------------------------------------------------------------------*/<br /> int Logger::mkdir(const char * _fdir)<br /> {<br /> if (_fdir == NULL || ACE_OS::strlen(_fdir) <= 0) return -1; /*文件名错误*/<br /> if (ACE_OS::access(_fdir, F_OK) >= 0) return 0; /*目录已存在*/<br /> if (ACE_OS::mkdir(_fdir, S_IRWXU) < 0) /*建立目录失败*/<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("%p/n to %s"), ACE_TEXT("mkdir"), _fdir), -1);<br /> }<br /> /*建立目录成功*/<br /> chmod(_fdir, S_IRWXU|S_IRWXG|S_IRWXO); /*开放权限*/<br /> return 1;<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 删除目录或文件<br /> * input: _fdir -- 目录或文件路劲<br /> * output:<br /> * return: >0 -- 删除成功<br /> * =0 -- 目录不存在<br /> * <0 -- 删除失败<br /> *-----------------------------------------------------------------------*/<br /> int Logger::rmdir(const char * _fdir)<br /> {<br /> if (_fdir == NULL || ACE_OS::strlen(_fdir) <= 0) return -1; /*文件名错误*/<br /> if (ACE_OS::access(_fdir, F_OK) < 0) return 0; /*目录不存在*/<br /> if (ACE_OS::rmdir(_fdir) < 0)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("%p/n to %s"), ACE_TEXT("rmdir"), _fdir), -1);<br /> }<br /> /*删除目录成功*/<br /> return 1;<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 检测目录<br /> * input: _fdir -- 日志根目录<br /> * output:<br /> * return: >0 -- 新建目录<br /> * =0 -- 目录无变化<br /> * <0 -- 失败<br /> *-----------------------------------------------------------------------*/<br /> int Logger::check_subdir(const char * _fdir)<br /> {<br /> int ret;<br /> char _subdir[FFCS_LOG_MAX_NAMESIZE];</p> <p> if (_fdir == NULL) return -1;</p> <p> ACE_OS::memset(this->filedir_, 0x00, sizeof(this->filedir_));<br /> ACE_OS::sprintf(this->filedir_, "%s", _fdir);<br /> if (this->filedir_[ACE_OS::strlen(this->filedir_)-1] != '/')<br /> {<br /> ACE_OS::sprintf(this->filedir_, "%s/", this->filedir_);<br /> }</p> <p> ACE_OS::memset(_subdir, 0x00, sizeof(_subdir));<br /> this->create_subdirname(_subdir, 1);<br /> ACE_OS::strncat(this->filedir_, _subdir, sizeof(this->filedir_));<br /> if ((ret = this->mkdir(this->filedir_)) < 0)<br /> {<br /> ACE_OS::memset(this->filedir_, 0x00, sizeof(this->filedir_));<br /> ACE_OS::sprintf(this->filedir_, "%s", _fdir);<br /> return -1;<br /> }<br /> ACE_OS::sprintf(this->filedir_, "%s/", this->filedir_);</p> <p> ACE_OS::memset(_subdir, 0x00, sizeof(_subdir));<br /> this->create_subdirname(_subdir, 2);<br /> ACE_OS::strncat(this->filedir_, _subdir, sizeof(this->filedir_));<br /> if ((ret = this->mkdir(this->filedir_)) < 0)<br /> {<br /> ACE_OS::memset(this->filedir_, 0x00, sizeof(this->filedir_));<br /> ACE_OS::sprintf(this->filedir_, "%s", _fdir);<br /> return -1;<br /> }<br /> ACE_OS::sprintf(this->filedir_, "%s/", this->filedir_);</p> <p> ACE_OS::memset(_subdir, 0x00, sizeof(_subdir));<br /> this->create_subdirname(_subdir, 3);<br /> ACE_OS::strncat(this->filedir_, _subdir, sizeof(this->filedir_));<br /> if ((ret = this->mkdir(this->filedir_)) < 0)<br /> {<br /> ACE_OS::memset(this->filedir_, 0x00, sizeof(this->filedir_));<br /> ACE_OS::sprintf(this->filedir_, "%s", _fdir);<br /> return -1;<br /> }<br /> ACE_OS::sprintf(this->filedir_, "%s/", this->filedir_);</p> <p> return ret;<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 创建一个日志文件子目录名<br /> * input: _level -- 目录级别<br /> * output: _subdir -- 子目录名字符串<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::create_subdirname(char * _subdir, int _level)<br /> {<br /> char _str[20] = {0};</p> <p> time_t timep;<br /> struct tm * p;<br /> ACE_Time_Value now(ACE_OS::gettimeofday());<br /> timep = now.sec();<br /> p = ACE_OS::localtime(&timep);</p> <p> switch (_level)<br /> {<br /> case 1:<br /> ACE_OS::sprintf(_str, "%4d", (1900+p->tm_year));<br /> ACE_OS::strncpy(_subdir, _str, 4);<br /> break;<br /> case 2:<br /> ACE_OS::sprintf(_str, "%02d", (1+p->tm_mon));<br /> ACE_OS::strncpy(_subdir, _str, 2);<br /> break;<br /> case 3:<br /> ACE_OS::sprintf(_str, "%02d", p->tm_mday);<br /> ACE_OS::strncpy(_subdir, _str, 2);<br /> break;<br /> default:<br /> ACE_OS::sprintf(_str, "%02d", 0);<br /> ACE_OS::strncpy(_subdir, _str, 2);<br /> break;<br /> }<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 创建日志文件名后续时间字符串<br /> * input:<br /> * output: _filename -- 日志文件名+后续时间字符串<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::create_filename(char * _filename)<br /> {<br /> char _str[20] = {0};</p> <p> time_t timep;<br /> struct tm * p;<br /> ACE_Time_Value now(ACE_OS::gettimeofday());<br /> timep = now.sec();<br /> p = ACE_OS::localtime(&timep);</p> <p> ACE_OS::sprintf(_str, "%02d_%02d_%02d", p->tm_hour, p->tm_min, p->tm_sec);<br /> ACE_OS::sprintf(_filename, "%s_%s%s", FFCS_LOG_FILENAME, _str, FFCS_LOG_FILETYPE);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 取日志级别<br /> * input: _var_log_level -- 日志级别<br /> * output: _level -- 日志级别<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::getloglevel(int _var_log_level, char * _level)<br /> {<br /> switch (_var_log_level)<br /> {<br /> case FFCS_LOGLEVEL_ERROR:<br /> ACE_OS::sprintf(_level, "ERROR");<br /> break;<br /> case FFCS_LOGLEVEL_WARN:<br /> ACE_OS::sprintf(_level, "WARN ");<br /> break;<br /> case FFCS_LOGLEVEL_DEBUG:<br /> ACE_OS::sprintf(_level, "DEBUG");<br /> break;<br /> case FFCS_LOGLEVEL_MESSAGE:<br /> ACE_OS::sprintf(_level, "MSG ");<br /> break;<br /> default:<br /> ACE_OS::sprintf(_level, "*****");<br /> break;<br /> }<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 取当前时间，输出长度23<br /> * input:<br /> * output: _stime -- 时间字符串<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::currenttime(char * _stime)<br /> {<br /> struct timeb tp;<br /> struct tm * p;<br /> ftime(&tp);<br /> p = ACE_OS::localtime(&tp.time);</p> <p> ACE_OS::sprintf(_stime, "%4d-%02d-%02d %02d:%02d:%02d.%03u", (1900+p->tm_year), (1+p->tm_mon), p->tm_mday, p->tm_hour, p->tm_min, p->tm_sec, tp.millitm);<br /> }</p> <p>/**********************************************************************************************************************************/</p> <p>/*-----------------------------------------------------------------------<br /> * name: 屏幕打印<br /> * input: fmt -- 带格式字符串<br /> *<br /> * output:<br /> * return: -1 -- 失败<br /> * >=0 -- 输出字符数<br /> *-----------------------------------------------------------------------*/<br /> int Logger::to_screen(const char * fmt)<br /> {<br /> int r;<br /> /*ACE_OSCALL(::vfprintf (stderr, fmt, ap), int, -1, r);*/<br /> r = ACE_OS::fprintf(stderr, fmt);<br /> ACE_OS::fflush(stderr);<br /> return r;<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 文件打印<br /> * input: fmt -- 带格式字符串<br /> *<br /> * output:<br /> * return: -1 -- 失败<br /> * >=0 -- 输出字符数<br /> *-----------------------------------------------------------------------*/<br /> int Logger::to_file(const char * fmt)<br /> {<br /> if (this->active_ != true)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("日志系统未启动/n")), -1);<br /> return -1;<br /> }</p> <p> const char * buffer = fmt;<br /> int recv_cnt = ACE_OS::strlen(buffer);</p> <p> ACE_Message_Block *mb = NULL;<br /> ACE_NEW_RETURN(mb, ACE_Message_Block(recv_cnt+1), -1);<br /> ACE_OS::memcpy(mb->wr_ptr(), buffer, recv_cnt);<br /> mb->wr_ptr(recv_cnt);</p> <p> if (this->putq(mb) == -1)<br /> {<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT ("(%P|%t) %p;/n"), ACE_TEXT ("日志入队列失败")));<br /> mb->release();<br /> return -1;<br /> }</p> <p> return recv_cnt;<br /> }</p> <p>/**********************************************************************************************************************************/</p> <p>/*-----------------------------------------------------------------------<br /> * name: error日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::error(const char * fmt, ...)<br /> {<br /> va_list ap;<br /> char _level[8];<br /> char _stime[24];<br /> char _buff[FFCS_LOG_INPUT_SIZE] = {0};</p> <p> if (this->level_ < FFCS_LOGLEVEL_ERROR) return;</p> <p> va_start(ap, fmt);</p> <p> ACE_OS::memset(_level, 0, sizeof(_level));<br /> ACE_OS::memset(_stime, 0, sizeof(_stime));<br /> ACE_OS::memset(_buff, 0, sizeof(_buff));</p> <p> this->getloglevel(FFCS_LOGLEVEL_ERROR, _level);<br /> this->currenttime(_stime);</p> <p> ACE_OS::sprintf(_buff, "[%s] [%s]: ", _stime, _level);<br /> ACE_OS::vsnprintf(_buff+ACE_OS::strlen(_buff), sizeof(_buff)-ACE_OS::strlen(_buff), fmt, ap);</p> <p> switch (this->media_)<br /> {<br /> case FFCS_LOGMEDIA_ALL:<br /> this->to_screen(_buff);<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_FILE:<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_SCREEN:<br /> default:<br /> this->to_screen(_buff);<br /> break;<br /> }</p> <p> va_end(ap);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: warn日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::warn(const char * fmt, ...)<br /> {<br /> va_list ap;<br /> char _level[8];<br /> char _stime[24];<br /> char _buff[FFCS_LOG_INPUT_SIZE] = {0};</p> <p> if (this->level_ < FFCS_LOGLEVEL_WARN) return;</p> <p> va_start(ap, fmt);</p> <p> ACE_OS::memset(_level, 0, sizeof(_level));<br /> ACE_OS::memset(_stime, 0, sizeof(_stime));<br /> ACE_OS::memset(_buff, 0, sizeof(_buff));</p> <p> this->getloglevel(FFCS_LOGLEVEL_WARN, _level);<br /> this->currenttime(_stime);</p> <p> ACE_OS::sprintf(_buff, "[%s] [%s]: ", _stime, _level);<br /> ACE_OS::vsnprintf(_buff+ACE_OS::strlen(_buff), sizeof(_buff)-ACE_OS::strlen(_buff), fmt, ap);</p> <p> switch (this->media_)<br /> {<br /> case FFCS_LOGMEDIA_ALL:<br /> this->to_screen(_buff);<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_FILE:<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_SCREEN:<br /> default:<br /> this->to_screen(_buff);<br /> break;<br /> }</p> <p> va_end(ap);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: message日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::message(const char * fmt, ...)<br /> {<br /> va_list ap;<br /> char _level[8];<br /> char _stime[24];<br /> char _buff[FFCS_LOG_INPUT_SIZE] = {0};</p> <p> if (this->level_ < FFCS_LOGLEVEL_MESSAGE) return;</p> <p> va_start(ap, fmt);</p> <p> ACE_OS::memset(_level, 0, sizeof(_level));<br /> ACE_OS::memset(_stime, 0, sizeof(_stime));<br /> ACE_OS::memset(_buff, 0, sizeof(_buff));</p> <p> this->getloglevel(FFCS_LOGLEVEL_MESSAGE, _level);<br /> this->currenttime(_stime);</p> <p> ACE_OS::sprintf(_buff, "[%s] [%s]: ", _stime, _level);<br /> ACE_OS::vsnprintf(_buff+ACE_OS::strlen(_buff), sizeof(_buff)-ACE_OS::strlen(_buff), fmt, ap);</p> <p> switch (this->media_)<br /> {<br /> case FFCS_LOGMEDIA_ALL:<br /> this->to_screen(_buff);<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_FILE:<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_SCREEN:<br /> default:<br /> this->to_screen(_buff);<br /> break;<br /> }</p> <p> va_end(ap);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: debug日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::debug(const char * fmt, ...)<br /> {<br /> va_list ap;<br /> char _level[8];<br /> char _stime[24];<br /> char _buff[FFCS_LOG_INPUT_SIZE] = {0};</p> <p> if (this->level_ < FFCS_LOGLEVEL_DEBUG) return;</p> <p> va_start(ap, fmt);</p> <p> ACE_OS::memset(_level, 0, sizeof(_level));<br /> ACE_OS::memset(_stime, 0, sizeof(_stime));<br /> ACE_OS::memset(_buff, 0, sizeof(_buff));</p> <p> this->getloglevel(FFCS_LOGLEVEL_DEBUG, _level);<br /> this->currenttime(_stime);</p> <p> ACE_OS::sprintf(_buff, "[%s] [%s]: ", _stime, _level);<br /> ACE_OS::vsnprintf(_buff+ACE_OS::strlen(_buff), sizeof(_buff)-ACE_OS::strlen(_buff), fmt, ap);</p> <p> switch (this->media_)<br /> {<br /> case FFCS_LOGMEDIA_ALL:<br /> this->to_screen(_buff);<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_FILE:<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_SCREEN:<br /> default:<br /> this->to_screen(_buff);<br /> break;<br /> }</p> <p> va_end(ap);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 以指定格式打印，不增加其他信息<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::printf(const char * fmt, ...)<br /> {<br /> va_list ap;<br /> char _buff[FFCS_LOG_INPUT_SIZE] = {0};</p> <p> va_start(ap, fmt);</p> <p> ACE_OS::memset(_buff, 0, sizeof(_buff));</p> <p> ACE_OS::vsnprintf(_buff, sizeof(_buff), fmt, ap);</p> <p> switch (this->media_)<br /> {<br /> case FFCS_LOGMEDIA_ALL:<br /> this->to_screen(_buff);<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_FILE:<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_SCREEN:<br /> default:<br /> this->to_screen(_buff);<br /> break;<br /> }</p> <p> va_end(ap);<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 枚举缓存<br /> * input: _buff -- 缓存<br /> * _size -- 缓存大小<br /> * _type -- 输出类型，1：接收，2：发送，其他：无<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void Logger::dump(const char * _buf, size_t _size, int _type)<br /> {<br /> char _level[24];<br /> char _stime[24];<br /> char _buff[FFCS_LOG_INPUT_SIZE] = {0};</p> <p> ACE_OS::memset(_level, 0, sizeof(_level));<br /> ACE_OS::memset(_stime, 0, sizeof(_stime));<br /> ACE_OS::memset(_buff, 0, sizeof(_buff));</p> <p> switch (_type)<br /> {<br /> case 1:<br /> ACE_OS::sprintf(_level, "接收(%d)：[", _size);<br /> break;</p> <p> case 2:<br /> ACE_OS::sprintf(_level, "发送(%d)：[", _size);<br /> break;</p> <p> default:<br /> ACE_OS::sprintf(_level, "报文(%d)：[", _size);<br /> break;<br /> }</p> <p> this->currenttime(_stime);</p> <p> ACE_OS::sprintf(_buff, "[%s] %s", _stime, _level);</p> <p> for (size_t i=0; i<_size; i++)<br /> {<br /> ACE_OS::snprintf(_buff+ACE_OS::strlen(_buff), sizeof(_buff)-ACE_OS::strlen(_buff), "%02X ", _buf[i]&0xFF);<br /> }</p> <p> ACE_OS::snprintf(_buff+ACE_OS::strlen(_buff), sizeof(_buff)-ACE_OS::strlen(_buff), "]/n");</p> <p> switch (this->media_)<br /> {<br /> case FFCS_LOGMEDIA_ALL:<br /> this->to_screen(_buff);<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_FILE:<br /> this->to_file(_buff);<br /> break;<br /> case FFCS_LOGMEDIA_SCREEN:<br /> default:<br /> this->to_screen(_buff);<br /> break;<br /> }<br /> }</p> <p>/**********************************************************************************************************************************/</p> <p>void Logger::set_active(bool b)<br /> {<br /> this->active_ = b;<br /> }</p> <p>bool Logger::get_active()<br /> {<br /> return this->active_;<br /> }</p> <p>int Logger::svc(void)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) *** 日志打印线程启动，日志文件根目录[%s]，日志级别[%d] ***/n"), this->parentdir_, this->level_));</p> <p> while (this->active_ == true)<br /> {<br /> ACE_Message_Block *mb = NULL;<br /> if (this->getq(mb) == -1)<br /> {<br /> if (mb) mb->release();<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) 读取队列异常/n")));<br /> continue;<br /> }<br /> if (this->active_ == false)<br /> {<br /> if (mb) mb->release();<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) 日志已关闭/n")));<br /> break;<br /> }</p> <p> char * data = mb->rd_ptr();<br /> size_t data_size = mb->length();</p> <p> ssize_t send_cnt = this->fp_.send(data, data_size);<br /> if (send_cnt == -1)<br /> {<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("%p/n"), "write()-1"));<br /> }<br /> else<br /> {<br /> mb->rd_ptr(ACE_static_cast(size_t, send_cnt));<br /> if (ACE_static_cast(size_t, send_cnt) != data_size)<br /> {<br /> ACE_DEBUG((LM_ERROR, ACE_TEXT("%p/n"), "write()-2"));<br /> }<br /> }</p> <p> /*数据处理结束必需释放内存*/<br /> mb->release();</p> <p> /*判断当前路径，判断文件大小*/<br /> ACE_FILE_Info finfo;<br /> this->fp_.get_info(finfo);<br /> if (this->check_subdir(this->parentdir_) > 0 || finfo.size_ > FFCS_LOG_MAX_FILESIZE)<br /> {<br /> this->fp_.close();<br /> this->create_filename(this->filename_);<br /> ACE_OS::memset(this->fullpath_, 0x00, sizeof(this->fullpath_));<br /> ACE_OS::sprintf(this->fullpath_, "%s%s", this->filedir_, this->filename_);<br /> if (this->fp_conn_.connect(this->fp_, ACE_FILE_Addr(ACE_TEXT(this->fullpath_)), 0, ACE_Addr::sap_any, 0, O_RDWR|O_APPEND|O_CREAT, ACE_DEFAULT_FILE_PERMS) == -1)<br /> {<br /> ACE_ERROR_RETURN((LM_ERROR, "%p/n to %s", "open", this->fullpath_), -1);<br /> }<br /> else<br /> {<br /> chmod(this->fullpath_, S_IRWXU|S_IRWXG|S_IRWXO); /*开放权限*/<br /> }<br /> }<br /> }</p> <p> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) *** 日志打印线程退出 ***/n")));<br /> return 0;<br /> }</p> <p>/*-----------------------------------------------------------------------<br /> * name: 日志清理线程<br /> * input:<br /> * output: arg -- void *<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> static void * pthr_cleaner_process(void * arg)<br /> {<br /> struct timespec rqt;<br /> time_t timep;<br /> struct tm * p;</p> <p> time_t curr_timep; /*当前检测时间*/<br /> time_t last_timep; /*上一次检测时间*/</p> <p> char rm_year[4+1], rm_month[2+1]; /*待删除年月*/<br /> char rm_dir[FFCS_LOG_MAX_NAMESIZE]; /*待删除目录路径*/<br /> int c_year, c_month; /*当前年月*/</p> <p> Logger * logger_0 = (Logger *)arg;<br /> if (logger_0 == NULL)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) 日志清理线程有异常，输入参数不正确，线程退出/n")));<br /> return 0;<br /> }</p> <p> last_timep = ACE_OS::gettimeofday().sec();</p> <p> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) *** 日志清理线程启动，日志文件根目录[%s]，日志保存月数[%d] ***/n"), logger_0->parentdir_, logger_0->saved_month_));</p> <p> while (logger_0->get_active() == true)<br /> {<br /> if (logger_0->cleaner_switch_ != FFCS_LOGCLEANER_OPEN || logger_0->saved_month_ <= 0 || logger_0->saved_month_ >= 120)<br /> {<br /> if (logger_0->saved_month_ <= 0 || logger_0->saved_month_ >= 120)<br /> {<br /> logger_0->saved_month_ = 0;<br /> }</p> <p> rqt.tv_sec = 1;<br /> rqt.tv_nsec = 0;<br /> ACE_OS::nanosleep(&rqt);<br /> continue;<br /> }</p> <p> curr_timep = ACE_OS::gettimeofday().sec();<br /> if ((curr_timep-last_timep) < 300) /*300秒 = 5分钟*/<br /> {<br /> rqt.tv_sec = 1;<br /> rqt.tv_nsec = 0;<br /> ACE_OS::nanosleep(&rqt);<br /> continue;<br /> }<br /> last_timep = curr_timep;</p> <p> if (ACE_OS::strlen(logger_0->parentdir_) <= 0)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) 日志清理线程有异常，日志文件根目录不合法/n")));<br /> break;<br /> }<br /> if (logger_0->parentdir_[ACE_OS::strlen(logger_0->parentdir_)-1] != '/')<br /> {<br /> ACE_OS::sprintf(logger_0->parentdir_, "%s/", logger_0->parentdir_);<br /> }</p> <p> ACE_OS::memset(rm_year, 0x00, sizeof(rm_year));<br /> ACE_OS::memset(rm_month, 0x00, sizeof(rm_month));<br /> ACE_OS::memset(rm_dir, 0x00, sizeof(rm_dir));</p> <p> /*取当前年月*/<br /> timep = ACE_OS::gettimeofday().sec();<br /> p = ACE_OS::localtime(&timep);<br /> c_year = (1900+p->tm_year);<br /> c_month = (1+p->tm_mon);</p> <p> /*取待删除年月*/<br /> if (c_month <= (logger_0->saved_month_+1))<br /> {<br /> ACE_OS::sprintf(rm_year, "%04d", c_year-1);<br /> ACE_OS::sprintf(rm_month, "%02d", c_month+12-(logger_0->saved_month_+1));<br /> }<br /> else<br /> {<br /> ACE_OS::sprintf(rm_year, "%04d", c_year);<br /> ACE_OS::sprintf(rm_month, "%02d", c_month-(logger_0->saved_month_+1));<br /> }</p> <p> /*删除*/<br /> if (ACE_OS::strcmp(rm_month, "12") == 0)<br /> {<br /> ACE_OS::sprintf(rm_dir, "%s%s", logger_0->parentdir_, rm_year);<br /> }<br /> else<br /> {<br /> ACE_OS::sprintf(rm_dir, "%s%s/%s", logger_0->parentdir_, rm_year, rm_month);<br /> }</p> <p> if (logger_0->rmdir(rm_dir) > 0)<br /> {<br /> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) *** 系统自动清理过期日志[%s] ***/n"), rm_dir));<br /> }<br /> }</p> <p> ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) *** 日志清理线程退出 ***/n")));<br /> return 0;<br /> }<br />

2、ffcs_logger.h

#ifndef FFCS_LOGGER_ACE_H_<br /> #define FFCS_LOGGER_ACE_H_</p> <p>#include <stdarg.h></p> <p>#include <ace/FILE_Connector.h><br /> #include <ace/FILE_IO.h><br /> #include <ace/Task.h><br /> #include <ace/Log_Msg.h></p> <p>/*默认日志保存月份*/<br /> #define DEFAULT_SAVED_MONTH 6</p> <p>/*日志级别 - 控制日志显示的级别*/<br /> #define FFCS_LOGLEVEL_ERROR 0x00 /*错误*/<br /> #define FFCS_LOGLEVEL_WARN 0x01 /*警告*/<br /> #define FFCS_LOGLEVEL_MESSAGE 0x02 /*提示*/<br /> #define FFCS_LOGLEVEL_DEBUG 0x03 /*调试*/</p> <p>/*日志媒体 - 控制日志输出的媒体*/<br /> #define FFCS_LOGMEDIA_SCREEN 0x00 /*屏幕*/<br /> #define FFCS_LOGMEDIA_FILE 0x01 /*文件*/<br /> #define FFCS_LOGMEDIA_ALL 0x02 /*全部*/</p> <p>/*日志队列状态*/<br /> #define FFCS_LOGCLEANER_CLOSED 0x00 /*日志清理关*/<br /> #define FFCS_LOGCLEANER_OPEN 0x01 /*日志清理开*/</p> <p>/*日志文件*/<br /> #define FFCS_LOG_MAX_NAMESIZE 255 /*最大文件名长度*/</p> <p>#define FFCS_LOG_FILEDIR "log" /*默认文件根目录*/<br /> #define FFCS_LOG_FILENAME "syslog" /*默认日志文件名*/<br /> #define FFCS_LOG_FILETYPE ".log" /*默认扩展名*/<br /> #define FFCS_LOG_MAX_FILESIZE (32*1024*1024) /*最大日志文件大小32M*/</p> <p>#define FFCS_LOG_GRP_ID 96469<br /> #define FFCS_LOG_INPUT_SIZE (2*1024) /*单个日志最大字节数*/<br /> #define FFCS_LOG_SEND_HIGHT_MARK (1024*1024) /*日志队列满负荷能力*/</p> <p>/*配置参数定义*/<br /> #define FFCS_LOG_CONF_SECTION "LOGGER"<br /> #define FFCS_LOG_CONF_LOGFILEDIR "LOGFILEDIR"<br /> #define FFCS_LOG_CONF_LOGMEDIA "LOGMEDIA"<br /> #define FFCS_LOG_CONF_LOGLEVEL "LOGLEVEL"<br /> #define FFCS_LOG_CONF_LOGCLEANER "LOGCLEANER"<br /> #define FFCS_LOG_CONF_LOGSAVEDMONTH "LOGSAVEDMONTH"</p> <p>/********************************************************************************************<br /> * 采用ACE_Task任务或主动对象处理模式，创建日志系统<br /> ********************************************************************************************/<br /> class Logger : public ACE_Task<ACE_MT_SYNCH><br /> {<br /> public:<br /> Logger() : active_(false)<br /> {<br /> this->media_ = FFCS_LOGMEDIA_ALL;<br /> this->level_ = FFCS_LOGLEVEL_DEBUG;<br /> this->cleaner_switch_ = FFCS_LOGCLEANER_OPEN;<br /> this->saved_month_ = DEFAULT_SAVED_MONTH;<br /> ACE_OS::memset(this->parentdir_, 0x00, sizeof(this->parentdir_));<br /> ACE_OS::memset(this->filedir_, 0x00, sizeof(this->filedir_));<br /> ACE_OS::memset(this->filename_, 0x00, sizeof(this->filename_));<br /> ACE_OS::memset(this->fullpath_, 0x00, sizeof(this->fullpath_));<br /> this->msg_queue()->high_water_mark(FFCS_LOG_SEND_HIGHT_MARK);<br /> /*ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Logger start/n")));*/<br /> }</p> <p> virtual ~Logger()<br /> {<br /> this->active_ = false;<br /> this->msg_queue()->close();<br /> /*ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) Logger stop/n")));*/<br /> }</p> <p> /*-----------------------------------------------------------------------<br /> * name: 初始化日志系统参数<br /> * input: fdir -- 日志文件根目录<br /> * _media -- 日志媒体<br /> * _level -- 日志级别<br /> * _cleaner_switch -- 日志清理开关<br /> * _saved_month -- 日志保存月数<br /> * output: NONE<br /> * return: NONE<br /> *-----------------------------------------------------------------------*/<br /> void init_logger(const char * _fdir, unsigned int _media = FFCS_LOGMEDIA_ALL, unsigned int _level = FFCS_LOGLEVEL_DEBUG, int _cleaner_switch = FFCS_LOGCLEANER_OPEN, int _saved_month = DEFAULT_SAVED_MONTH);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 初始化日志系统<br /> * 每次系统调用此日志类时 需要调用此函数初始化日志系统<br /> * input: NONE<br /> * output: NONE<br /> * return: RT_NG -- 失败<br /> * RT_OK -- 成功<br /> *-----------------------------------------------------------------------*/<br /> int open_logger();</p> <p> /*-----------------------------------------------------------------------<br /> * name: 关闭日志系统<br /> * input: NONE<br /> * output: NONE<br /> * return: NONE<br /> *-----------------------------------------------------------------------*/<br /> void close_logger();</p> <p> /*-----------------------------------------------------------------------<br /> * name: 载入配置文件<br /> * input: _config_filename -- 日志文件路径<br /> * output: NONE<br /> * return: RT_NG -- 失败<br /> * RT_OK -- 成功<br /> *-----------------------------------------------------------------------*/<br /> int load_config(const char * _config_filename);</p> <p> /*-----------------------------------------------------------------------<br /> * name: error日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void error(const char * fmt, ...);</p> <p> /*-----------------------------------------------------------------------<br /> * name: warn日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void warn(const char * fmt, ...);</p> <p> /*-----------------------------------------------------------------------<br /> * name: message日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void message(const char * fmt, ...);</p> <p> /*-----------------------------------------------------------------------<br /> * name: debug日志<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void debug(const char * fmt, ...);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 以指定格式打印，不增加其他信息<br /> * input: fmt -- 带格式字符串<br /> * ... -- 不定参数列表<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void printf(const char * fmt, ...);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 枚举缓存<br /> * input: _buff -- 缓存<br /> * _size -- 缓存大小<br /> * _type -- 输出类型，1：接收，2：发送，其他：无<br /> * output:<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void dump(const char * _buf, size_t _size, int _type);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 建立目录<br /> * input: _fdir -- 目录<br /> * output:<br /> * return: >0 -- 新建目录<br /> * =0 -- 目录已存在<br /> * <0 -- 创建失败<br /> *-----------------------------------------------------------------------*/<br /> int mkdir(const char * _fdir);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 删除目录或文件<br /> * input: _fdir -- 目录或文件路劲<br /> * output:<br /> * return: >0 -- 删除成功<br /> * =0 -- 目录不存在<br /> * <0 -- 删除失败<br /> *-----------------------------------------------------------------------*/<br /> int rmdir(const char * _fdir);</p> <p> virtual int svc(void);</p> <p> void set_active(bool b);<br /> bool get_active();</p> <p>private:</p> <p> /*-----------------------------------------------------------------------<br /> * name: 检测目录<br /> * input: _fdir -- 日志根目录<br /> * output:<br /> * return: >0 -- 新建目录<br /> * =0 -- 目录无变化<br /> * <0 -- 失败<br /> *-----------------------------------------------------------------------*/<br /> int check_subdir(const char * _fdir);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 创建一个日志文件子目录名<br /> * input: _level -- 目录级别<br /> * output: _subdir -- 子目录名字符串<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void create_subdirname(char * _subdir, int _level);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 创建日志文件名后续时间字符串<br /> * input:<br /> * output: _filename -- 日志文件名+后续时间字符串<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void create_filename(char * _filename);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 取日志级别<br /> * input: _var_log_level -- 日志级别<br /> * output: _level -- 日志级别<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void getloglevel(int _var_log_level, char * _level);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 取当前时间，输出长度23<br /> * input:<br /> * output: _stime -- 时间字符串<br /> * return:<br /> *-----------------------------------------------------------------------*/<br /> void currenttime(char * _stime);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 屏幕打印<br /> * input: fmt -- 带格式字符串<br /> *<br /> * output:<br /> * return: -1 -- 失败<br /> * >=0 -- 输出字符数<br /> *-----------------------------------------------------------------------*/<br /> int to_screen(const char * fmt);</p> <p> /*-----------------------------------------------------------------------<br /> * name: 文件打印<br /> * input: fmt -- 带格式字符串<br /> *<br /> * output:<br /> * return: -1 -- 失败<br /> * >=0 -- 输出字符数<br /> *-----------------------------------------------------------------------*/<br /> int to_file(const char * fmt);</p> <p>public:<br /> int media_; /*日志媒体 默认=FFCS_LOGMEDIA_SCREEN*/<br /> int level_; /*日志级别 默认=FFCS_LOGLEVEL_MESSAGE*/</p> <p> int cleaner_switch_; /*日志清理开关，=1时有效*/<br /> int saved_month_; /*日志保存月数，=0表示不删除，要求小于120*/</p> <p> char parentdir_[FFCS_LOG_MAX_NAMESIZE]; /*日志文件根目录*/<br /> char filedir_ [FFCS_LOG_MAX_NAMESIZE]; /*日志文件目录, 包括根目录、子目录*/<br /> char filename_ [FFCS_LOG_MAX_NAMESIZE]; /*日志文件名,不包含目录*/<br /> char fullpath_ [FFCS_LOG_MAX_NAMESIZE*2]; /*日志文件全路径名，包括目录和文件名*/</p> <p> ACE_FILE_IO fp_;</p> <p>private:<br /> bool active_;</p> <p> ACE_FILE_Connector fp_conn_;<br /> };</p> <p>#endif<br />

3、main.cpp

#include <stdio.h><br /> #include <stdlib.h></p> <p>#include <string></p> <p>#include <ace/OS.h></p> <p>#include "ffcs_logger.h"</p> <p>#define CONFIG_FILE ACE_TEXT("../config/config.cfg")</p> <p>int ACE_TMAIN(int argc, ACE_TCHAR* argv[])<br /> {<br /> Logger g_logger;</p> <p> /*初始化日志系统*/<br /> g_logger.load_config(CONFIG_FILE);<br /> g_logger.open_logger();</p> <p> ACE_OS::sleep(1);</p> <p> g_logger.debug("测试日志/n");<br /> g_logger.message("测试日志/n");<br /> g_logger.warn("测试日志/n");<br /> g_logger.error("测试日志/n");</p> <p> /*关闭日志系统*/<br /> g_logger.close_logger();</p> <p> getchar();<br /> return 0;<br /> }</p> <p>

4、config.cfg

##########日志输出配置信息######################################<br /> [LOGGER]<br /> #日志输出根路径<br /> LOGFILEDIR = "../logs"</p> <p> #日志输出媒体 0：屏幕 1：文件 2：屏幕+文件<br /> LOGMEDIA = 2</p> <p> #日志打印级别 0：ERROR 1：WARN 2：MESSAGE 3：DEBUG<br /> LOGLEVEL = 3</p> <p> #日志清理开关 1：开，0：关<br /> LOGCLEANER = 1</p> <p> #日志保存月数，日志清理开时有效 0：表示不删除<br /> LOGSAVEDMONTH = 6</p> <p>################################################################</p> <p>