• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

springmvc处理异步请求的示例

java 搞代码 4年前 (2022-01-05) 21次浏览 已收录 0个评论

这篇文章主要介绍了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库

  ... 

2.在web.xml的servlet还有f来源gao@daima#com搞(%代@#码网ilter添加true子节点

 <!-- springMVC的Servlet配置 --> dispatcherorg.springframework.web.servlet.DispatcherServlet contextConfigLocationclasspath*:META-INF/dispatcher-context.xml1true<!-- 编码拦截 --> CharacterEncodingFilterorg.springframework.web.filter.CharacterEncodingFiltertrue encodingUTF-8 forceEncodingtrue

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

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

 @RequestMapping("/mvc25") public Callable mvc25() { return new Callable() { @Override public String call() throws Exception { Thread.sleep(2000); return "task/task"; } }; } 

利用Callable执行异步请求,并把请求结果通过@response由httpmessageconverter进行转化返回客户端

 @RequestMapping("/mvc26") @ResponseBody public Callable mvc26() { return new Callable() { @Override public String call() throws Exception { Thread.sleep(2000); return "hello task"; } }; } 

可以自定义客户端超时间

 @RequestMapping("/mvc27") @ResponseBody public WebAsyncTask mvc27() { Callable callable = new Callable() { @Override public String call() throws Exception { Thread.sleep(10000); return "hello task"; } }; return new WebAsyncTask(10000, callable); } 

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

 @RequestMapping("/mvc28") @ResponseBody public Callable mvc28() { Callable callable = new Callable() { @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 mvc29() { DeferredResult deferredResult = 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处理完成,setResult的时候就会触发springmvc分配一个request到DispatcherServlet,然后DispatcherServlet处理DeferredResult的返回结果,并返回视图。

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

以上就是springmvc处理异步请求的示例的详细内容,更多请关注gaodaima搞代码网其它相关文章!


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:springmvc处理异步请求的示例

喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址