如何在Golang中编写一个将日志异步写入磁盘的缓冲写入函数-Golang-PHP中文网

不能直接用 os.file.write 写日志，因其同步写磁盘会阻塞主线程，高并发时可能卡住几十毫秒；需通过 channel 队列+单 goroutine 串行落盘，控制缓冲区上限、复用 buf、确保 flush，兼顾不丢日志、内存可控与主流程性能。

如何在golang中编写一个将日志异步写入磁盘的缓冲写入函数

为什么不能直接用 `os.File.Write` 写日志

同步写磁盘会卡住主线程，尤其在高并发或频繁打日志时，Write 可能阻塞几十毫秒甚至更久。Go 的 log 包默认就是同步写，不加改造没法扛住真实业务流量。

真正要解决的不是“怎么异步”，而是“怎么避免丢日志 + 控制内存 + 不拖慢主流程”。常见错误是只起 goroutine 丢 Write，结果日志堆积、OOM 或 panic：比如多个 goroutine 同时写同一个 *os.File（未加锁），或者缓冲区无限增长。

必须串行化写入：同一文件只能由一个 goroutine 负责落盘
缓冲区要有硬上限，超限时要么丢日志、要么阻塞生产者（根据业务容忍度选）
程序退出前要调用 Flush，否则最后一段日志就丢了

用 `chan` 做日志队列 + 单写 goroutine

这是最轻量、可控性最强的方式。核心是把日志条目（字符串或结构体）发到 channel，后台 goroutine 拿到后批量写入文件。

示例关键片段：

type LogWriter struct {
    ch   chan string
    file *os.File
    done chan struct{}
}
<p>func NewLogWriter(path string) (*LogWriter, error) {
f, err := os.OpenFile(path, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
return nil, err
}
w := &LogWriter{
ch:   make(chan string, 1000), // 缓冲区大小按需设（如 1k 条）
file: f,
done: make(chan struct{}),
}
go w.writerLoop()
return w, nil
}</p><p>func (w *LogWriter) Write(s string) {
select {
case w.ch </p><p>func (w *LogWriter) writerLoop() {
buf := make([]byte, 0, 4096)
for {
select {
case line :=  8192 { // 达到阈值就刷一次
w.file.Write(buf)
buf = buf[:0]
}
case  0 {
w.file.Write(buf)
}
w.file.Close()
return
}
}
}</p>

注意：buf 复用避免频繁 alloc；Write 不带 error 检查——实际中应判断返回值并重试/告警；default 分支决定是丢日志还是背压，别漏掉。