深入理解Spring注解@Async解决异步调用问题

序言:Spring中@Async

根据Spring的文档说明,默认采用的是单线程的模式的。所以在Java应用中,绝大多数情况下都是通过同步的方式来实现交互处理的。

那么当多个任务的执行势必会相互影响。例如,如果A任务执行时间比较长,那么B任务必须等到A任务执行完毕后才会启动执行。又如在处理与第三方系统交互的时候,容易造成响应迟缓的情况,之前大部分都是使用多线程来完成此类任务,其实,在spring3.x之后,已经内置了@Async来完美解决这个问题。

1. 何为异步调用?

在解释之前,我们先来看二者的定义:

同步调用:顺序执行,需等待上一个任务执行完毕

就是整个处理过程顺序执行,当各个过程都执行完毕,并返回结果。

异步调用:接收到指令就执行,无需等待

则是只是发送了调用的指令,调用者无需等待被调用的方法完全执行完毕;而是继续执行下面的流程。

例如, 在某个调用中,需要顺序调用A,B,C三个过程方法:
如他们都是同步调用,则需要将他们都顺序执行完毕之后,方算作过程执行完毕;如B为一个异步的调用方法,则在执行完A之后,调用B,并不等待B完成,而是执行开始调用C,待C执行完毕之后,就意味着这个过程执行完毕了。

如图所示:

2. 常规的异步调用处理方式

在Java中,一般在处理类似的场景之时,都是基于创建独立的线程去完成相应的异步调用逻辑,通过主线程和不同的线程之间的执行流程,从而在启动独立的线程之后,主线程继续执行而不会产生停滞等待的情况。或是使用TaskExecutor执行异步线程,参看https://www.jb51.net/article/191512.htm

3. 如何在Spring中启用@Async?

3.0、@Async介绍

在Spring中,基于@Async标注的方法,称之为异步方法;这些方法在执行的时候,将会在独立的线程中被执行,调用者无需等待它的完成,即可继续其他的操作。

3.1、启用@Async注解

3.1.1、基于Java配置的启用方式

@Configuration
@EnableAsync
public class SpringAsyncConfig { ... } 

3.1.2、基于SpringBoot配置的启用方式

@SpringBootApplication
@EnableAsync
public class SpringBootApplication {
 public static void main(String[] args) {
 SpringApplication.run(SpringBootApplication.class, args);
 }
}

3.2、使用@Async注解,声明方法为异步调用

3.2.0、在无返回值方法上使用:

在方法上申明为异步调用方法即可

 @Async //标注使用
 public void downloadFile() throws Exception { ... } 

3.2.1、在有返回值方法上使用

@Async
public Future<String> asyncMethodWithReturnType() {
 System.out.println("Execute method asynchronously - " + Thread.currentThread().getName());
 try {
 Thread.sleep(5000);
 return new AsyncResult<String>("hello world !!!!");
 } catch (InterruptedException e) {
 //
 } 

 return null;
}

以上示例可以发现,返回的数据类型为Future类型,其为一个接口。具体的结果类型为AsyncResult,这个是需要注意的地方。

调用返回结果的异步方法示例:

public void testAsyncAnnotationForMethodsWithReturnType()
 throws InterruptedException, ExecutionException {
 System.out.println("Invoking an asynchronous method. " + Thread.currentThread().getName());
 Future<String> future = asyncAnnotationExample.asyncMethodWithReturnType(); 

 while (true) { ///这里使用了循环判断,等待获取结果信息
 if (future.isDone()) { //判断是否执行完毕
 System.out.println("Result from asynchronous process - " + future.get());
 break;
 }
 System.out.println("Continue doing something else. ");
 Thread.sleep(1000);
 }
}

这些获取异步方法的结果信息,是通过不停的检查Future的状态来获取当前的异步方法是否执行完毕来实现的。

4. 基于@Async调用中的异常处理机制

在异步方法中,如果出现异常,对于调用者caller而言,是无法感知的。如果确实需要进行异常处理,则按照如下方法来进行处理:

自定义实现AsyncTaskExecutor的任务执行器
在这里定义处理具体异常的逻辑和方式。

