AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

jackson学习之二：jackson-core

2023-09-09 496
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 了解jackson最底层的功能逻辑

欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos

系列文章汇总

名称 链接 备注
项目主页 https://github.com/zq2599/blog_demos 该项目在GitHub上的主页
git仓库地址(https) https://github.com/zq2599/blog_demos.git 该项目源码的仓库地址，https协议
git仓库地址(ssh) git@github.com:zq2599/blog_demos.git 该项目源码的仓库地址，ssh协议
  • 这个git项目中有多个文件夹，本章的应用在jacksondemo文件夹下，如下图红框所示：
    在这里插入图片描述

    创建父子工程

    创建名为jacksondemo的maven工程，这是个父子结构的工程，其pom.xml内容如下：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <groupId>com.bolingcavalry</groupId>
    <artifactId>jacksondemo</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>pom</packaging>
    <modules>
        <module>core</module>
        <module>beans</module>
        <module>databind</module>
    </modules>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-databind</artifactId>
                <version>2.11.0</version>
                <scope>compile</scope>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
                <version>1.7.25</version>
                <scope>compile</scope>
            </dependency>
            <dependency>
                <groupId>commons-io</groupId>
                <artifactId>commons-io</artifactId>
                <version>2.7</version>
                <scope>compile</scope>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>3.10</version>
                <scope>compile</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

新增子工程beans

  • 在父工程jscksondemo下新增名为beans的子工程，这里面是一些常量和Pojo类；
  • 增加定义常量的类Constant.java：
package com.bolingcavalry.jacksondemo.beans;

public class Constant {
   
   
    /**
     * 该字符串的值是个网络地址，该地址对应的内容是个JSON
     */
    public final static String TEST_JSON_DATA_URL = "https://raw.githubusercontent.com/zq2599/blog_demos/master/files/twitteer_message.json";
    /**
     * 用来验证反序列化的JSON字符串
     */
    public final static String TEST_JSON_STR = "{\n" +
            "  \"id\":1125687077,\n" +
            "  \"text\":\"@stroughtonsmith You need to add a \\\"Favourites\\\" tab to TC/iPhone. Like what TwitterFon did. I can't WAIT for your Twitter App!! :) Any ETA?\",\n" +
            "  \"fromUserId\":855523, \n" +
            "  \"toUserId\":815309,\n" +
            "  \"languageCode\":\"en\"\n" +
            "}";
    /**
     * 用来验证序列化的TwitterEntry实例
     */
    public final static TwitterEntry TEST_OBJECT = new TwitterEntry();
    /**
     * 准备好TEST_OBJECT对象的各个参数
     */
    static {
   
   
        TEST_OBJECT.setId(123456L);
        TEST_OBJECT.setFromUserId(101);
        TEST_OBJECT.setToUserId(102);
        TEST_OBJECT.setText("this is a message for serializer test");
        TEST_OBJECT.setLanguageCode("zh");
    }}
  • 增加一个Pojo，对应的是一条推特消息：
package com.bolingcavalry.jacksondemo.beans;
/**
 * @Description: 推特消息bean
 * @author: willzhao E-mail: zq2599@gmail.com
 * @date: 2020/7/4 16:24
 */
public class TwitterEntry {
   
   
    /**
     * 推特消息id
     */
    long id;
    /**
     * 消息内容
     */
    String text;    /**
     * 消息创建者
     */
    int fromUserId;
    /**
     * 消息接收者
     */
    int toUserId;
    /**
     * 语言类型
     */
    String languageCode;    public long getId() {
   
   
        return id;
    }    public void setId(long id) {
   
   
        this.id = id;
    }    public String getText() {
   
   
        return text;
    }    public void setText(String text) {
   
   
        this.text = text;
    }    public int getFromUserId() {
   
   
        return fromUserId;
    }    public void setFromUserId(int fromUserId) {
   
   
        this.fromUserId = fromUserId;
    }    public int getToUserId() {
   
   
        return toUserId;
    }    public void setToUserId(int toUserId) {
   
   
        this.toUserId = toUserId;
    }    public String getLanguageCode() {
   
   
        return languageCode;
    }    public void setLanguageCode(String languageCode) {
   
   
        this.languageCode = languageCode;
    }    public TwitterEntry() {
   
   
    }    public String toString() {
   
   
        return "[Tweet, id: "+id+", text='"+text+"', from: "+fromUserId+", to: "+toUserId+", lang: "+languageCode+"]";
    }}
  • 以上就是准备工作了，接下来开始实战jackson-core；

    JsonFactory线程安全吗?

  • JsonFactory是否是线程安全的，这是编码前要弄清楚的问题，因为JsonParser和JsonGenerator的创建都离不开JsonFactory；
  • 如下图红框所示，jackson官方文档中明确指出JsonFactory是线程安全的，可以放心的作为全局变量给多线程同时使用：
    在这里插入图片描述
  • 官方文档地址：http://fasterxml.github.io/jackson-core/javadoc/2.11/

    jackson-core实战

  • 新建子工程core，pom.xml如下：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>jacksondemo</artifactId>
        <groupId>com.bolingcavalry</groupId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../pom.xml</relativePath>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.bolingcavalry</groupId>
    <artifactId>core</artifactId>
    <name>core</name>
    <description>Demo project for jackson core use</description>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </dependency>
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
        </dependency>
        <dependency>
            <groupId>com.bolingcavalry</groupId>
            <artifactId>beans</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>
