異步任務(wù)

同步

1、創(chuàng)建一個(gè)service包

2、創(chuàng)建一個(gè)類(lèi)AsyncService

異步處理還是非常常用的，比如我們?cè)诰W(wǎng)站上發(fā)送郵件，后臺(tái)會(huì)去發(fā)送郵件，此時(shí)前臺(tái)會(huì)造成響應(yīng)不動(dòng)，直到郵件發(fā)送完畢，響應(yīng)才會(huì)成功，所以我們一般會(huì)采用多線(xiàn)程的方式去處理這些任務(wù)。

編寫(xiě)方法，假裝正在處理數(shù)據(jù)，使用線(xiàn)程設(shè)置一些延時(shí)，模擬同步等待的情況；

@Service public class AsyncService {public void hello(){try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("業(yè)務(wù)進(jìn)行中....");} }

3、編寫(xiě)controller包

4、編寫(xiě)AsyncController類(lèi)

我們?nèi)?xiě)一個(gè)Controller測(cè)試一下

@RestController public class AsyncController {@AutowiredAsyncService asyncService;@GetMapping("/hello")public String hello(){asyncService.hello();return "success";}}

5、訪(fǎng)問(wèn)http://localhost:8080/hello進(jìn)行測(cè)試，3秒后出現(xiàn)success，這是同步等待的情況。

問(wèn)題：我們?nèi)绻胱層脩?hù)直接得到消息，就在后臺(tái)使用多線(xiàn)程的方式進(jìn)行處理即可，但是每次都需要自己手動(dòng)去編寫(xiě)多線(xiàn)程的實(shí)現(xiàn)的話(huà)，太麻煩了，我們只需要用一個(gè)簡(jiǎn)單的辦法，在我們的方法上加一個(gè)簡(jiǎn)單的注解即可，如下：

異步

6、給hello方法添加@Async注解；

//告訴Spring這是一個(gè)異步方法 @Async public void hello(){try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("業(yè)務(wù)進(jìn)行中...."); }

SpringBoot就會(huì)自己開(kāi)一個(gè)線(xiàn)程池，進(jìn)行調(diào)用！但是要讓這個(gè)注解生效，我們還需要在主程序上添加一個(gè)注解@EnableAsync ，開(kāi)啟異步注解功能；

@EnableAsync //開(kāi)啟異步注解功能 @SpringBootApplication public class SpringbootTaskApplication {public static void main(String[] args) {SpringApplication.run(SpringbootTaskApplication.class, args);}}

7、重啟測(cè)試，網(wǎng)頁(yè)瞬間響應(yīng)，后臺(tái)代碼依舊執(zhí)行！

總結(jié)

以上是生活随笔為你收集整理的异步任务---SpringBoot的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。