如何使用Jackson从对象流生成JSON流并流式输出至HttpServletResponse（避免内存过载）

这问题我熟，要实现Jackson流式输出JSON数组到HttpServletResponse且不加载所有数据到内存，核心是用Jackson的流式API逐个处理Stream里的元素，而不是把整个Stream转成List再序列化。下面给你完整的实现步骤和代码：

完整代码示例 #

import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.http.MediaType;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Stream;

public class Person {
    public String name;
    public Integer age;
    // 构造器、getter/setter根据需求补充
}

@RequestMapping(value = "/my/path", produces = MediaType.APPLICATION_JSON_VALUE)
public void getPersons(HttpServletRequest request, HttpServletResponse response) throws IOException {
    // 1. 获取Jackson的ObjectMapper实例（Spring项目建议用注入的单例，复用全局配置）
    ObjectMapper objectMapper = new ObjectMapper();
    JsonFactory jsonFactory = objectMapper.getFactory();

    // 2. 配置响应的Content-Type和字符编码
    response.setContentType(MediaType.APPLICATION_JSON_VALUE);
    response.setCharacterEncoding("UTF-8");

    // 3. 用try-with-resources管理JsonGenerator，自动关闭资源
    try (JsonGenerator jsonGenerator = jsonFactory.createGenerator(response.getOutputStream())) {
        // 4. 写入JSON数组的起始标记
        jsonGenerator.writeStartArray();

        Stream<Person> stream = getMyStream();
        // 5. 遍历Stream，逐个序列化对象，处理元素间的逗号分隔
        AtomicBoolean isFirst = new AtomicBoolean(true);
        stream.forEachRemaining(person -> {
            try {
                if (!isFirst.getAndSet(false)) {
                    jsonGenerator.writeRaw(',');
                }
                // 直接将单个Person对象序列化到响应流
                objectMapper.writeValue(jsonGenerator, person);
            } catch (IOException e) {
                throw new UncheckedIOException(e);
            }
        });

        // 6. 写入JSON数组的结束标记
        jsonGenerator.writeEndArray();
    }
}

关键细节解释 #

• 流式API的核心优势：不同于objectMapper.writeValue(response.getOutputStream(), stream.collect(Collectors.toList()))会把所有元素加载到内存，这里的写法是序列化一个对象就输出一个，内存占用始终维持在单个对象的级别，完美适配大数据量场景。
• 资源安全：用try-with-resources包裹JsonGenerator，确保生成器和响应输出流能被自动关闭，避免资源泄漏。
• 逗号处理：JSON数组要求元素间用逗号分隔，通过AtomicBoolean标记第一个元素，后续元素先写逗号再序列化对象，避免出现多余逗号导致JSON格式错误。
• Stream遍历优化：用forEachRemaining遍历Stream比普通for-each更稳妥，能更好适配流式数据源的特性，避免提前终止或异常。

额外优化建议 #

• Spring项目中优先注入ObjectMapper实例（Spring Boot会自动配置全局实例，包含日期格式化、空值处理等通用配置），不要手动new。
• 可以给JsonGenerator添加配置，比如jsonGenerator.enable(JsonGenerator.Feature.AUTO_CLOSE_TARGET)（默认已开启），确保响应流在生成器关闭时自动关闭。

内容的提问来源于stack exchange，提问作者Holger Ludvigsen