Java处理海量JSON应避免ObjectMapper直接解析字符串，改用Function<InputStream, T>配合Jackson流式API、自定义缓冲池、StreamReadConstraints防护及复用ObjectMapper。

Java中用Function<String, T>处理海量JSON文本时，关键不在Function本身，而在于它内部如何调用Jackson——尤其是避免把整段大JSON一次性加载进内存再传给Function。Function只是个函数式接口，真正扛内存压力的是Jackson的解析方式和资源管理策略。

用Streaming API替代ObjectMapper.readValue(String)
ObjectMapper.readValue(String, Class)会先把整个JSON字符串加载为String对象，再解析，这对GB级文本是灾难性的。正确做法是让Function接收InputStream或Reader，内部用JsonParser流式推进：

Function<InputStream, List<User>> parser = is -> {
    List<User> users = new ArrayList<>();
    JsonFactory factory = new JsonFactoryBuilder()
        .streamReadConstraints(StreamReadConstraints.builder()
            .maxStringLength(1_000_000)
            .maxArraySize(100_000)
            .build())
        .build();
    try (JsonParser p = factory.createParser(is)) {
        while (p.nextToken() != JsonToken.END_ARRAY) {
            if (p.getCurrentToken() == JsonToken.START_OBJECT) {
                User u = p.readValueAs(User.class);
                users.add(u);
            }
        }
    }
    return users;
};

禁用默认缓冲区回收池（尤其在Android或容器化短生命周期场景）
Jackson 2.10+ 默认用SoftReference实现的JsonRecyclerPools.defaultPool()，但在Android或Serverless环境中可能失效，反而引发GC抖动。应显式切换为线程安全且无软引用依赖的池：

JsonFactory factory = JsonFactoryBuilder()
    .recyclerPool(JsonRecyclerPools.threadLocalPool()) // 推荐：每个线程独占缓冲区
    // 或 .recyclerPool(JsonRecyclerPools.nonRecyclingPool()) // 极简场景，不复用也比误用强
    .build();

配合StreamReadConstraints做主动防护
海量JSON常伴随恶意输入风险（如超长字符串、超深嵌套、极大数组）。必须设置硬性约束，防止OOM：

StreamReadConstraints constraints = StreamReadConstraints.builder()
    .maxNestingDepth(100)           // 防止深度嵌套爆炸
    .maxNumberLength(1000)         // 数字字符串长度上限
    .maxStringLength(5_000_000)   // 单字段最大字符数
    .maxArraySize(500_000)         // 数组元素上限（适用于顶层大数组）
    .build();

避免在Function里反复创建ObjectMapper
ObjectMapper是线程安全且开销大的对象，不要在每次调用apply()时新建。应作为外部依赖注入，或用静态单例（注意配置不可变）：

Feishu calendar sync, local ics to json data for AI agent

将ICS日历文件转为JSON格式，用于飞书日历导入导出及数据集成。

下载

// ✅ 正确：复用、预配置
private static final ObjectMapper MAPPER = new ObjectMapper()
    .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
    .configure(JsonParser.Feature.AUTO_CLOSE_SOURCE, true);

Function<InputStream, User> userParser = is -> {
    try {
        return MAPPER.readValue(is, User.class);
    } catch (IOException e) {
        throw new RuntimeException(e);
    }
};

不复杂但容易忽略。

立即学习“Java免费学习笔记（深入）”；