详解SpringBoot中异步请求和异步调用(看完这一篇就够了)

一、SpringBoot中异步请求的使用

1、异步请求与同步请求

特点:

可以先释放容器分配给请求的线程与相关资源,减轻系统负担,释放了容器所分配线程的请求,其响应将被延后,可以在耗时处理完成(例如长时间的运算)时再对客户端进行响应。一句话:增加了服务器对客户端请求的吞吐量(实际生产上我们用的比较少,如果并发请求量很大的情况下,我们会通过nginx把请求负载到集群服务的各个节点上来分摊请求压力,当然还可以通过消息队列来做请求的缓冲)。

2、异步请求的实现

方式一:Servlet方式实现异步请求

@RequestMapping(value = "/email/servletReq", method = GET)
 public void servletReq (HttpServletRequest request, HttpServletResponse response) {
  AsyncContext asyncContext = request.startAsync();
  //设置监听器:可设置其开始、完成、异常、超时等事件的回调处理
 asyncContext.addListener(new AsyncListener() {
   @Override
   public void onTimeout(AsyncEvent event) throws IOException {
    System.out.println("超时了...");
    //做一些超时后的相关操作...
   }
   @Override
   public void onStartAsync(AsyncEvent event) throws IOException {
    System.out.println("线程开始");
   }
   @Override
   public void onError(AsyncEvent event) throws IOException {
    System.out.println("发生错误:"+event.getThrowable());
   }
   @Override
   public void onComplete(AsyncEvent event) throws IOException {
    System.out.println("执行完成");
    //这里可以做一些清理资源的操作...
   }
  });
  //设置超时时间
  asyncContext.setTimeout(20000);
  asyncContext.start(new Runnable() {
   @Override
   public void run() {
    try {
     Thread.sleep(10000);
     System.out.println("内部线程:" + Thread.currentThread().getName());
     asyncContext.getResponse().setCharacterEncoding("utf-8");
     asyncContext.getResponse().setContentType("text/html;charset=UTF-8");
     asyncContext.getResponse().getWriter().println("这是异步的请求返回");
    } catch (Exception e) {
     System.out.println("异常:"+e);
    }
    //异步请求完成通知
    //此时整个请求才完成
    asyncContext.complete();
   }
  });
  //此时之类 request的线程连接已经释放了
  System.out.println("主线程:" + Thread.currentThread().getName());
 }

方式二:使用很简单,直接返回的参数包裹一层callable即可,可以继承WebMvcConfigurerAdapter类来设置默认线程池和超时处理

@RequestMapping(value = "/email/callableReq", method = GET)
 @ResponseBody
 public Callable<String> callableReq () {
  System.out.println("外部线程:" + Thread.currentThread().getName());
  return new Callable<String>() {
   @Override
   public String call() throws Exception {
    Thread.sleep(10000);
    System.out.println("内部线程:" + Thread.currentThread().getName());
    return "callable!";
   }
  };
 }
 @Configuration
 public class RequestAsyncPoolConfig extends WebMvcConfigurerAdapter {
 @Resource
 private ThreadPoolTaskExecutor myThreadPoolTaskExecutor;
 @Override
 public void configureAsyncSupport(final AsyncSupportConfigurer configurer) {
  //处理 callable超时
  configurer.setDefaultTimeout(60*1000);
  configurer.setTaskExecutor(myThreadPoolTaskExecutor);
  configurer.registerCallableInterceptors(timeoutCallableProcessingInterceptor());
 }
 @Bean
 public TimeoutCallableProcessingInterceptor timeoutCallableProcessingInterceptor() {
  return new TimeoutCallableProcessingInterceptor();
 }
}

方式三:和方式二差不多,在Callable外包一层,给WebAsyncTask设置一个超时回调,即可实现超时处理

@RequestMapping(value = "/email/webAsyncReq", method = GET)
@ResponseBody
public WebAsyncTask<String> webAsyncReq () {
 System.out.println("外部线程:" + Thread.currentThread().getName());
 Callable<String> result = () -> {
  System.out.println("内部线程开始:" + Thread.currentThread().getName());
  try {
   TimeUnit.SECONDS.sleep(4);
  } catch (Exception e) {
   // TODO: handle exception
  }
  logger.info("副线程返回");
  System.out.println("内部线程返回:" + Thread.currentThread().getName());
  return "success";
 };
 WebAsyncTask<String> wat = new WebAsyncTask<String>(3000L, result);
 wat.onTimeout(new Callable<String>() {

  @Override
  public String call() throws Exception {
   // TODO Auto-generated method stub
   return "超时";
  }
 });
 return wat;
}

