Go sdk 记录器如何以及何时刷新？

Question

我正在尝试确定默认/sdk 记录器 log.PrintYYY() 函数是否在某个时间点、退出时、恐慌时等被刷新。我不确定是否需要找到一种方法来刷新编写器记录器连接到，尤其是在使用 SetOutput(...) 设置输出编写器时。当然，writer 接口没有 flush() 方法，所以不太确定如何完成。Go sdk 记录器如何以及何时刷新？

Answer 1

该log包不负责刷新底层io.Writer. 包可能会log执行一个类型断言，看看当前是否io.Writer有Flush()方法，如果有则调用它，但不能保证如果多个io.Writers被“链接”，数据最终会被刷新到最底层。

log在我看来，包不刷新的主要原因是性能。我们使用缓冲写入器，因此我们不必在每次向其写入单个字节（或字节片）时都到达底层，但我们可以缓存最近写入的数据，并且当我们达到特定大小时（或特定大小）时间），我们可以一次高效地编写“批处理”。

如果log程序包在每个日志语句之后刷新，这将使缓冲 IO 变得无用。在小型应用程序的情况下这可能无关紧要，但如果您有一个高流量的 Web 服务器，在每个日志语句（每个请求处理中可能有很多）之后发出刷新将导致严重的性能缺陷。

那么是的，如果应用程序终止，就会出现问题，最后的日志语句可能无法到达底层。正确的解决方案是正常关闭：实施信号处理，当您的应用程序即将终止时，正确刷新并关闭io.Writer您使用的记录器的底层。

如果——只是为了简单——你仍然需要一个在每个日志语句之后刷新的记录器，你可以轻松实现。这是因为该类型保证通过一次调用log.Logger将每条日志消息传送到目的地：io.WriterWriter.Write()

每个日志记录操作都会调用 Writer 的 Write 方法。多个 goroutine 可以同时使用一个 Logger；它保证序列化对 Writer 的访问。

所以基本上你需要做的就是创建一个“包装器”，io.Writer其方法在“转发”对其底层编写器的调用Write()后进行刷新。Write()

这就是它的样子：

type myWriter struct {

    io.Writer

}

func (m *myWriter) Write(p []byte) (n int, err error) {

    n, err = m.Writer.Write(p)

    if flusher, ok := m.Writer.(interface{ Flush() }); ok {

        flusher.Flush()

    } else if syncer := m.Writer.(interface{ Sync() error }); ok {

        // Preserve original error

        if err2 := syncer.Sync(); err2 != nil && err == nil {

            err = err2

        }

    }

    return

}

此实现检查 methodFlush()和os.File的Sync()方法，并在它们“存在”时调用。

这就是如何使用它，以便日志记录语句始终刷新：

f, err := os.Create("log.txt")

if err != nil {

    panic(err)

}

defer f.Close()

log.SetOutput(&myWriter{Writer: f})

log.Println("hi")

Answer 2

记录器不应该知道如何刷新数据。您必须刷新您在创建记录器时指定的输出编写器（如果它具有这种功能）。

package main

import (

    "bufio"

    "flag"

    "log"

    "os"

    "strings"

)

func main() {

    var flush bool

    flag.BoolVar(&flush, "flush", false, "if set, will flush the buffered io before exiting")

    flag.Parse()

    br := bufio.NewWriter(os.Stdout)

    logger := log.New(br, "", log.Ldate)

    logger.Printf("%s\n", strings.Repeat("This is a test\n", 5))

    if flush {

        br.Flush()

    }

    logger.Fatalf("exiting now!")

}