怎么在Spring中使用Async注解實(shí)現(xiàn)異步操作-四川平武建站

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

怎么在Spring中使用Async注解實(shí)現(xiàn)異步操作

這篇文章給大家介紹怎么在Spring中使用Async注解實(shí)現(xiàn)異步操作，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

成都創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站與策劃設(shè)計(jì),含山網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)十年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:含山等地區(qū)。含山做網(wǎng)站價(jià)格咨詢:028-86922220

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

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

@Async介紹

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

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

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

在@Async標(biāo)注的方法，同時也適用了@Transactional進(jìn)行了標(biāo)注；在其調(diào)用數(shù)據(jù)庫操作之時，將無法產(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.程序啟動時開啟@EnableAsync注解

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

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

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

Async幾種方式

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

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

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

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

調(diào)用方法

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

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