1. 日志切割归档

1.1.1. 使用Lumberjack进行日志切割归档

这个日志程序中唯一缺少的就是日志切割归档功能。

Zap本身不支持切割归档日志文件

为了添加日志切割归档功能，我们将使用第三方库Lumberjack来实现。

1.1.2. 安装

执行下面的命令安装Lumberjack

  1.     go get -u github.com/natefinch/lumberjack

1.1.3. zap logger中加入Lumberjack

要在zap中加入Lumberjack支持，我们需要修改WriteSyncer代码。我们将按照下面的代码修改getLogWriter()函数：

  1. func getLogWriter() zapcore.WriteSyncer {
  2.     lumberJackLogger := &lumberjack.Logger{
  3.         Filename:   "./test.log",
  4.         MaxSize:    10,
  5.         MaxBackups: 5,
  6.         MaxAge:     30,
  7.         Compress:   false,
  8.     }
  9.     return zapcore.AddSync(lumberJackLogger)
  10. }

Lumberjack Logger采用以下属性作为输入:

  • Filename: 日志文件的位置
  • MaxSize：在进行切割之前，日志文件的最大大小（以MB为单位）
  • MaxBackups：保留旧文件的最大个数
  • MaxAges：保留旧文件的最大天数
  • Compress：是否压缩/归档旧文件

1.1.4. 测试所有功能

最终，使用Zap/Lumberjack logger的完整示例代码如下：

  1. package main
  3. import (
  4.     "net/http"
  6.     "github.com/natefinch/lumberjack"
  7.     "go.uber.org/zap"
  8.     "go.uber.org/zap/zapcore"
  9. )
  11. var sugarLogger *zap.SugaredLogger
  13. func main() {
  14.     InitLogger()
  15.     defer sugarLogger.Sync()
  16.     simpleHttpGet("www.topgoer.com")
  17.     simpleHttpGet("http://www.topgoer.com")
  18. }
  20. func InitLogger() {
  21.     writeSyncer := getLogWriter()
  22.     encoder := getEncoder()
  23.     core := zapcore.NewCore(encoder, writeSyncer, zapcore.DebugLevel)
  25.     logger := zap.New(core, zap.AddCaller())
  26.     sugarLogger = logger.Sugar()
  27. }
  29. func getEncoder() zapcore.Encoder {
  30.     encoderConfig := zap.NewProductionEncoderConfig()
  31.     encoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
  32.     encoderConfig.EncodeLevel = zapcore.CapitalLevelEncoder
  33.     return zapcore.NewConsoleEncoder(encoderConfig)
  34. }
  36. func getLogWriter() zapcore.WriteSyncer {
  37.     lumberJackLogger := &lumberjack.Logger{
  38.         Filename:   "./test.log",
  39.         MaxSize:    1,
  40.         MaxBackups: 5,
  41.         MaxAge:     30,
  42.         Compress:   false,
  43.     }
  44.     return zapcore.AddSync(lumberJackLogger)
  45. }
  47. func simpleHttpGet(url string) {
  48.     sugarLogger.Debugf("Trying to hit GET request for %s", url)
  49.     resp, err := http.Get(url)
  50.     if err != nil {
  51.         sugarLogger.Errorf("Error fetching URL %s : Error = %s", url, err)
  52.     } else {
  53.         sugarLogger.Infof("Success! statusCode = %s for URL %s", resp.Status, url)
  54.         resp.Body.Close()
  55.     }
  56. }