Josson库实战：高效更新JSON数组对象方法
时间：2025-08-24 22:55:07 273浏览 收藏
还在为Java中高效更新JSON数组对象而烦恼吗？本文将带你深入了解如何利用Josson库，告别传统嵌套循环的低效与繁琐。针对需要根据特定键值（如userid和scripcode）将一个JSON数组（websocketjsonArray）的数据更新到另一个JSON数组（http）的场景，Josson提供了强大的查询和连接功能，以简洁的声明式方法实现复杂的数据合并与更新。本文将详细介绍Josson库的集成、数据准备以及关键的左连接操作，通过实例代码展示如何显著提升JSON数据处理的效率和代码可读性，助你轻松应对JSON数据更新的挑战。
1. 问题背景与传统方法的局限性
在数据处理场景中，我们经常会遇到需要同步或合并来自不同数据源的 JSON 数据。例如，给定两个 JSONArray：http 和 websocketjsonArray，它们都包含一系列 JSONObject。我们的目标是，如果 websocketjsonArray 中的某个对象与 http 数组中的某个对象在 userid 和 scripcode 字段上完全匹配，则将 websocketjsonArray 中该对象的特定字段（如 bfqty）的值更新到 http 数组中对应的对象上。
传统的实现方式通常涉及嵌套循环：遍历 websocketjsonArray，在内部循环遍历 http 数组，然后使用 if 条件判断 userid 和 scripcode 是否匹配。一旦匹配成功，就手动从源对象获取值并更新目标对象。这种方法虽然直观，但存在以下局限性：
- 效率低下：对于大型 JSON 数组，嵌套循环的时间复杂度为 O(N*M)，其中 N 和 M 分别是两个数组的长度，这会导致性能瓶颈。
- 代码冗余：手动的数据查找、比较和更新逻辑会使代码变得冗长且难以维护。
- 易出错：在复杂的条件判断和数据类型转换中，容易引入逻辑错误。
2. 引入 Josson 库：高效的 JSON 数据操作利器
为了解决上述问题，我们可以利用 Josson 和 Jossons 库。Josson 是一个强大的 Java JSON 处理器，它提供了一种类似 SQL 的查询语言来操作 JSON 数据，包括数据选择、过滤、转换和连接等。Jossons 则是 Josson 的一个扩展，支持多数据集操作，非常适合我们当前的需求。
2.1 添加 Josson 依赖
在使用 Josson 之前，需要将其添加到项目的 pom.xml（Maven）或 build.gradle（Gradle）文件中。
Maven:
com.github.octomix.josson josson 1.4.1
Gradle:
implementation 'com.github.octomix.josson:josson:1.4.1' // 请使用最新版本
2.2 数据准备与数据集注册
首先，我们需要将原始的 JSON 字符串解析成 Josson 对象，并通过 Jossons 注册为命名数据集。这使得我们可以在查询中通过名称引用它们。
import com.fasterxml.jackson.databind.JsonNode;
import com.octomix.josson.Josson;
import com.octomix.josson.Jossons;
public class JsonArrayUpdater {
public static void main(String[] args) {
try {
// 原始 HTTP 数据
String httpJsonString = "[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":-1500,\"bfrate\":122.35,\"bfamt\":18352.5,\"buyqty\":0,\"sellqty\":0,\"netqty\":0,\"cfqty\":-150,\"cfamt\":18352.5,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":0,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1},{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38026\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":0,\"bfrate\":0,\"bfamt\":0,\"buyqty\":10800,\"sellqty\":15000,\"netqty\":-4200,\"cfqty\":-4200,\"cfamt\":590729.9999999998,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":3400.2888479999992,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":11},{\"userid\":\"CNC01\",\"groupname\":\"abhishek\",\"segment\":\"Cosmic\",\"accountcode\":\"APP\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"40034\",\"securitytype\":\"OPT\",\"strikeprice\":1200,\"opttype\":\"PE\",\"bfqty\":12,\"bfrate\":2,\"bfamt\":0,\"buyqty\":100,\"sellqty\":121,\"netqty\":200,\"cfqty\":11,\"cfamt\":78,\"ltp\":9,\"grossmtm\":0,\"brokerageamt\":12222,\"netmtm\":45,\"currency\":\"INR\",\"usdrate\":2,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":0,\"multiplier\":99}]";
// WebSocket 更新数据
String websocketJsonString = "[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":20,\"bfrate\":122.35,\"bfamt\":18352.5,\"buyqty\":0,\"sellqty\":0,\"netqty\":0,\"cfqty\":-150,\"cfamt\":18352.5,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":0,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1},{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38026\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":30,\"bfrate\":0,\"bfamt\":0,\"buyqty\":10800,\"sellqty\":15000,\"netqty\":-4200,\"cfqty\":-4200,\"cfamt\":590729.9999999998,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":3400.2888479999992,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1}]]";
Jossons jossons = new Jossons();
jossons.putDataset("http", Josson.fromJsonString(httpJsonString));
jossons.putDataset("websocket", Josson.fromJsonString(websocketJsonString));
System.out.println("原始 http 数据:\n" + jossons.getDataset("http").toPrettyString());
System.out.println("原始 websocket 数据:\n" + jossons.getDataset("websocket").toPrettyString());
// ... 后续执行查询
} catch (Exception e) {
e.printStackTrace();
}
}
}2.3 执行数据合并与更新（左连接操作）
Josson 提供了强大的查询语法来实现数据连接和更新。在本例中，我们将使用左连接（<=<）操作符来将 websocket 数据集中的匹配字段更新到 http 数据集中。
核心查询语句是： http{userid,scripcode} <=< websocket->map(userid,scripcode,bfqty){userid,scripcode}
让我们分解这个查询：
- http{userid,scripcode}: 指定左侧数据集为 http，并且定义用于匹配的键是 userid 和 scripcode。
- <=<: 这是 Josson 的左连接操作符，它表示将右侧数据集的匹配项更新到左侧数据集中。如果左侧没有匹配项，则保持不变。
- websocket->map(userid,scripcode,bfqty){userid,scripcode}:
- websocket: 指定右侧数据集为 websocket。
- ->map(userid,scripcode,bfqty): 这是一个映射（map）操作，它从 websocket 数据集中为每个对象选择 userid, scripcode, bfqty 这三个字段。这意味着只有这些字段会被考虑用于更新。
- {userid,scripcode}: 指定右侧数据集用于匹配的键也是 userid 和 scripcode。
当查询执行时，Josson 会根据 userid 和 scripcode 将 http 中的对象与 websocket 中映射后的对象进行匹配。如果找到匹配，websocket 中 map 操作选取的字段（即 bfqty）的值将覆盖 http 中对应对象的 bfqty 值。
完整代码示例：
import com.fasterxml.jackson.databind.JsonNode;
import com.octomix.josson.Josson;
import com.octomix.josson.Jossons;
import org.json.JSONArray; // 引入 org.json.JSONArray 以匹配原始问题中的数据结构
public class JsonArrayUpdateExample {
// 假设这是您的Activity或主类
public static void main(String[] args) {
try {
// 原始 HTTP 数据，使用 org.json.JSONArray 兼容原始问题
JSONArray http = new JSONArray("[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":-1500,\"bfrate\":122.35,\"bfamt\":18352.5,\"buyqty\":0,\"sellqty\":0,\"netqty\":0,\"cfqty\":-150,\"cfamt\":18352.5,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":0,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1},{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38026\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":0,\"bfrate\":0,\"bfamt\":0,\"buyqty\":10800,\"sellqty\":15000,\"netqty\":-4200,\"cfqty\":-4200,\"cfamt\":590729.9999999998,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":3400.2888479999992,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":11},{\"userid\":\"CNC01\",\"groupname\":\"abhishek\",\"segment\":\"Cosmic\",\"accountcode\":\"APP\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"40034\",\"securitytype\":\"OPT\",\"strikeprice\":1200,\"opttype\":\"PE\",\"bfqty\":12,\"bfrate\":2,\"bfamt\":0,\"buyqty\":100,\"sellqty\":121,\"netqty\":200,\"cfqty\":11,\"cfamt\":78,\"ltp\":9,\"grossmtm\":0,\"brokerageamt\":12222,\"netmtm\":45,\"currency\":\"INR\",\"usdrate\":2,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":0,\"multiplier\":99}]");
// WebSocket 更新数据，使用 org.json.JSONArray 兼容原始问题
JSONArray websocketjsonArray = new JSONArray("[{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38021\",\"securitytype\":\"OPT\",\"strikeprice\":17700,\"opttype\":\"PE\",\"bfqty\":20,\"bfrate\":122.35,\"bfamt\":18352.5,\"buyqty\":0,\"sellqty\":0,\"netqty\":0,\"cfqty\":-150,\"cfamt\":18352.5,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":0,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1},{\"userid\":\"CNRM04\",\"groupname\":\"Rohit\",\"segment\":\"CosPROFIN\",\"accountcode\":\"OWN\",\"symbol\":\"NIFTY\",\"exchange\":\"NSEFO\",\"expirydate\":\"03NOV2022\",\"scripcode\":\"38026\",\"securitytype\":\"OPT\",\"strikeprice\":17800,\"opttype\":\"PE\",\"bfqty\":30,\"bfrate\":0,\"bfamt\":0,\"buyqty\":10800,\"sellqty\":15000,\"netqty\":-4200,\"cfqty\":-4200,\"cfamt\":590729.9999999998,\"ltp\":0,\"grossmtm\":0,\"brokerageamt\":3400.2888479999992,\"netmtm\":0,\"currency\":\"INR\",\"usdrate\":1,\"clientsharing\":0,\"broksharing\":0,\"comsharing\":100,\"multiplier\":1}]]");
// 初始化 Jossons 实例
Jossons jossons = new Jossons();
// 将 JSONArray 转换为 Josson 对象并注册为数据集
// 注意：Josson.fromJsonString 接受 JSON 字符串，而不是 org.json.JSONArray 对象
jossons.putDataset("http", Josson.fromJsonString(http.toString()));
jossons.putDataset("websocket", Josson.fromJsonString(websocketjsonArray.toString()));
System.out.println("--- 原始数据 ---");
System.out.println("http:\n" + jossons.getDataset("http").toPrettyString());
System.out.println("websocket:\n" + jossons.getDataset("websocket").toPrettyString());
// 执行左连接更新操作
JsonNode updatedHttpNode = jossons.evaluateQuery(
"http{userid,scripcode} <=< websocket->map(userid,scripcode,bfqty){userid,scripcode}");
System.out.println("\n--- 更新后的数据 ---");
System.out.println(updatedHttpNode.toPrettyString());
} catch (Exception e) {
e.printStackTrace();
}
}
}2.4 预期输出
运行上述代码，您将看到 http 数组中 bfqty 字段的值根据 websocket 数组中的匹配项进行了更新：
[ {
"userid" : "CNRM04",
"groupname" : "Rohit",
"segment" : "CosPROFIN",
"accountcode" : "OWN",
"symbol" : "NIFTY",
"exchange" : "NSEFO",
"expirydate" : "03NOV2022",
"scripcode" : "38021",
"securitytype" : "OPT",
"strikeprice" : 17700,
"opttype" : "PE",
"bfqty" : 20,
"bfrate" : 122.35,
"bfamt" : 18352.5,
"buyqty" : 0,
"sellqty" : 0,
"netqty" : 0,
"cfqty" : -150,
"cfamt" : 18352.5,
"ltp" : 0,
"grossmtm" : 0,
"brokerageamt" : 0,
"netmtm" : 0,
"currency" : "INR",
"usdrate" : 1,
"clientsharing" : 0,
"broksharing" : 0,
"comsharing" : 100,
"multiplier" : 1
}, {
"userid" : "CNRM04",
"groupname" : "Rohit",
"segment" : "CosPROFIN",
"accountcode" : "OWN",
"symbol" : "NIFTY",
"exchange" : "NSEFO",
"expirydate" : "03NOV2022",
"scripcode" : "38026",
"securitytype" : "OPT",
"strikeprice" : 17800,
"opttype" : "PE",
"bfqty" : 30,
"bfrate" : 0,
"bfamt" : 0,
"buyqty" : 10800,
"sellqty" : 15000,
"netqty" : -4200,
"cfqty" : -4200,
"cfamt" : 590729.9999999998,
"ltp" : 0,
"grossmtm" : 0,
"brokerageamt" : 3400.2888479999992,
"netmtm" : 0,
"currency" : "以上就是《Josson库实战：高效更新JSON数组对象方法》的详细内容，更多关于的资料请关注golang学习网公众号！
相关阅读
更多>
-
501 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
501 收藏
最新阅读
更多>
-
208 收藏
-
336 收藏
-
225 收藏
-
181 收藏
-
334 收藏
-
483 收藏
-
253 收藏
-
155 收藏
-
288 收藏
-
182 收藏
-
241 收藏
-
364 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案，代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景，打造一站式知识长龙服务，适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例，全面具体可落地，从理论到实践，一步一步将GO核心编程技术、编程思想、底层实现融会贯通，使学习者贴近时代脉搏，做IT互联网时代的弄潮儿。
- 立即学习 511次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信：Le-studyg；在课程中，我们将首先介绍MySQL8的新特性，包括性能优化、安全增强、新数据类型等，帮助学生快速熟悉MySQL8的最新功能。接着，我们将深入解析MySQL的网络通信机制，包括协议、连接管理、数据传输等，让
- 立即学习 498次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网，分为导航，轮播，关于我们，成功案例，服务流程，团队介绍，数据部分，公司动态，底部信息等内容区块。网站整体采用CSSGrid布局，支持响应式，有流畅过渡和展现动画。
- 立即学习 484次学习