</project>
  • 新建StreamingDemo类，这里面是调用jackson-core的API进行序列化和反序列化的所有demo，如下：
package com.bolingcavalry.jacksondemo.core;

import com.bolingcavalry.jacksondemo.beans.TwitterEntry;
import com.fasterxml.jackson.core.*;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.net.URL;

/**
 * @Description: jackson低阶方法的使用
 * @author: willzhao E-mail: zq2599@gmail.com
 * @date: 2020/7/4 15:50
 */
public class StreamingDemo {
   
   

    private static final Logger logger = LoggerFactory.getLogger(StreamingDemo.class);

    JsonFactory jsonFactory = new JsonFactory();

    /**
     * 该字符串的值是个网络地址，该地址对应的内容是个JSON
     */
    final static String TEST_JSON_DATA_URL = "https://raw.githubusercontent.com/zq2599/blog_demos/master/files/twitteer_message.json";

    /**
     * 用来验证反序列化的JSON字符串
     */
    final static String TEST_JSON_STR = "{\n" +
            "  \"id\":1125687077,\n" +
            "  \"text\":\"@stroughtonsmith You need to add a \\\"Favourites\\\" tab to TC/iPhone. Like what TwitterFon did. I can't WAIT for your Twitter App!! :) Any ETA?\",\n" +
            "  \"fromUserId\":855523, \n" +
            "  \"toUserId\":815309,\n" +
            "  \"languageCode\":\"en\"\n" +
            "}";

    /**
     * 用来验证序列化的TwitterEntry实例
     */
    final static TwitterEntry TEST_OBJECT = new TwitterEntry();

    /**
     * 准备好TEST_OBJECT对象的各个参数
     */
    static {
   
   
        TEST_OBJECT.setId(123456L);
        TEST_OBJECT.setFromUserId(101);
        TEST_OBJECT.setToUserId(102);
        TEST_OBJECT.setText("this is a message for serializer test");
        TEST_OBJECT.setLanguageCode("zh");
    }


    /**
     * 反序列化测试(JSON -> Object)，入参是JSON字符串
     * @param json JSON字符串
     * @return
     * @throws IOException
     */
    public TwitterEntry deserializeJSONStr(String json) throws IOException {
   
   

        JsonParser jsonParser = jsonFactory.createParser(json);

        if (jsonParser.nextToken() != JsonToken.START_OBJECT) {
   
   
            jsonParser.close();
            logger.error("起始位置没有大括号");
            throw new IOException("起始位置没有大括号");
        }

        TwitterEntry result = new TwitterEntry();

        try {
   
   
            // Iterate over object fields:
            while (jsonParser.nextToken() != JsonToken.END_OBJECT) {
   
   

                String fieldName = jsonParser.getCurrentName();

                logger.info("正在解析字段 [{}]", jsonParser.getCurrentName());

                // 解析下一个
                jsonParser.nextToken();

                switch (fieldName) {
   
   
                    case "id":
                        result.setId(jsonParser.getLongValue());
                        break;
                    case "text":
                        result.setText(jsonParser.getText());
                        break;
                    case "fromUserId":
                        result.setFromUserId(jsonParser.getIntValue());
                        break;
                    case "toUserId":
                        result.setToUserId(jsonParser.getIntValue());
                        break;
                    case "languageCode":
                        result.setLanguageCode(jsonParser.getText());
                        break;
                    default:
                        logger.error("未知字段 '" + fieldName + "'");
                        throw new IOException("未知字段 '" + fieldName + "'");
                }
            }
        } catch (IOException e) {
   
   
            logger.error("反序列化出现异常 :", e);
        } finally {
   
   
            jsonParser.close(); // important to close both parser and underlying File reader
        }

        return result;
    }

