实时统计文件需流式读取+增量更新：小文件用os.ReadFile，大文件或需逐行处理时用bufio.Scanner（默认64KB缓冲，可扩容），二进制或需精细控制时用io.Reader.Read配合固定缓冲区。
实时统计文件内容，不能靠一次性读完再处理——它会卡住、爆内存、失去“实时”意义。核心是用流式读取 + 增量更新，让统计逻辑跑在数据流动的路径上。
用 bufio.Scanner 边读边计数，别用 os.ReadFile
一次性读整个文件看似简单，但遇到几百 MB 的日志或 CSV 就直接 OOM；os.ReadFile 返回 []byte，你得自己切分行、解析结构，还无法控制缓冲区大小。
-
bufio.Scanner默认 64KB 缓冲，自动按行/按分隔符切分，错误时返回具体原因（比如scanner.Err() == bufio.ErrTooLong） - 它不暴露底层
io.Reader，没法做进度回调，但胜在轻量、稳定、适合纯文本流 - 若需自定义分隔符（如 JSON 行、TSV），用
scanner.Split(bufio.ScanLines)或自己实现SplitFunc
大文件或二进制协议里要自己控制 Read 循环，别依赖 for range scanner
当文件不是纯文本、或者你得在读取中途插入校验、解密、限速等逻辑时，bufio.Scanner 就不够用了。必须退到更底层的 io.Reader.Read 接口。
- 用固定大小 buffer（如
buf := make([]byte, 4096)），反复调用file.Read(buf)，每次拿到n字节就喂给统计器 - 注意：最后一次
Read可能返回n > 0 && err == io.EOF，不能只看err判定结束 - 如果原始数据是带帧头的二进制流（如 Kafka 消息体），先用
bytes.NewReader(payload)包一层再交给解析器，别硬塞进Scanner
统计逻辑必须无锁、低开销，否则成为瓶颈
实时场景下，I/O 往往不是瓶颈，反而是你写的 map[string]int 累加或字符串拼接拖慢整条流水线。
立即学习“go语言免费学习笔记（深入）”；
- 高频更新计数器优先用
sync.Map或预分配的数组（如状态码只有 2xx/3xx/4xx/5xx，直接用[5]int） - 避免在循环里做
fmt.Sprintf、strings.ToLower这类分配新字符串的操作；可复用bytes.Buffer或提前建好sync.Pool池 - 如果统计项太多（比如每 URL 一个计数），考虑采样或布隆过滤器预筛，别让 map 查找变成 O(log n)
别忘了上下文控制和背压反馈
真实系统里，没人希望一个统计脚本跑着跑着就吃光内存、卡死磁盘、或把下游 API 打挂。实时 ≠ 不可控。
- 用
context.WithTimeout包裹整个读取流程，防止某一行卡死（比如超长未换行）导致整个任务悬停 - 如果统计结果要发 HTTP 上报，别在读循环里同步发请求；改用带缓冲的 channel 中转，下游 goroutine 控制 QPS 和重试
- 当发现统计 goroutine 消费不过来（channel 满、pool 分配失败、
runtime.ReadMemStats().Mallocs暴涨），该降级就降级——比如跳过解析，只记总字节数
真正难的不是写个能跑的统计器，而是让它的吞吐、延迟、内存占用都可预期。每个 Read 调用、每次 map 写入、每个 goroutine 启动，都在悄悄改变背压传导的方向。盯住 runtime.ReadMemStats 和 pprof 的 goroutine profile，比多写十行业务逻辑更重要。
