使用Gson解析NDJSON文件中的多个JSON记录

使用gson解析ndjson文件中的多个json记录

本文详细介绍了如何在Java中利用Gson库解析NDJSON(换行符分隔的JSON)文件,以读取并映射文件中的所有独立JSON记录到对应的DTO对象列表中。针对一次性只能读取一个记录的问题,文章提出了基于JsonReader的循环读取策略,并强调了reader.peek()方法在判断文件末尾时的关键作用,同时提供了完整的示例代码和重要注意事项。

理解NDJSON格式与Gson的初始挑战

NDJSON(Newline Delimited JSON)是一种特殊的数据格式,其中每行都是一个独立的、有效的JSON对象,各行之间通过换行符分隔。与传统的JSON数组不同,NDJSON文件本身并非一个单一的JSON数组,而是多个JSON对象的集合。

当尝试使用Gson库解析NDJSON文件时,常见的初学者误区是直接调用gson.fromJson(reader, YourDTO.class)。例如,对于一个包含多条客户记录的customer.json文件:

// Record # 1{ "profile":{      "salutation":"Mr",      "title":null,      "company":null   },   "phone":{      "home_phone":null   },   "addresses":[      {         "address_id":"1",         "first_name":"Veronica"      }   ],   "orders":{      "placed_orders_count":2   }}// Record # 2{    "profile":{      "salutation":null,      "title":null   },   "phone":{      "home_phone":null   },   "addresses":[      {         "address_id":"2",         "title":""      }   ],   "orders":{      "placed_orders_count":0   }}// ... 更多记录

如果使用以下代码尝试读取:

import com.google.gson.Gson;import com.google.gson.stream.JsonReader;import java.io.FileReader;import java.io.IOException;// 假设 CustomerFeedDTO 已经定义// ...public class InitialNdjsonReaderExample {    public static void main(String[] args) {        Gson gson = new Gson();        try (JsonReader reader = new JsonReader(new FileReader("customer.json"))) {            // 这种方式只能读取第一个JSON对象            CustomerFeedDTO customerFeedDTO = gson.fromJson(reader, CustomerFeedDTO.class);            System.out.println("成功读取第一个记录: " + customerFeedDTO);            // 后续的记录将无法读取到,因为fromJson方法在读取完一个完整的JSON对象后就会停止。        } catch (IOException e) {            e.printStackTrace();        }    }}

这段代码只会成功解析文件中的第一个JSON对象,因为gson.fromJson()方法在读取完一个完整的JSON对象后就会停止。为了读取所有记录,我们需要一种机制来逐个处理文件中的每个JSON对象。

解决方案:循环读取与JsonReader

要正确解析NDJSON文件中的所有记录,核心思想是利用JsonReader的流式读取特性,通过循环逐个解析JSON对象。

aspx1财付通支付接口源码 aspx1财付通支付接口源码

本支付接口的特点,主要是用xml文件来记录订单详情和支付详情。代码比较简单,只要将里面的商户号、商户key换成你自己的,将回调url换成你的网站,就可以使用了。通过这个实例也可以很好的了解一般在线支付接口的基本工作原理。其中的pay.config文件记录的是支付详情,order.config是订单详情

aspx1财付通支付接口源码 0 查看详情 aspx1财付通支付接口源码

以下是实现这一目标的详细步骤和示例代码:

初始化JsonReader和Gson: 创建Gson实例和指向NDJSON文件的JsonReader。设置宽松模式: 调用reader.setLenient(true)。这在处理一些非严格符合JSON规范的输入时非常有用,例如可能存在注释或未引用的字段名等。对于NDJSON文件,虽然通常是严格的,但开启此模式可以增加兼容性。循环读取: 使用while (reader.peek() != JsonToken.END_DOCUMENT)作为循环条件。reader.peek()方法用于查看下一个令牌的类型,而不会实际消耗它。JsonToken.END_DOCUMENT表示已经到达JSON文档的末尾。通过检查这个令牌,我们可以确保在文件完全读取完毕后安全地退出循环。解析并添加: 在循环内部,每次迭代都调用gson.fromJson(reader, CustomerFeedDTO.class)来解析当前行的JSON对象,并将其添加到预先创建的List中。

