Go io.ReadFull 怎样处理固定长度协议的半包和 EOF

处理固定长度协议时，io.ReadFull 的职责很明确：继续从 io.Reader 读取，直到填满目标缓冲区，或者遇到错误。它解决了网络流一次 Read 只返回半包的问题，但不会替你决定半包是重连、丢弃还是告警。

先把固定帧读满：io.ReadFull 的返回契约

普通的 Reader.Read 允许返回小于目标切片长度的字节数，即使后面仍然有数据。因此，下面这种写法只能表达“本次拿到多少”，不能表达“一个固定帧已经完整到达”。

n, err := r.Read(buf) // 中文说明：一次 Read 可能只拿到半包，不能据此判定帧完成

io.ReadFull(r, buf) 会持续读取，目标是填满 buf。官方契约规定，返回 nil 时 n 必须等于 len(buf)；如果在中途遇到 EOF，则说明固定长度块没有读完。

用 n 和错误类型区分 EOF 与半包

固定帧读取可以封装为一个小函数。这里把长度校验放在分配之前，把错误分类留给调用方；示例只负责读满，不解析帧内字段。

package frame

import (
    "errors" // 中文说明：用 errors.Is 识别被包装过的哨兵错误
    "fmt"
    "io"
)

func readFixedFrame(r io.Reader, size int) ([]byte, error) {
    // 中文说明：长度来自协议配置时先设上限，避免异常输入触发超大分配。
    const maxFrameSize = 64 * 1024
    if size  maxFrameSize {
        return nil, fmt.Errorf("invalid fixed frame size: %d", size)
    }

    buf := make([]byte, size)
    n, err := io.ReadFull(r, buf)
    switch {
    case err == nil:
        // 中文说明：只有填满整个缓冲区，调用方才拿到可解析的完整帧。
        return buf, nil
    case errors.Is(err, io.EOF):
        // 中文说明：一字节都没读到，表示当前帧尚未开始或流已正常结束。
        return nil, io.EOF
    case errors.Is(err, io.ErrUnexpectedEOF):
        // 中文说明：已读到 n 个字节但不足 size，这是固定帧半包而非正常完整帧。
        return nil, fmt.Errorf("truncated fixed frame: %d/%d bytes: %w", n, size, err)
    default:
        // 中文说明：网络断开、超时等底层错误保留原错误，便于上层决定是否重试。
        return nil, fmt.Errorf("read fixed frame: %w", err)
    }
}

判断重点不是“有没有错误”这么简单，而是错误发生在帧边界还是帧内部。io.EOF 表示没有读到新帧的第一个字节；io.ErrUnexpectedEOF 表示已经消耗了部分帧，却没能凑齐固定长度。若 Reader 返回的是超时或连接错误，应保留它，不要统一改成 EOF。

接入协议循环时的边界和资源策略

如果连接上连续承载多个固定长度帧，循环的退出策略应由错误类别驱动。完整帧才进入 decode；遇到 EOF 退出；遇到半包记录上下文并结束这条连接。不要在同一个损坏的流上无条件重试，否则会把已经消费的前半帧和下一次读取混在一起。

for {
    frame, err := readFixedFrame(conn, frameSize)
    if err != nil {
        if errors.Is(err, io.EOF) {
            // 中文说明：没有开始新帧，按正常连接结束处理。
            return nil
        }
        // 中文说明：半包和底层错误都结束当前流，重试策略交给连接管理层。
        return err
    }
    if err := decode(frame); err != nil {
        // 中文说明：只让完整帧进入解析器，字段错误与读取错误分开记录。
        return fmt.Errorf("decode frame: %w", err)
    }
}

生产代码还应限制单帧上限，避免把来自对端的长度直接转换成切片；对长连接设置读取超时，并让连接关闭动作集中在连接管理层。这样，readFixedFrame 只做一件事：返回完整帧或可分类的读取错误。

常见问题

io.ReadFull 会把半包自动补成完整帧吗？

它会继续读取，但前提是 Reader 后续仍能提供字节；如果流在中途结束，仍然返回 io.ErrUnexpectedEOF。

为什么不能把 EOF 和 ErrUnexpectedEOF 当成同一个错误？

前者通常说明新帧尚未开始，后者说明当前帧已经开始但被截断，连接循环和日志策略往往不同。

读取完成后能否复用同一个缓冲区？

可以，但只有在下游同步消费、不会保存切片引用时才安全；异步队列应复制帧内容，避免下一轮读取覆盖数据。