热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

muduo网络库学习之Logger类、LogStream类、LogFile类封装中的知识点

一、Logger类、LogStream类1、日志作用开发过程中:调试错误更好的理解程序运行过程中:诊断系统故障并处理记录系统运行状态2、日志级别TRAC



一、Logger类、LogStream类




1、日志作用




开发过程中:


调试错误
更好的理解程序


运行过程中:


诊断系统故障并处理
记录系统运行状态





2、日志级别



TRACE


指出比DEBUG粒度更细的一些信息事件(开发过程中使用)

DEBUG


指出细粒度信息事件对调试应用程序是非常有帮助的。(开发过程中使用)

INFO


表明消息在粗粒度级别上突出强调应用程序的运行过程。

WARN


系统能正常运行,但可能会出现潜在错误的情形。

ERROR


指出虽然发生错误事件,但仍然不影响系统的继续运行。

FATAL


指出每个严重的错误事件将会导致应用程序的退出。






class Logger

{

public:

enum LogLevel
{


TRACE,
DEBUG,
INFO,
WARN,
ERROR,
FATAL,
NUM_LOG_LEVELS,


};


// compile time calculation of basename of source file

class SourceFile { };


private:
       class Impl { };

};







template
class FixedBuffer : boost::noncopyable



class LogStream : boost::noncopyable
{
typedef LogStream self;
public:                                        // 4000
typedef detail::FixedBuffer Buffer;
};



class Fmt // : boost::noncopyable
{
public:
template
Fmt(const char* fmt, T val)
{     // 按照fmt 格式将val 格式化成字符串放入buf_中
length_ = snprintf(buf_, sizeof buf_, fmt, val);
};
};

3、formatInteger()  //是把数字或者指针的值当作字符串写入
C++ Code 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 

const char digits[] = "9876543210123456789";
const char* zero = digits + 9;
const char digitsHex[] = "0123456789ABCDEF";

LogStream& LogStream::operator<<(int v)
{
  formatInteger(v);
  return *this;
}

