标签：block val nlog 日志 高效 class tor push empty
实现一个高效的网络日志库要解决那些问题？
首先明确一下问题的模型，这是一个典型的多生产者 单消费者问题，对于前端的日志库使用者来说，应该做到非阻塞添加，作为后端的文件写入，应该注意磁盘IO的瓶颈。
- 日志的级别分级
- 发生时间和具体线程信息
- 线程安全
多个线程共有一个前端，通过后端写入磁盘文件
异步日志是必须的，所以需要一个缓冲区，在这里我们使用的是多缓冲技术，基本思路是准备多块Buffer，前端负责向Buffer中填数据，后端负责将Buffer中数据取出来写入文件，这种实现的好处在于在新建日志消息的时候不必等待磁盘IO操作，前端写的时候也不会阻塞。
LogStream 负责写入消息的格式化
LogFile 负责文件写入
AsyncLogging 负责实现 多缓冲技术 协调前后端
是及实现采用了四个缓冲区，这样可以进一步减少前端等待，数据结构
typedef boost::ptr_vector<LargeBuffer> BufferVector;
typedef BufferVector::auto_type BufferPtr;
MutexLock lock;
Condition cond;
BufferPtr nextBuffer;
BufferVector buffers_;append的具体实现
在当前的缓冲区和备用缓冲区中选择一个足够使用的进行写入。
void AsynLogging::append(const char* logline, int len){
LockGuard(mutex);
if(curbuf->avail() > len){//当前缓冲区足够
curbuf->append(logline,len);
}
else{
buffers.push_back(curbuf->release());
if(nextbuf){
curbuf = std::move(nextbuf);
}
else{
curbuf.reset(new LargeBuffer);
}
curbuf->append(logline, len);
cond.notify();
}
}
- 接收方的后端实现
首先准备好两块空闲的buffer，已备在临界区内交换，等待条件标量出发的条件又两个，超时或者是前端写满了一个或者多个Buffer,当条件满足时，先将当前缓冲移入buffer，并且立刻将空闲的newBuffer1作为当前缓冲，接下来将buffers和buffersToWrite交换，随后将buffersToWrite写入文件，重新设计设置Buffer。
void AsyncLogging::threadFunc(){
BufferPtr nweBuffer1(new LargeBuffer);
BufferPtr newBuffer2(new LargeBuffer);
BufferVector bufferToWrite;
while(running_){
{
MutexLockGuard lock(mutex);
if(buffers.empty()){
cond.wait_for(muted,flushInterval_);
}
buffers.push_back(currentBuffer_.release());
currentBuffer = move(newBuffer1);
buffersTowrite.swap(buffers_);
if(!nextBuf){
nextBuf = std::move(newBuffer2);
}
}
}
}c++ 高性能日志库(muduo_AsyncLogging)
标签：block val nlog 日志 高效 class tor push empty
原文地址：https://www.cnblogs.com/joeylee97/p/8886326.html
