当前位置:首页 > 文章列表 > Golang > Go问答 > Go json.Decoder 为什么连续读取时遇到 EOF

Go json.Decoder 为什么连续读取时遇到 EOF

来源:17golang原创 2026-10-25 23:21:55 0浏览 收藏

json.Decoder.Decode每次读取下一个完整JSON值。当输入已结束、只剩空白且没有下一个值时,连续读取循环会收到 io.EOF,通常应正常退出。对象或字符串尚未结束时发生的截断则是错误,不能把所有包含“EOF”的错误文本都当作成功。

官方地址:https://go.dev/

假设导入程序已经读到两条记录,第三次Decode返回EOF。这不一定是第三条记录损坏,也可能是文件本来就只有两条。先定义输入协议,才能决定EOF代表正常结束还是缺少必需数据。

先确定输入是值流还是数组

输入约定读取方式结束判断
连续独立JSON值同一个Decoder反复Decode下次Decode返回io.EOF
一个JSON数组解成切片,或Token配合More逐元素读取数组闭合,并按协议检查尾部
只允许一个JSON值第一次Decode后检查第二次第二次必须返回io.EOF

连续对象之间可以用换行或其他合法空白分隔,换行并不是Decoder的记录边界。带格式缩进的对象跨多行也能是一个值。若协议严格要求一行一条,应额外设计逐行输入规则,而不是假设Decode每调用一次只读一行。

数组本身也是一个JSON值。把整个数组Decode进Entry结构体不会自动变成逐元素读取;需要切片目标,或先消费左方括号,再在当前数组范围用More判断元素,最后消费右方括号。

让同一个Decoder持有读取位置

把解码器建在循环外。它有自己的预读缓冲,可能从底层Reader多读取尚未Decode的数据。每轮重新NewDecoder会丢掉上一实例已缓冲的后续字节,导致底层Reader提前EOF。

输入Reader与Decoder缓冲区静态结构说明图
结构说明图:同一个Decoder持有内部缓冲并关联底层Reader,Decode从其状态读取值;不表示实际运行轨迹。

同理,不要在Decoder使用期间又直接对同一个Reader调用ReadAll或换一个扫描器读取,除非明确处理了已预读内容。需要把解析后的剩余字节交给其他协议时,应考虑Decoder.Buffered与底层Reader的组合,而不是仅查看底层Reader剩余长度。

把正常EOF与解码错误分开

以下完整示例只处理独立对象值流。保存为main.go即可阅读或自行执行:

package main

import (
    "encoding/json"
    "fmt"
    "io"
    "strings"
)

type Entry struct {
    Key string `json:"key"`
    Count int `json:"count"`
}

func consume(r io.Reader) (int, error) {
    dec := json.NewDecoder(r) // 整个值流共用一个解码器,保留内部缓冲。
    total := 0
    for {
        var item Entry // 每轮新建目标,避免缺失字段沿用上条数据。
        err := dec.Decode(&item)
        if err == io.EOF {
            return total, nil // 没有下一个值,是协议允许的正常结束。
        }
        if err != nil {
            return total, fmt.Errorf("第%d条解码失败: %w", total+1, err)
        }
        // 只有Decode成功才处理;失败时不使用可能已部分修改的目标。
        if item.Key == "" || item.Count 
key=alpha count=4
key=beta count=7
处理完成,共2条

上面是代码的预期输出,没有声称已在本机执行。循环先判断直接返回的io.EOF,再处理其他错误,最后才使用item。空输入在这个“允许零条”的协议中返回零条成功;如果业务要求至少一条,应在consume返回后检查数量。

若把第二个对象截断到字段名或冒号附近,预期得到解码错误而不是两条成功。对于io.ErrUnexpectedEOF、语法错误和字段类型不匹配,应保留错误并停止当前导入;不能用strings.Contains(err.Error(), "EOF")模糊匹配。

每轮新建Entry也有意义:JSON对象没有出现的字段不会自动代表上一条记录。重复使用带旧内容的结构体或map,容易把前一条数据误带入后续处理。

只允许一个JSON值时检查尾部

HTTP配置接口或单文件配置往往只允许一个JSON值。第一次Decode成功不代表尾部没有第二个对象,下面函数可放到同一文件并复用Entry及导入:

func decodeOne(r io.Reader) (Entry, error) {
    dec := json.NewDecoder(r)
    var item Entry
    if err := dec.Decode(&item); err != nil {
        return Entry{}, fmt.Errorf("读取首个JSON值: %w", err)
    }
    var extra json.RawMessage
    // 第二次Decode必须是EOF,才能排除额外值或非法尾部内容。
    err := dec.Decode(&extra)
    if err == io.EOF {
        return item, nil
    }
    if err != nil {
        return Entry{}, fmt.Errorf("JSON尾部内容错误: %w", err)
    }
    return Entry{}, fmt.Errorf("只允许一个JSON值")
}
正常结束与额外内容的结果分类结构说明图
结构说明图:结束判断关联io.EOF、解码错误与额外JSON值;单值协议和多值协议采用不同接受条件。

这里用RawMessage接收可能存在的任意额外值。如果第二次成功,即使内容是null,也属于多出的JSON值;如果第二次报语法错误,则尾部不是合法结束。不能把“第二次不是一个对象”误当成“尾部没数据”。

decodeOne只负责结构上的单值约束,字段必填、范围和未知字段策略仍需按业务补充。网络输入还应有大小和时间限制,否则等待尾部结束也可能持续阻塞。

按输入来源安排结束与清理

文件Reader读到末尾才产生EOF;持续连接若没有下一条数据也没有结束信号,Decode可能等待,而不是立即返回EOF。是否结束由底层输入和协议共同决定。不要用忙循环反复重试同一个已经耗尽的Reader。

Decoder接收io.Reader,不接管文件或HTTP响应体的关闭责任。打开文件或成功获得响应后,应由拥有者在合适的函数作用域关闭。若读取已经消费完HTTP Body,再创建Decoder读取同一个Body,首个Decode就可能是EOF;这与原始响应是否为空是两回事。

More可以用来判断顶层值流有没有结束吗?

不要这样替代Decode的错误判断。More描述当前数组或对象是否还有元素,不是通用的输入结束检测接口。

末尾多一个换行为什么仍是EOF?

空白不会产生新的JSON值,前一个值处理完后再次读取,无新值可得就是正常流结束。

EOF后能继续向同一个Decoder追加新文件吗?

不应把耗尽输入当作可自动续接的消息队列。新输入应有明确Reader和协议边界,通常为新来源创建解码器。

连续读取的关键是先固定输入形状,再复用解码器状态,只有成功才处理结果。io.EOF用于正常结束时,不必当作异常;截断与非法内容仍应保留为失败。

官方资料:Decoder说明;io.EOF定义。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go JSON 重复字段为什么得到不同结果Go JSON 重复字段为什么得到不同结果
上一篇
Go JSON 重复字段为什么得到不同结果
Go HTTP 重定向为什么丢失 Authorization
下一篇
Go HTTP 重定向为什么丢失 Authorization
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    693次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    705次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    767次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    731次使用
  • MMBench详解:多模态大模型基准测试、功能特点与使用指南
    MMBench
    MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
    565次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码