配置由自定义的TaskExecutor替代内置的任务执行器

示例步骤1,自定义的TaskExecutor

public class ExceptionHandlingAsyncTaskExecutor implements AsyncTaskExecutor {
 private AsyncTaskExecutor executor;
 public ExceptionHandlingAsyncTaskExecutor(AsyncTaskExecutor executor) {
 this.executor = executor;
 }
 ////用独立的线程来包装,@Async其本质就是如此
 public void execute(Runnable task) {
 executor.execute(createWrappedRunnable(task));
 }
 public void execute(Runnable task, long startTimeout) {
 /用独立的线程来包装,@Async其本质就是如此
 executor.execute(createWrappedRunnable(task), startTimeout);
 }
 public Future submit(Runnable task) { return executor.submit(createWrappedRunnable(task));
 //用独立的线程来包装,@Async其本质就是如此。
 }
 public Future submit(final Callable task) {
 //用独立的线程来包装,@Async其本质就是如此。
 return executor.submit(createCallable(task));
 } 

 private Callable createCallable(final Callable task) {
 return new Callable() {
 public T call() throws Exception {
  try {
  return task.call();
  } catch (Exception ex) {
  handle(ex);
  throw ex;
  }
  }
 };
 } 

 private Runnable createWrappedRunnable(final Runnable task) {
 return new Runnable() {
 public void run() {
  try {
  task.run();
  } catch (Exception ex) {
  handle(ex);
  }
 }
 };
 }
 private void handle(Exception ex) {
 //具体的异常逻辑处理的地方
 System.err.println("Error during @Async execution: " + ex);
 }
}

分析: 可以发现其是实现了AsyncTaskExecutor, 用独立的线程来执行具体的每个方法操作。在createCallable和createWrapperRunnable中,定义了异常的处理方式和机制。

handle()就是未来我们需要关注的异常处理的地方。
xml配置文件中的内容:

<task:annotation-driven executor="exceptionHandlingTaskExecutor" scheduler="defaultTaskScheduler" />
<bean id="exceptionHandlingTaskExecutor" class="nl.jborsje.blog.examples.ExceptionHandlingAsyncTaskExecutor">
 <constructor-arg ref="defaultTaskExecutor" />
</bean>
<task:executor id="defaultTaskExecutor" pool-size="5" />
<task:scheduler id="defaultTaskScheduler" pool-size="1" />

也可以使用注解的形式将其配置注册到bean中。

5. @Async调用中的事务处理机制

在@Async标注的方法,同时也使用@Transactional进行标注;在其调用数据库操作之时,将无法产生事务管理的控制,原因就在于其是基于异步处理的操作。

那该如何给这些操作添加事务管理呢?

可以将需要事务管理操作的方法放置到异步方法内部,在内部被调用的方法上添加@Transactional

示例:

方法A, 使用了@Async/@Transactional来标注,但是无法产生事务控制的目的。

方法B, 使用了@Async来标注,B中调用了C、D,C/D分别使用@Transactional做了标注,则可实现事务控制的目的。

6. 参考文章:

[1]、https://www.jb51.net/article/109345.htm
[2]、https://www.jb51.net/article/191512.htm