    /**
     * 反序列化测试(JSON -> Object)，入参是JSON字符串
     * @param url JSON字符串的网络地址
     * @return
     * @throws IOException
     */
    public TwitterEntry deserializeJSONFromUrl(String url) throws IOException {
   
   
        // 从网络上取得JSON字符串
        String json = IOUtils.toString(new URL(TEST_JSON_DATA_URL), JsonEncoding.UTF8.name());

        logger.info("从网络取得JSON数据 :\n{}", json);

        if(StringUtils.isNotBlank(json)) {
   
   
            return deserializeJSONStr(json);
        } else {
   
   
            logger.error("从网络获取JSON数据失败");
            return null;
        }
    }


    /**
     * 序列化测试(Object -> JSON)
     * @param twitterEntry
     * @return 由对象序列化得到的JSON字符串
     */
    public String serialize(TwitterEntry twitterEntry) throws IOException{
   
   
        String rlt = null;
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
        JsonGenerator jsonGenerator = jsonFactory.createGenerator(byteArrayOutputStream, JsonEncoding.UTF8);

        try {
   
   
            jsonGenerator.useDefaultPrettyPrinter();

            jsonGenerator.writeStartObject();
            jsonGenerator.writeNumberField("id", twitterEntry.getId());
            jsonGenerator.writeStringField("text", twitterEntry.getText());
            jsonGenerator.writeNumberField("fromUserId", twitterEntry.getFromUserId());
            jsonGenerator.writeNumberField("toUserId", twitterEntry.getToUserId());
            jsonGenerator.writeStringField("languageCode", twitterEntry.getLanguageCode());
            jsonGenerator.writeEndObject();
        } catch (IOException e) {
   
   
            logger.error("序列化出现异常 :", e);
        } finally {
   
   
            jsonGenerator.close();
        }

        // 一定要在
        rlt = byteArrayOutputStream.toString();

        return rlt;
    }


    public static void main(String[] args) throws Exception {
   
   

        StreamingDemo streamingDemo = new StreamingDemo();

        // 执行一次对象转JSON操作
        logger.info("********************执行一次对象转JSON操作********************");
        String serializeResult = streamingDemo.serialize(TEST_OBJECT);
        logger.info("序列化结果是JSON字符串 : \n{}\n\n", serializeResult);

        // 用本地字符串执行一次JSON转对象操作
        logger.info("********************执行一次本地JSON反序列化操作********************");
        TwitterEntry deserializeResult = streamingDemo.deserializeJSONStr(TEST_JSON_STR);
        logger.info("\n本地JSON反序列化结果是个java实例 : \n{}\n\n", deserializeResult);

        // 用网络地址执行一次JSON转对象操作
        logger.info("********************执行一次网络JSON反序列化操作********************");
        deserializeResult = streamingDemo.deserializeJSONFromUrl(TEST_JSON_DATA_URL);
        logger.info("\n网络JSON反序列化结果是个java实例 : \n{}", deserializeResult);

        ObjectMapper a;
    }
}
  • 上述代码可见JsonParser负责将JSON解析成对象的变量值，核心是循环处理JSON中的所有内容；
  • JsonGenerator负责将对象的变量写入JSON的各个属性，这里是开发者自行决定要处理哪些字段；
  • 不论是JsonParser还是JsonGenerator，大家都可以感觉到工作量很大，需要开发者自己动手实现对象和JSON字段的关系映射，实际应用中不需要咱们这样辛苦的编码，jackson的另外两个库(annonation的databind)已经帮我们完成了大量工作，上述代码只是揭示最基础的jackson执行原理；
  • 执行StreamingDemo类，得到结果如下，序列化和反序列化都成功了：
    在这里插入图片描述
  • 以上就是jackson-core的基本功能，咱们了解了jackson最底层的工作原理，接下来的文章会继续实践更多操作；

欢迎关注阿里云开发者社区：程序员欣宸

学习路上，你不孤单，欣宸原创一路相伴...

