当前位置：首页 > 文章列表 > Golang > Go教程 > Go bufio.Reader.ReadBytes 遇到 EOF 时怎么判断记录是否完整

Go bufio.Reader.ReadBytes 遇到 EOF 时怎么判断记录是否完整

来源：17golang原创 2026-11-10 20:54:16 0浏览收藏

用 bufio.Reader.ReadBytes(delim) 读取文件或长连接时，判断记录是否完整不能只看 err。最可靠的规则是：返回数据以分隔符结尾时，记录完整且 err == nil；返回数据没有分隔符时，io.EOF 表示流结束前留下了一段尾数据，这段数据是否算记录要由业务协议决定；没有数据且收到 io.EOF，才是干净结束。

官方文档：

https://pkg.go.dev/bufio#Reader.ReadBytes

先把 ReadBytes 的返回契约固定下来

ReadBytes 从当前缓冲位置读到第一个分隔字节，并把分隔字节一起放进返回切片。如果在找到分隔字节之前底层读取遇到错误，它仍会返回已经读到的数据和错误。官方契约还给出了一个很实用的判断：只要返回数据没有以分隔字节结尾，err 就不会是 nil。

Go bufio Reader ReadBytes 的输入、分隔符、返回数据和错误关系结构图 — 图1：ReadBytes 返回契约说明图，展示输入流、分隔符、返回数据和 err 的对应关系，不是运行截图。

因此，下面这类代码不能把任何非空数据都直接当成完整记录：

chunk, err := reader.ReadBytes('\n')
// ReadBytes 会把换行一起返回，先判断记录是否真的带有终止符。
complete := len(chunk) > 0 && chunk[len(chunk)-1] == '\n'
if complete && err == nil {
    // 只有到达分隔符且没有错误时，才按完整记录处理。
    consumeRecord(chunk)
}

如果读取的分隔符不是换行，例如协议使用 0x04 作为消息结束字节，完整性判断也必须使用同一个字节，不能把“有数据”误当成“有终止符”。

把 EOF 分成三种输入状态

很多导入 bug 都来自把 io.EOF 直接当成失败。对 ReadBytes 来说，至少要区分下面三种状态。

返回数据	错误	含义	常见处理
以分隔符结尾	`nil`	完整记录	交给记录处理函数
非空且不以分隔符结尾	`io.EOF`	流结束前的尾数据	按协议接受、拒绝或单独标记
空	`io.EOF`	没有剩余数据	正常结束循环

Go ReadBytes 完整记录、尾部 EOF 和非 EOF 错误的状态关系图 — 图2：ReadBytes 的 EOF 状态关系图，帮助区分完整性判断与错误分类，不是运行截图。

非 EOF 错误要单独处理。它可能来自底层文件、连接或自定义 io.Reader，此时返回切片仍可能包含有用的部分数据，但不能因为“有数据”就提交成完整记录。

在循环里保留同一个 Reader

读取连续记录时，应在循环外创建一次 bufio.Reader。Reader 自己维护着缓冲区，反复用新的 Reader 包装同一个底层流，可能丢掉前一个缓冲实例已经预读的数据。

package main

import (
    "bufio"
    "bytes"
    "errors"
    "fmt"
    "io"
)

// readRecords 读取以换行结束的记录，并返回是否发现不完整尾记录。
func readRecords(src io.Reader, acceptTail bool) ([][]byte, bool, error) {
    reader := bufio.NewReader(src)
    var records [][]byte
    var tailIncomplete bool

    for {
        chunk, err := reader.ReadBytes('\n')
        // ReadBytes 返回的数据可能同时包含业务内容和终止字节。
        complete := len(chunk) > 0 && chunk[len(chunk)-1] == '\n'
        if complete {
            // 复制一份，避免把后续处理和底层缓冲生命周期混在一起。
            records = append(records, bytes.TrimSuffix(append([]byte(nil), chunk...), []byte{'\n'}))
        }

        if err == nil {
            // 找到分隔符后继续读取下一条记录。
            continue
        }
        if errors.Is(err, io.EOF) {
            if len(chunk) == 0 {
                // 没有尾数据的 EOF 是正常结束。
                return records, tailIncomplete, nil
            }
            if !complete {
                // 尾数据没有换行，是否接受由调用方的协议策略决定。
                tailIncomplete = true
                if acceptTail {
                    records = append(records, append([]byte(nil), chunk...))
                }
            }
            return records, tailIncomplete, nil
        }
        // 非 EOF 错误不能被吞掉，即使本次返回了部分字节。
        return records, tailIncomplete, fmt.Errorf("读取记录失败: %w", err)
    }
}

这个函数把三个决策分开了：是否有终止符决定记录完整性，io.EOF 决定流是否结束，acceptTail 决定协议是否接受没有换行的最后一段。这样导入任务可以把尾记录单独计数，而不是把它和底层 I/O 失败混为一谈。