Spring MVC中的延迟结果返回错误响应

Question

我使用spring mvc 3.2.4和jquery 1.9.0进行长轮询.我的应用程序部署在Tomcat 7.0.42上.我的spring配置文件如下:

应用程序Web.xml

<web-app xmlns="http://java.sun.com/xml/ns/javaee"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://java.sun.com/xml/ns/javaee"   
  version="3.0">

    <welcome-file-list>
        <welcome-file>index.html</welcome-file>
    </welcome-file-list>

    <servlet>
        <servlet-name>app</servlet-name>

        <servlet-class>
            org.springframework.web.servlet.DispatcherServlet
        </servlet-class>

        <load-on-startup>1</load-on-startup>
        <async-supported>true</async-supported>
    </servlet>

    <servlet-mapping>
        <servlet-name>app</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>

    <listener>
        <listener-class>
            org.springframework.web.context.ContextLoaderListener
        </listener-class>
    </listener>

    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>
            /WEB-INF/app-servlet.xml
        </param-value>
    </context-param>

</web-app>

Spring Configration xml为: -

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:p="http://www.springframework.org/schema/p"
    xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
    http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.2.xsd">
        <context:annotation-config/>
        <mvc:annotation-driven/>  
        <mvc:default-servlet-handler/>
        <context:component-scan base-package="com.webchat"/>
        <bean id="defferedResult" class="com.exp.DeferredResultContainer"></bean>
</beans>

发布数据的控制器看起来像

@RequestMapping(value = "/postComment", method = RequestMethod.POST)
public @ResponseBody String postComment(HttpServletRequest request) {
    deferredResultContainer.updateAllResults(request.getParameter("comment"));
    return "success";
}

延迟结果容器类

public class DeferredResultContainer {
    private final Set<DeferredResult<String>> deferredResults =   Collections.synchronizedSet(new HashSet<DeferredResult<String>>() ); 

    public void put(DeferredResult<String> deferredResult){ 
        deferredResults.add(deferredResult); 
    } 

    public void updateAllResults(String value){
        for (DeferredResult<String> deferredResult : deferredResults){ 
            deferredResult.setResult(value); 
        }
    }

    public void remove(DeferredResult<String> deferredResult){ 
        deferredResults.remove(deferredResult); 
    } 

    public int determineSize(){
        return deferredResults.size();
    }
}

延迟结果的控制器看起来像

 @RequestMapping(value = "/getComments", method = RequestMethod.GET)
 @ResponseBody
 public DeferredResult<String> getComments() throws Exception{
     final DeferredResult<String> deferredResult= new DeferredResult<String>(); 
     deferredResultContainer.put(deferredResult);
     deferredResult.onTimeout(new Runnable() {

         @Override public void run() {
             deferredResultContainer.remove(deferredResult);
         }
     });

     deferredResult.onCompletion(new Runnable() { 
         @Override public void run() { 
             deferredResultContainer.remove(deferredResult); 
         } 
     });
     return deferredResult;
 }

当我试图通过ajax进行长时间轮询时,我得到以下回应: -

{"setOrExpired":false}

并且onCompletion方法也没有被执行.

简单来说控制器下面的东西可以得到完美的响应{{1":"2"}

@RequestMapping(value = "/test1", method = RequestMethod.GET)
@ResponseBody
public Map test1() throws Exception{
     Map m1 = new HashMap<String, Object>();
     m1.put("1", "2");
     return m1;
}

一旦我将其更改为下面并添加延迟结果我得到响应为{"setOrExpired":true}

@RequestMapping(value = "/test", method = RequestMethod.GET)
@ResponseBody
public DeferredResult<Map> test() throws Exception{
    DeferredResult<Map> result = new DeferredResult<Map>();
     Map m1 = new HashMap<String, Object>();
     m1.put("1", "2");
     result.setResult(m1);
     return result;
}

轮询代码

$(document).ready(function() {
    longPoll();

    function longPoll(){
         $.support.cors = true;
        var path = "http://localhost:8080/WebChatExp/rest";
         $.ajax({
            url: path + "/getComments",
            cache:false,
            success: function(data){
                //To Do
                            alert("Data" + JSON.stringify(data));
            },
            error: function(err, status, errorThrown ) {

            },
            type: "GET",
            dataType: "json",
            complete: longPoll,
            timeout: 60000 // timeout every one minute
        }); 
    }

我搜索了各种示例,但无法确定延迟结果是否需要任何额外配置.请指教.

Answer 1

您收到的响应正文

{"setOrExpired":true}

表示 Spring 将您的DeferredResult（具有各种属性，包括setOrExpired）序列化为 JSON，而不是使用DeferredResultMethodReturnValueHandler. 换句话说，它HandlerMethodReturnValueHandler很可能使用另一个RequestResponseBodyMethodProcessor（它处理@ResponseBody）来处理从带注释的处理程序方法返回的值@RequestMapping。（测试这一点的最简单方法是看看删除注释时会发生什么@ResponseBody。）

查看 的3.2.x 源代码RequestMappingHandlerAdapter，其中注册了默认HandlerMethodReturnValueHandler实例，DeferredResultMethodReturnValueHandler是在之前注册的RequestResponseBodyMethodProcessor，因此将DeferredResult首先处理返回值。

由于您看到了不同的行为，我们必须假设您的配置与此处显示的不同。（请注意，<mvc:annotation-driven/>注册了一个RequestMappingHandlerAdapter。）

另请注意，您当前正在两次加载配置/WEB-INF/app-servlet.xml，一次由ContextLoaderListener加载，一次由DispatcherServlet.

完全摆脱你的ContextLoaderListener和相应的context-param。您的示例中不需要它们。