本文详解 Go 中多协程消费同一 channel 时日志输出混乱的根本原因——误用全局 log 包，以及如何通过为每个协程创建独立 *log.Logger 实例实现真正的并行日志写入。
本文详解 go 中多协程消费同一 channel 时日志输出混乱的根本原因——误用全局 `log` 包，以及如何通过为每个协程创建独立 `*log.logger` 实例实现真正的并行日志写入。
在 Go 中，使用多个 goroutine 并发消费同一个 channel 是常见模式，但若处理不当（尤其是涉及共享状态时），极易引发竞态或行为异常。您遇到的“所有日志只写入第四个文件”问题，并非 channel 分发逻辑失效，而是对 Go 标准库 log 包的误用所致。
核心问题在于：log.SetOutput() 和 log.SetFlags() 操作修改的是全局、包级的默认 logger（即 log.Default() 返回的实例）。当 4 个 LogWorker.Work() 方法依次执行时，每个都会调用 log.SetOutput(...)，将全局 logger 的输出目标覆盖为自己的 lumberjack.Logger。最终，只有最后一个执行的 goroutine（通常是第 4 个）的设置生效；其余 goroutine 虽然在运行，但它们调用的 log.Println(...) 实际都写入了同一个、已被最后覆盖的输出目标——即第四个文件。这就是为何仅看到一个日志文件被写入。
✅ 正确做法是：*为每个 goroutine 创建专属的 `log.Logger实例**，而非篡改全局 logger。修改LogWorker.Work` 方法如下：
func (lw *LogWorker) Work(evChannel <-chan Event) {
fmt.Printf("LogWorker started: %s\n", lw.FileName)
// ✅ 为本 goroutine 创建独立 logger
lg := log.New(&lumberjack.Logger{
Filename: lw.FileName,
MaxSize: int64(lw.MaxSize) * 1024 * 1024, // 注意：lumberjack.MaxSize 单位是字节
MaxBackups: lw.MaxBackups,
MaxAge: lw.MaxAge,
}, "", log.LstdFlags) // 可选：添加时间戳等标志
// ✅ 使用 range 遍历 channel，优雅退出
for event := range evChannel {
lg.Println(Csv(event))
}
}关键改进说明：
- 独立 logger：log.New(...) 返回新实例，各 goroutine 持有互不干扰的 logger，彻底避免全局状态污染。
- channel 类型注解：将参数改为
- range 替代 for-select：for event := range evChannel 在 channel 关闭后自动退出循环，避免 for {} 空转；同时更符合 Go idiomatic 风格。
- 单位修正：lumberjack.MaxSize 接收字节数，原代码传入 int（MB）需转换为字节（int64(lw.MaxSize) * 1024 * 1024），否则日志轮转可能失效。
⚠️ 补充注意事项：
- channel 关闭管理：当前示例未展示如何关闭 evChannel。生产环境建议在服务关闭前（如接收到 SIGINT）显式关闭 channel，以通知所有 worker 退出。可配合 sync.WaitGroup 等待 worker 结束。
- 错误处理增强：Csv(event) 若可能 panic 或返回 error，应在 lg.Println() 前做防御性检查。
- 性能考量：lumberjack.Logger 本身是线程安全的，无需额外加锁；但若 CSV 序列化开销大，可考虑在 worker 内部做批处理（如缓冲 N 条后一次性写入）。
通过以上重构，4 个 LogWorker 将真正并行、独立地消费 evChannel，各自将日志写入指定文件（如 event_0, event_1...），完美实现负载分散与日志隔离。