方式四:DeferredResult可以处理一些相对复杂一些的业务逻辑,最主要还是可以在另一个线程里面进行业务处理及返回,即可在两个完全不相干的线程间的通信。

@RequestMapping(value = "/email/deferredResultReq", method = GET)
@ResponseBody
public DeferredResult<String> deferredResultReq () {
 System.out.println("外部线程:" + Thread.currentThread().getName());
 //设置超时时间
 DeferredResult<String> result = new DeferredResult<String>(60*1000L);
 //处理超时事件 采用委托机制
 result.onTimeout(new Runnable() {

  @Override
  public void run() {
   System.out.println("DeferredResult超时");
   result.setResult("超时了!");
  }
 });
 result.onCompletion(new Runnable() {

  @Override
  public void run() {
   //完成后
   System.out.println("调用完成");
  }
 });
 myThreadPoolTaskExecutor.execute(new Runnable() {

  @Override
  public void run() {
   //处理业务逻辑
   System.out.println("内部线程:" + Thread.currentThread().getName());
   //返回结果
   result.setResult("DeferredResult!!");
  }
 });
 return result;
}

二、SpringBoot中异步调用的使用

1、介绍

异步请求的处理。除了异步请求,一般上我们用的比较多的应该是异步调用。通常在开发过程中,会遇到一个方法是和实际业务无关的,没有紧密性的。比如记录日志信息等业务。这个时候正常就是启一个新线程去做一些业务处理,让主线程异步的执行其他业务。

2、使用方式(基于spring下)

  • 需要在启动类加入@EnableAsync使异步调用@Async注解生效
  • 在需要异步执行的方法上加入此注解即可@Async(“threadPool”),threadPool为自定义线程池
  • 代码略。。。就俩标签,自己试一把就可以了

3、注意事项

  • 在默认情况下,未设置TaskExecutor时,默认是使用SimpleAsyncTaskExecutor这个线程池,但此线程不是真正意义上的线程池,因为线程不重用,每次调用都会创建一个新的线程。可通过控制台日志输出可以看出,每次输出线程名都是递增的。所以最好我们来自定义一个线程池。
  • 调用的异步方法,不能为同一个类的方法(包括同一个类的内部类),简单来说,因为Spring在启动扫描时会为其创建一个代理类,而同类调用时,还是调用本身的代理类的,所以和平常调用是一样的。其他的注解如@Cache等也是一样的道理,说白了,就是Spring的代理机制造成的。所以在开发中,最好把异步服务单独抽出一个类来管理。下面会重点讲述。。

4、什么情况下会导致@Async异步方法会失效?

调用同一个类下注有@Async异步方法:在spring中像@Async和@Transactional、cache等注解本质使用的是动态代理,其实Spring容器在初始化的时候Spring容器会将含有AOP注解的类对象“替换”为代理对象(简单这么理解),那么注解失效的原因就很明显了,就是因为调用方法的是对象本身而不是代理对象,因为没有经过Spring容器,那么解决方法也会沿着这个思路来解决。

  • 调用的是静态(static )方法
  • 调用(private)私有化方法

5、解决4中问题1的方式(其它2,3两个问题自己注意下就可以了)

将要异步执行的方法单独抽取成一个类,原理就是当你把执行异步的方法单独抽取成一个类的时候,这个类肯定是被Spring管理的,其他Spring组件需要调用的时候肯定会注入进去,这时候实际上注入进去的就是代理类了。

其实我们的注入对象都是从Spring容器中给当前Spring组件进行成员变量的赋值,由于某些类使用了AOP注解,那么实际上在Spring容器中实际存在的是它的代理对象。那么我们就可以通过上下文获取自己的代理对象调用异步方法。

@Controller
@RequestMapping("/app")
public class EmailController {
 //获取ApplicationContext对象方式有多种,这种最简单,其它的大家自行了解一下
 @Autowired
 private ApplicationContext applicationContext;

