快捷導(dǎo)航

Spring里的Async注解實(shí)現(xiàn)異步操作的方法步驟

更新時(shí)間：2019年04月30日 11:22:25 作者：張占嶺

這篇文章主要介紹了Spring里的Async注解實(shí)現(xiàn)異步操作的方法步驟，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

異步執(zhí)行一般用來發(fā)送一些消息數(shù)據(jù)，數(shù)據(jù)一致性不要求太高的場(chǎng)景，對(duì)于spring來說，它把這個(gè)異步進(jìn)行了封裝，使用一個(gè)注解就可以實(shí)現(xiàn)。

何為異步調(diào)用？

在解釋異步調(diào)用之前，我們先來看同步調(diào)用的定義；同步就是整個(gè)處理過程順序執(zhí)行，當(dāng)各個(gè)過程都執(zhí)行完畢，并返回結(jié)果。異步調(diào)用則是只是發(fā)送了調(diào)用的指令，調(diào)用者無需等待被調(diào)用的方法完全執(zhí)行完畢；而是繼續(xù)執(zhí)行下面的流程。例如，在某個(gè)調(diào)用中，需要順序調(diào)用 A, B, C三個(gè)過程方法；如他們都是同步調(diào)用，則需要將他們都順序執(zhí)行完畢之后，方算作過程執(zhí)行完畢；如B為一個(gè)異步的調(diào)用方法，則在執(zhí)行完A之后，調(diào)用B，并不等待B完成，而是執(zhí)行開始調(diào)用C，待C執(zhí)行完畢之后，就意味著這個(gè)過程執(zhí)行完畢了。

@Async介紹

在Spring中，基于@Async標(biāo)注的方法，稱之為異步方法；這些方法將在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線程中被執(zhí)行，調(diào)用者無需等待它的完成，即可繼續(xù)其他的操作。

分為不帶參數(shù)的異步調(diào)用；帶參數(shù)的異步調(diào)用；調(diào)用返回Future的異步線程

@Async調(diào)用中的事務(wù)處理機(jī)制

在@Async標(biāo)注的方法，同時(shí)也適用了@Transactional進(jìn)行了標(biāo)注；在其調(diào)用數(shù)據(jù)庫操作之時(shí)，將無法產(chǎn)生事務(wù)管理的控制，原因就在于其是基于異步處理的操作。那該如何給這些操作添加事務(wù)管理呢？可以將需要事務(wù)管理操作的方法放置到異步方法內(nèi)部，在內(nèi)部被調(diào)用的方法上添加@Transactional. 例如：方法A，使用了@Async/@Transactional來標(biāo)注，但是無法產(chǎn)生事務(wù)控制的目的。方法B，使用了@Async來標(biāo)注， B中調(diào)用了C、D，C/D分別使用@Transactional做了標(biāo)注，則可實(shí)現(xiàn)事務(wù)控制的目的。

用法

1.程序啟動(dòng)時(shí)開啟@EnableAsync注解

2.建立新的類型，建立異步方法，為方法添加@Async注解

3.在業(yè)務(wù)代碼中，@Autowired注入你的類型，使用它即可

我們可以關(guān)注到在配置task的時(shí)候，是有參數(shù)讓我們配置線程池的數(shù)量的。因?yàn)檫@種實(shí)現(xiàn)方法，所以在同一個(gè)類中的方法調(diào)用，添加@async注解是失效的！，原因是當(dāng)你在同一個(gè)類中的時(shí)候，方法調(diào)用是在類體內(nèi)執(zhí)行的，spring無法截獲這個(gè)方法調(diào)用.

Async幾種方式

1.沒有返回值的，不會(huì)阻塞主線程，相當(dāng)于開啟新線程在后臺(tái)執(zhí)行這個(gè)任務(wù)

  @Async
  public String sayHello2() throws InterruptedException {
    Thread.sleep(2 * 1000);//網(wǎng)絡(luò)連接中 。。。消息發(fā)送中。。。
    return "我愛你啊!";// 調(diào)用方調(diào)用后會(huì)立即返回,所以返回null
  }

1.帶有返回值的，返回類型必須為Future<>，它會(huì)開啟新的線程執(zhí)行任務(wù)，并阻塞主線程，執(zhí)行完成后把結(jié)果返回給主線程

 @Async
 public Future<String> asyncFunc() throws InterruptedException {
  int thinking = 2;
  Thread.sleep(thinking * 1000);
  System.out.println("async!");
  return new AsyncResult<String>("發(fā)送消息用了" + thinking + "秒");
 }

調(diào)用方法

 @GetMapping("/lind-demo/asyncFunc")
 public void async() throws Exception {
  Future<String> future = null;
  future = asyncService.asyncFunc();
  System.out.println(future.get());
  System.out.println("主線程被阻塞執(zhí)行完成");
 }

執(zhí)行結(jié)果