import com.google.gson.Gson;import com.google.gson.stream.JsonReader;import com.google.gson.stream.JsonToken; // 导入 JsonTokenimport java.io.FileReader;import java.io.IOException;import java.util.ArrayList;import java.util.List;import java.util.Map;// CustomerFeedDTO 类定义 (详见下一节)class CustomerFeedDTO {    private Map profile;    private Map phone;    private ArrayList addresses;    private Map orders;    private ArrayList customs;    // Getters and setters (省略具体实现,但实际应用中需要)    public Map getProfile() { return profile; }    public void setProfile(Map profile) { this.profile = profile; }    public Map getPhone() { return phone; }    public void setPhone(Map phone) { this.phone = phone; }    public ArrayList getAddresses() { return addresses; }    public void setAddresses(ArrayList addresses) { this.addresses = addresses; }    public Map getOrders() { return orders; }    public void setOrders(Map orders) { this.orders = orders; }    public ArrayList getCustoms() { return customs; }    public void setCustoms(ArrayList customs) { this.customs = customs; }    @Override    public String toString() {        return "CustomerFeedDTO{" +               "profile=" + profile +               ", phone=" + phone +               ", addresses=" + addresses +               ", orders=" + orders +               ", customs=" + customs +               '}';    }}public class NdjsonMultiRecordReader {    public static void main(String[] args) {        List customerFeedDTOs = new ArrayList();        Gson gson = new Gson();        // 使用 try-with-resources 确保资源自动关闭        try (JsonReader reader = new JsonReader(new FileReader("customer.json"))) {            // 启用宽松模式,以处理可能存在的非严格JSON格式            reader.setLenient(true);            // 循环读取直到文档结束            while (reader.peek() != JsonToken.END_DOCUMENT) {                CustomerFeedDTO customerFeedDTO = gson.fromJson(reader, CustomerFeedDTO.class);                customerFeedDTOs.add(customerFeedDTO);                System.out.println("成功读取记录: " + customerFeedDTO); // 打印每条记录以验证            }            System.out.println("n所有记录读取完毕。总计 " + customerFeedDTOs.size() + " 条记录。");        } catch (IOException e) {            System.err.println("读取文件时发生错误: " + e.getMessage());            e.printStackTrace();        }    }}

DTO类定义

为了成功映射NDJSON数据,需要一个对应的Java数据传输对象(DTO)类。根据提供的NDJSON结构,一个示例的CustomerFeedDTO可以定义如下:

