Go io.ReadFull 读不到完整消息时怎么处理 ErrUnexpectedEOF

处理 Go 的固定长度消息时，io.ReadFull 返回 io.ErrUnexpectedEOF 并不表示要继续等待或把已有字节直接交给解析器，而是说明消息已经开始读取，却在规定长度之前结束了。只有一个字节都没有读到时，才可能得到代表正常流结束的 io.EOF；完整读满目标缓冲区时，err 才是 nil。

先区分 EOF 与 ErrUnexpectedEOF

自由长度的流可以把 EOF 当作自然终点，但固定长度消息有更严格的边界。例如一帧声明需要 12 个字节，调用方已经拿到 5 个字节后连接关闭，这 5 个字节不能当作一条可解析消息。标准库把这种“结构化数据读到中途结束”表达为 io.ErrUnexpectedEOF。

当使用`io.ReadFull`读取网络流、文件这类变长数据源时，出现`ErrUnexpectedEOF`属于正常场景，只要返回的已读字节数大于0，先把已读到的合法内容处理完，再根据业务场景选择重试读取剩余字节、返回已读内容、直接上报错误这三种对应方案即可，不需要把这个错误当成必崩的异常直接抛出。

按帧头和帧体读取固定长度消息

实际协议通常先读一个固定大小的帧头，再从帧头得到帧体长度。每一个边界都要单独调用 io.ReadFull，不能把一次普通 Read 返回的字节数误当作完整消息。下面的示例把长度前缀限制在 1 MiB 内，并且在头部或帧体不完整时立即返回。

package frame

import (
    "encoding/binary"
    "fmt"
    "io"
)

const maxPayload = 1  maxPayload {
        return nil, fmt.Errorf("帧体长度 %d 超过上限 %d", size, maxPayload)
    }

    payload := make([]byte, size)
    if _, err := io.ReadFull(r, payload); err != nil {
        // 帧头已完整读取，帧体 EOF 一定意味着当前消息不完整。
        return nil, fmt.Errorf("读取帧体(%d字节): %w", size, err)
    }
    return payload, nil
}

这里没有尝试“用已有部分 payload 继续解析”，因为长度前缀已经承诺了一条完整消息。若协议允许分片，应该在协议层设计分片编号、超时和重组，而不是在 readFrame 内静默吞掉 ErrUnexpectedEOF。

用 errors.Is 分类处理读取错误

读取函数通常会用 fmt.Errorf("...: %w", err) 增加帧头或帧体位置。此时不要比较完整错误字符串，也不要因为错误被包装就丢失分类；用 errors.Is 判断哨兵错误即可。

package frame

import (
    "errors"
    "fmt"
    "io"
)

func consume(r io.Reader) error {
    payload, err := readFrame(r)
    if err == nil {
        fmt.Printf("收到完整帧: %d 字节\n", len(payload))
        return nil
    }

    switch {
    case errors.Is(err, io.EOF):
        // 没有开始下一帧时，调用方可以把它视为连接自然结束。
        return io.EOF
    case errors.Is(err, io.ErrUnexpectedEOF):
        // 当前帧已开始但被截断，重试前要确认连接是否仍可复用。
        return fmt.Errorf("丢弃截断帧: %w", err)
    default:
        // 其他 I/O 错误保留上下文，交给上层记录或触发故障处理。
        return fmt.Errorf("读取帧失败: %w", err)
    }
}

需要注意的是，上面的 consume 把 io.EOF 作为返回值交给循环控制者。服务端是否重连、客户端是否重试、消息是否需要告警，都属于更高层的策略；底层读取函数只负责准确表达边界。

固定长度读取的四个常见坑

1. 把一次 Read 当成完整读取。网络、管道和文件系统都可能短读；需要固定字节数时用 ReadFull 或明确的循环。
2. 忽略 n。ErrUnexpectedEOF 携带了“只读到一部分”的事实，日志或指标可以记录 n 与目标长度，便于定位上游截断。
3. 不限制长度前缀。长度来自对端时，先校验上限再分配缓冲区，避免错误数据造成不必要的内存压力。
4. 无条件重试。连接已关闭时重试只会重复失败；若业务允许重连，应重新建立连接并从协议规定的安全边界开始。

常见问题

io.ReadFull 返回 io.EOF 是不是也代表错误？

它只表示这次固定长度读取一个字节都没拿到。若调用方是在读取“下一条可选消息”，可以把它视为正常结束；若协议明确要求当前消息存在，则应由上层把它升级为协议错误。

为什么不直接判断 err == io.ErrUnexpectedEOF？

因为读取函数可能用 %w 增加上下文。使用 errors.Is(err, io.ErrUnexpectedEOF) 能保留分类判断，同时保留原始错误链。

读到部分 payload 后能不能继续解析？

除非协议明确支持增量解析，否则不能。固定长度消息的字段偏移依赖完整帧，部分数据应先丢弃或缓存到协议层的重组器。