Go encoding/csv ReuseRecord 的低分配读取方式

Go 的 csv.Reader.ReuseRecord = true 允许连续的 Read 复用上一条记录的 []string 底层数组。适合读完一条就完成转换、统计或同步写出的场景；如果要缓存整行、发送给异步消费者，必须先取得独立切片。它减少的是记录切片的分配机会，不能理解为 CSV 解析零分配，也不承诺固定提速比例。

官方地址：https://pkg.go.dev/encoding/csv

界定复用对象与生命周期

可以把 Reader 的返回值拆成三层：调用方持有的切片描述、切片引用的底层数组、数组元素保存的字符串值。启用复用后，两次返回的切片可能指向同一数组；下一次 Read 会改变数组中的字符串元素。只写 saved := record 复制的是切片描述，没有创建独立字段槽位。

这与修改字符串内容不同。单独保存 name := record[0] 得到的字符串值不会因为下一条记录被读取而变成另一个名称。风险集中在保留整条 []string 所引用的可变槽位。不要依赖某一次恰好没有发生覆盖：容量不足时可能重新分配，但 API 并不保证每条都如此。

同步消费一条记录

下面的函数面向没有表头、固定两列的输入，例如商品标识与整数数量。先处理 EOF 和解析错误，再使用字段；业务转换也在当前循环内结束。示例展示读取方式，没有提供实测性能数据，生产业务还应按数量范围补充累计溢出等规则。

package csvstream

import (
    "encoding/csv"
    "fmt"
    "io"
    "strconv"
)

// SumUnits 同步处理无表头的两列 CSV：商品标识、数量。
// 输入流由调用方持有；此函数不关闭调用方传入的资源。
func SumUnits(src io.Reader) (int64, error) {
    r := csv.NewReader(src)
    r.FieldsPerRecord = 2
    r.ReuseRecord = true
    var total int64
    for {
        record, err := r.Read()
        if err == io.EOF {
            return total, nil
        }
        if err != nil {
            // 即使返回了部分字段，也不让错误行进入累计结果。
            return 0, fmt.Errorf("读取 CSV: %w", err)
        }
        units, err := strconv.ParseInt(record[1], 10, 64)
        if err != nil {
            return 0, fmt.Errorf("商品 %q 的数量无效: %w", record[0], err)
        }
        // 当前记录的使用在下一次 Read 之前结束，不保存 record 切片。
        total += units
    }
}

FieldsPerRecord = 2 让列数假设显式化。默认的零值会根据首条记录确定后续列数；设为负数才是不检查列数。存在表头时应单独读取并完成表头检查，不要让表头进入数量转换。Read 遇到列数不符可能同时返回记录与错误，解析错误也可能给出部分记录；此例选择整条失败，避免误把不完整字段当成有效业务数据。

保留记录时复制切片

如果下一次 Read 之后还需要整行，复制字段槽位即可。下面是嵌入读取循环的片段，前提是已经处理当前 Read 的错误。

// rows 是循环外声明的 [][]string；为当前行创建独立字段槽位。
snapshot := append([]string(nil), record...)
rows = append(rows, snapshot)
// 不要直接 rows = append(rows, record)，否则可能保留共享数组。

这里复制字符串值，不需要为了防止后续 Read 而逐字段复制字符串字节。若每行都完整复制并长期保留，记录切片的分配收益往往会被抵消；这时关闭 ReuseRecord 通常更容易维护。开启复用更适合只保留少量命中行，或者只输出聚合结果的读取器。

异步交接与字段保留

把 record 直接发送到 channel 不会复制底层数组。即使通道没有缓冲，发送成功也只代表接收发生，不代表接收方已经处理完整行；读取方继续 Read 仍可能与消费重叠。简单可靠的交接方式是在发送前复制当前行，再让消费者拥有这个快照，并且不并发操作同一个 Reader。

// 在已经处理读取错误的循环里，复制后交给异步消费者。
// ctx 和 jobs 由调用方管理；取消时退出，避免发送永久阻塞。
snapshot := append([]string(nil), record...)
select {
case jobs 

此片段适用于返回 error 的读取函数，需导入并接收相应的 context 与通道参数。对只保留少数列的业务，可以把字段解析成业务结构体，避免保留整行切片。当前实现会把一条记录的字段构造成同一字符串的子串，因此保留一个很短字段也可能延长整条记录字符串的存活；当超大行中只长期保存极少文字时，可以按实际内存需求考虑 strings.Clone。这属于保留内存的取舍，与修复切片覆盖是两个问题。

选择配置并衡量收益

比较性能时应使用相同 CSV 数据、相同列数规则和相同业务处理，关注每次操作的分配次数、分配字节及耗时，同时区分“逐条消费”与“全部保留”。不需要把一次程序运行变成图片证据，也不能用没有测量过的数字承诺收益。Reader 内部缓冲与字段字符串仍可能分配，ReuseRecord 只针对其中一部分。

为什么保存的前一行变成了后一行？

首先检查是否保存了原始 record 切片，以及是否在消费者使用它期间再次 Read。复制切片描述、包进结构体或放入 channel，都不能自动解除数组共享。

只保存 record[0] 也需要复制整行吗？

不需要为防止切片覆盖而复制整行；保留字符串值即可。若需要释放超大记录的其他字符串存储，再单独评估克隆字段字节。

ReadAll 能把整个文件变成低内存读取吗？

不能。ReadAll 的目标是返回全部记录，它仍会把整个结果保留在内存；希望内存随处理窗口而非文件大小增长，应使用 Read 循环并限制业务缓存。

技术资料：Go encoding/csv 文档；Reader 官方实现。