詳解springboot中使用異步的常用兩種方式及其比較

發(fā)布時(shí)間：2020-09-03 11:48:01 來源：腳本之家閱讀：196 作者：萬米高空欄目：編程語言

一般對(duì)于業(yè)務(wù)復(fù)雜的流程，會(huì)有一些處理邏輯不需要及時(shí)返回，甚至不需要返回值，但是如果充斥在主流程中，占用大量時(shí)間來處理，就可以通過異步的方式來優(yōu)化。

實(shí)現(xiàn)異步的常用方法遠(yuǎn)不止兩種，但是個(gè)人經(jīng)驗(yàn)常用的，好用的，這里我就說兩種，最好用的是第二種。

spring的注解方式@Async org.springframework.scheduling.annotation.Async
jdk1.8后的CompletableFuture java.util.concurrent.CompletableFuture

其中第一種的使用注意事項(xiàng)比較多

1.不要在本類中異步調(diào)用。即一個(gè)方法是異步方法，然后用另一個(gè)方法調(diào)用這個(gè)異步方法。

2.不要有返回值，使用void

3.不能使用本類的私有方法或者非接口化加注@Async,因?yàn)榇聿坏绞?/p>

4.異步方法不能使用static修飾

5.異步類需使用@Component注解，不然將導(dǎo)致spring無法掃描到異步類

6.SpringBoot框架必須在啟動(dòng)類中增加@EnableAsync注解

7.異步方法不要和事物注解同時(shí)存在?？梢栽谑挛锏姆椒ㄖ姓{(diào)用另外一個(gè)類中的異步方法。在調(diào)用Async方法的方法上標(biāo)注@Transactional是管理調(diào)用方法的事務(wù)的,在Async方法上標(biāo)注@Transactional是管理異步方法的事務(wù),事務(wù)因線程隔離

@Async的使用方式

1.pom引入依賴。只要依賴中存在spring-context包即可。

詳解springboot中使用異步的常用兩種方式及其比較

2.需要在springboot啟動(dòng)類上加上開啟異步的注解@EnableAsync

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.scheduling.annotation.EnableAsync;

@EnableAsync
@EnableHystrix
@EnableFeignClients
@SpringBootApplication
public class OrderServerApplication extends SpringBootServletInitializer {

 @Override
 protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
  return application.sources(OrderServerApplication.class);
 }

 public static void main(String[] args) {
  SpringApplication.run(OrderServerApplication.class, args);
 }
}

3.可以專門封裝一個(gè)異步類。然后那個(gè)方法需要用到異步的操作。在這個(gè)類中封裝，然后在類中引入異步類即可。

詳解springboot中使用異步的常用兩種方式及其比較

在使用異步的地方引入調(diào)用即可。

詳解springboot中使用異步的常用兩種方式及其比較

CompletableFuture中的異步方法是在一個(gè)正常的方法體內(nèi)使用即可。

 private ExecutorService pool = Executors.newFixedThreadPool(2);

 @Override
 public void synOrder(String orderId, OrderSourceEnum type, Integer status) {
  try {
   CompletableFuture.runAsync(() -> {
   		 //下面是一些業(yè)務(wù)操作。
    PageVO pageVO = new PageVO();
    Set<String> orderIds = new HashSet<>();
    orderIds.add(orderId);
    pageVO.setIds(orderIds);
    pageVO.setOrderType(type);
    List<MaisOrderDTO> maisOrderDTOS = orderSourceService.batchGetDetails(pageVO);
    if (CollectionUtils.isEmpty(maisOrderDTOS)) {
     throw new RuntimeException("未找到id=" + orderId + "類型為:" + type.getDesc() + "的訂單");
    }
   }, pool);
  } catch (Exception e) {
   log.info("同步單個(gè)訂單給群脈出現(xiàn)異常：{}", e);
  }
 }

參考博客：[Java并發(fā)-15] CompletableFuture: 異步編程

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持億速云。

向AI問一下細(xì)節(jié)

詳解springboot中使用異步的常用兩種方式及其比較

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