  @RequestMapping(value = "/email/asyncCall", method = GET)
  @ResponseBody
  public Map<String, Object> asyncCall () {
    Map<String, Object> resMap = new HashMap<String, Object>();
    try{
  //这样调用同类下的异步方法是不起作用的
      //this.testAsyncTask();
  //通过上下文获取自己的代理对象调用异步方法
   EmailController emailController = (EmailController)applicationContext.getBean(EmailController.class);
   emailController.testAsyncTask();
      resMap.put("code",200);
    }catch (Exception e) {
  resMap.put("code",400);
      logger.error("error!",e);
    }
    return resMap;
  }
 //注意一定是public,且是非static方法
 @Async
  public void testAsyncTask() throws InterruptedException {
    Thread.sleep(10000);
    System.out.println("异步任务执行完成!");
  }
}

开启cglib代理,手动获取Spring代理类,从而调用同类下的异步方法。

首先,在启动类上加上@EnableAspectJAutoProxy(exposeProxy = true)注解。

代码实现,如下:

@Service
@Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
public class EmailService {
  @Autowired
  private ApplicationContext applicationContext;
  @Async
  public void testSyncTask() throws InterruptedException {
    Thread.sleep(10000);
    System.out.println("异步任务执行完成!");
  }
  public void asyncCallTwo() throws InterruptedException {
    //this.testSyncTask();
//    EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class);
//    emailService.testSyncTask();
    boolean isAop = AopUtils.isAopProxy(EmailController.class);//是否是代理对象;
    boolean isCglib = AopUtils.isCglibProxy(EmailController.class); //是否是CGLIB方式的代理对象;
    boolean isJdk = AopUtils.isJdkDynamicProxy(EmailController.class); //是否是JDK动态代理方式的代理对象;
    //以下才是重点!!!
 EmailService emailService = (EmailService)applicationContext.getBean(EmailService.class);
    EmailService proxy = (EmailService) AopContext.currentProxy();
    System.out.println(emailService == proxy ? true : false);
    proxy.testSyncTask();
    System.out.println("end!!!");
  }
}

三、异步请求与异步调用的区别

  • 两者的使用场景不同,异步请求用来解决并发请求对服务器造成的压力,从而提高对请求的吞吐量;而异步调用是用来做一些非主线流程且不需要实时计算和响应的任务,比如同步日志到kafka中做日志分析等。
  • 异步请求是会一直等待response相应的,需要返回结果给客户端的;而异步调用我们往往会马上返回给客户端响应,完成这次整个的请求,至于异步调用的任务后台自己慢慢跑就行,客户端不会关心。

四、总结

  • 异步请求和异步调用的使用到这里基本就差不多了,有问题还希望大家多多指出。
  • 这边文章提到了动态代理,而spring中Aop的实现原理就是动态代理,后续会对动态代理做详细解读,还望多多支持哈~

总结

以上所述是小编给大家介绍的SpringBoot中异步请求和异步调用问题,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对我们网站的支持!

时间: 2019-04-06

springboot获取URL请求参数的多种方式

