2

我正在尝试测试Spring MVC 控制器的最新异步功能，但我无法让它工作。

这是我的异步方法的代码：

@RequestMapping(value = "/hello")
    public Callable<String> async(final Model model) {
        System.out.println("entered async controller method");
        return new Callable<String>() {
            public String call() throws Exception {
                Thread.sleep(2000L);
                model.addAttribute("message", "asyncRequest dealt with");
                System.out.println("about to return from call()");
                return "hello";
            }
        };
}

以下是 web.xml 中的相关部分：

<servlet>
    <servlet-name>SpringMVC</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <init-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/spring/webmvc-config.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
    <async-supported>true</async-supported>
</servlet>

但是，控制台中永远不会打印“即将从 call() 返回”，我也永远不会看到这样的日志： 08:25: 17 [MvcAsync1] WebAsyncManager - ...在控制台中......

仅供参考，我使用 Spring 3.2.RC2

4

3 回答 3

6

为了进一步配置async-support工具AsyncTaskExecutor

默认情况下，Spring MVC 使用 aSimpleAsyncTaskExecutor来执行控制器方法返回的 Callable 实例。对于生产，您必须将其替换AsyncTaskExecutor为为您的环境适当配置的实现。

创建 AsyncTaskExecutor

<beans:bean id="asyncTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <beans:property name="corePoolSize" value="5" />
    <beans:property name="maxPoolSize" value="10" />
    <beans:property name="queueCapacity" value="25" />
</beans:bean>

然后分配task-executor

<mvc:annotation-driven >
    <mvc:async-support default-timeout="30000" task-executor="asyncTaskExecutor" />
</mvc:annotation-driven>

http://blog.springsource.org/2012/05/10/spring-mvc-3-2-preview-making-a-controller-method-asynchronous/

于 2013-07-27T02:14:52.413 回答
2

我终于找到了我的示例不起作用的原因：必须将以下内容添加到 web-mvc 配置文件中：

<mvc:annotation-driven>
    <mvc:async-support default-timeout="3000"/>
</mvc:annotation-driven>
于 2012-11-30T20:02:32.867 回答
0

嗨，使用以下代码执行类似的应用程序：

public String doSlowWork() {

     System.out.println("Start  slow work");
    try {
      Thread.sleep(3000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    System.out.println("finish slow work");

    return "index";       // return view's name
  }

返回索引但不给出方法的日志信息

于 2015-09-28T08:49:38.293 回答