如何在 Golang 中实现异步日志系统_Golang 并发写入与缓冲机制实战

type LogEntry struct {
    Level   string
    Message string
    Time    time.Time
}
<p>const logQueueSize = 10000</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">go语言免费学习笔记（深入）</a>”；</p><p>var logChan = make(chan *LogEntry, logQueueSize)

func startLogger(filename string) {
    file, err := os.OpenFile(filename, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
    if err != nil {
        panic(err)
    }
    defer file.Close()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">for entry := range logChan {
    line := fmt.Sprintf("[%s] %s - %s\n", entry.Time.Format("2006-01-02 15:04:05"), entry.Level, entry.Message)
    file.WriteString(line)
}

func Info(msg string) {
    logChan <- &LogEntry{Level: "INFO", Message: msg, Time: time.Now()}
}
<p>func Error(msg string) {
logChan <- &LogEntry{Level: "ERROR", Message: msg, Time: time.Now()}
}

func startLogger(filename string) {
    file, err := os.OpenFile(filename, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
    if err != nil {
        panic(err)
    }
    defer file.Close()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">var buffer []string
ticker := time.NewTicker(500 * time.Millisecond)
defer ticker.Stop()

for {
    select {
    case entry, ok := <-logChan:
        if !ok {
            return
        }
        line := fmt.Sprintf("[%s] %s - %s\n", entry.Time.Format("2006-01-02 15:04:05"), entry.Level, entry.Message)
        buffer = append(buffer, line)

        if len(buffer) >= 100 {
            flushBuffer(file, buffer)
            buffer = nil
        }

    case <-ticker.C:
        if len(buffer) > 0 {
            flushBuffer(file, buffer)
            buffer = nil
        }
    }
}

var logWg sync.WaitGroup
<p>func StopLogger() {
close(logChan)
logWg.Wait()
}