189 8069 5689
众所周知，kafka中存储的数据是经过BASE64加密后的jsonObject，因此从kafka中读取的数据经过base64解码，得到的是json串，利用JSONObect的方法可以对json串进行解析，拿到对应的数据。那么要如何将scala对象或者java对象转换为JsonObject对象或JSONObject对象呢？（注意：JsonObject对象和JSONObject对象不同，调用的API也不一样）
网站建设哪家好，找创新互联建站！专注于网页设计、网站建设、微信开发、小程序定制开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了霞山免费建站欢迎大家使用！
三种转换方式依赖的包源码都是用JAVA编写，所以构建Map对象时完全使用java对象，不会发生错误。构建过程如下：
三种将java对象转换为jsonObject对象的开源包有：
1、google提供的Genson是一个完全的Java和JSON转换的类库，提供了全面的数据绑定、流操作等。基于Apache 2.0协议发布。转换结果为
JsonObject对象。
使用需要先导入Jar包：import com.google.gson.{Gson, JsonParser}
引入依赖：这里选用版本为：2.2.4，具体版本可以根据业务需求选择。
dependency
groupIdcom.google.code.gson/groupId
artifactIdgson/artifactId
version2.2.4/version
/dependency
2、Fastjson 是一个 Java 库，可以将 Java 对象转换为 JSON 格式，当然它也可以将 JSON 字符串转换为 Java 对象。
导入jar包：import com.alibaba.fastjson.JSON
引入依赖：
dependency
groupIdcom.alibaba/groupId
artifactIdfastjson/artifactId
version1.2.8/version
/dependency
3、net.sf.json-lib方式
导入jar包：import net.sf.json.JSONObject
引入依赖：
dependency
groupIdnet.sf.json-lib/groupId
artifactIdjson-lib-ext-spring/artifactId
version1.0.2/version
/dependency
Google Gson来构造的JSON字符串里面，保留了传递参数key/value的顺序；
FastJson没有保留顺序（这个是符合JSON国际标准的，本身没有错误。是SugarCRM REST API有bug，要求传递过来的参数是按照它的顺序要求的）。
Google Gson代码片段：
import com.google.gson.Gson;
...
LinkedHashMap map = new LinkedHashMap();
map.put(f1,xxx);
map.put(f2,xxxx);
map.put(f3,xxxxx);
Gson gson = new Gson();
String json = gson.toJson(map);,,
Alibaba FastJson代码片段：
import com.alibaba.fastjson.JSONObject;
JSONObject jsonObject = new JSONObject();
jsonObject.put(f1, xxx);
jsonObject.put(f2, xxx);
String json = jsonObject.toJSONString();
我想了一下，但是得有一个前提，就是第一个json数组的size必须和第二个json数组的size相同，并且一一对应，否则将造成数组溢出。
如果是基于上面这个前提，那么实现的方法就简单了。
操作json对象，其实标准的方法是将实体类转换成json后再操作，我这里的话为了便捷直接使用谷歌的Gson来创建JsonObject了，其他的json依赖还有阿里巴巴的FastJson等等，看你平时用什么习惯。
引入Gson依赖：
dependency
groupIdcom.google.code.gson/groupId
artifactIdgson/artifactId
version2.8.0/version
/dependency
实现代码：
public class Main {
public static void main(String[] args) {
JsonArray jsonArray1 = new JsonArray();
JsonObject json11 = new JsonObject();
json11.addProperty("数据1", "0000");
json11.addProperty("数据2", "1111");
JsonObject json12 = new JsonObject();
json12.addProperty("数据1", "0000");
json12.addProperty("数据2", "1111");
JsonObject json13 = new JsonObject();
json13.addProperty("数据1", "0000");
json13.addProperty("数据2", "1111");
jsonArray1.add(json11);
jsonArray1.add(json12);
jsonArray1.add(json13);
System.out.println(jsonArray1);
JsonArray jsonArray2 = new JsonArray();
JsonObject json21 = new JsonObject();
json21.addProperty("数据3", "6666");
JsonObject json22 = new JsonObject();
json22.addProperty("数据3", "6666");
JsonObject json23 = new JsonObject();
json23.addProperty("数据3", "6666");
jsonArray2.add(json21);
jsonArray2.add(json22);
jsonArray2.add(json23);
System.out.println(jsonArray2);
//遍历json数组，按位取出对象
for (int i = 0; i jsonArray1.size(); i++) {
JsonObject json1 = jsonArray1.get(i).getAsJsonObject();
JsonObject json3 = jsonArray2.get(i).getAsJsonObject();
//遍历数据3内容，通过Entry获取数据3的key和value，并合并到数据1中
for (Map.EntryString, JsonElement item : json3.entrySet()) {
json1.addProperty(item.getKey(), item.getValue().getAsString());
}
}
System.out.println(jsonArray1);
}
}
整体思路为：遍历两个json数组，按位进行合并操作。合并时，遍历数据3的jsonObject，获取其key和value，并将其合并到数据1中即可。
运行结果：
如果聊天数据的结构是固定的或变化不大的。
就直接“编排”json字符串。
为要输出的对象增加一个String toJSON()方法
StringBuilder b=new StringBuilder();
b.append("{ name:\"");
b.append(username);
b.append("\"}");
依次类推
return b.toString();
适合绝大多数情况。
补充：json是做交换格式，查询效率非常低，如果做存储的检索格式就误用了。
就是说“聊天信息的保存用json应该可以吧”还不如你之前的mysql数据库。
json用在客户端往服务端发送的通讯交换数据的格式上。服务端收到后转为数据库中或内存中存放。
直接调用类库里的属性和方法就行，没必要自己写啊！你说的源码是什么意思？
你这个json格式本身就有问题，不符合标准。