如何基于字段存在性与字段值实现 JSON 多级类型反序列化-java教程-PHP中文网

如何基于字段存在性与字段值实现 JSON 多级类型反序列化

本文详解如何使用 Jackson 实现两级条件反序列化：先根据 job 或 notify 字段存在性判断抽象子类（JobCallback/NotificationCallback），再依据 object.type 值精确映射到四个具体实现类。核心在于自定义反序列化器 + 正确配置 ObjectMapper 的可见性策略。

本文详解如何使用 jackson 实现两级条件反序列化：先根据 `job` 或 `notify` 字段存在性判断抽象子类（jobcallback/notificationcallback），再依据 `object.type` 值精确映射到四个具体实现类。核心在于自定义反序列化器 + 正确配置 objectmapper 的可见性策略。

在复杂 JSON 消息路由场景中，常需根据动态字段组合决定目标 Java 类型。本例涉及四层继承结构：根抽象类 Callback → 两个中间抽象类 JobCallback 和 NotificationCallback → 四个终态实现类（如 DomainJobCallback）。反序列化逻辑需分两步决策：

第一级判别：检查 JSON 是否含 "job"（→ JobCallback）或 "notify"（→ NotificationCallback）字段；
第二级判别：解析 "object.type" 字段值（"Domain" 或 "Transfer"），确定最终具体类型。

直接使用 @JsonTypeInfo 配合嵌套 @JsonSubTypes 会失败——Jackson 不支持在子类上覆盖父类的类型信息配置（jackson-databind #3358），且手动调用 treeToValue() 易引发 StackOverflowError（因递归触发同一自定义反序列器）。

✅ 正确实践：模块化注册 + 字段级可见性控制

关键在于避免递归反序列化，改用 Jackson 内置的字段访问机制直接构造对象。以下是完整可运行方案：

Miller CSV TSV JSON 数据处理器

Miller (mlr) 是一个命令行工具，用于查询、整形和重新格式化名称索引数据，如 CSV、TSV、JSON 和 JSON Lines。它将 awk、sed、cut、join 和 sort 的功能整合到一个专为结构化数据处理而构建的单一工具中。

下载

// 1. 配置 ObjectMapper（必须！）
ObjectMapper objectMapper = new ObjectMapper();
SimpleModule module = new SimpleModule();
module.addDeserializer(Callback.class, new CallbackDeserializer());
objectMapper.registerModule(module);
// 关键：禁用 getter/setter 自动发现，启用字段直读
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.NONE);
objectMapper.setVisibility(PropertyAccessor.FIELD, JsonAutoDetect.Visibility.ANY);

⚠️ 注意：若不设置 PropertyAccessor.FIELD 可见性，Jackson 默认仅通过 public getter/setter 访问字段，而示例中所有字段均为 private 且无 accessor，将导致反序列化失败或空对象。

? 自定义反序列化器实现（无递归、高内聚）

public static class CallbackDeserializer extends JsonDeserializer<callback> {
    @Override
    public Callback deserialize(JsonParser p, DeserializationContext ctxt) 
            throws IOException {
        JsonNode node = p.getCodec().readTree(p);

        // 第一级：识别子类类型
        if (node.has("job")) {
            return deserializeJobCallback(node);
        } else if (node.has("notify")) {
            return deserializeNotificationCallback(node);
        }
        throw new JsonMappingException(p, "Missing 'job' or 'notify' field");
    }

    private Callback deserializeJobCallback(JsonNode node) {
        String type = node.path("object").path("type").asText();
        return switch (type) {
            case "Domain" -> new Callback.JobCallback.DomainJobCallback(
                    node.path("job").asText(),
                    new Callback.Obj(type)
            );
            case "Transfer" -> new Callback.JobCallback.TransferJobCallback(
                    node.path("job").asText(),
                    new Callback.Obj(type)
            );
            default -> throw new IllegalArgumentException("Unknown job type: " + type);
        };
    }

    private Callback deserializeNotificationCallback(JsonNode node) {
        String type = node.path("object").path("type").asText();
        return switch (type) {
            case "Domain" -> new Callback.NotificationCallback.DomainNotificationCallback(
                    node.path("notify").asText(),
                    new Callback.Obj(type)
            );
            case "Transfer" -> new Callback.NotificationCallback.TransferNotificationCallback(
                    node.path("notify").asText(),
                    new Callback.Obj(type)
            );
            default -> throw new IllegalArgumentException("Unknown notify type: " + type);
        };
    }
}</callback>

? 类定义要点（精简、无冗余注解）

@JsonDeserialize(using = CallbackDeserializer.class)
public abstract static class Callback {
    protected Obj object; // 必须为 protected 或 package-private（配合 FIELD 可见性）

    public static class Obj {
        public String type; // public 字段，或保留 private + @JsonProperty
    }

    public abstract static class JobCallback extends Callback {
        public String job;
    }

    public static class DomainJobCallback extends JobCallback {
        public DomainJobCallback(String job, Obj object) {
            this.job = job;
            this.object = object;
        }
    }

    public static class TransferJobCallback extends JobCallback {
        public TransferJobCallback(String job, Obj object) {
            this.job = job;
            this.object = object;
        }
    }

    public static class NotificationCallback extends Callback {
        public String notify;
    }

    public static class DomainNotificationCallback extends NotificationCallback {
        public DomainNotificationCallback(String notify, Obj object) {
            this.notify = notify;
            this.object = object;
        }
    }

    public static class TransferNotificationCallback extends NotificationCallback {
        public TransferNotificationCallback(String notify, Obj object) {
            this.notify = notify;
            this.object = object;
        }
    }
}