springmvc处理异步请求的示例

发布时间 - 2026-01-10 22:47:49    点击率:

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库

<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可以注册一个请求完成的回调函数。

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


# springmvc的异步请求  # spring  # mvc异步处理  # mvc  # 异步请求  # SpringMVC文件上传请求问题分析  # SpringMVC请求、响应和拦截器的使用实例详解  # 详解springmvc如何处理接受http请求  # SpringMVC的五大核心组件用法及说明  # SpringMVC处理multipart请求的示例代码  # Springmvc ajax跨域请求处理方法实例详解  # Spring MVC核心组件与请求处理流程分析  # 就会  # 回调  # 是由  # 客户端  # 都是  # 还可以  # 可以用  # 自定义  # 重新启动  # 并把  # 大家多多  # 就可以  # 过程中  # 应用程序  # 结束之后  # 返回值  # 拦截器  # xsi  # www  # supported 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: 作用域操作符会触发自动加载吗_php类自动加载机制与::调用【教程】  Windows10电脑怎么设置虚拟光驱_Win10右键装载ISO镜像文件  Laravel如何优雅地处理服务层_在Laravel中使用Service层和Repository层  如何快速重置建站主机并恢复默认配置?  Microsoft Edge如何解决网页加载问题 Edge浏览器加载问题修复  Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程  Laravel模型关联查询教程_Laravel Eloquent一对多关联写法  大连网站制作费用,大连新青年网站,五年四班里的视频怎样下载啊?  高端企业智能建站程序:SEO优化与响应式模板定制开发  标题:Vue + Vuex + JWT 身份认证的正确实践与常见误区解析  如何在新浪SAE免费搭建个人博客?  Python面向对象测试方法_mock解析【教程】  韩国服务器如何优化跨境访问实现高效连接?  Laravel如何发送邮件_Laravel Mailables构建与发送邮件的简明教程  网站制作大概要多少钱一个,做一个平台网站大概多少钱?  什么是JavaScript解构赋值_解构赋值有哪些实用技巧  Laravel Vite是做什么的_Laravel前端资源打包工具Vite配置与使用  Laravel广播系统如何实现实时通信_Laravel Reverb与WebSockets实战教程  如何用wdcp快速搭建高效网站?  Win11搜索栏无法输入_解决Win11开始菜单搜索没反应问题【技巧】  如何在万网主机上快速搭建网站?  Laravel项目结构怎么组织_大型Laravel应用的最佳目录结构实践  Win11怎么恢复误删照片_Win11数据恢复工具使用【推荐】  微信h5制作网站有哪些,免费微信H5页面制作工具?  JavaScript如何实现路由_前端路由原理是什么  Python函数文档自动校验_规范解析【教程】  iOS UIView常见属性方法小结  如何快速启动建站代理加盟业务?  如何为不同团队 ID 动态生成多个“认领值班”按钮  为什么php本地部署后css不生效_静态资源加载失败修复技巧【技巧】  千问怎样用提示词获取健康建议_千问健康类提示词注意事项【指南】  如何快速生成高效建站系统源代码?  canvas 画布在主流浏览器中的尺寸限制详细介绍  如何在 Telegram Web View(iOS)中防止键盘遮挡底部输入框  如何在腾讯云服务器上快速搭建个人网站?  焦点电影公司作品,电影焦点结局是什么?  Laravel怎么实现微信登录_Laravel Socialite第三方登录集成  桂林网站制作公司有哪些,桂林马拉松怎么报名?  长沙企业网站制作哪家好,长沙水业集团官方网站?  Laravel如何清理系统缓存命令_Laravel清除路由配置及视图缓存的方法【总结】  Laravel DB事务怎么使用_Laravel数据库事务回滚操作  北京企业网站设计制作公司,北京铁路集团官方网站?  JavaScript如何实现继承_有哪些常用方法  浅谈Javascript中的Label语句  php打包exe后无法访问网络共享_共享权限设置方法【教程】  如何使用 jQuery 正确渲染 Instagram 风格的标签列表  Laravel如何实现API资源集合?(Resource Collection教程)  如何打造高效商业网站?建站目的决定转化率  深圳网站制作的公司有哪些,dido官方网站?  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛,就是里面都是武汉人的?