轉載： https://blog.csdn.net/yingxiake/article/details/51193319
因為服務器請求處理線程的總數是有限的，如果類似的請求多了，所有的處理線程處於阻塞的狀態，那新的請求也就無法處理了，也就所謂影響了服務器的吞吐能力。要更加好地發揮服務器的全部性能，就要使用異步：
由於Spring MVC的良好封裝，異步功能使用起來出奇的簡單。傳統的同步模式的Controller是返回ModelAndView，而異步模式則是返回DeferredResult<ModelAndView>。
springmvc3.2之后支持異步請求，能夠在controller中返回一個Callable或者DeferredResult。當返回Callable的時候，大概的執行過程如下：
-
當controller返回值是Callable的時候，springmvc就會啟動一個線程將Callable交給TaskExecutor去處理
-
然后DispatcherServlet還有所有的spring攔截器都退出主線程，然后把response保持打開的狀態
-
當Callable執行結束之后，springmvc就會重新啟動分配一個request請求，獲取異步執行的返回結果，然后返回視圖
DeferredResult的執行過程和Callable差不多，唯一不同的時候，DeferredResult是由應用程序其他線程執行返回結果，而Callable是由TaskExecutor執行返回結果。
springmvc配置異步請求
1.需要在web.xml加上servlet3.0的scheme庫
<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/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") public Callable<String> mvc25() { return new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); return "task/task"; } }; }
利用Callable執行異步請求，並把請求結果通過@response由httpmessageconverter進行轉化返回客戶端
@RequestMapping("/mvc26") @ResponseBody public Callable<String> mvc26() { return new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); return "hello task"; } }; }可以自定義客戶端超時間
@RequestMapping("/mvc27") @ResponseBody public 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); }
如果在線程的執行過程中，遇到異常，處理過程和普通請求的一樣，你可以用@ExceptionHandler來處理或者定義全局的HandlerExceptionResolver來處理
@RequestMapping("/mvc28") @ResponseBody public 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) @ResponseBody public JSONObject handlerException(){ JSONObject jsonObject = new JSONObject(); jsonObject.put("aaa", 123); return jsonObject ; }
還可以通過返回DeferredResult返回，DeferredResult的作用是返回一個實例給其他線程來處理這個異步請求。
@RequestMapping("/mvc29") @ResponseBody public 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的時候就會觸發springmvc分配一個request到DispatcherServlet，然后DispatcherServlet處理DeferredResult的返回結果，並返回視圖。
DeferredResult還提供了其他返回來處理線程請求，例如onTimeout(Runnable) 還有onCompletion(Runnable)，onTimeout可以注冊一個線程回調，當請求延時的時候的回調函數，onCompletion可以注冊一個請求完成的回調函數。
@RequestMapping
(value =
"/asynctask"
, method = RequestMethod.GET)
public
DeferredResult<ModelAndView> asyncTask() {
DeferredResult<ModelAndView> deferredResult =
new
DeferredResult<ModelAndView>(2000L);
System.out.println(
"/asynctask 調用！thread id is : "
+ Thread.currentThread().getId());
longTimeAsyncCallService.makeRemoteCallAndUnknownWhenFinish(
new
LongTermTaskCallback() {
@Override
public
void
callback(Object result) {
System.out.println(
"異步調用執行完成, thread id is : "
+ Thread.currentThread().getId());
ModelAndView mav =
new
ModelAndView(
"remotecalltask"
);
mav.addObject(
"result"
, result);
deferredResult.setResult(mav);
}
});
deferredResult.onTimeout(
new
Runnable() {
@Override
public
void
run() {
System.out.println(
"異步調用執行超時！thread id is : "
+ Thread.currentThread().getId());
ModelAndView mav =
new
ModelAndView(
"remotecalltask"
);
mav.addObject(
"result"
,
"異步調用執行超時"
);
deferredResult.setResult(mav);
}
});
return
deferredResult;
}
WebAsyncTask 超時處理：
@RequestMapping(value="/longtimetask", method = RequestMethod.GET)
public WebAsyncTask longTimeTask(){
System.out.println("/longtimetask被調用 thread id is : " + Thread.currentThread().getId());
Callable<ModelAndView> callable = new Callable<ModelAndView>() {
public ModelAndView call() throws Exception {
Thread.sleep(3000); //假設是一些長時間任務
ModelAndView mav = new ModelAndView("longtimetask");
mav.addObject("result", "執行成功");
System.out.println("執行成功 thread id is : " + Thread.currentThread().getId());
return mav;
}
};
WebAsyncTask asyncTask = new WebAsyncTask(2000, callable);
asyncTask.onTimeout(
new Callable<ModelAndView>() {
public ModelAndView call() throws Exception {
ModelAndView mav = new ModelAndView("longtimetask");
mav.addObject("result", "執行超時");
System.out.println("執行超時 thread id is ：" + Thread.currentThread().getId());
return mav;
}
}
);
return asyncTask ;
超時歸超時，超時並不會打斷正常執行流程，但注意，出現超時后我們給客戶端返回了“超時”的結果，那接下來即便正常處理流程成功，客戶端也收不到正常處理成功所產生的結果了，這帶來的問題就是：客戶端看到了“超時”，實際上操作到底有沒有成功，客戶端並不知道，但通常這也不是什么大問題，因為用戶在瀏覽器上再刷新一下就好了
}