Java異步事務

有一個數據分析的接口特別耗時，請求一次要大約半小時才能出結果。

於是，我對它這樣處理：請求這個接口后，將其直接異步執行，並直接向前端返回true。當其執行完成后，自動向管理員郵箱發送一封郵件。

這時候我發現，常規添加@Transactional注解，異步事務無法生效。於是就有了下面的解決方法。

一、異步配置

import org.apache.tomcat.util.threads.ThreadPoolExecutor;
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.aop.interceptor.SimpleAsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@EnableAsync
@Configuration
public class AsyncConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);//核心線程數
        executor.setMaxPoolSize(20);//最大線程數
        executor.setQueueCapacity(1000);//隊列大小
        executor.setKeepAliveSeconds(300);//線程最大空閑時間
        executor.setThreadNamePrefix("fsx-Executor-"); //指定用於新創建的線程名稱的前綴。
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());//拒絕策略（一共四種，此處省略）
        executor.initialize();
        return executor;
    }

    /**
     * 異常處理器
     *
     * @return 異常處理器
     */
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        System.out.println("異常處理器！！你可以自定義異常處理器～");
        return new SimpleAsyncUncaughtExceptionHandler();
    }
}

二、使用異步事務

public class MyController {

    private final ApplicationContext applicationContext;

    public MyController(ApplicationContext applicationContext) {
        this.applicationContext = applicationContext;
    }

    @PostMapping("/test")
    @ApiOperation(value = "測試")
    public Boolean test() {
        applicationContext.getBean(MyController.class).saveWithTransactional();
        return true;
    }

    @Async
    @Transactional
    public void saveWithTransactional() {
        //你需要異步事務的業務代碼
    }
}

好啦，這樣就大功告成了～

 

參考：

異步事務？關於異步@Async + 事務@Transactional的結合使用問題分析【享學Spring MVC】