我正在尝试确定默认/sdk 记录器 log.PrintYYY() 函数是否在某个时间点、退出时、 panic 等时刷新。我不确定是否需要找到一种刷新方法记录器连接的编写器,尤其是使用 SetOutput(...) 设置输出编写器时。当然,编写器接口(interface)没有flush()方法,所以不太确定如何完成。
Go sdk 记录器如何以及何时刷新?
最佳答案
log
包不负责刷新底层io.Writer
。 log
包可以执行类型断言来查看当前的 io.Writer
是否具有 Flush()
方法,如果是则调用它,但不能保证如果多个 io.Writer 被“链接”,数据最终会刷新到最底层。
在我看来,log
包没有刷新的主要原因是性能。我们使用缓冲写入器,因此每次写入单个字节(或 byte slice )时,我们不必到达底层,但我们可以缓存最近写入的数据,当达到一定大小(或某个特定大小)时,我们可以缓存最近写入的数据。 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
type 保证通过单个 Writer.Write()
调用将每条日志消息传递到目标 io.Writer
:
Each logging operation makes a single call to the Writer's Write method. A Logger can be used simultaneously from multiple goroutines; it guarantees to serialize access to the 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
关于go - Go sdk 记录器如何以及何时刷新?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52935858/