1.直接把表单的参数写在Controller相应的方法的形参中,适用于get方式提交,不适用于post方式提交. /** * 1.直接把表单的参数写在Controller相应的方法的形参中 * @param username * @param password * @return */ @RequestMapping("/addUser1") public String addUser1(String username,String password) { System.out.pri

详解SpringBoot多跨域请求的支持(JSONP)

在我们做项目的过程中,有可能会遇到跨域请求,所以需要我们自己组装支持跨域请求的JSONP数据,而在4.1版本以后的SpringMVC中,为我们提供了一个AbstractJsonpResponseBodyAdvice的类用来支持jsonp的数据(SpringBoot接收解析web请求是依赖于SpringMVC实现的).下面我们就看一下怎么用AbstractJsonpResponseBodyAdvice来支持跨域请求. 使用AbstractJsonpResponseBodyAdvice来支持跨域请求

SpringBoot构建Restful service完成Get和Post请求

一个基本的RESTfule service最进场向外提供的请求Method就是Get和Post. 在Get中,常用的都会在请求上带上参数,或者是路径参数.响应Json. 在Post中,常用的会提交form data或者json data作为参数,响应Json. 1. Get请求,url传参,返回json. 先准备一个请求后,响应的对象. package com.example.demo; public class Echo { private final long id; private fin

spring boot配合前端实现跨域请求访问

一.方法: 服务端设置Respone Header头中Access-Control-Allow-Origin 配合前台使用jsonp 继承WebMvcConfigurerAdapter 添加配置类 二.实例: 1.前端:因为我们用了前后端分离,前端用node服务器,node服务器再用了ajax反向代理请求到我的spring boot 服务器.其中node服务器也用了ajax发出请求所以也存在跨域的问题.具体代码: app.all(apiRoot + '/*', proxy('127.0.0.1:

spring boot请求异常处理并返回对应的html页面

通过之前的学习,我知道中间件可以预处理http请求并返回相应页面(比如出现404异常,可以返回一个自己编写的异常界面,而非默认使用的白板404页面,很难看).其实spring boot也提供了这样的功能. 404异常处理: @Controller public class ErrorHandler404 implements ErrorController { private static final String ERROR_PATH = "/error"; @RequestMapp

vue+springboot实现项目的CORS跨域请求

跨域资源共享CORS(Cross-origin Resource Sharing),是W3C的一个标准,允许浏览器向跨源的服务器发起XMLHttpRequest请求,克服ajax请求只能同源使用的限制.关于CORS的详细解读,可参考阮一峰大神的博客:跨域资源共享CORS详解.本文为通过一个小demo对该博客中分析内容的一些验证. 1.springboot+vue项目的构建和启动 细节不在此赘述,任何简单的springboot项目就可以,而前端vue项目只需用axios发ajax请求即可. 我的d

spring boot中使用http请求的示例代码

因为项目需求,需要两个系统之间进行通信,经过一番调研,决定使用http请求. 服务端没有什么好说的,本来就是使用web 页面进行访问的,所以spring boot启动后,controller层的接口就自动暴露出来了,客户端通过调用对应的url即可,所以这里主要就客户端. 首先我自定义了一个用来处理http 请求的工具类DeviceFactoryHttp,既然是url访问,那就有两个问题需要处理,一个请求服务的url,和请求服务端的参数,客户端的消息头请求服务的url:请求服务端url我定义的是跟

Spring Boot实现异步请求(Servlet 3.0)

在spring 3.2 及以后版本中增加了对请求的异步处理,旨在提高请求的处理速度降低服务性能消耗. 在我们的请求中做了耗时处理,当并发请求的情况下,为了避免web server的连接池被长期占用而引起性能问题,调用后生成一个非web的服务线程来处理,增加web服务器的吞吐量. 为此 Servlet 3.0 新增了请求的异步处理,Spring 也在此基础上做了封装处理. 本文还是以代码例子的方式说明如何在 Spring Boot 中应用异步请求. 首先说一下几个要点: 1.@WebFilter

SpringBoot+SpringSecurity处理Ajax登录请求问题(推荐)

最近在项目中遇到了这样一个问题:前后端分离,前端用Vue来做,所有的数据请求都使用vue-resource,没有使用表单,因此数据交互都是使用JSON,后台使用Spring Boot,权限验证使用了Spring Security,因为之前用Spring Security都是处理页面的,这次单纯处理Ajax请求,因此记录下遇到的一些问题.这里的解决方案不仅适用于Ajax请求,也可以解决移动端请求验证. 创建工程 首先我们需要创建一个Spring Boot工程,创建时需要引入Web.Spring S

spring boot配置多个请求服务代理的完整步骤

springboot 配置服务代理 有时候,我们可能有下边这样的需求: 即,针对于分布式服务,我们会有多种业务接口服务,但是服务器上可能只要求开放一个服务的端口,比如上图的restA项目端口是对外开放的,但是restB项目端口并未对外开放,这样带来的问题就是,用户无法直接请求restB项目. 那就想到了可以通过访问restA ,请求路径符合一定规范的时候,比如http://ip:port/test ,当请求中以rest 开头时,可以再转发请求到restB 项目中即可. 当然代理转发 ,有很多的解

通过Spring Boot配置动态数据源访问多个数据库的实现代码

之前写过一篇博客<Spring+Mybatis+Mysql搭建分布式数据库访问框架>描述如何通过Spring+Mybatis配置动态数据源访问多个数据库.但是之前的方案有一些限制(原博客中也描述了):只适用于数据库数量不多且固定的情况.针对数据库动态增加的情况无能为力. 下面讲的方案能支持数据库动态增删,数量不限. 数据库环境准备 下面一Mysql为例,先在本地建3个数据库用于测试.需要说明的是本方案不限数据库数量,支持不同的数据库部署在不同的服务器上.如图所示db_project_001.d

Spring Boot和Docker实现微服务部署的方法

Spring boot 开发轻巧的微服务提供了便利,Docker 的发展又极大的方便了微服务的部署.这篇文章介绍一下如果借助 maven 来快速的生成微服务的镜像以及快速启动服务. 其实将 Spring Boot 项目用 Docker 部署也不是什么多么神秘的技术,也要先生成镜像,再用镜像启动容器,如果说有什么方便的地方,也就是一些工具可以帮助我们节省手动操作的过程. 知识背景: 掌握 docker 的安装以及基本的操作,熟悉 Dockerfile 文件创建镜像的方法. 创建 Spring bo

详解spring boot配置单点登录

概述 企业内部一般都有一套单点登录系统(常用的实现有apereo cas),所有的内部系统的登录认证都对接它.本文介绍spring boot的程序如何对接CAS服务. 常用的安全框架有spring security和apache shiro.shiro的配置和使用相对简单,本文使用shrio对接CAS服务. 配置 新增依赖 pom.xml新增: <properties> <shiro.version>1.2.4</shiro.version> </properti

详解Spring Boot 配置多个RabbitMQ

闲话 好久没有写博客了,6月份毕业,因为工作原因,公司上网受限,一直没能把学到的知识点写下来,工作了半年,其实学到的东西也不少,但是现在回忆起来的东西少之又少,有时甚至能在同个问题中踩了几次,越来越觉得及时记录一下学到的东西很重要. 好了,闲话少说,写下这段时间学习的东西,先记录一下用spring Boot配置多个RabbitMQ的情况... 最近公司新启动一个新平台的项目,需要用微服务这个这几年很火的概念来做,所以就学习了Spring Boot方面的知识,给同事展示Spring Boot的一些

Spring Boot搭建文件上传服务的方法

本文实例为大家分享了Spring Boot搭建文件上传服务的具体代码,供大家参考,具体内容如下 一.服务端 pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http:/

Spring Boot配置过滤器的2种方式示例

前言 过滤器(Filter)是Servlet中常用的技术,可以实现用户在访问某个目标资源之前,对访问的请求和响应进行拦截,常用的场景有登录校验.权限控制.敏感词过滤等,下面介绍下Spring Boot配置过滤器的两种方式. 一.@WebFilter注解方式 使用@WebFilter注解为声明当前类为filter,第一个参数为该filter起一个名字,第二个参数为说明要拦截的请求地址,当前类需要实现Filter接口,里面有三个方法,分别为过滤器初始化.过滤方法和过滤器销毁. @Slf4j @Web

spring boot配置拦截器代码实例

这篇文章主要介绍了spring boot配置拦截器代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 首先引入web模块的依赖: 复制代码 <!-- spring boot web 组件 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</ar

Spring Boot中扩展XML请求与响应的支持详解

前言 在之前的所有Spring Boot教程中,我们都只提到和用到了针对HTML和JSON格式的请求与响应处理.那么对于XML格式的请求要如何快速的在Controller中包装成对象,以及如何以XML的格式返回一个对象呢? 什么是xml文件格式 我们要给对方传输一段数据,数据内容是"too young,too simple,sometimes naive",要将这段话按照属性拆分为三个数据的话,就是,年龄too young,阅历too simple,结果sometimes naive.

spring boot使用WebClient调用HTTP服务代码示例

这篇文章主要介绍了spring boot使用WebClient调用HTTP服务代码示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 WebClient的请求模式属于异步非阻塞,能够以少量固定的线程处理高并发的HTTP请求 WebClient是Spring WebFlux模块提供的一个非阻塞的基于响应式编程的进行Http请求的客户端工具,从Spring5.0开始提供 在Spring Boot应用中 1.添加Spring WebFlux依赖 <d