template<typename T>
void LogStream::formatInteger(T v)
{                       //32
  if (buffer_.avail() >&#61; kMaxNumericSize)
  {
    size_t len &#61; convert(buffer_.current(), v);
    buffer_.add(len);
  }
}

// Efficient Integer to String Conversions, by Matthew Wilson.
template<typename T>
size_t convert(char buf[], T value)
{
  T i &#61; value;
  char* p &#61; buf;

  do
  {
    int lsd &#61; static_cast<int>(i % 10);
    i /&#61; 10;
    *p&#43;&#43; &#61; zero[lsd];
  } while (i !&#61; 0);

  if (value < 0)
  {
    *p&#43;&#43; &#61; &#39;-&#39;;
  }
  *p &#61; &#39;\0&#39;;
  std::reverse(buf, p);

  return p - buf;
}

LogStream& LogStream::operator<<(const void* p)
{
  uintptr_t v &#61; reinterpret_cast(p);
  if (buffer_.avail() >&#61; kMaxNumericSize)
  {
    char* buf &#61; buffer_.current();
    buf[0] &#61; &#39;0&#39;;
    buf[1] &#61; &#39;x&#39;;
    size_t len &#61; convertHex(buf&#43;2, v);
    buffer_.add(len&#43;2);
  }
  return *this;
}

// Efficient Pointer to String Conversions
// uintptr_t on 32bit as unsigned int; on 64bit as unsigned long int
size_t convertHex(char buf[], uintptr_t value)
{
  uintptr_t i &#61; value;
  char* p &#61; buf;

  do
  {
    int lsd &#61; i % 16;
    i /&#61; 16;
    *p&#43;&#43; &#61; digitsHex[lsd];
  } while (i !&#61; 0);

  *p &#61; &#39;\0&#39;;
  std::reverse(buf, p);

  return p - buf;
}


4、Logger使用时序图:




#define LOG_INFO if (muduo::Logger::logLevel() <&#61; muduo::Logger::INFO) \
  muduo::Logger(__FILE__, __LINE__).stream()

LOG_INFO<<“info ...”;     // 使用方式
muduo::Logger(__FILE__, __LINE__).stream()<<“info”;

// LogStream& stream() { return impl_.stream_; }

Logger &#61;> Impl &#61;> LogStream &#61;> operator< g_output &#61;> g_flush

栈上匿名的Logger对象使用完就要析构&#xff0c;在~Logger()中调用 g_output&#xff0c;即 g_output(buf.data(), buf.length());
如果是FATAL错误&#xff0c;还要调用g_flush&#xff0c;最后abort()程序。

如果没有调用g_flush&#xff0c;会一直输出到缓冲区&#xff08;标准输出缓冲区&#xff0c;文件FILE缓冲区&#xff09;满才会真的输出在标准输出&#xff0c;或者写入到文件中去。注&#xff1a;可以使用setvbuf设置缓冲区的大小。

int setvbuf ( FILE * stream, char * buffer, int mode, size_t size );


默认日志信息输出到标准输出&#xff08;g_output &#61; defaultOutput、g_flush &#61; defaultFlush&#xff09;&#xff0c;也可以输出到文件&#xff0c;使用SetOutput、SetFlush 设置。



测试程序&#xff1a;
C&#43;&#43; Code 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
#include 
#include 
#include 

using namespace muduo;

FILE *g_file;

void dummyOutput(const char *msg, int len)
{
    if (g_file)
    {
        fwrite(msg, 1, len, g_file);
    }
}

void dummyFlush()
{
    fflush(g_file);
}

int main()
{
    g_file &#61; ::fopen("/tmp/muduo_log""ae");
    Logger::setOutput(dummyOutput);
    Logger::setFlush(dummyFlush);

    LOG_TRACE << "trace ...";
    LOG_DEBUG << "debug ...";
    LOG_INFO << "info ...";
    LOG_WARN << "warn ...";
    LOG_ERROR << "error ...";
    //LOG_FATAL<<"fatal ...";
    errno &#61; 13;
    LOG_SYSERR << "syserr ...";
    //LOG_SYSFATAL<<"sysfatal ...";

    ::fclose(g_file);

    return 0;
}

程序执行后查看写入文件的内容&#xff1a;
simba&#64;ubuntu:~/Documents/build/debug/bin$ cat /tmp/muduo_log 
20131102 12:33:29.812878Z  4021 TRACE main trace ... - Log_test2.cc:28
20131102 12:33:29.813108Z  4021 DEBUG main debug ... - Log_test2.cc:29
20131102 12:33:29.813112Z  4021 INFO  info ... - Log_test2.cc:30
20131102 12:33:29.813114Z  4021 WARN  warn ... - Log_test2.cc:31
20131102 12:33:29.813117Z  4021 ERROR error ... - Log_test2.cc:32
20131102 12:33:29.813120Z  4021 ERROR Permission denied (errno&#61;13) syserr ... - Log_test2.cc:35
simba&#64;ubuntu:~/Documents/build/debug/bin$ 

5、StringPiece类

// We provide non-explicit singleton constructors so users can pass
  // in a "const char*" or a "string" wherever a "StringPiece" is
  // expected.

只是复制字符串的指针&#xff0c;故不涉及具体字符串内存的拷贝&#xff0c;高效地传递字符串。

class StringPiece {
private:
  const char*   ptr_;
  int           length_;
....
C&#43;&#43; Code 
1
2
3
4
5
6
7
8
9
10
 
#define STRINGPIECE_BINARY_PREDICATE(cmp,auxcmp)                             \
  bool operator cmp (const StringPiece& x) const {                           \
    int r &#61; memcmp(ptr_, x.ptr_, length_ < x.length_ ? length_ : x.length_); \
    return ((r auxcmp 0) || ((r &#61;&#61; 0) && (length_ cmp x.length_)));          \
  }
STRINGPIECE_BINARY_PREDICATE( < ,  < );
STRINGPIECE_BINARY_PREDICATE( <&#61; , < );
STRINGPIECE_BINARY_PREDICATE( >&#61; , > );
STRINGPIECE_BINARY_PREDICATE( > ,  > );
#undef STRINGPIECE_BINARY_PREDICATE

};

二、LogFile类

日志滚动条件
文件大小&#xff08;例如每写满1G换下一个文件&#xff09;
时间&#xff08;每天零点新建一个日志文件&#xff0c;不论前一个文件是否写满&#xff09;
一个典型的日志文件名
logfile_test.20130411-115604.popo.7743.log
// 运行程序.时间.主机名.线程名.log

class LogFile : boost::noncopyable

const string basename_; // 日志文件 basename

const size_t rollSize_; // 日志文件达到rollSize_换一个新文件

const int flushInterval_; // 日志写入文件间隔时间

time_t startOfPeriod_; // 开始记录日志时间&#xff08;调整到零时时间&#xff09;

time_t lastRoll_; // 上一次滚动日志文件时间

time_t lashFlush_; // 上一次日志写入文件时间

// 60*60*24
time_t start &#61; now / kRollPerSeconds_ * kRollPerSeconds_;
表示start对齐到kR的整数倍&#xff0c;也就是时间调整到当天零时

// not thread safe
class LogFile::File : boost::noncopyable

 ::setbuffer(fp_, buffer_, sizeof buffer_);

测试程序&#xff1a;

LogFile_test.cc&#xff1a;

C&#43;&#43; Code 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
#include 
#include 

boost::scoped_ptr g_logFile;

void outputFunc(const char *msg, int len)
{
    g_logFile->append(msg, len);
// scoped_ptr 重载operator->&#xff0c;调用LogFile::append(), 
// 间接调用File::append(); 最后 ::fwrite_unlocked(fp_);
}

void flushFunc()
{
    g_logFile->flush();
// scoped_ptr 重载operator->&#xff0c;调用LogFile::flush(), 
//间接调用File::flush()&#xff0c;最后::fflush(fp_);
}

int main(int argc, char *argv[])
{
    char name[256];
    strncpy(name, argv[0], 256);
    g_logFile.reset(new muduo::LogFile(::basename(name), 200 * 1000));
    muduo::Logger::setOutput(outputFunc);
    muduo::Logger::setFlush(flushFunc);

    muduo::string line &#61; "1234567890 abcdefghijklmnopqrstuvwxyz ABCDEFGHIJKLMNOPQRSTUVWXYZ ";

    for (int i &#61; 0; i < 10000; &#43;&#43;i)
    {
        LOG_INFO << line << i;
// 不断地构造匿名的Logger对象&#xff0c;在~Logger()中调用dummyOutput&#xff0c;将日志信息写入文件

        usleep(1000);
    }
}

执行程序后查看创建的日志文件&#xff1a;

simba&#64;ubuntu:~/Documents/build/debug/bin$ ls -lh *.log
-rw-rw-r-- 1 simba simba 196K Nov  2 05:37 logfile_test.20131102-123753.ubuntu.4044.log
-rw-rw-r-- 1 simba simba 196K Nov  2 05:37 logfile_test.20131102-123756.ubuntu.4044.log
-rw-rw-r-- 1 simba simba 196K Nov  2 05:38 logfile_test.20131102-123759.ubuntu.4044.log
-rw-rw-r-- 1 simba simba 196K Nov  2 05:38 logfile_test.20131102-123802.ubuntu.4044.log
-rw-rw-r-- 1 simba simba 196K Nov  2 05:38 logfile_test.20131102-123805.ubuntu.4044.log
-rw-rw-r-- 1 simba simba 196K Nov  2 05:38 logfile_test.20131102-123808.ubuntu.4044.log
-rw-rw-r-- 1 simba simba  87K Nov  2 05:38 logfile_test.20131102-123811.ubuntu.4044.log



因为我们设置的滚动日志文件大小为200 *1000/1024 &#61; 196k&#xff0c;所以现在即使没有到另一个零时&#xff0c;因为文件大小已到上限&#xff0c;也会自动滚动文件。





参考&#xff1a;
muduo manual.pdf
《linux 多线程服务器编程&#xff1a;使用muduo c&#43;&#43;网络库》





推荐阅读
  • PHP预处理常量详解:如何定义与使用常量 ... [详细]
  • 本文详细介绍了在 CentOS 7 系统中配置 fstab 文件以实现开机自动挂载 NFS 共享目录的方法,并解决了常见的配置失败问题。 ... [详细]
  • 在多线程并发环境中,普通变量的操作往往是线程不安全的。本文通过一个简单的例子,展示了如何使用 AtomicInteger 类及其核心的 CAS 无锁算法来保证线程安全。 ... [详细]
  • 开机自启动的几种方式
    0x01快速自启动目录快速启动目录自启动方式源于Windows中的一个目录,这个目录一般叫启动或者Startup。位于该目录下的PE文件会在开机后进行自启动 ... [详细]
  • 在软件开发过程中,经常需要将多个项目或模块进行集成和调试,尤其是当项目依赖于第三方开源库(如Cordova、CocoaPods)时。本文介绍了如何在Xcode中高效地进行多项目联合调试,分享了一些实用的技巧和最佳实践,帮助开发者解决常见的调试难题,提高开发效率。 ... [详细]
  • PTArchiver工作原理详解与应用分析
    PTArchiver工作原理及其应用分析本文详细解析了PTArchiver的工作机制,探讨了其在数据归档和管理中的应用。PTArchiver通过高效的压缩算法和灵活的存储策略,实现了对大规模数据的高效管理和长期保存。文章还介绍了其在企业级数据备份、历史数据迁移等场景中的实际应用案例,为用户提供了实用的操作建议和技术支持。 ... [详细]
  • 如何将TS文件转换为M3U8直播流:HLS与M3U8格式详解
    在视频传输领域,MP4虽然常见,但在直播场景中直接使用MP4格式存在诸多问题。例如,MP4文件的头部信息(如ftyp、moov)较大,导致初始加载时间较长,影响用户体验。相比之下,HLS(HTTP Live Streaming)协议及其M3U8格式更具优势。HLS通过将视频切分成多个小片段,并生成一个M3U8播放列表文件,实现低延迟和高稳定性。本文详细介绍了如何将TS文件转换为M3U8直播流,包括技术原理和具体操作步骤,帮助读者更好地理解和应用这一技术。 ... [详细]
  • Java Socket 关键参数详解与优化建议
    Java Socket 的 API 虽然被广泛使用,但其关键参数的用途却鲜为人知。本文详细解析了 Java Socket 中的重要参数,如 backlog 参数,它用于控制服务器等待连接请求的队列长度。此外,还探讨了其他参数如 SO_TIMEOUT、SO_REUSEADDR 等的配置方法及其对性能的影响,并提供了优化建议,帮助开发者提升网络通信的稳定性和效率。 ... [详细]
  • 在Android平台中,播放音频的采样率通常固定为44.1kHz,而录音的采样率则固定为8kHz。为了确保音频设备的正常工作,底层驱动必须预先设定这些固定的采样率。当上层应用提供的采样率与这些预设值不匹配时,需要通过重采样(resample)技术来调整采样率,以保证音频数据的正确处理和传输。本文将详细探讨FFMpeg在音频处理中的基础理论及重采样技术的应用。 ... [详细]
  • 本文介绍了如何利用 Delphi 中的 IdTCPServer 和 IdTCPClient 控件实现高效的文件传输。这些控件在默认情况下采用阻塞模式,并且服务器端已经集成了多线程处理,能够支持任意大小的文件传输,无需担心数据包大小的限制。与传统的 ClientSocket 相比,Indy 控件提供了更为简洁和可靠的解决方案,特别适用于开发高性能的网络文件传输应用程序。 ... [详细]
  • 在Android应用开发中,实现与MySQL数据库的连接是一项重要的技术任务。本文详细介绍了Android连接MySQL数据库的操作流程和技术要点。首先,Android平台提供了SQLiteOpenHelper类作为数据库辅助工具,用于创建或打开数据库。开发者可以通过继承并扩展该类,实现对数据库的初始化和版本管理。此外,文章还探讨了使用第三方库如Retrofit或Volley进行网络请求,以及如何通过JSON格式交换数据,确保与MySQL服务器的高效通信。 ... [详细]
  • 本指南从零开始介绍Scala编程语言的基础知识,重点讲解了Scala解释器REPL(读取-求值-打印-循环)的使用方法。REPL是Scala开发中的重要工具,能够帮助初学者快速理解和实践Scala的基本语法和特性。通过详细的示例和练习,读者将能够熟练掌握Scala的基础概念和编程技巧。 ... [详细]
  • 本文介绍了如何在iOS平台上使用GLSL着色器将YV12格式的视频帧数据转换为RGB格式,并展示了转换后的图像效果。通过详细的技术实现步骤和代码示例,读者可以轻松掌握这一过程,适用于需要进行视频处理的应用开发。 ... [详细]
  • 本文深入解析了Java 8并发编程中的`AtomicInteger`类,详细探讨了其源码实现和应用场景。`AtomicInteger`通过硬件级别的原子操作,确保了整型变量在多线程环境下的安全性和高效性,避免了传统加锁方式带来的性能开销。文章不仅剖析了`AtomicInteger`的内部机制,还结合实际案例展示了其在并发编程中的优势和使用技巧。 ... [详细]
  • AIX编程挑战赛:AIX正方形问题的算法解析与Java代码实现
    在昨晚的阅读中,我注意到了CSDN博主西部阿呆-小草屋发表的一篇文章《AIX程序设计大赛——AIX正方形问题》。该文详细阐述了AIX正方形问题的背景,并提供了一种基于Java语言的解决方案。本文将深入解析这一算法的核心思想,并展示具体的Java代码实现,旨在为参赛者和编程爱好者提供有价值的参考。 ... [详细]
author-avatar
大头莎LALA
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有