Go问答：bufio.Writer.Buffered怎样判断 Flush 前还有多少数据怎样完成一个可复用的最小示例

如果你想知道 bufio.Writer 在调用 Flush 前还积累了多少输出，直接读取 Buffered() 即可。它返回的是当前写入器内部缓冲区中的字节数，不是底层文件的长度，也不代表这些字节已经持久化到磁盘。

实际使用时可以把它当作一个轻量的批量写入信号：写入后检查缓冲量，达到业务阈值就主动刷新；最后无论循环是否提前结束，都要处理最后一次 Flush 的错误。

官方资料：https://pkg.go.dev/bufio#Writer.Buffered

Buffered 到底统计什么

bufio.NewWriter 在目标 io.Writer 前增加了一层内存缓冲。调用 Write 时，数据通常先进入这块缓冲区；当缓冲区装不下时，写入器会把部分或全部数据交给下游，并继续保留剩余数据。

Buffered() 的返回值就是此刻仍留在这层缓冲区中的字节数。它有三个容易混淆的边界：

因此，想判断“这一批数据是否还堆在 bufio 中”，看 Buffered()；想判断“写入目标是否接受了数据”，要处理 Write 或 Flush 返回的错误。

用最小示例看 Flush 前后的变化

下面用 bytes.Buffer 作为下游目标，方便集中观察 bufio 层的变化。示例中每个代码注释都说明关键逻辑，真正写文件或网络时只需替换下游的 io.Writer。

package main

import (
	"bytes"
	"fmt"
	"bufio"
)

func main() {
	var sink bytes.Buffer
	w := bufio.NewWriterSize(&sink, 16)

	// 写入尚未触发自动刷新时，Buffered 返回内部暂存的字节数。
	_, err := w.WriteString("hello")
	if err != nil {
		// 真实文件或网络写入可能失败，不能只看 Buffered 判断成功。
		panic(err)
	}
	fmt.Println("写入后:", w.Buffered())

	// Flush 把暂存数据交给 sink；成功后内部缓冲量通常变为零。
	if err := w.Flush(); err != nil {
		panic(err)
	}
	fmt.Println("Flush 后:", w.Buffered())
	fmt.Println("下游内容:", sink.String())
}

在这个例子里，写入 hello 后缓冲量是 5；调用 Flush 后，bufio 层不再暂存这 5 个字节，而 sink 才能看到内容。这里的“字节数”也解释了为什么中文文本的数量通常大于字符数：UTF-8 一个汉字可能占用多个字节。

按阈值批量刷新

批量生成日志、导出文本或拼接协议数据时，不必每写一小段就刷新。可以设置一个业务阈值，让 Buffered() 达到阈值后再把数据交给下游，同时在函数退出前补一次 Flush。

package main

import (
	"bufio"
	"bytes"
	"fmt"
)

func writeLines(lines []string) ([]byte, error) {
	var sink bytes.Buffer
	w := bufio.NewWriterSize(&sink, 32)

	for _, line := range lines {
		// 每行都带换行，Buffered 统计的是编码后的字节，不是行数。
		if _, err := w.WriteString(line + "\n"); err != nil {
			return nil, fmt.Errorf("写入行失败: %w", err)
		}
		// 阈值只控制刷新时机，不能替代最后一次 Flush。
		if w.Buffered() >= 24 {
			if err := w.Flush(); err != nil {
				return nil, fmt.Errorf("批量刷新失败: %w", err)
			}
		}
	}

	// 循环结束仍可能有不足阈值的尾部数据，必须再次刷新。
	if err := w.Flush(); err != nil {
		return nil, fmt.Errorf("刷新尾部数据失败: %w", err)
	}
	return sink.Bytes(), nil
}

func main() {
	data, err := writeLines([]string{"alpha", "beta", "gamma"})
	if err != nil {
		panic(err)
	}
	fmt.Printf("输出 %d 字节\n%s", len(data), data)
}

阈值是应用层取舍，不是 bufio.Writer 的固定规则。阈值太小会增加下游写入次数，太大则可能让单次任务占用更多内存；可以结合单条记录大小和下游吞吐量调整。

为什么 Buffered 的数字会突然变小

写入触发了自动刷新

当一次写入让内部缓冲区装不下时，bufio.Writer 会先把已有数据写给下游，所以写入结束后再次读取 Buffered()，数值可能比刚写入的字节数小，甚至为零。这是正常的自动刷新，不代表数据丢失。

你统计的是字节，不是字符

字符串的长度、记录数和 Buffered() 不一定相等。比如中文、emoji 和带转义的文本都会让“可见字符数”与 UTF-8 字节数出现差异。需要统一口径时，使用 []byte 长度或直接以 Buffered() 的字节数作为阈值。

Flush 成功不等于持久化

Flush 的职责是把 bufio 层的数据写到下游 io.Writer。如果下游是文件，它通常还不等价于操作系统已经完成稳定存储；如果下游是网络，也不等于对端已经处理。文章只讨论缓冲层的暂存量，持久化和协议确认应由对应下游 API 负责。

实际排查时记住这四点

1. 用 Buffered() 看内部未下发字节数，用 Size() 看容量。
2. 每次 Write 和 Flush 都保留错误处理，不能只依据计数。
3. 阈值刷新后仍要在循环结束时 Flush，避免尾部数据留在内存中。
4. 不要把 Buffered 当成文件大小、字符数、已落盘字节数或对端确认数。

相关问题

Buffered 返回 0 是不是说明没有写入成功？

不一定。它可能表示数据刚刚自动刷新或显式 Flush 到了下游；应结合 Write、Flush 的错误以及下游对象的语义判断。

应该使用 Buffered 还是 Size 设置批量阈值？

阈值判断使用 Buffered，容量观察使用 Size。通常让业务阈值小于容量，给一次写入留下余量。

函数返回前忘记 Flush 会怎样？

尚在 bufio 内部的数据可能不会到达下游。把 Flush 放在明确的收尾路径，并处理它的返回错误。

总结：bufio.Writer.Buffered() 适合回答“当前还有多少字节暂存在缓冲层”。围绕这个定义安排阈值刷新，并把最后一次 Flush 的错误纳入控制流，就能写出可复用且不丢尾部数据的批量输出代码。