在go語言中，可以通過使用goroutine與channel機制來實現日志的異步記錄。以下是一個基礎示例，演示了如何構建一個異步日志處理模塊：
package main <p>import ( "fmt" "log" "os" "sync" "time" )</p><p>// 定義日志條目結構體 type LogEntry struct { Timestamp time.Time // 日志時間戳 Message string // 日志內容 }</p><p>// 異步日志記錄器結構體 type AsyncLogger struct { logChan chan LogEntry // 日志通道 wg sync.WaitGroup logger *log.Logger // 實際用于輸出的日志對象 }</p><p>// 初始化異步日志記錄器 func NewAsyncLogger(logLevel int) *AsyncLogger { return &AsyncLogger{ logChan: make(chan LogEntry, 100), logger: log.New(os.Stdout, "", log.LstdFlags), } }</p><p>// 啟動日志協程 func (al *AsyncLogger) Start() { al.wg.Add(1) go func() { defer al.wg.Done() for entry := range al.logChan { al.logger.Printf("[%s] %s", entry.Timestamp.Format(time.RFC3339), entry.Message) } }() }</p><p>// 停止日志記錄器 func (al *AsyncLogger) Stop() { close(al.logChan) al.wg.Wait() }</p><p>// 提交日志消息到通道 func (al *AsyncLogger) Log(message string) { al.logChan <- LogEntry{ Timestamp: time.Now(), Message: message, } }
在這個實現中，我們定義了一個AsyncLogger結構體，其中包含一個緩沖的日志channel、一個WaitGroup用于同步goroutine的退出以及一個標準庫中的log.Logger用于實際輸出。
通過調用Start()方法啟動后臺goroutine監聽日志channel，并依次打印日志信息；而Stop()方法負責關閉channel并等待所有日志處理完成。
在主函數中可以這樣使用：
立即學習“go語言免費學習筆記（深入）”；
func main() { logger := NewAsyncLogger(0) logger.Start()</p><pre class="brush:php;toolbar:false">// 模擬并發寫入日志 for i := 0; i < 10; i++ { go func(i int) { logger.Log(fmt.Sprintf("這是第 %d 條日志信息", i)) }(i) } time.Sleep(12 * time.Second) logger.Stop()
}
該示例展示了如何利用Go的并發特性實現高效的日志異步寫入機制。用戶可以根據具體業務需求調整日志格式、輸出目標和channel容量等參數。