到此这篇关于深入理解Spring注解@Async解决异步调用问题的文章就介绍到这了,更多相关Spring注解@Async解决异步调用内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • 浅谈Spring @Async异步线程池用法总结

    本文介绍了Spring @Async异步线程池用法总结,分享给大家,希望对大家有帮助 1. TaskExecutor spring异步线程池的接口类,其实质是Java.util.concurrent.Executor Spring 已经实现的异常线程池: 1. SimpleAsyncTaskExecutor:不是真的线程池,这个类不重用线程,每次调用都会创建一个新的线程. 2. SyncTaskExecutor:这个类没有实现异步调用,只是一个同步操作.只适用于不需要多线程的地方 3. Conc

  • Spring中@Async注解实现异步调详解

    异步调用 在解释异步调用之前,我们先来看同步调用的定义:同步就是整个处理过程顺序执行,当各个过程都执行完毕,并返回结果. 异步调用则是只是发送了调用的指令,调用者无需等待被调用的方法完全执行完毕,继续执行下面的流程.例如, 在某个调用中,需要顺序调用 A, B, C三个过程方法:如他们都是同步调用,则需要将他们都顺序执行完毕之后,过程才执行完毕: 如B为一个异步的调用方法,则在执行完A之后,调用B,并不等待B完成,而是执行开始调用C,待C执行完毕之后,就意味着这个过程执行完毕了. 概述说明 Sp

  • Spring中@Async注解执行异步任务的方法

    引言 在业务处理中,有些业务使用异步的方式更为合理.比如在某个业务逻辑中,把一些数据存入到redis缓存中,缓存只是一个辅助的功能,成功或者失败对主业务并不会产生根本影响,这个过程可以通过异步的方法去进行. Spring中通过在方法上设置@Async注解,可使得方法被异步调用.也就是说该方法会在调用时立即返回,而这个方法的实际执行交给Spring的TaskExecutor去完成. 代码示例 项目是一个普通的Spring的项目,Spring的配置文件: <?xml version="1.0&

  • Spring中异步注解@Async的使用、原理及使用时可能导致的问题及解决方法

    前言 其实最近都在研究事务相关的内容,之所以写这么一篇文章是因为前面写了一篇关于循环依赖的文章: <Spring循环依赖的解决办法,你真的懂了吗> 然后,很多同学碰到了下面这个问题,添加了Spring提供的一个异步注解@Async循环依赖无法被解决了,下面是一些读者的留言跟群里同学碰到的问题: 本着讲一个知识点就要讲明白.讲透彻的原则,我决定单独写一篇这样的文章对@Async这个注解做一下详细的介绍,这个注解带来的问题远远不止循环依赖这么简单,如果对它不够熟悉的话建议慎用. 文章要点 @Asy

  • Spring里的Async注解实现异步操作的方法步骤

    异步执行一般用来发送一些消息数据,数据一致性不要求太高的场景,对于spring来说,它把这个异步进行了封装,使用一个注解就可以实现. 何为异步调用? 在解释异步调用之前,我们先来看同步调用的定义:同步就是整个处理过程顺序执行,当各个过程都执行完毕,并返回结果. 异步调用则是只是发送了调用的指令,调用者无需等待被调用的方法完全执行完毕:而是继续执行下面的流程.例如, 在某个调用中,需要顺序调用 A, B, C三个过程方法:如他们都是同步调用,则需要将他们都顺序执行完毕之后,方算作过程执行完毕: 如

  • 深入理解Spring注解@Async解决异步调用问题

    序言:Spring中@Async 根据Spring的文档说明,默认采用的是单线程的模式的.所以在Java应用中,绝大多数情况下都是通过同步的方式来实现交互处理的. 那么当多个任务的执行势必会相互影响.例如,如果A任务执行时间比较长,那么B任务必须等到A任务执行完毕后才会启动执行.又如在处理与第三方系统交互的时候,容易造成响应迟缓的情况,之前大部分都是使用多线程来完成此类任务,其实,在spring3.x之后,已经内置了@Async来完美解决这个问题. 1. 何为异步调用? 在解释之前,我们先来看二

  • spring boot 使用@Async实现异步调用方法

    使用@Async实现异步调用 什么是"异步调用"与"同步调用" "同步调用"就是程序按照一定的顺序依次执行,,每一行程序代码必须等上一行代码执行完毕才能执行:"异步调用"则是只要上一行代码执行,无需等待结果的返回就开始执行本身任务. 通常情况下,"同步调用"执行程序所花费的时间比较多,执行效率比较差.所以,在代码本身不存在依赖关系的话,我们可以考虑通过"异步调用"的方式来并发执行. &q

  • 彻底理解Spring注解@Autowired实现原理

    目录 前言 1.@Autowired注解用法 2.@Autowired注解的作用到底是什么 3.@Autowired注解是如何实现的 自己实现一个注解 4.@Autowired注解实现逻辑分析 5.问题 5.1.注解的有效周期是什么? 5.2.注入的bean和用它的bean的关系是如何维护的? 5.3.为什么注入的bean不能被定义为static的? 前言 使用spring开发时,进行配置主要有两种方式,一是xml的方式,二是java config的方式. spring技术自身也在不断的发展和改

  • spring boot中使用@Async实现异步调用任务

    什么是"异步调用"? "异步调用"对应的是"同步调用",同步调用指程序按照定义顺序依次执行,每一行程序都必须等待上一行程序执行完成之后才能执行:异步调用指程序在顺序执行时,不等待异步调用的语句返回结果就执行后面的程序.  同步调用 下面通过一个简单示例来直观的理解什么是同步调用: 定义Task类,创建三个处理函数分别模拟三个执行任务的操作,操作消耗时间随机取(10秒内) package com.kfit.task; import java.uti

  • 关于Spring注解@Async引发其他注解失效的解决

    概述 在前面一篇文章中,介绍,在一个Bean中注入自己,如果有@Async和@Transaction,如果使用@Autowire注入自身,会报循环依赖,如果使用BeanFactoryAware注入自己,会使得@Transaction失效. 例如: @Service public class MyService implements BeanFactoryAware{ private MyService self; //事务注解无效 @Transactional public void notWo

  • Spring @async方法如何添加注解实现异步调用

    这篇文章主要介绍了Spring @async方法如何添加注解实现异步调用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 在我们使用spring框架的过程中,在很多时候我们会使用@async注解来异步执行某一些方法,提高系统的执行效率.今天我们来探讨下 spring 是如何完成这个功能的. spring 在扫描bean的时候会扫描方法上是否包含@async的注解,如果包含的,spring会为这个bean动态的生成一个子类,我们称之为代理类(?),

  • Spring Boot集成教程之异步调用Async

    前言 本文主要给大家介绍了关于Spring Boot集成之异步调用Async的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧. 什么是异步调用? 异步调用是相对于同步调用而言的,同步调用是指程序按预定顺序一步步执行,每一步必须等到上一步执行完后才能执行,异步调用则无需等待上一步程序执行完即可执行. 异步处理方式 调用之后,不返回任何数据. 调用之后,返回数据,通过Future来获取返回数据 如何实现异步调用? 多线程,这是很多人第一眼想到的关键词,没错,多线程就是一种实

  • Spring Boot利用@Async如何实现异步调用:自定义线程池

    前言 在之前的Spring Boot基础教程系列中,已经通过<Spring Boot中使用@Async实现异步调用>一文介绍过如何使用@Async注解来实现异步调用了.但是,对于这些异步执行的控制是我们保障自身应用健康的基本技能.本文我们就来学习一下,如果通过自定义线程池的方式来控制异步调用的并发. 本文中的例子我们可以在之前的例子基础上修改,也可以创建一个全新的Spring Boot项目来尝试. 定义线程池 第一步,先在Spring Boot主类中定义一个线程池,比如: @SpringBoo

  • Spring Boot利用@Async异步调用:ThreadPoolTaskScheduler线程池的优雅关闭详解

    前言 之前分享了一篇关于Spring Boot中使用@Async来实现异步任务和线程池控制的文章:<Spring Boot使用@Async实现异步调用:自定义线程池>.由于最近身边也发现了不少异步任务没有正确处理而导致的不少问题,所以在本文就接前面内容,继续说说线程池的优雅关闭,主要针对ThreadPoolTaskScheduler线程池. 问题现象 在上篇文章的例子Chapter4-1-3中,我们定义了一个线程池,然后利用@Async注解写了3个任务,并指定了这些任务执行使用的线程池.在上文

  • Spring Boot利用@Async异步调用:使用Future及定义超时详解

    前言 之前连续写了几篇关于使用@Async实现异步调用的内容,也得到不少童鞋的反馈,其中问题比较多的就是关于返回Future的使用方法以及对异步执行的超时控制,所以这篇就来一起讲讲这两个问题的处理. 如果您对于@Async注解的使用还不了解的话,可以看看之前的文章,具体如下: 使用@Async实现异步调用 使用@Async实现异步调用:自定义线程池 使用@Async实现异步调用:资源优雅关闭 定义异步任务 首先,我们先使用@Async注解来定义一个异步任务,这个方法返回Future类型,具体如下

随机推荐