引言: 在Java应用中,绝大多数情况下都是通过同步的方式来实现交互处理的;但是在处理与第三方系统交互的时候,容易造成响应迟缓的情况,之前大部分都是使用多线程来完成此类任务,其实,在Spring 3.x之后,就已经内置了@Async来完美解决这个问题,本文将完成介绍@Async的用法。
1. 何为异步调用?
在解释异步调用之前,我们先来看同步调用的定义;同步就是整个处理过程顺序执行,当各个过程都执行完毕,并返回结果。 异步调用则是只是发送了调用的指令,调用者无需等待被调用的方法完全执行完毕;而是继续执行下面的流程。
例如, 在某个调用中,需要顺序调用 A, B, C三个过程方法;如他们都是同步调用,则需要将他们都顺序执行完毕之后,方算作过程执行完毕; 如B为一个异步的调用方法,则在执行完A之后,调用B,并不等待B完成,而是执行开始调用C,待C执行完毕之后,就意味着这个过程执行完毕了。
2. 常规的异步调用处理方式
在Java中,一般在处理类似的场景之时,都是基于创建独立的线程去完成相应的异步调用逻辑,通过主线程和不同的线程之间的执行流程,从而在启动独立的线程之后,主线程继续执行而不会产生停滞等待的情况。
3. @Async介绍
在Spring中,基于@Async标注的方法,称之为异步方法;这些方法将在执行的时候,将会在独立的线程中被执行,调用者无需等待它的完成,即可继续其他的操作。
如何在Spring中启用@Async
基于Java配置的启用方式:
- @Configuration
- @EnableAsync
- public class SpringAsyncConfig { ... }
基于XML配置文件的启用方式,配置如下:
- <task:executor id="myexecutor" pool-size="5" />
- <task:annotation-driven executor="myexecutor"/>
以上就是两种定义的方式。
4. 基于@Async无返回值调用
示例如下:
- @Async //标注使用
- public void asyncMethodWithVoidReturnType() {
- System.out.println("Execute method asynchronously. "
- + Thread.currentThread().getName());
- }
使用的方式非常简单,一个标注即可解决所有的问题。
5. 基于@Async返回值的调用
示例如下:
- @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的状态来获取当前的异步方法是否执行完毕来实现的。
6. 基于@Async调用中的异常处理机制
在异步方法中,如果出现异常,对于调用者caller而言,是无法感知的。如果确实需要进行异常处理,则按照如下方法来进行处理:
1. 自定义实现AsyncTaskExecutor的任务执行器
在这里定义处理具体异常的逻辑和方式。
2. 配置由自定义的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()就是未来我们需要关注的异常处理的地方。
配置文件中的内容:
- <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" />
分析: 这里的配置使用自定义的taskExecutor来替代缺省的TaskExecutor。
7. @Async调用中的事务处理机制
在@Async标注的方法,同时也适用了@Transactional进行了标注;在其调用数据库操作之时,将无法产生事务管理的控制,原因就在于其是基于异步处理的操作。
那该如何给这些操作添加事务管理呢?可以将需要事务管理操作的方法放置到异步方法内部,在内部被调用的方法上添加@Transactional.
例如: 方法A,使用了@Async/@Transactional来标注,但是无法产生事务控制的目的。
方法B,使用了@Async来标注, B中调用了C、D,C/D分别使用@Transactional做了标注,则可实现事务控制的目的。
8. 总结
通过以上的描述,应该对@Async使用的方法和注意事项了。
http://blog.csdn.net/blueheart20/article/details/44648667
相关推荐
主要介绍了JAVA 中Spring的@Async用法总结的相关资料,需要的朋友可以参考下
在业务处理中,有些业务使用异步的方式更为合理,这篇文章主要介绍了Spring中@Async注解执行异步任务的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
主要介绍了Spring中@Async用法详解及简单实例的相关资料,需要的朋友可以参考下
主要给大家介绍了关于Spring Boot利用@Async如何实现异步调用:自定义线程池的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
本篇文章主要介绍了浅谈Spring @Async异步线程池用法总结,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
本篇文章主要介绍了spring boot 使用@Async实现异步调用方法,具有一定的参考价值,有兴趣的可以了解一下。
主要介绍了Spring中异步注解@Async的使用、原理及使用时可能导致的问题及解决方法,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
本篇文章主要介绍了spring boot中使用@Async实现异步调用任务,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Spring Async / JMX控制台示例此示例说明: @Async注释在Spring中的用法JMX控制台显示应用程序的当前线程使用情况@Async注释配置AsyncController-AsyncController中的getAsyncResults进行完全并行的调用,并在不同的...
在Spring Boot中,可以使用多种方式来实现任务管理。 使用Java自带的定时任务库: 1.在Spring Boot中,你可以使用@Scheduled注解来创建定时任务。将@Scheduled注解与方法一起使用,指定任务执行的时间表达式。 2....
弹簧异步该项目是使用Spring Boot,Spring Hateoas和Spring Data开发的。 该项目的目的是展示Servlet 3.0规范中添加的Async功能。 该API仅具有带有POST方法的Controller。 资源的名称是/ operation。 要进行新操作,...
该解决方案的逻辑非常简单,该应用程序使用Spring的@EnableAsync来配置ThreadPoolTaskExecutor ,该ThreadPoolTaskExecutor将用于运行异步方法。 在此应用程序中,使用提供的此ThreadPoolTaskExecutor获取用户及其...
Spring Boot并行数据聚合库基于注解实现并行地依赖注入(调用),可以看做Spring @Async注解的升级版。特性初步获取依赖所有@DataConsumer定义的依赖将逐步获取。当provider方法参数中的所有依赖获取完成,才执行...
在没有使用spring boot之前,我们的做法是在配置文件中定义一个任务池,然后将@Async注解的任务丢到任务池中去执行,那么在spring boot中,怎么来实现异步任务的调用了,下面通过本文给大家讲解,需要的朋友参考下
Spring 集成事件总线 Java/Spring 项目的事件总线库,基于 Spring 集成框架。 事件驱动架构促进了事件发布者和事件订阅者之间松散耦合的交互。 事件本质上是具有附加语义的消息,这就是为什么许多事件基础设施都...
异步配置程序执行器端点 该项目包含一个Spring Boot执行器端点实现,该实现充当async-profiler( )的包装。 它允许直接将HTTP配置文件请求发送到配置文件的Spring Boot服务,并在响应中(或以任何其他受支持的格式...
前言 第一篇 网站基础知识 第1章 网站架构及其演变过程2 1.1 软件的三大类型2 1.2 基础的结构并不简单3 1.3 架构演变的起点5 1.4 海量数据的解决方案5 1.4.1 缓存和页面静态化5 ...22.3 小结309
Spring Boot Web 异步示例 包括同步控制器方法、延迟... 有趣的是,在没有异常处理程序的 Tomcat 下,同步和异步方法的错误行为是不同的:在后一种情况下,Spring 不使用默认视图渲染,而是返回容器错误页面。 网址:
PushSocket 基本的Sprig Web应用程序,它使用Web套接字进行推送通知。 还演示了使用Spring @Async和@EnableAsync异步执行方法。
springboot学习资料 一、 Spring介绍 1 1.1、SpringBoot简介 1 ...8.2、使用@Async实现异步调用 9 8.3、自定义参数 9 8.4、多环境配置 9 8.5、修改端口号 9 8.6、SpringBoot yml 使用 9 8.7、发布打包 9