Spring中@Async注解实现“方法”的异步调用

1、简介
在Java应用中，绝大多数状况下都是经过同步的方式来实现交互处理的；可是在处理与第三方系统交互的时候，容易形成响应迟缓的状况

2、解决办法
办法一：采用多线程实现异步操做

新建一个线程类：

public class MyThread extends Thread {
    @Override
    public void run() {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("。。。。。异步方法调用了。。。。。");
    }
}

在须要异步操做的地方，开启异步线程：

@RequestMapping("/index")
public String loginpage() {
    //开启异步操做
   Thread thread1=new Thread(new MyThread());
   thread1.start();
    return "login";
}

方法二:@Async注解
在Spring中，基于@Async标注的方法，称之为异步方法；这些方法将在执行的时候，将会在独立的线程中被执行，调用者无需等待它的完成，便可继续其余的操做。
(1)基于Java配置的启用方式：
@Configuration
@EnableAsync
public class SpringAsyncConfig { ... } 

(2)基于XML配置文件的启用方式
//加载bean
<bean id="asyncTest" class="com.utils.AsyncTest" lazy-init="false"/>
<task:executor id="myexecutor"pool-size="5"/> 
<task:annotation-driven executor="myexecutor"/>

3、实际使用
(1)新建一个异步操做类

@Component
public class AsyncTest {
    @Async("myexecutor")
    public void sayHello(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("hello...hello");
    }
}

(2)在须要异步的地方，使用上述方法：

@Autowired
private AsyncTest asyncTest;
@RequestMapping("/index")
public String loginpage() {
    System.out.println("开始调用 asyncTest.sayHello()");
    asyncTest.sayHello();
    System.out.println("结束调用 asyncTest.sayHello()");
    return "login";
}

上述方法返回值是void的演示，还有存在返回值的异步操做;

改写sayHello()方法

@Async("myexecutor")
public Future<String> sayHello(){
    try {
        Thread.sleep(3000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("hello...hello");
    return new AsyncResult<String>("这是sayHello（）返回值");
}

 

打印sayHello()返回值

@RequestMapping("/index")
public String loginpage() throws ExecutionException, InterruptedException {
    System.out.println("开始调用 asyncTest.sayHello()");
    Future<String> results=asyncTest.sayHello();
    System.out.println("结束调用 asyncTest.sayHello()");
    while(true) { //这里使用了循环判断，等待获取结果信息
            if (results.isDone()) { //判断是否执行完毕
                System.out.println("Result from asynchronous process - " + results.get());
                break;
            }
        }
    return "login";
}

获取异步方法的结果信息，是经过不停的检查Future的状态来获取当前的异步方法是否执行完毕来实现的
经实际测试发现，若是打印异步操做返回值，则是等待异步操做执行结束后才能得到返回值，如此一来整个流程下来花费时间和同步方法同样。

4、@Async调用中的事务处理机制
在@Async标注的方法，同时也适用了@Transactional进行了标注；在其调用数据库操做之时，将没法产生事务管理的控制，缘由就在于其是基于异步处理的操做。那该如何给这些操做添加事务管理呢？能够将须要事务管理操做的方法放置到异步方法内部，在内部被调用的方法上添加@Transactional.
例如：

 方法A，使用了@Async/@Transactional来标注，可是没法产生事务控制的目的。 方法B，使用了@Async来标注，  B中调用了C、D，C/D分别使用@Transactional作了标注，则可实现事务控制的目的。