文章标签：
云解析DNS
API
数据格式
JSON
Java
安全
程序员欣宸
目录
相关文章
wljslmz
|
域名解析 缓存 网络协议
如何在 Linux 上刷新 DNS 缓存？
如何在 Linux 上刷新 DNS 缓存？
wljslmz
1253 0
Java极客技术
|
canal 消息中间件 存储
手把手告诉你如何监听 MySQL binlog 实现数据变化后的实时通知！
Hello 大家好，我是阿粉。不知道大家在日常的工作中有没有遇到这样的场景，很多时候业务数据有变更需要及时加载到缓存、ES 或者发送到消息队列中通知下游服务。
Java极客技术
7567 0
手把手告诉你如何监听 MySQL binlog 实现数据变化后的实时通知！
chen2ha
|
Kubernetes 容器
kubeadm 部署的 k8s 增加 ip 并重新生成证书
kubeadm 部署的 k8s 增加 ip 并重新生成证书
chen2ha
1605 0
半盏清茶
|
网络协议 网络安全
华为openEuler欧拉系统的防火墙常用设置方法
在有防火墙的系统中，比如我们部署了一个WEB项目，我们需要给该WEB项目所需的端口放行。本文介绍了防火墙常用设置方法。
半盏清茶
2057 81
Java开发者
|
11月前
|
存储 监控 BI
评测：大模型时代的智能BI—Quick BI
作为一位数据平台开发工程师，我近期体验了阿里云Quick BI的深度功能。以下从技术视角总结：1. 数据集成支持本地文件快速建模，但大文件上传和多表关联有待优化；2. 开放API便于报表嵌入，建议增加频次限制与实时推送能力；3. 计算引擎性能良好，复杂查询时需优化分布式调度；4. 资源监控模块实用，但缺乏预警机制；5. 安全体系完善，建议增强自动权限管理和KMS集成。总体而言，Quick BI是一款适合中大型企业的智能BI工具，具备强大API生态和多租户设计。
Java开发者
388 1
hhzz
|
消息中间件 JSON Java
Spring Boot、Spring Cloud与Spring Cloud Alibaba版本对应关系
Spring Boot、Spring Cloud与Spring Cloud Alibaba版本对应关系
hhzz
32527 0
肖申克的陪伴
|
SQL 关系型数据库 MySQL
使用IntelliJ IDEA连接数据库，快速创建实体类对象，自动生成get，set，toString方法以及无参有参构造器
使用IntelliJ IDEA连接数据库，快速创建实体类对象，自动生成get，set，toString方法以及无参有参构造器
肖申克的陪伴
3042 0
aliyun7689123603-22772
|
机器学习/深度学习 编解码 自然语言处理
卷积神经网络（CNN）的发展历程
【10月更文挑战第1天】卷积神经网络（CNN）的发展历程
aliyun7689123603-22772
2416 0
Ganos全空间数据库
|
关系型数据库 分布式数据库 数据库
基于PolarDB的图分析：保险数据分析实践
本文以公开的保险数据集为例，示例了基于云原生数据库PolarDB上，在保险理赔场景下，执行图查询来发现异常理赔记录和欺诈团伙：例如，查询与欺诈保单有相同理赔病人的其他保单，或者找出欺诈保单的投保人社交关系，以便进行欺诈预警。PolarDB在关系型数据库的基础上，提供了图分析能力，为企业的统一数据管理和分析，提供了强有力的支撑。
Ganos全空间数据库
821 8

热门文章

最新文章

  • 1
    Ubuntu22.04上Docker的安装
  • 2
    ccxt中文教程
  • 3
    CC：基于组件总线的Android组件化开源框架
  • 4
    Linux系统小技巧（1）：/dev/random设备可能导致java程序启动慢或者操作耗时不正常
  • 5
    SQL SERVER数据库删除LOG文件和清空日志的方案
  • 6
    RESTful API 文档生成神器 Wisdom REST Client
  • 7
    面对复杂业务，if-else coder 如何升级？
  • 8
    RestHighLevelClient查询es
  • 9
    Maven3 package时报 &#39;version&#39; contains an expression but should be a constant
  • 10
    用awk数组处理两个文件的例子
  • 1
    OpenClaw（Clawdbot）部署教程+6个超实用OpenClaw Skills实操分享：从聊天工具到学习神器
    179
  • 2
    2026年OpenClaw（Clawdbot）部署WordPress网站教程：零基础也能快速搞定
    65
  • 3
    2026年OpenClaw（Clawdbot）部署成功教程及OpenClaw+Skills可以做什么参考
    191
  • 4
    2026年新手快速部署OpenClaw（Clawdbot）+接入Telegram步骤流程
    96
  • 5
    阿里云无影AgentBay部署OpenClaw（Clawdbot）步骤教程，新手小白直接抄作业
    56
  • 6
    《零信任架构运维监控信任体系构建实操手册》
    42
  • 7
    《分布式跨域业务事务可用性与性能度量手册》
    38
  • 8
    2026年OpenClaw(Clawdbot)部署 + 接入Discord教程，小白直接抄作业（必看）
    105
  • 9
    2026年新手零门槛部署OpenClaw(Clawdbot) + 接入WhatsApp保姆级教程
    77
  • 10
    2026年新手小白一键部署OpenClaw(Clawdbot) + Slack接入喂饭级教程
    45

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    第五届伏魔挑战赛如约来袭，诚邀各路高手来战！