import java.util.ArrayList;import java.util.Map;public class CustomerFeedDTO {    // 使用Map来灵活处理内部结构不固定的JSON对象    private Map profile;    private Map phone;    // 使用ArrayList来处理JSON数组    private ArrayList addresses;    private Map orders;    private ArrayList customs;    // 构造函数 (可选)    public CustomerFeedDTO() {}    // Getters and Setters (必须提供,Gson通过反射调用它们进行数据绑定)    public Map getProfile() {        return profile;    }    public void setProfile(Map profile) {        this.profile = profile;    }    public Map getPhone() {        return phone;    }    public void setPhone(Map phone) {        this.phone = phone;    }    public ArrayList getAddresses() {        return addresses;    }    public void setAddresses(ArrayList addresses) {        this.addresses = addresses;    }    public Map getOrders() {        return orders;    }    public void setOrders(Map orders) {        this.orders = orders;    }    public ArrayList getCustoms() {        return customs;    }    public void setCustoms(ArrayList customs) {        this.customs = customs;    }    @Override    public String toString() {        return "CustomerFeedDTO{" +               "profile=" + profile +               ", phone=" + phone +               ", addresses=" + addresses +               ", orders=" + orders +               ", customs=" + customs +               '}';    }}

注意: 实际应用中,Map 和 ArrayList 可以被更具体的DTO类或泛型类型替换,以实现更强类型的数据访问和更清晰的代码结构。例如,profile可以是一个ProfileDTO对象,addresses可以是一个List,这样可以更好地封装数据并提供类型安全。

注意事项

reader.setLenient(true)的重要性:此方法允许JsonReader在解析JSON时更加宽容,例如接受未引用的名称、单引号字符串、C风格注释等。虽然NDJSON规范通常要求严格的JSON,但实际文件中可能存在一些不规范的格式。开启此模式可以提高解析的健壮性。

reader.peek()与reader.hasNext()的比较:JsonReader确实有一个hasNext()方法,但它在到达文档末尾时可能会抛出IllegalStateException。相比之下,reader.peek() != JsonToken.END_DOCUMENT是一种更安全、更推荐的判断文件末尾的方式,它通过检查下一个令牌类型来避免异常。

资源管理:try-with-resources:在处理文件I/O时,确保FileReader和JsonReader等资源被正确关闭至关重要,以防止资源泄露。Java 7及更高版本提供的try-with-resources语句是管理这些可关闭资源的最佳实践,它能确保在try块结束时(无论正常结束还是异常结束)自动关闭资源。

异常处理:文件读取和JSON解析过程中可能会出现IOException或JsonSyntaxException等异常。在生产代码中,应提供健壮的异常处理机制,例如记录错误日志、向用户提供友好的错误信息或采取恢复措施。

以上就是使用Gson解析NDJSON文件中的多个JSON记录的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1099747.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
Flex布局如何将最后一个子元素置顶显示?
上一篇 2025年12月2日 16:47:00
如何改进正则表达式才能精准分割省市县与更详细的地址?
下一篇 2025年12月2日 16:47:10

相关推荐

  • 随便记录下系列 – node->express

    系列记录 – node.js到express的一站式指南 一、在Windows上安装Node.js环境:从官方网站下载Node.js,需替换下载链接 https://nodejs.org/dist/v6.2.0/node-v6.2.0-x64.msi 中的版本号6.2.0为所需版本即可。…

    2026年8月25日
    400
  • 华硕TUF GAMING A17对决宏碁暗影骑士·龙:AMD Advantage游戏本的性能与续航,3A平台加持下表现如何?

    华硕TUF GAMING A17在做工、散热和稳定性上优于宏碁暗影骑士·龙,搭载AMD锐龙处理器与RTX 30/40系显卡,性能强劲且通过军规测试,续航达6-8小时,接口丰富但无SD卡槽;暗影骑士·龙配置相似,性价比高但机身刚性稍弱,适合预算敏感用户。 当考虑购买一款主打性价比和稳定性能的游戏本时,…

    2026年8月25日
    000
  • 硬件监控软件横评:HWiNFO64、AIDA64、CPU-Z 功能对比

    CPU-Z适合快速查看硬件配置,AIDA64提供全面信息与压力测试,HWiNFO64则以深度传感器数据成为专业监控首选,三者各有侧重,按需选用。 说到看电脑硬件信息和监控状态,HWiNFO64、AIDA64和CPU-Z是很多人会用的工具。它们都能告诉你电脑里有什么,但侧重点和功能深度差别不小。简单说…

    2026年8月25日
    100
  • Java中IoC是什么概念 图解控制反转和依赖注入的实现原理

    Java中IoC是什么概念 图解控制反转和依赖注入的实现原理Java中IoC是什么概念 图解控制反转和依赖注入的实现原理Java中IoC是什么概念 图解控制反转和依赖注入的实现原理Java中IoC是什么概念 图解控制反转和依赖注入的实现原理

    ioc反转的是对象的控制权。传统开发中对象自己管理依赖,而ioc将对象创建和依赖管理交给外部容器,从而实现控制权的反转。ioc是一种设计原则,di是其具体实现方式,通过构造器、setter或接口注入依赖。java中依赖注入主要有三种方式:1.构造器注入,通过构造函数传递依赖,优点是依赖明确且不可变;…

    2026年8月25日 用户投稿
    000
  • java中的field有什么用 字段field的3个访问控制技巧

    java中的field有什么用 字段field的3个访问控制技巧java中的field有什么用 字段field的3个访问控制技巧java中的field有什么用 字段field的3个访问控制技巧java中的field有什么用 字段field的3个访问控制技巧

    java中的field主要用于反射,允许运行时检查和修改类的字段,包括私有字段。具体步骤如下:1. 获取class对象后,使用getfield()或getdeclaredfield()获取field对象,前者用于获取public字段(包括继承的),后者用于获取本类声明的所有字段;2. 使用setac…

    2026年8月25日 用户投稿
    000
  • 云原生(Kubernetes)适配进展

    kubernetes的适配进展主要体现在:1) 生态系统的扩展,涌现了如istio和linkerd等工具;2) 与云服务的集成,如gke和eks的托管服务;3) 对新兴技术的支持,如knative的无服务器平台。尽管面临复杂性和安全性挑战,kubernetes仍是云原生技术的领导者。 云原生(Kub…

    2026年8月25日
    000
  • Java中如何包装异常传递给上层方法

    使用异常链包装并传递异常时,需将原始异常作为新异常的cause参数传入,例如捕获IOException后抛出包含该异常的ServiceException。自定义异常类应提供接收Throwable的构造函数以支持异常链,确保堆栈信息完整。此策略适用于将技术异常转换为业务异常、隐藏底层细节及添加上下文信…

    2026年8月25日
    000
  • Java中锁的分类有哪些 详解Java中的各种锁机制

    Java中锁的分类有哪些 详解Java中的各种锁机制Java中锁的分类有哪些 详解Java中的各种锁机制Java中锁的分类有哪些 详解Java中的各种锁机制Java中锁的分类有哪些 详解Java中的各种锁机制

    java中的锁主要分为悲观锁与乐观锁、公平锁与非公平锁、可重入锁与不可重入锁、独占锁与共享锁等类型。1.悲观锁如synchronized和reentrantlock适用于写多场景,每次操作都加锁保证数据一致性;2.乐观锁通过版本号或cas实现,适用于读多写少的场景,提高吞吐量;3.公平锁按申请顺序获…

    2026年8月25日 用户投稿
    100
  • ActiveRecord基础:定义模型与CRUD操作

    在ruby on rails开发中,如何使用activerecord定义模型及进行crud操作?首先,定义模型:1.创建post模型,继承自applicationrecord,并添加验证逻辑。其次,进行crud操作:2.创建:使用new和save方法;3.读取:使用all或find方法;4.更新:修…

    2026年8月25日
    000
  • 如何在Laravel应用中快速集成用户消息系统?使用cmgmyr/messenger轻松实现!

    可以通过一下地址学习composer:学习地址 告别从零开始的痛苦:Laravel 消息系统开发的挑战 想象一下,你正在开发一个社交平台或一个团队协作工具,用户之间需要进行私聊、群聊,甚至多方会话。如果你决定从头开始构建这个消息系统,你很快就会发现这远比想象中复杂: 数据库设计: 如何存储会话(Th…

    用户投稿 2026年8月25日
    000
  • 抖音小程序是用什么语音做的

    抖音小程序由字节跳动自主研发,基于其自有的“字节跳动小程序”技术框架构建。该框架在设计上借鉴了微信小程序的开发模式,同时融合了平台自身的特点与需求。开发者可通过 JavaScript、HTML 和 CSS 完成前端界面与逻辑开发,后端则可灵活选用多种服务端语言和技术进行对接。 抖音小程序的技术架构解…

    2026年8月25日
    000
  • 如何解决JWT等安全令牌的复杂性和安全隐患,使用PASETO构建更安全的平台无关安全令牌

    可以通过一下地址学习composer:学习地址 在当今高度互联的数字世界里,无论是用户登录、api访问还是微服务间的通信,安全令牌都扮演着至关重要的角色。其中,json web tokens (jwt) 因其无状态、可扩展的特性,被广泛应用于各种场景。然而,随着我深入开发和维护多个项目,我开始对jw…

    用户投稿 2026年8月25日
    000
  • 空中版高德地图“空中高德”发布,低空飞行器也能用导航

    感谢网友 sp_ce 提供的线索! 7 月 30 日讯,由龙岗区人民政府携手高德软件有限公司共同主办的“空中高德・龙岗启航”—— 深圳市龙岗区空中高德时空底座发布会今日在香港中文大学(深圳)隆重召开。标志着覆盖全业务场景的低空经济示范项目——“空中高德”在龙岗正式落地启动。 据高德地图官方消息,作为…

    2026年8月25日
    000
  • Java中Feign的用法 详解声明式调用

    Java中Feign的用法 详解声明式调用Java中Feign的用法 详解声明式调用Java中Feign的用法 详解声明式调用Java中Feign的用法 详解声明式调用

    feign 是一个声明式的 web 服务客户端,它允许开发者像调用本地方法一样调用远程服务。1. feign 的核心优势在于声明式调用,通过定义接口并使用注解即可自动生成实现类;2. 使用 feign 需要添加依赖、启用 feign 客户端并注入 feign 接口;3. 常用注解包括 @feignc…

    2026年8月25日 用户投稿
    000
  • ai绘画免费图生图在线生成

    免费在线AI绘画图生图工具推荐: whee:www.whee.com boardmixAI:boardmix.cn boardmix AI整合了丰富多样的AI智能体,涵盖办公效率提升、数据分析报告、文案创作、AI绘图、虚拟角色互动等多个应用场景。每个智能体都具备专业化、垂直化的功能,能够自动执行特定…

    2026年8月25日
    000
  • 多进程数据共享与锁机制(避免竞争)

    多进程数据共享和避免竞争条件可以通过锁机制实现。1) 使用锁确保在某个时刻只有一个进程可以访问共享数据,避免竞争条件。2) 锁机制虽然有效,但过度使用可能导致性能瓶颈,需考虑更细粒度的锁或无锁数据结构。 在编程的世界里,处理多进程数据共享和避免竞争条件是一个既让人兴奋又充满挑战的领域。我们经常需要在…

    2026年8月25日
    000
  • Step-R1-V-Mini— 阶跃星辰最新推出的多模态推理模型

    step-r1-v-mini:一款强大的多模态推理模型 Step-R1-V-Mini是阶跃星辰最新发布的多模态大型语言模型,它支持图像和文本输入,并以文本形式输出推理结果。该模型在指令遵循和通用能力方面表现出色,尤其在视觉推理领域处于领先地位,同时在数学、代码和文本推理方面也名列前茅。其核心技术在于…

    2026年8月25日
    000
  • LaravelEloquentORM扩展:使用sofa/eloquence-base解决复杂数据处理难题

    在 Laravel 项目开发中,我们经常需要对 Eloquent 模型进行扩展,以实现诸如灵活搜索、属性映射、元数据管理等功能。如果手动实现这些功能,不仅代码量大,而且容易出错。幸运的是, sofa/eloquence-base 库提供了一系列强大的 Eloquent ORM 扩展,可以帮助我们轻松…

    用户投稿 2026年8月25日
    000
  • ThinkPHP应用性能瓶颈分析与定位

    性能瓶颈是导致thinkphp应用性能下降的关键点。定位这些瓶颈的方法包括:1.使用xdebug进行性能分析;2.优化数据库查询,使用explain语句分析执行计划;3.优化模板渲染,减少逻辑处理或使用静态化技术;4.应用缓存机制,使用redis或memcached缓存查询结果。 在探索ThinkP…

    2026年8月25日
    000
  • Java中断点的作用 解析调试技巧

    Java中断点的作用 解析调试技巧Java中断点的作用 解析调试技巧Java中断点的作用 解析调试技巧Java中断点的作用 解析调试技巧

    java中断点的作用是暂停程序执行以便调试。它允许检查变量值、单步执行代码,并理解程序运行流程。设置方法:在ide中点击代码行左侧即可添加中断点。管理方法包括启用/禁用单个或全部中断点。高级用法有:1.条件中断点,满足特定条件时暂停程序;2.异常中断点,抛出指定异常时暂停。高效调试技巧包括合理设置中…

    2026年8月25日 用户投稿
    000

发表回复

登录后才能评论
关注微信