Go SDK 记录器何时以及如何执行刷新操作？

Golang不知道大家是否熟悉？今天我将给大家介绍《Go SDK 记录器何时以及如何执行刷新操作？》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

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

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

解决方案

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

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

如果 log 包在每个日志语句后刷新，这将使缓冲 io 无用。对于小型应用程序来说，这可能并不重要，但如果您有一个高流量的 web 服务器，在每个日志语句（每个请求处理中可能有很多语句）之后发出刷新将导致严重的性能缺陷。

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

Is it possible to capture a Ctrl+C signal and run a cleanup function, in a "defer" fashion?

Is there something like finally() in Go just opposite to what init()?

Are deferred functions called when SIGINT is received in Go?

如果（仅为简单起见）您仍然需要一个在每个日志语句后刷新的记录器，您可以轻松实现这一点。这是因为 log.Logger 类型保证通过单个 writer.write() 调用将每条日志消息传递到目标 io.writer：

每个日志记录操作都会对 writer 的 write 方法进行一次调用。 logger 可以在多个 goroutine 中同时使用；它保证对 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
}

此实现会检查 flush() 方法和 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")

查看相关问题：

Go: Create io.Writer inteface for logging to mongodb database

net/http set custom logger

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

参见 github discussion 中的示例

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!")
}

您可以阅读与您的问题 on github 相关的整个讨论

或者，您可以查看具有 flush 的 3rd 方记录器。查看 zap logger，其中有方法 logger.sync()

到这里，我们也就讲完了《Go SDK 记录器何时以及如何执行刷新操作？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！