个人中心
gpt4 book ai didi

springmvc处理异步请求的示例

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 24 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章springmvc处理异步请求的示例由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

springmvc 3.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库 。

?
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/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>子节点 。

?
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中执行异步请求了 。

利用Callable执行异步请求，并返回视图 。

?
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执行异步请求，并把请求结果通过@response由httpmessageconverter进行转化返回客户端 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
@RequestMapping ( "/mvc26" )
@ResponseBody
public Callable<String> mvc26() {
 
   return new Callable<String>() {
     @Override
     public String call() throws Exception {
       Thread.sleep( 2000 );
       return "hello task" ;
     }
   };
 
}

可以自定义客户端超时间 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
@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来处理 。

?
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" )
@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的作用是返回一个实例给其他线程来处理这个异步请求.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
@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可以注册一个请求完成的回调函数.

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.

原文链接：http://blog.csdn.net/yingxiake/article/details/51193319 。

最后此篇关于springmvc处理异步请求的示例的文章就讲到这里了,如果你想了解更多关于springmvc处理异步请求的示例的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

24 4 0
文章推荐： 简单易用的倒计时js代码
文章推荐： PHP 搜索查询功能实现
文章推荐： javascript中with()方法的语法格式及使用
文章推荐： php文件上传 你真的掌握了吗
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com