Go语言日志滚动：实现文件大小限制的日志切割

花韻仙語

发布时间：2025-09-28 10:46:40

161人浏览过

来源于php中文网

原创

go语言日志滚动：实现文件大小限制的日志切割

Go语言本身并没有内置日志滚动功能，这意味着标准的log包无法自动在日志文件达到一定大小时进行切割。虽然log4go等第三方库曾经被推荐，但它们存在一些问题，例如可能导致消息丢失。因此，我们需要寻找其他的解决方案来实现日志滚动。

实现日志滚动的方法

虽然Go标准库没有直接提供日志滚动，但我们可以通过以下几种方式实现类似的功能：

第三方库： 使用专门的日志库，如lumberjack。
自定义实现： 编写自己的日志滚动逻辑，利用Go的文件操作和时间函数。

使用lumberjack库实现日志滚动

lumberjack是一个流行的Go语言日志滚动库，它简单易用，并且功能强大。

安装lumberjack：

立即学习“go语言免费学习笔记（深入）”；

go get github.com/natefinch/lumberjack

使用示例：

package main

import (
    "log"
    "os"

    "gopkg.in/natefinch/lumberjack.v2"
)

func main() {
    // 配置 lumberjack logger
    lumberjackLogger := &lumberjack.Logger{
        Filename:   "./app.log", // 日志文件路径
        MaxSize:    10,       // 每个日志文件最大大小，单位是MB
        MaxBackups: 5,        // 最多保留的旧日志文件数量
        MaxAge:     30,       // 最多保留多少天的日志
        Compress:   true,      // 是否压缩/归档旧文件
    }

    // 设置 log 包使用 lumberjack logger
    log.SetOutput(lumberjackLogger)
    log.SetFlags(log.LstdFlags | log.Lshortfile) // 可选：设置日志格式

    // 写入一些日志
    for i := 0; i < 1000; i++ {
        log.Printf("This is a test log message: %d", i)
    }

    // 应用程序退出时，确保关闭 lumberjack logger
    lumberjackLogger.Close()
}

代码解释：

MiniMax Agent

MiniMax平台推出的Agent智能体助手

下载

Filename: 指定日志文件的路径。
MaxSize: 设置每个日志文件的最大大小，单位是MB。当日志文件达到这个大小时，lumberjack会自动切割并创建新的日志文件。
MaxBackups: 指定最多保留的旧日志文件数量。当旧日志文件数量超过这个值时，lumberjack会自动删除最旧的日志文件。
MaxAge: 指定最多保留多少天的日志。超过这个天数的旧日志文件会被删除。
Compress: 指定是否压缩/归档旧的日志文件。

注意事项：

确保在程序退出时关闭lumberjackLogger，释放资源。
根据实际需求调整MaxSize、MaxBackups和MaxAge等参数。
lumberjack库会自动处理并发写入，因此可以在多线程环境中使用。

自定义实现日志滚动

如果不想使用第三方库，也可以自己实现日志滚动功能。以下是一个简单的示例：

package main

import (
    "fmt"
    "log"
    "os"
    "path/filepath"
    "time"
)

const (
    logDir      = "./logs"       // 日志目录
    logFileName = "app.log"    // 日志文件名
    maxLogSize  = 10 * 1024 * 1024 // 10MB  最大日志文件大小
)

var (
    logFile *os.File
)

func init() {
    // 确保日志目录存在
    if _, err := os.Stat(logDir); os.IsNotExist(err) {
        os.MkdirAll(logDir, 0755)
    }

    // 获取当前日志文件路径
    logFilePath := filepath.Join(logDir, logFileName)

    // 检查日志文件大小，如果超出限制则滚动
    fileInfo, err := os.Stat(logFilePath)
    if err == nil && fileInfo.Size() > maxLogSize {
        rotateLogFile(logFilePath)
    }

    // 打开或创建日志文件
    logFile, err = os.OpenFile(logFilePath, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
    if err != nil {
        panic(err)
    }

    // 设置 log 包使用我们的日志文件
    log.SetOutput(logFile)
    log.SetFlags(log.LstdFlags | log.Lshortfile)
}

func rotateLogFile(logFilePath string) {
    // 构建新的日志文件名，包含时间戳
    newLogFileName := fmt.Sprintf("%s.%s", logFilePath, time.Now().Format("20060102150405"))
    // 重命名旧的日志文件
    err := os.Rename(logFilePath, newLogFileName)
    if err != nil {
        log.Printf("Failed to rotate log file: %v", err)
    }
}

func main() {
    for i := 0; i < 1000; i++ {
        log.Printf("This is a test log message: %d", i)
    }

    defer logFile.Close()
}

代码解释：