java - 使用 Jackson 直接流式传输 JSON 以进行响应

Question

目前，我需要向 ajax 请求发送一个大的 json 对象。为此，我使用以下 Controller 方法，效果很好。

   @RequestMapping(method = RequestMethod.POST,params = {"dynamicScenario"})
   @ResponseBody
    public String getDynamicScenarioData(@RequestParam Map<String, String> map) throws JsonParseException, JsonMappingException, IOException
 {

  ObjectMapper mapper = new ObjectMapper();

    @SuppressWarnings("unchecked")
    Map<String,Object> queryParameters = mapper.readValue(map.get("parameters") , Map.class);

    Map<String, Object> getData = service.runDynamicScenario(queryParameters, map.get("queryString"));

    return writer.writeValueAsString(getData); //here java throws java.lang.OutOfMemoryError: Java heap space memory
} 

更新: 我的ajax是:

          $.ajax({
          type: "POST",
          url: "dynamicScenario.htm",
          data : tags,
          dataType: "json",
          success: function(data){});

我的 DispatcherServlet 设置:

           public class ApplicationInitializer implements      WebApplicationInitializer
      {
       public void onStartup(ServletContext servletContext) throws      
     ServletException 
     {
    AnnotationConfigWebApplicationContext context = new AnnotationConfigWebApplicationContext();
    context.register(ApplicationConfig.class);

    servletContext.addListener(new ContextLoaderListener(context));

    ServletRegistration.Dynamic servletRegistration = servletContext.addServlet("dispatcher", new DispatcherServlet(context));
    servletRegistration.setLoadOnStartup(1);
    servletRegistration.addMapping("*.htmlx");
  }
}

我正在使用 jackson 序列化不同对象的映射，然后将其发送回 ajax。但是，如果 json 的大小很大，那么 java 会抛出内存不足。我知道 Jackson 方法 writer.writeValueAsString 效率低下，因为它写入字符串，但还有其他选择吗？我不能使用普通的 java POJO，因为我不知道我必须序列化的映射将包含哪些对象，所以我不能简单地将它映射到某个 java 对象。有任何想法吗？谢谢

Answer 1

您要解决的问题是

return writer.writeValueAsString(getData); 

创建太大的String并导致OutOfMemoryError 。 jackson 支持 Streaming API ，Spring 在其 MappingJackson2HttpMessageConverter 中使用了它，它处理将响应正文(和请求正文)中的 POJO 序列化为 JSON。

有几种方法可以处理这个问题。最简单的方法是将返回类型更改为 Map<String, Object并直接返回对应的对象。

@RequestMapping(method = RequestMethod.POST,params = {"dynamicScenario"})
@ResponseBody
public Map<String, Object> getDynamicScenarioData(@RequestParam Map<String, String> map) throws JsonParseException, JsonMappingException, IOException
 {
     ObjectMapper mapper = new ObjectMapper();

     @SuppressWarnings("unchecked")
     Map<String,Object> queryParameters = mapper.readValue(map.get("parameters") , Map.class);

     Map<String, Object> getData = service.runDynamicScenario(queryParameters, map.get("queryString"));

     return getData;
} 

Spring 将负责序列化 getData通过将结果直接流式传输到响应 OutputStream .

这本身是行不通的。其中之一是您用来访问服务的网址

/dynamicScenario.htm

导致Spring's content negotiation它看到 .htm并认为您正在期待 text/html内容。关闭内容协商或使用不带扩展名的 URL

/dynamicScenario

Spring 将改为查看 Accept用于弄清楚您的客户期望什么的 header 。因为那是

dataType: "json"

它将写成application/json与 MappingJackson2HttpMessageConverter .

<小时/>

还有一些问题需要修复

AnnotationConfigWebApplicationContext context = new AnnotationConfigWebApplicationContext();
context.register(ApplicationConfig.class);

servletContext.addListener(new ContextLoaderListener(context));

ServletRegistration.Dynamic servletRegistration = servletContext.addServlet("dispatcher", new DispatcherServlet(context));
servletRegistration.setLoadOnStartup(1);
servletRegistration.addMapping("*.htmlx");

您目前正在制作 ContextLoaderListener和DispatcherServlet加载相同的ApplicationContext 。这是不必要的并且可能有害。 DispatcherServlet已经使用 ContextLoaderListener上下文作为父上下文。您可以在这里阅读更多相关信息:

• What is the difference between ApplicationContext and WebApplicationContext in Spring MVC?

如果您的ApplicationConfig只包含MVC配置元素，只有DispatcherServlet加载它。您不需要ContextLoaderListener 。

如果它有与 MVC 堆栈无关的其他类型的配置元素，请将其拆分为两个 @Configuration类。将 MVC 传递给 DispatcherServlet另一个到 ContextLoaderListener .

不要将 JSON 作为表单参数传递。直接将其传递到请求正文中并使用 @RequestBody将其直接反序列化为您期望的类型。

@RequestMapping(method = RequestMethod.POST)
@ResponseBody
public Map<String, Object> getDynamicScenarioData(@RequestBody Map<String,Object> queryParameters) throws JsonParseException, JsonMappingException, IOException
 {
     Map<String, Object> getData = service.runDynamicScenario(queryParameters, /* find a better way to pass this map.get("queryString") */);

     return getData;
}

你为自己节省了ObjectMapper每个请求上都有一个对象(它是一个重对象)，然后让 Spring 负责所有反序列化(再次流式传输)。您必须找到另一种方法来通过 queryString (您仍然可以将其作为单个查询参数传递并使用“@RequestParam”获取)。