本文详解为何多个 goroutine 共享 log.SetOutput() 会导致日志全部写入最后一个文件，并提供基于独立 log.Logger 实例的正确实现方案，确保每个 LogWorker 写入专属日志文件。
本文详解为何多个 goroutine 共享 `log.setoutput()` 会导致日志全部写入最后一个文件，并提供基于独立 `log.logger` 实例的正确实现方案，确保每个 logworker 写入专属日志文件。
问题根源在于：Go 标准库的 log 包使用全局变量管理默认 logger（log.std），而 log.SetOutput() 和 log.SetFlags() 会直接修改该全局实例。当多个 LogWorker.Work() 并发调用 log.SetOutput(&lumberjack.Logger{...}) 时，后执行的 goroutine 会覆盖前者的输出目标——最终所有 log.Println() 调用都流向最后一个设置的 lumberjack.Logger，导致仅生成一个日志文件（如 event_3），其余 worker 彻底失效。
✅ 正确做法是为每个 worker 创建*独立的 `log.Logger实例**，而非复用全局 logger。修改LogWorker.Work` 方法如下：
func (lw *LogWorker) Work(evChannel <-chan Event) {
fmt.Printf("LogWorker started: %s\n", lw.FileName)
// ✅ 为每个 worker 创建专属 logger，避免全局污染
lg := log.New(&lumberjack.Logger{
Filename: lw.FileName,
MaxSize: lw.MaxSize,
MaxBackups: lw.MaxBackups,
MaxAge: lw.MaxAge,
}, "", 0) // prefix 为空，flag 为 0（不加时间戳等）
// ✅ 使用 range 遍历通道，支持优雅关闭
for event := range evChannel {
lg.Println(Csv(event))
}
}关键改进点说明：
- 独立 logger 实例：log.New(...) 返回新 *log.Logger，各 worker 持有完全隔离的日志输出对象，互不影响；
- 只读通道参数：将 evChannel chan Event 改为 evChannel
- range 替代 for { ：当通道被关闭（例如程序退出时需清理），range 会自动退出循环，避免 goroutine 泄漏；而无限 for {
- 移除 log.SetFlags(0) 的副作用：该调用影响全局 logger，已无必要；专属 logger 的 flag 在 log.New() 中直接指定。
? 补充建议：
- 在 main() 中，可通过 sync.WaitGroup 管理 worker 生命周期，确保服务关闭前所有日志落盘；
- 若需动态增减 worker 数量，应使用带缓冲的 channel 或结合 select + default 实现非阻塞写入，防止请求因日志队列满而丢失；
- 生产环境建议增加日志错误处理（如 lg.Output() 返回 error 时告警），并考虑结构化日志库（如 zap）替代 log + lumberjack 组合以获得更高性能与灵活性。
通过以上重构，四个 LogWorker 将严格按预期分别写入 event_0, event_1, event_2, event_3 四个独立文件，真正实现并发日志分流。
