本文介绍在 go 语言中安全实现多 goroutine 并发写入同一文件的推荐方案，重点剖析为何简单共享 *os.file 并加锁仍存在风险，并详解基于通道（channel）的服务化写入模型——它不仅消除竞态，更符合 go 的 csp 设计哲学。
在你的示例代码中，虽然多个 goroutine 共享同一个 *os.File 句柄并调用 fmt.Fprintf，但你并未观察到预期的乱序或截断输出（如 "PrintinPriting out: 3"），这容易让人误以为 *os.File 是线程安全的。事实并非如此：*os.File 的底层 Write 方法本身是并发安全的（因内部使用了文件描述符级系统调用，且多数操作系统对单个 fd 的 write 是原子的），但 fmt.Fprintf 是一个复合操作——它先格式化字符串到缓冲区，再调用 Write。当多个 goroutine 同时执行该过程时，仍可能因缓冲区竞争、写入偏移错乱或 os.File 内部状态（如 offset 字段）未同步而导致数据覆盖、丢失或顺序错乱，尤其在追加模式（O_APPEND）缺失或高并发场景下风险陡增。
因此，*依赖 `os.File` 自身的“看似安全”是危险的反模式。真正健壮的解决方案应遵循 Go 的核心并发哲学：不要通过共享内存来通信，而应通过通信来共享内存（Do not communicate by sharing memory; instead, share memory by communicating）**。
✅ 推荐方案：通道驱动的写入服务（CSP 风格）
我们构建一个专属的“日志写入服务” goroutine，它独占文件句柄，所有写入请求均通过 channel 发送，由该服务串行处理。这种方式天然避免竞态，逻辑清晰，且易于扩展（如添加缓冲、限流、格式化统一等）。
以下是完整可运行示例：
package main
import (
"fmt"
"os"
"sync"
"time"
)
// 定义写入消息结构体
type LogMessage struct {
Content string
Done chan<- error // 可选：支持写入结果回调
}
func main() {
// 创建日志文件（追加模式更安全）
f, err := os.OpenFile("log.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
panic(fmt.Sprintf("failed to open file: %v", err))
}
defer f.Close()
// 创建写入通道（带缓冲提升吞吐，此处设为100）
logChan := make(chan LogMessage, 100)
// 启动写入服务 goroutine
var wg sync.WaitGroup
wg.Add(1)
go func() {
defer wg.Done()
for msg := range logChan {
_, writeErr := fmt.Fprintln(f, msg.Content)
if msg.Done != nil {
msg.Done <- writeErr
}
}
}()
// 模拟10个并发写入者
var writersWg sync.WaitGroup
writersWg.Add(10)
for i := 1; i <= 10; i++ {
go func(id int) {
defer writersWg.Done()
// 每个写入者发送一条消息
done := make(chan error, 1)
logChan <- LogMessage{
Content: fmt.Sprintf("Log from goroutine %d at %s", id, time.Now().Format("15:04:05")),
Done: done,
}
// 可选：等待写入完成（若需强顺序保证或错误处理）
if err := <-done; err != nil {
fmt.Printf("Write failed for %d: %v\n", id, err)
}
}(i)
}
// 等待所有写入者完成
writersWg.Wait()
// 关闭通道，通知服务退出
close(logChan)
// 等待服务 goroutine 结束
wg.Wait()
fmt.Println("All writes completed.")
}? 关键优势与注意事项
- 零竞态保证：文件句柄仅被单一 goroutine 访问，彻底规避并发写入问题。
- 天然顺序性：channel 的 FIFO 特性确保日志按发送顺序落盘（注意：发送顺序 ≠ 启动顺序，但可通过控制发送时机保障逻辑顺序）。
- 解耦与可维护性：写入逻辑与业务逻辑分离；后续可轻松替换为网络日志、带缓冲的批量写入或异步刷盘策略。
- 错误处理明确：通过 Done channel 或返回值集中处理 I/O 错误。
- 性能考量：对于极高吞吐场景，可升级为带缓冲的批量写入（例如收集 N 条后一次性 Write），减少系统调用开销。
⚠️ 重要提醒： 切勿在多个 goroutine 中直接调用 f.Seek() 或修改 *os.File 状态（如 f.Sync()），这会破坏服务模型的隔离性。 若必须支持并发读写，应使用 os.O_RDWR 并严格区分读/写通道，或采用更高级的日志库（如 zap、zerolog）内置的并发安全 writer。 始终使用 defer f.Close() 并在 close(logChan) 后等待服务 goroutine 退出，防止资源泄漏。
这种基于 channel 的服务化设计，正是 Go “用通信共享内存”思想的典型落地——它让并发变得简单、可靠且富有表现力。
