服务器开发学习 -- 异步双缓冲日志系统
源码链接：https://github.com/RaKiRaKiRa/Cyclone
通过 git clone https://github.com/RaKiRaKiRa/Cyclone.git可直接下载，有详细的注释
异步双缓冲日志系统 ,由AppendFile( base/FileUtil.h, base/FileUtil.cc ), LogFile ( base/LogFile.h, base/LogFile.cc), LogStream ( base/LogStream.h , base/LogStream.cc), FixedBuffer (base/LogStream.h), Logger (base/Logging.h , base/Logging.cc), AsyncLogging (base/AsyncLogging.h, base/AsyncLogging.cc) 组成。
双缓冲指缓冲分为前端部分与后端部分，由AsyncLogging进行调度。前端缓冲区负责接收Logger传来的日志，后端缓冲区是在以flush间隔为间隔的频率下将处理后得到的空缓冲区与前端缓冲区交换得到已收到日志，再通过LogFile存入文件中。
- LogStream主要用来格式化输出，重载了<<运算符，同时也有自己的一块缓冲区,即为FixedBuffer，这里缓冲区的存在是为了缓存一行，把多个<<的结果连成一块。
- Logger是对外接口，内含一个LogStream对象，主要是为了每次打log的时候在log之前和之后加上固定的格式化的信息，比如打log的行、文件名、时间、日志等级等信息。
- Logger通过建立匿名对象进行使用,在析构函数中调用指定函数将内含LogStream的缓冲区输出到指定函数。默认输出到stdout
- FileUtil是最底层的文件类，封装了Log文件的打开、写入并在类析构的时候关闭文件，底层使用了标准IO，该append函数直接向文件写。使用setbuffer设置用户行缓存区。
- LogFile进一步封装了FileUtil，设置了Roll和Flush策略。
- roll即更换文件进行存储日志，策略为已写入指定行数或到达第二天后执行
- flush即冲洗流中的信息进入文件，策略为间隔指定事件（默认为3秒）
- AsyncLogging是核心，它负责启动一个log线程，专门用来将log写入LogFile
- AsyncLogging负责(定时到或被填满时)将缓冲区中的数据写入LogFile中，需要事先通过setOutput将AsyncLogging::append()绑定给Logger。
- 应用了“双缓冲技术”（指前后端），其实有4个以上的缓冲区（前端 后端各两个）。使新建日志时不必等待磁盘文件操作，也避免每个新日志消息都唤醒后端日志线程，减少开销。
- 前端缓冲区负责接收Logger传来的日志，后端缓冲区是在以flush间隔为间隔的频率下将处理后得到的空缓冲区与前端缓冲区交换得到日志，再通过LogFile存入文件中。
- 将日志分为TRACE , DEBUG , INFO , WARN , ERROR , FATAL六个级别，通过LOG_TRACE , LOG_DEBUG , LOG_INFO , LOG_WARN , LOG_ERROR , LOG_FATAL进行输出。
- TRACE，细粒度最高的日志信息，打印的最详细
- DEBUG，细粒度级别上对调试有帮助的日志信息
- INFO，粗粒度级别上强调程序的运行信息
- WARN，程序能正常运行，但存在潜在风险的信息
- ERROR，执行出错，但不影响程序继续执行的错误信息
- FATAL，将导致程序退出的严重信息
测试代码为与src/base/test/log_test.cc
/********************************************************** * Author : RaKiRaKiRa * Email : 763600693@qq.com * Create time : 2019-06-05 15:05 * Last modified : 2019-06-05 15:05 * Filename : log_test.cc * Description : **********************************************************/
#include <string.h>
#include "../AsyncLogging.h"
#include "../Logging.h"
AsyncLogging *logptr = NULL;
void output(const char* logline, int len)
{
logptr -> append(logline, len);
}
int main()
{
//log输出到标准输出stdout
LOG<<"Rua!!!!!!!";
//输出到文件
logptr = new AsyncLogging("asynclog", 50*1024*1000);
Logger::setOutput(output);
logptr -> start();
for(int i=0;i<10;i++){
LOG<<"Rua!!!!!!!";
LOG_INFO<<"ASYNC LOG";
struct timespec ts = { 0, 500*1000*1000 };
nanosleep(&ts, NULL);
}
//测试各等级的日志
LOG<<"Rua!!!!!!!";
LOG_WARN<<"Rua!!!!!!!";
LOG_ERROR<<"Rua!!!!!!!";
LOG_FATAL<<"Rua!!!!!!!";
LOG_TRACE<<"Rua!!!!!!!";
LOG_DEBUG<<"Rua!!!!!!!";
LOG<<"Rua!!!!!!!";
LOG<<"Rua!!!!!!!";
struct timespec ts2 = { 10,0};
nanosleep(&ts2, NULL);
}
在终端进入src/base/test，通过输入cmake ..生成makefile文件，然后输入make进行编译，进入test，输入./log_test运行，下面是输出结果
