Go中批量写入需手动调用Flush()确保数据落盘，因bufio.Writer默认仅在缓冲满或显式调用时刷新；常见场景包括写入完成校验、流式通信及防进程退出丢失；推荐按场景选用固定批次、时间驱动或写后即刷策略。
Go 中批量写入的缓冲刷新策略，核心在于控制 bufio.Writer 的刷新时机，而不是依赖自动 flush —— 它默认只在缓冲区满或显式调用 Flush() 时才真正落盘。
什么时候该手动调用 Flush()
默认情况下，bufio.NewWriter 使用 4KB 缓冲区，写入小数据时可能长期滞留内存，导致日志丢失、下游读取阻塞或测试超时。常见触发场景包括：
- 写入完成后必须确保数据已提交（如写入文件后立即
os.Stat()检查大小） - 向管道或网络连接写入，对方在等完整批次（如 HTTP 响应流、gRPC server streaming）
- 长时间运行的服务中，避免因 panic 或 os.Exit 导致未 flush 数据丢失（
defer w.Flush()不可靠，因为 panic 可能跳过 defer）
Write() 后不 Flush() 的典型错误现象
最常被忽略的问题是：程序看似“写完了”，但目标文件为空或大小远小于预期，cat 或 tail -f 看不到内容。这是因为：
-
bufio.Writer.Write()只是拷贝到内部缓冲区，不触发系统调用 -
os.File.Write()才真正调用 write(2)，而bufio.Writer把它攒着 - 如果程序 exit 前没
Flush()，缓冲区内容直接丢弃（无 panic 保护）
验证方式：在写入后加一行 fmt.Printf("buf size: %d\n", w.Buffered())，常看到非零值。
三种安全的刷新策略及适用条件
没有“通用最优解”，需按场景选：
-
固定大小批次：适合日志、ETL 导出等可预估单条体积的场景。用
bufio.NewWriterSize(f, 64*1024)配合每 N 条后Flush()；注意 N 要结合缓冲区大小估算，避免频繁 flush 影响吞吐 -
时间驱动刷新：适合实时性要求中等的流式写入（如 metrics 上报）。启动 goroutine 每 500ms 调用一次
w.Flush()，但需加锁或用sync.Once防止并发写冲突 -
写入后立即 flush：仅用于调试、单元测试或极低吞吐场景（如配置生成）。虽简单，但会退化为无缓冲写，性能下降 5–10 倍，
WriteString()+Flush()组合务必避免在循环内使用
容易被忽略的底层细节
缓冲刷新不是原子操作，且受操作系统影响：
-
Flush()成功只表示数据已交由内核，不保证磁盘落盘（除非打开os.O_SYNC） - 对同一
os.File多个bufio.Writer并发写会导致数据错乱，必须串行或用独立文件句柄 -
bufio.Writer不支持部分写（partial write），若Flush()返回io.ErrShortWrite，说明底层写入失败，需重试或降级处理
真正稳定的批量写入，往往要组合缓冲、错误重试和写入确认逻辑，不能只靠一个 Flush() 调用兜底。
