Jackson - 流媒体 API

流 API 将 JSON 内容作为离散事件读取和写入。JsonParser 读取数据，而 JsonGenerator 写入数据。它是三者中最强大的方法，开销最低，读/写操作速度最快。它类似于 XML 的 Stax 解析器。

在本文中，我们将展示如何使用 Jackson 流 API 来读取和写入 JSON 数据。Streaming API 使用 token 的概念，Json 的每个细节都要小心处理。以下是我们将在示例中使用的两个类：

JsonGenerator - 写入 JSON 字符串。
JsonParser - 解析 JSON 字符串。

使用 JsonGenerator 编写 JSON

使用 JsonGenerator 非常简单。首先使用 JsonFactory.createJsonGenerator() 方法创建 JsonGenerator，并使用它的 write***() 方法写入每个 json 值。

JsonFactory jsonFactory = new JsonFactory();
JsonGenerator jsonGenerator = jsonFactory.createGenerator(new File(
   "student.json"), JsonEncoding.UTF8);
// {
jsonGenerator.writeStartObject();
// "name" : "Mahesh Kumar"
jsonGenerator.writeStringField("name", "Mahesh Kumar");

让我们看看 JsonGenerator 的实际应用。在C:\>Jackson_WORKSPACE中创建一个名为 JacksonTester 的 java 类文件。

文件：JacksonTester.java

导入java.io.File；
导入java.io.IOException；
导入java.util.Map；

导入 com.fasterxml.jackson.core.JsonEncoding；
导入 com.fasterxml.jackson.core.JsonFactory;
导入 com.fasterxml.jackson.core.JsonGenerator;
导入 com.fasterxml.jackson.core.JsonParseException；
导入 com.fasterxml.jackson.databind.JsonMappingException；
导入 com.fasterxml.jackson.databind.ObjectMapper;

公共类 JacksonTester {
   公共静态无效主（字符串参数[]）{

      尝试 {         
         JsonFactory jsonFactory = new JsonFactory();
         JsonGenerator jsonGenerator = jsonFactory.createGenerator(new File("student.json"), JsonEncoding.UTF8);

         jsonGenerator.writeStartObject();

         //“名称”：“马赫什·库马尔”
         jsonGenerator.writeStringField("name", "Mahesh Kumar");

         //“年龄”：21
         jsonGenerator.writeNumberField("年龄", 21);

         //“已验证”：假
         jsonGenerator.writeBooleanField("已验证", false);

         // “分数” : [100, 90, 85]
         jsonGenerator.writeFieldName("标记");

         // [
         jsonGenerator.writeStartArray();
         // 100, 90, 85
         jsonGenerator.writeNumber(100);
         jsonGenerator.writeNumber(90);
         jsonGenerator.writeNumber(85);
         //]

         jsonGenerator.writeEndArray();

         jsonGenerator.writeEndObject();
         jsonGenerator.close();        

         //结果student.json
         //{
         //“名称”：“马赫什·库马尔”，
         //“年龄”：21，
         //“已验证”：假，
         // “标记”:[100,90,85]
         //}

         ObjectMapper 映射器 = new ObjectMapper();
         Map<String,Object> dataMap = mapper.readValue(new File("student.json"), Map.class);

         System.out.println(dataMap.get("名称"));
         System.out.println(dataMap.get("年龄"));
         System.out.println(dataMap.get("已验证"));
         System.out.println(dataMap.get("标记"));
      }
      catch (JsonParseException e) { e.printStackTrace(); }
      catch (JsonMappingException e) { e.printStackTrace(); }
      catch (IOException e) { e.printStackTrace(); }
   }
}

验证结果

使用javac编译器编译类，如下所示：

C:\Jackson_WORKSPACE>javac JacksonTester.java

现在运行 jacksonTester 查看结果：

C:\Jackson_WORKSPACE>java JacksonTester

验证输出

Mahesh Kumar
21
false
[100, 90, 85]

