前言

作者：JAVA旭陽

SpringBoot想必大家都用過，但是大家平時(shí)使用發(fā)布的接口大都是同步的，那么你知道如何優(yōu)雅的實(shí)現(xiàn)異步呢？

這篇文章就是關(guān)于如何在Spring Boot中實(shí)現(xiàn)異步行為的。但首先，讓我們看看同步和異步之間的區(qū)別。

• 同步編程：在同步編程中，任務(wù)一次執(zhí)行一個(gè)，只有當(dāng)一個(gè)任務(wù)完成時(shí)，下一個(gè)任務(wù)才會(huì)被解除阻塞。

• 異步編程：在異步編程中，可以同時(shí)執(zhí)行多個(gè)任務(wù)。您可以在上一個(gè)任務(wù)完成之前轉(zhuǎn)到另一個(gè)任務(wù)。

在Spring Boot中，我們可以使用@Async注解來實(shí)現(xiàn)異步行為。

實(shí)現(xiàn)步驟

1. 定義一個(gè)異步服務(wù)接口AsyncService.java

public interface AsyncService { ? ?void asyncMethod() throws InterruptedException; ? ?Future<String> futureMethod() throws InterruptedException; }

1. 實(shí)現(xiàn)定義的接口AsyncServiceImpl.java

@Service@Slf4jpublic class AsyncServiceImpl implements AsyncService ?{ ? ?@Async ? ?@Override ? ?public void asyncMethod() throws InterruptedException { ? ? ? ?Thread.sleep(3000); ? ? ? ?log.info("Thread: [{}], Calling other service..", Thread.currentThread().getName()); ? ?} ? ?@Async ? ?@Override ? ?public Future<String> futureMethod() throws InterruptedException { ? ? ? ?Thread.sleep(5000); ? ? ? ?log.info("Thread: [{}], Calling other service..", Thread.currentThread().getName()); ? ? ? ?return new AsyncResult<>("task Done"); ? ?} }

• AsyncServiceImpl?是一個(gè)?spring?管理的?bean。

• 您的異步方法必須是公共的，而且是被@Async注解修飾。

• 返回類型被限制為?void?或?Future。

1. 定義一個(gè)控制器AsyncController.java

@EnableAsync@RestController@Slf4jpublic class AsyncController { ? ?@Autowired ? ?AsyncService asyncService; ? ?@GetMapping("/async") ? ?public String asyncCallerMethod() throws InterruptedException { ? ? ? ?long start = System.currentTimeMillis(); ? ? ? ?log.info("call async method, thread name: [{}]", Thread.currentThread().getName()); ? ? ? ?asyncService.asyncMethod(); ? ? ? ?String response = "task completes in :" + ? ? ? ? ? ? ? ?(System.currentTimeMillis() - start) + "milliseconds"; ? ? ? ?return response; ? ?} ? ?@GetMapping("/asyncFuture") ? ?public String asyncFuture() throws InterruptedException, ExecutionException { ? ? ? ?long start = System.currentTimeMillis(); ? ? ? ?log.info("call async method, thread name: [{}]", Thread.currentThread().getName()); ? ? ? ?Future<String> future = asyncService.futureMethod(); ? ? ? ?// 阻塞獲取結(jié)果 ? ? ? ?String taskResult = future.get(); ? ? ? ?String response = taskResult + "task completes in :" + ? ? ? ? ? ? ? ?(System.currentTimeMillis() - start) + "milliseconds"; ? ? ? ?return response; ? ?} }

• 關(guān)鍵點(diǎn)，需要添加啟用異步的注解@EnableAsync?，當(dāng)然這個(gè)注解加在其他地方也ok得。

• 當(dāng)外部調(diào)用該接口時(shí)，asyncMethod()將由默認(rèn)任務(wù)執(zhí)行程序創(chuàng)建的另一個(gè)線程執(zhí)行，主線程不需要等待完成異步方法執(zhí)行。

1. 運(yùn)行一下

現(xiàn)在我們運(yùn)行一下看看，是不是異步返回的。

• 可以看到調(diào)用/async接口，最終一步調(diào)用了方法。

• 調(diào)用/asyncFuture，發(fā)現(xiàn)返回5秒多，難道不是異步的嗎？其實(shí)也是異步的，看日志可以看出來，只不過我們返回的是Future,調(diào)用Futrue.get()是阻塞的。

自定義異步任務(wù)執(zhí)行器和異常處理

我們現(xiàn)在看看如果異常方法中報(bào)錯(cuò)了會(huì)怎么樣？修改異步代碼如下所示，會(huì)拋運(yùn)行時(shí)異常：

再次執(zhí)行異步接口，如下所示，會(huì)使用默認(rèn)的線程池和異常處理。

我們也可以自定義異步方法的處理異常和異步任務(wù)執(zhí)行器，我們需要配置?AsyncUncaughtExceptionHandler，如下代碼所示：

@Configurationpublic class AsynConfiguration extends AsyncConfigurerSupport { ? @Override ? public Executor getAsyncExecutor() { ? ? ?ThreadPoolTaskExecutor executor = new ? ? ? ? ? ? ? ?ThreadPoolTaskExecutor(); ? ? ?executor.setCorePoolSize(3); ? ? ?executor.setMaxPoolSize(4); ? ? ?executor.setThreadNamePrefix("asyn-task-thread-"); ? ? ?executor.setWaitForTasksToCompleteOnShutdown(true); ? ? ?executor.initialize(); ? ? ?return executor; ?} ?@Override ?public AsyncUncaughtExceptionHandler ? ? ? ? ? getAsyncUncaughtExceptionHandler() { ? ? return new AsyncUncaughtExceptionHandler() { ? ? ? ? ?@Override ? ? ? ?public void handleUncaughtException(Throwable ex, ? ? ? ? ? Method method, Object... params) { ? ? ? ? ? System.out.println("Exception: " + ex.getMessage()); ? ? ? ? ? System.out.println("Method Name: " + method.getName()); ? ? ? ? ? ex.printStackTrace(); ? ? ? ?} ? ?}; ?} }

再次運(yùn)行，得到的結(jié)果如下：

@Async如何工作的？

必須通過使用?@EnableAsync注解注解主應(yīng)用程序類或任何直接或間接異步方法調(diào)用程序類來啟用異步支持。主要通過代理模式實(shí)現(xiàn)，默認(rèn)模式是?Proxy，另一種是?AspectJ。代理模式只允許通過代理攔截調(diào)用。永遠(yuǎn)不要從定義它的同一個(gè)類調(diào)用異步方法，它不會(huì)起作用。

當(dāng)使用?@Async對(duì)方法進(jìn)行注解時(shí)，它會(huì)根據(jù)“proxyTargetClass”屬性為該對(duì)象創(chuàng)建一個(gè)代理。當(dāng)?spring?執(zhí)行這個(gè)方法時(shí)，默認(rèn)情況下它會(huì)搜索關(guān)聯(lián)的線程池定義。上下文中唯一的?spring?框架?TaskExecutor bean?或名為“taskExecutor”的?Executor bean。如果這兩者都不可解析，默認(rèn)會(huì)使用spring框架SimpleAsyncTaskExecutor來處理異步方法的執(zhí)行。

總結(jié)

在本文中，我們演示了在 spring boot 中如何使用?@Async?注解和異步方法中的異常處理實(shí)現(xiàn)異步行為。我們可以在一個(gè)接口中，需要訪問不同的資源，比如異步調(diào)用各個(gè)其他服務(wù)的接口，可以使用@Async，然后將結(jié)果通過Future的方式阻塞匯總，不失為一個(gè)提高性能的好方法。