使用带缓冲Channel和互斥锁实现并发安全日志写入:定义容量为1000的logChan接收日志,生产者异步发送,单一消费者通过文件锁同步写入文件,避免竞争。

在高并发场景下,多个 goroutine 同时写入日志容易引发竞争问题,导致日志内容错乱或丢失。Golang 提供了 Channel 和文件锁(*sync.Mutex)两种机制来安全地实现并发日志写入。结合 Channel 缓冲与文件锁,可以兼顾性能与线程安全。
使用带缓冲 Channel 异步接收日志消息
通过创建一个带缓冲的 Channel,将日志写入操作异步化。多个 goroutine 可快速发送日志消息而不阻塞,由单独的消费者 goroutine 负责持久化到文件。
说明:- 定义容量为 1000 的日志 Channel:logChan := make(chan string, 1000)
- 每个日志生产者调用 logChan 发送消息
- 主循环中启动一个后台 goroutine 持续从 Channel 读取并写入文件
这种方式避免了频繁磁盘 I/O 对业务逻辑的影响,提升整体吞吐量。
使用 sync.Mutex 实现文件写入互斥
即使使用 Channel 隔离了写入请求,最终仍需确保文件操作的原子性。多个消费者同时写入同一文件会破坏数据完整性。
立即学习“go语言免费学习笔记(深入)”;
建议做法:- 声明一个全局互斥锁:var fileMutex sync.Mutex
- 在写入文件前调用 fileMutex.Lock(),完成后立即 Unlock()
- 配合 defer fileMutex.Unlock() 防止死锁
例如打开文件句柄后,每次 Write 操作都受锁保护,确保写入顺序一致且无交叉。
整合 Channel 与文件锁的完整模式
典型结构是在程序启动时启动一个日志协程,它监听 Channel 并在加锁后写入文件。生产端只需发送消息,无需关心底层细节。
关键代码片段:go func() {
file, _ := os.OpenFile("app.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
defer file.Close()
for msg := range logChan {
fileMutex.Lock()
file.WriteString(msg + "\n")
fileMutex.Unlock()
}
}()
这种设计实现了生产与消费解耦,Channel 提供缓冲能力,Mutex 保证写入安全。
基本上就这些。合理设置 Channel 容量可防止内存溢出,配合超时机制能进一步增强健壮性。不复杂但容易忽略的是:始终关闭文件、处理异常、以及避免在锁内执行耗时操作。










