springmvc 3.2開始就支持servlet3.0的異步請(qǐng)求。平常我們請(qǐng)求一個(gè)controller一般都是同步的，如果在代碼執(zhí)行中，遇到耗時(shí)的業(yè)務(wù)操作，那servlet容器線程就會(huì)被鎖死，當(dāng)有其他請(qǐng)求進(jìn)來的時(shí)候就會(huì)受堵了。
springmvc3.2之后支持異步請(qǐng)求，能夠在controller中返回一個(gè)Callable或者DeferredResult。當(dāng)返回Callable的時(shí)候，大概的執(zhí)行過程如下：
- 當(dāng)controller返回值是Callable的時(shí)候，springmvc就會(huì)啟動(dòng)一個(gè)線程將Callable交給TaskExecutor去處理
- 然后DispatcherServlet還有所有的spring攔截器都退出主線程，然后把response保持打開的狀態(tài)
- 當(dāng)Callable執(zhí)行結(jié)束之后，springmvc就會(huì)重新啟動(dòng)分配一個(gè)request請(qǐng)求，然后DispatcherServlet就重新調(diào)用和處理Callable異步執(zhí)行的返回結(jié)果，然后返回視圖
DeferredResult的執(zhí)行過程和Callable差不多，唯一不同的時(shí)候，DeferredResult是由應(yīng)用程序其他線程執(zhí)行返回結(jié)果，而Callable是由TaskExecutor執(zhí)行返回結(jié)果。
springmvc配置異步請(qǐng)求
1.需要在web.xml加上servlet3.0的scheme庫(kù)
|
1
2
3
4
5
6
7
|
<web-app xmlns="http://java.sun.com/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"http://java.sun.com/xml/ns/javaeehttp://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>子節(jié)點(diǎn)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
<!-- 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中執(zhí)行異步請(qǐng)求了
利用Callable執(zhí)行異步請(qǐng)求，并返回視圖
|
1
2
3
4
5
6
7
8
9
10
11
12
|
@RequestMapping("/mvc25")public Callable<String> mvc25() { return new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); return "task/task"; } };} |
利用Callable執(zhí)行異步請(qǐng)求，并把請(qǐng)求結(jié)果通過@response由httpmessageconverter進(jìn)行轉(zhuǎn)化返回客戶端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
@RequestMapping("/mvc26")@ResponseBodypublic Callable<String> mvc26() { return new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); return "hello task"; } };} |
可以自定義客戶端超時(shí)間
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@RequestMapping("/mvc27")@ResponseBodypublic WebAsyncTask<String> mvc27() { Callable<String> callable = new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(10000); return "hello task"; } }; return new WebAsyncTask<String>(10000, callable);} |
如果在線程的執(zhí)行過程中，遇到異常，處理過程和普通請(qǐng)求的一樣，你可以用@ExceptionHandler來處理或者定義全局的HandlerExceptionResolver來處理
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
@RequestMapping("/mvc28")@ResponseBodypublic Callable<String> mvc28() { Callable<String> callable = new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); throw new RuntimeException(); } }; return callable;}@ExceptionHandler(RuntimeException.class)@ResponseBodypublic JSONObject handlerException(){ JSONObject jsonObject = new JSONObject(); jsonObject.put("aaa", 123); return jsonObject ;} |
還可以通過返回DeferredResult返回，DeferredResult的作用是返回一個(gè)實(shí)例給其他線程來處理這個(gè)異步請(qǐng)求。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
@RequestMapping("/mvc29")@ResponseBodypublic DeferredResult<String> mvc29() { DeferredResult<String> deferredResult = new DeferredResult<String>(); dealInOtherThread(deferredResult); return deferredResult;}private void dealInOtherThread(DeferredResult<String> deferredResult) { try { Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } deferredResult.setResult("hello task");} |
dealInOtherThread處理完成，setResult的時(shí)候就會(huì)觸發(fā)springmvc分配一個(gè)request到DispatcherServlet，然后DispatcherServlet處理DeferredResult的返回結(jié)果，并返回視圖。
DeferredResult還提供了其他返回來處理線程請(qǐng)求，例如onTimeout(Runnable) 還有onCompletion(Runnable)，onTimeout可以注冊(cè)一個(gè)線程回調(diào)，當(dāng)請(qǐng)求延時(shí)的時(shí)候的回調(diào)函數(shù)，onCompletion可以注冊(cè)一個(gè)請(qǐng)求完成的回調(diào)函數(shù)。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：http://blog.csdn.net/yingxiake/article/details/51193319
