使用sync.Mutex可实现Golang并发安全日志写入，通过封装Logger结构体并加锁保护Write方法，确保多goroutine下文件写入串行化；结合io.Writer接口或channel消息队列可扩展为同步或异步方案，前者简单可靠，后者适用于高并发场景。
在Golang中实现并发安全的日志写入，关键在于避免多个goroutine同时写入文件导致内容错乱或丢失。通过使用sync.Mutex保护文件写入操作，结合io.Writer接口和结构封装，可以轻松构建一个线程安全的并发日志系统。
使用互斥锁保护文件写入
多个goroutine同时写入同一个日志文件时，必须确保写操作是串行化的。最直接的方式是用sync.Mutex加锁。
定义一个带锁的日志结构体：
type Logger struct { file *os.File mu sync.Mutex}func (l *Logger) Write(data []byte) error {l.mu.Lock()defer l.mu.Unlock()_, err := l.file.Write(data)return err}
每次调用Write都会被锁保护，防止并发冲突。这种方式简单可靠，适用于大多数场景。
立即学习“go语言免费学习笔记（深入）”；
封装日志方法并支持格式化输出
在实际使用中，通常希望像标准库log那样支持Printf、Println等方法。
可以基于自定义Logger结构体扩展功能：
func (l *Logger) Printf(format string, v ...interface{}) { l.mu.Lock() defer l.mu.Unlock() log.Printf(format, v...) // 或者直接写入文件 msg := fmt.Sprintf(format+"n", v...) l.file.Write([]byte(msg))}
注意：如果使用标准log包，也可以将文件句柄作为io.Writer传入，同时加锁控制：
var mu sync.Mutexwriter := io.MultiWriter(os.Stdout, file)logger := log.New(&lockedWriter{writer, &mu}, "", 0)type lockedWriter struct {w io.Writerm *sync.Mutex}
func (lw *lockedWriter) Write(p []byte) (n int, err error) {lw.m.Lock()defer lw.m.Unlock()return lw.w.Write(p)}
使用channel进行日志消息队列化（可选高级方案）
另一种思路是引入异步机制：所有goroutine把日志发送到channel，由单独的写入goroutine顺序处理。
这种方式能减少锁竞争，提升性能：
type LogEntry struct { message []byte}type AsyncLogger struct {entries chan LogEntry}
func (al *AsyncLogger) Start() {go func() {for entry := range al.entries {file.Write(entry.message)}}()}
func (al *AsyncLogger) Log(msg []byte) {select {case al.entries <- LogEntry{msg}:default:// 队列满时可丢弃或阻塞}}
适合高并发、日志量大的场景，但需注意内存占用和关闭时机。
基本上就这些。对于大多数应用，使用sync.Mutex保护文件写入已足够安全高效。不复杂但容易忽略的是：记得在程序退出前关闭文件，避免数据丢失。
以上就是如何在Golang中实现并发日志写入的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1416404.html
微信扫一扫 
支付宝扫一扫 
