我正在嘗試確定默認(rèn)/sdk 記錄器 log.PrintYYY() 函數(shù)是否在某個(gè)時(shí)間點(diǎn)、退出時(shí)、恐慌時(shí)等被刷新。我不確定是否需要找到一種方法來刷新編寫器記錄器連接到，尤其是在使用 SetOutput(...) 設(shè)置輸出編寫器時(shí)。當(dāng)然，writer 接口沒有 flush() 方法，所以不太確定如何完成。Go sdk 記錄器如何以及何時(shí)刷新？
2 回答
猛跑小豬
TA貢獻(xiàn)1858條經(jīng)驗(yàn) 獲得超8個(gè)贊
該log包不負(fù)責(zé)刷新底層io.Writer.?包可能會(huì)log執(zhí)行一個(gè)類型斷言，看看當(dāng)前是否io.Writer有Flush()方法，如果有則調(diào)用它，但不能保證如果多個(gè)io.Writers被“鏈接”，數(shù)據(jù)最終會(huì)被刷新到最底層。
log在我看來，包不刷新的主要原因是性能。我們使用緩沖寫入器，因此我們不必在每次向其寫入單個(gè)字節(jié)（或字節(jié)片）時(shí)都到達(dá)底層，但我們可以緩存最近寫入的數(shù)據(jù)，并且當(dāng)我們達(dá)到特定大小時(shí)（或特定大?。r(shí)間），我們可以一次高效地編寫“批處理”。
如果log程序包在每個(gè)日志語(yǔ)句之后刷新，這將使緩沖 IO 變得無用。在小型應(yīng)用程序的情況下這可能無關(guān)緊要，但如果您有一個(gè)高流量的 Web 服務(wù)器，在每個(gè)日志語(yǔ)句（每個(gè)請(qǐng)求處理中可能有很多）之后發(fā)出刷新將導(dǎo)致嚴(yán)重的性能缺陷。
那么是的，如果應(yīng)用程序終止，就會(huì)出現(xiàn)問題，最后的日志語(yǔ)句可能無法到達(dá)底層。正確的解決方案是正常關(guān)閉：實(shí)施信號(hào)處理，當(dāng)您的應(yīng)用程序即將終止時(shí)，正確刷新并關(guān)閉io.Writer您使用的記錄器的底層。
如果——只是為了簡(jiǎn)單——你仍然需要一個(gè)在每個(gè)日志語(yǔ)句之后刷新的記錄器，你可以輕松實(shí)現(xiàn)。這是因?yàn)樵擃愋捅ＷC通過一次調(diào)用log.Logger將每條日志消息傳送到目的地：io.WriterWriter.Write()
每個(gè)日志記錄操作都會(huì)調(diào)用 Writer 的 Write 方法。多個(gè) goroutine 可以同時(shí)使用一個(gè) Logger；它保證序列化對(duì) Writer 的訪問。
所以基本上你需要做的就是創(chuàng)建一個(gè)“包裝器”，io.Writer其方法在“轉(zhuǎn)發(fā)”對(duì)其底層編寫器的調(diào)用Write()后進(jìn)行刷新。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
}
此實(shí)現(xiàn)檢查 methodFlush()和os.File的Sync()方法，并在它們“存在”時(shí)調(diào)用。
這就是如何使用它，以便日志記錄語(yǔ)句始終刷新：
f, err := os.Create("log.txt")
if err != nil {
? ? panic(err)
}
defer f.Close()
log.SetOutput(&myWriter{Writer: f})
log.Println("hi")
函數(shù)式編程
TA貢獻(xiàn)1807條經(jīng)驗(yàn) 獲得超9個(gè)贊
記錄器不應(yīng)該知道如何刷新數(shù)據(jù)。您必須刷新您在創(chuàng)建記錄器時(shí)指定的輸出編寫器（如果它具有這種功能）。
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!")
}
- 2 回答
- 0 關(guān)注
- 194 瀏覽
添加回答
舉報(bào)
0/150
提交
取消