使用 JsonParser 读取 JSON

使用 JsonParser 也非常简单。首先使用 JsonFactory.createJsonParser() 方法创建 JsonParser，并使用它的 nextToken() 方法将每个 json 字符串读取为令牌。检查每个令牌并进行相应处理

JsonFactory jasonFactory = new JsonFactory();
JsonParser jsonParser = jasonFactory.createJsonParser(new File("student.json"));
while (jsonParser.nextToken() != JsonToken.END_OBJECT) {
   //get the current token
   String fieldname = jsonParser.getCurrentName();
   if ("name".equals(fieldname)) {
      //move to next token
      jsonParser.nextToken();
      System.out.println(jsonParser.getText());        	 
   }
}

让我们看看 JsonParser 的实际应用。在C:\>Jackson_WORKSPACE中创建一个名为 JacksonTester 的 java 类文件。

文件：JacksonTester.java

导入java.io.File；
导入java.io.IOException；
导入java.util.Map；

导入 com.fasterxml.jackson.core.JsonEncoding；
导入 com.fasterxml.jackson.core.JsonFactory;
导入 com.fasterxml.jackson.core.JsonGenerator;
导入 com.fasterxml.jackson.core.JsonParseException；
导入 com.fasterxml.jackson.databind.JsonMappingException；
导入 com.fasterxml.jackson.databind.ObjectMapper;

公共类 JacksonTester {
   公共静态无效主（字符串参数[]）{
      JacksonTester 测试器 = new JacksonTester();
      尝试 {        	
         JsonFactory jsonFactory = new JsonFactory();

         JsonGenerator jsonGenerator = jsonFactory.createGenerator(新文件(
            “student.json”），JsonEncoding.UTF8）；
         jsonGenerator.writeStartObject();
         jsonGenerator.writeStringField("name", "Mahesh Kumar");
         jsonGenerator.writeNumberField("年龄", 21);
         jsonGenerator.writeBooleanField("已验证", false);
         jsonGenerator.writeFieldName("标记");
         jsonGenerator.writeStartArray(); // [
         jsonGenerator.writeNumber(100);
         jsonGenerator.writeNumber(90);
         jsonGenerator.writeNumber(85);
         jsonGenerator.writeEndArray();
         jsonGenerator.writeEndObject();
         jsonGenerator.close();       	 

         //结果student.json
         //{
         //“名称”：“马赫什·库马尔”，
         //“年龄”：21，
         //“已验证”：假，
         // “标记”:[100,90,85]
         //}

         JsonParser jsonParser = jsonFactory.createParser(new File("student.json"));
         while (jsonParser.nextToken() != JsonToken.END_OBJECT) {
            //获取当前令牌
            字符串字段名 = jsonParser.getCurrentName();
            if ("name".equals(字段名)) {
               //移动到下一个标记
               jsonParser.nextToken();
               System.out.println(jsonParser.getText());        	 
            }
            if("年龄".equals(字段名)){
               //移动到下一个标记
               jsonParser.nextToken();
               System.out.println(jsonParser.getNumberValue());        	 
            }
            if("已验证".equals(字段名)){
               //移动到下一个标记
               jsonParser.nextToken();
               System.out.println(jsonParser.getBooleanValue());        	 
            }
            if("marks".equals(字段名)){
               //搬去 [
               jsonParser.nextToken();
               // 循环直到标记等于“]”
               while (jsonParser.nextToken() != JsonToken.END_ARRAY) {
                  System.out.println(jsonParser.getNumberValue());
               }
            }
         }
      } catch (JsonParseException e) {
         e.printStackTrace();
      } catch (JsonMappingException e) {
         e.printStackTrace();
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

验证结果

使用javac编译器编译类，如下所示：

C:\Jackson_WORKSPACE>javac JacksonTester.java

现在运行 jacksonTester 查看结果：

C:\Jackson_WORKSPACE>java JacksonTester

验证输出

Mahesh Kumar
21
false
[100, 90, 85]