java异步提交退出,springmvc处理异步请求的示例

springmvc 3.2开始就支持servlet3.0的异步请求。平常我们请求一个controller一般都是同步的&＃xff0c;如果在代码执行中&＃xff0c;遇到耗时的业务操作&＃xff0c;那servlet容器线程就会被锁死&＃xff0c;当有其他请求进来的时候就会受堵了。

springmvc3.2之后支持异步请求&＃xff0c;能够在controller中返回一个Callable或者DeferredResult。当返回Callable的时候&＃xff0c;大概的执行过程如下&＃xff1a;

当controller返回值是Callable的时候&＃xff0c;springmvc就会启动一个线程将Callable交给TaskExecutor去处理

然后DispatcherServlet还有所有的spring拦截器都退出主线程&＃xff0c;然后把response保持打开的状态

当Callable执行结束之后&＃xff0c;springmvc就会重新启动分配一个request请求&＃xff0c;然后DispatcherServlet就重新调用和处理Callable异步执行的返回结果&＃xff0c;然后返回视图

DeferredResult的执行过程和Callable差不多&＃xff0c;唯一不同的时候&＃xff0c;DeferredResult是由应用程序其他线程执行返回结果&＃xff0c;而Callable是由TaskExecutor执行返回结果。

springmvc配置异步请求

1.需要在web.xml加上servlet3.0的scheme库

xmlns:xsi&＃61;"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&＃61;"3.0">

...

2.在web.xml的servlet还有filter添加true子节点

dispatcher

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath*:META-INF/dispatcher-context.xml

1

true

CharacterEncodingFilter

org.springframework.web.filter.CharacterEncodingFilter

true

encoding

UTF-8

forceEncoding

true

3.然后就可以在controller中执行异步请求了

利用Callable执行异步请求&＃xff0c;并返回视图

&＃64;RequestMapping("/mvc25")

public Callable mvc25() {

return new Callable() {

&＃64;Override

public String call() throws Exception {

Thread.sleep(2000);

return "task/task";

}

};

}

利用Callable执行异步请求&＃xff0c;并把请求结果通过&＃64;response由httpmessageconverter进行转化返回客户端

&＃64;RequestMapping("/mvc26")

&＃64;ResponseBody

public Callable mvc26() {

return new Callable() {

&＃64;Override

public String call() throws Exception {

Thread.sleep(2000);

return "hello task";

}

};

}

可以自定义客户端超时间

&＃64;RequestMapping("/mvc27")

&＃64;ResponseBody

public WebAsyncTask mvc27() {

Callable callable &＃61; new Callable() {

&＃64;Override

public String call() throws Exception {

Thread.sleep(10000);

return "hello task";

}

};

return new WebAsyncTask(10000, callable);

}

如果在线程的执行过程中&＃xff0c;遇到异常&＃xff0c;处理过程和普通请求的一样&＃xff0c;你可以用&＃64;ExceptionHandler来处理或者定义全局的HandlerExceptionResolver来处理

&＃64;RequestMapping("/mvc28")

&＃64;ResponseBody

public Callable mvc28() {

Callable callable &＃61; new Callable() {

&＃64;Override

public String call() throws Exception {

Thread.sleep(2000);

throw new RuntimeException();

}

};

return callable;

}

&＃64;ExceptionHandler(RuntimeException.class)

&＃64;ResponseBody

public JSONObject handlerException(){

JSONObject jsonObject &＃61; new JSONObject();

jsonObject.put("aaa", 123);

return jsonObject ;

}

还可以通过返回DeferredResult返回&＃xff0c;DeferredResult的作用是返回一个实例给其他线程来处理这个异步请求。

&＃64;RequestMapping("/mvc29")

&＃64;ResponseBody

public DeferredResult mvc29() {

DeferredResult deferredResult &＃61; new DeferredResult();

dealInOtherThread(deferredResult);

return deferredResult;

}

private void dealInOtherThread(DeferredResult deferredResult) {

try {

Thread.sleep(2000);

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

deferredResult.setResult("hello task");

}

dealInOtherThread处理完成&＃xff0c;setResult的时候就会触发springmvc分配一个request到DispatcherServlet&＃xff0c;然后DispatcherServlet处理DeferredResult的返回结果&＃xff0c;并返回视图。

DeferredResult还提供了其他返回来处理线程请求&＃xff0c;例如onTimeout(Runnable) 还有onCompletion(Runnable)&＃xff0c;onTimeout可以注册一个线程回调&＃xff0c;当请求延时的时候的回调函数&＃xff0c;onCompletion可以注册一个请求完成的回调函数。

以上就是本文的全部内容&＃xff0c;希望对大家的学习有所帮助&＃xff0c;也希望大家多多支持脚本之家。