使用Spring中@Async注解實現異步調用

異步調用？

    在解釋異步調用之前，我們先來看同步調用的定義；同步就是整個處理過程順序執行，當各個過程都執行完畢，並返回結果。 異步調用則是只是發送了調用的指令，調用者無需等待被調用的方法完全執行完畢,繼續執行下面的流程。例如， 在某個調用中，需要順序調用 A, B, C三個過程方法；如他們都是同步調用，則需要將他們都順序執行完畢之后，過程才執行完畢； 如B為一個異步的調用方法，則在執行完A之后，調用B，並不等待B完成，而是執行開始調用C，待C執行完畢之后，就意味着這個過程執行完畢了。

概述說明

Spring中通過任務執行器(TaskExecutor)來實現多線程和並發編程。使用ThreadPoolTaskExecutor可實現一個基於線程池的TaskExcutor。而實際開發中任務一般是異步的，我們可以在配置類中通過@EnableAsync開啟對異步任務的支持，並通過在實際執行的Bean的方法中使用@Async注解來聲明其是一個異步任務。

從Spring3開始提供了@Async注解，該注解可以被標注在方法上，以便異步地調用該方法。調用者將在調用時先返回結果標志，方法的實際執行將提交給Spring TaskExecutor的任務中，由指定的線程池中的線程執行。

@Async應用自定義線程池

配置類

/**
 * @author 佛大Java程序員
 * @since 1.0.0
 */
@Configuration
@ComponentScan("com.whl.asyncdemo")
@EnableAsync
public class TaskExecutorConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(5);
        taskExecutor.setMaxPoolSize(10);
        taskExecutor.setQueueCapacity(25);
        taskExecutor.initialize();
        return taskExecutor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

說明：

* 利用@EnableAsync 注解開啟異步任務支持
* 自定義線程池需要定義的配置類中實現AsyncConfigurer接口並重寫getAsyncExecutor()，返回一個ThreadPoolTaskExecutor，這樣我們就獲得了一個基於線程池的TaskExecutor

執行類

/**
 * @author 佛大Java程序員
 * @since 1.0.0
 */
@Service
public class AsyncTaskService {

    @Async
    public void executeAsyncTask(Integer i){
        System.out.println("執行異步任務1：" + i);
    }

    @Async
    public void executeAsyncTaskPlus(Integer i){
        System.out.println("執行異步任務2 " +(i+1));
    }
}

說明:

@Async注解表明方法是個異步方法，如果注解在類級別，則表明該類所有的方法都是異步方法，而這里的方法自動注入使用ThreadPoolTaskExecutor作為TaskExecutor。

測試類

/**
 * @author 佛大Java程序員
 * @since 1.0.0
 */
public class Main {

    public static void main(String[] args) {

        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TaskExecutorConfig.class);
        AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class);

        for (int i = 0; i < 5 ; i++) {
            asyncTaskService.executeAsyncTask(i);
            asyncTaskService.executeAsyncTaskPlus(i);
        }

        //校驗異步方法是否先返回結果值
        System.out.println("返回執行成功，驗證異步是否先返回結果值");
        context.close();

    }
}

執行結果

注釋@Async

放開@Async注釋

 

@Async應用默認線程池

 待補充

@Async調用中的事務處理機制?

　　 在@Async標注的方法，同時也適用了@Transactional進行了標注；在其調用數據庫操作之時，將無法產生事務管理的控制，原因就在於其是基於異步處理的操作。那該如何給這些操作添加事務管理呢？可以將需要事務管理操作的方法放置到異步方法內部，在內部被調用的方法上添加@Transactional.

(1)   使用了@Async/@Transactional來標注，但是無法產生事務控制的目的。

(2)   使用了@Async來標注，  B中調用了C、D，C/D分別使用@Transactional做了標注，則可實現事務控制的目的。

項目實戰

WKD項目里面使用Easypoi技術來導出Excel，導出數據量數據量不大的時候用同步導出也沒事，但是對於數據量大且需要導出的數據封裝業務較復雜，就會出現應用OOM或者出現響應超時。為了解決此問題，通過用線程池異步導出的方式實現。

 

 參考/好文：

書籍 -- SpringBoot實戰 -- 汪雲飛 編著