Go bufio.Reader.Buffered 怎样判断缓冲区还有多少字节

在 Go 里，如果你想知道 bufio.Reader 当前已经准备好、可以直接读取多少字节，应调用 Buffered()。它返回的是“当前缓冲区可读字节数”，不是底层缓冲区的总容量，也不是文件或网络流还剩多少数据。

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

Buffered() 适合观察读取器当前的缓冲状态；要看缓冲区容量使用 Size()，要判断整个输入是否读完则必须结合实际读取结果和错误处理。

Buffered 和 Size 不是一回事

bufio.Reader.Buffered() 返回当前缓冲区中“可以被直接读取”的字节数。这个数值会随着读取器填充底层数据、消费缓冲内容而变化。Size() 返回的则是底层缓冲区容量，表示这个读取器能够容纳多少字节的缓冲空间。

用 NewReaderSize 构造一个可观察的读取器

下面的示例使用字符串构造底层读取源，再用 NewReaderSize 指定缓冲容量。代码不把 Buffered() 当成总长度，而是把它当作读取器状态的一次观察。

package main

import (
    "bufio"
    "fmt"
    "strings"
)

func main() {
    // 使用固定文本作为底层读取源，便于观察缓冲状态变化。
    source := strings.NewReader("go-buffered")
    reader := bufio.NewReaderSize(source, 8)

    // Size 表示缓冲容量，Buffered 表示当前可以直接读取的字节数。
    fmt.Println("size:", reader.Size())
    fmt.Println("buffered:", reader.Buffered())
}

这里需要注意两点。第一，Size() 是容量指标，不等于输入字符串的长度。第二，Buffered() 是当前状态指标；读取器是否已经向底层读取源填充数据，取决于具体的读取动作和内部实现状态，不能只凭容量猜测。

Read 和 Discard 会改变当前可读字节数

当代码真正从 Reader 读取或丢弃数据时，缓冲区中的可读字节数可能减少。Read 会把数据复制到调用方的切片，Discard 则跳过指定字节；二者都不应被写成“查询剩余总长度”的替代方法。

package main

import (
    "bufio"
    "fmt"
    "strings"
)

func main() {
    // 读取器包装一个固定字符串，示例只关注缓冲状态而不是网络行为。
    reader := bufio.NewReaderSize(strings.NewReader("abcdef"), 4)
    buffer := make([]byte, 2)

    // Read 的返回值 n 表示本次实际读出的字节数，必须优先依据 n 处理数据。
    n, err := reader.Read(buffer)
    fmt.Println("read:", string(buffer[:n]), "err:", err)
    fmt.Println("buffered after read:", reader.Buffered())

    // Discard 只跳过指定字节；同时检查返回的 discarded 和 err，避免静默丢失数据。
    discarded, err := reader.Discard(1)
    fmt.Println("discarded:", discarded, "err:", err)
    fmt.Println("buffered after discard:", reader.Buffered())
}

如果底层输入仍然可以继续读取，缓冲区变少并不等于输入结束；下一次读取可能再次触发底层读取。反过来，Buffered() 变成零也只表示当前缓冲区没有可直接读取的数据，不能单独推出底层读取源已经到达 EOF。

Reset 会清理旧状态并切换读取源

Reset 用于让同一个 Reader 改读新的 io.Reader。调用后，旧的缓冲数据和读取状态会被丢弃，后续的 Buffered() 应当按新的读取源重新理解。这个方法适合复用读取器对象，但不适合在仍需要旧缓冲数据时调用。

package main

import (
    "bufio"
    "fmt"
    "strings"
)

func main() {
    // 先绑定第一份数据，读取器随后会被切换到第二份数据。
    reader := bufio.NewReader(strings.NewReader("first"))
    _, _ = reader.ReadByte()
    beforeReset := reader.Buffered()

    // Reset 会丢弃旧缓冲状态；切换后要把它视为新的读取源。
    reader.Reset(strings.NewReader("second"))
    fmt.Println("before reset:", beforeReset)
    fmt.Println("after reset:", reader.Buffered())
}

不要把 Reset 当成“保留旧数据并追加新数据”。它表达的是读取源切换，旧数据是否已经被消费、是否还需要保存，都应在调用前由业务代码处理。

常见误用与判断边界

Buffered 为零是不是 EOF？

不是。它只说明当前缓冲区没有可直接读取的字节。是否到达 EOF，要看实际读取方法返回的字节数和错误，并按 io.Reader 的约定处理非零字节与错误同时返回的情况。

Buffered 返回值是不是整个文件剩余大小？

不是。它只覆盖当前已经进入 bufio.Reader 缓冲区的部分；底层文件、网络连接或其他读取源可能还有更多数据。

怎样查看缓冲区的容量？

调用 Size()。容量和当前可读字节数是两个不同指标，不要用一个方法的结果替代另一个。

需要保证读取固定长度时只看 Buffered 可以吗？

不可以。Buffered() 只能告诉你当前缓存里有多少字节，不能保证底层输入会提供完整消息。固定长度读取应结合 io.ReadFull 或明确的协议读取逻辑，并检查返回的字节数和错误。

总的来说，Buffered() 是一个读取状态观察工具：它回答“现在缓存里能直接读多少”，Size() 回答“缓存能装多少”，而输入是否结束必须由实际读取结果判断。把这三个问题分开，排查缓冲读取代码时就不容易把容量、当前状态和总剩余量混在一起。