如何在 Go 中为单个通道配置多个独立的日志协程-Golang-PHP中文网

本文详解 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 <p>关键改进说明：</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件"><img
														src="https://img.php.cn/upload/webcode/000/000/164/636a2b4d84031727.png" alt="使用Go语言搭建家庭相册系统-相关课件" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件" class="overflowclass">使用Go语言搭建家庭相册系统-相关课件</a>
													<p class="overflowclass">使用Go语言搭建家庭相册系统-相关课件</p>
												</div>
												<a rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
												</a>
											</div>
										</div>

独立 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...），完美实现负载分散与日志隔离。