springmvc处理异步请求的示例
springmvc3.2开始就支持servlet3.0的异步请求。平常我们请求一个controller一般都是同步的，如果在代码执行中，遇到耗时的业务操作，那servlet容器线程就会被锁死，当有其他请求进来的时候就会受堵了。
springmvc3.2之后支持异步请求，能够在controller中返回一个Callable或者DeferredResult。当返回Callable的时候，大概的执行过程如下：
- 当controller返回值是Callable的时候，springmvc就会启动一个线程将Callable交给TaskExecutor去处理
- 然后DispatcherServlet还有所有的spring拦截器都退出主线程，然后把response保持打开的状态
- 当Callable执行结束之后，springmvc就会重新启动分配一个request请求，然后DispatcherServlet就重新调用和处理Callable异步执行的返回结果，然后返回视图
DeferredResult的执行过程和Callable差不多，唯一不同的时候，DeferredResult是由应用程序其他线程执行返回结果，而Callable是由TaskExecutor执行返回结果。
springmvc配置异步请求
1.需要在web.xml加上servlet3.0的scheme库
<web-appxmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" version="3.0"> ... </web-app>
2.在web.xml的servlet还有filter添加<asyncsupported>true</async-supported>子节点
<!--springMVC的Servlet配置--> <servlet> <servlet-name>dispatcher</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value>classpath*:META-INF/dispatcher-context.xml</param-value> </init-param> <load-on-startup>1</load-on-startup> <async-supported>true</async-supported> </servlet> <!--编码拦截--> <filter> <filter-name>CharacterEncodingFilter</filter-name> <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class> <async-supported>true</async-supported> <init-param> <param-name>encoding</param-name> <param-value>UTF-8</param-value> </init-param> <init-param> <param-name>forceEncoding</param-name> <param-value>true</param-value> </init-param> </filter>
3.然后就可以在controller中执行异步请求了
利用Callable执行异步请求，并返回视图
@RequestMapping("/mvc25")
publicCallable<String>mvc25(){
returnnewCallable<String>(){
@Override
publicStringcall()throwsException{
Thread.sleep(2000);
return"task/task";
}
};
}
利用Callable执行异步请求，并把请求结果通过@response由httpmessageconverter进行转化返回客户端
@RequestMapping("/mvc26")
@ResponseBody
publicCallable<String>mvc26(){
returnnewCallable<String>(){
@Override
publicStringcall()throwsException{
Thread.sleep(2000);
return"hellotask";
}
};
}
可以自定义客户端超时间
@RequestMapping("/mvc27")
@ResponseBody
publicWebAsyncTask<String>mvc27(){
Callable<String>callable=newCallable<String>(){
@Override
publicStringcall()throwsException{
Thread.sleep(10000);
return"hellotask";
}
};
returnnewWebAsyncTask<String>(10000,callable);
}
如果在线程的执行过程中，遇到异常，处理过程和普通请求的一样，你可以用@ExceptionHandler来处理或者定义全局的HandlerExceptionResolver来处理
@RequestMapping("/mvc28")
@ResponseBody
publicCallable<String>mvc28(){
Callable<String>callable=newCallable<String>(){
@Override
publicStringcall()throwsException{
Thread.sleep(2000);
thrownewRuntimeException();
}
};
returncallable;
}
@ExceptionHandler(RuntimeException.class)
@ResponseBody
publicJSONObjecthandlerException(){
JSONObjectjsonObject=newJSONObject();
jsonObject.put("aaa",123);
returnjsonObject;
}
还可以通过返回DeferredResult返回，DeferredResult的作用是返回一个实例给其他线程来处理这个异步请求。
@RequestMapping("/mvc29")
@ResponseBody
publicDeferredResult<String>mvc29(){
DeferredResult<String>deferredResult=newDeferredResult<String>();
dealInOtherThread(deferredResult);
returndeferredResult;
}
privatevoiddealInOtherThread(DeferredResult<String>deferredResult){
try{
Thread.sleep(2000);
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
deferredResult.setResult("hellotask");
}
dealInOtherThread处理完成，setResult的时候就会触发springmvc分配一个request到DispatcherServlet，然后DispatcherServlet处理DeferredResult的返回结果，并返回视图。
DeferredResult还提供了其他返回来处理线程请求，例如onTimeout(Runnable)还有onCompletion(Runnable)，onTimeout可以注册一个线程回调，当请求延时的时候的回调函数，onCompletion可以注册一个请求完成的回调函数。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。