建站
咨詢(xún)
售后
建站咨詢(xún)
新聞中心
[[403136]]
本文轉(zhuǎn)載自微信公眾號(hào)「六脈神劍的程序人生」，作者六脈神劍小六六。轉(zhuǎn)載本文請(qǐng)聯(lián)系六脈神劍的程序人生公眾號(hào)。
絮叨
剛好在讀項(xiàng)目代碼的時(shí)候，發(fā)現(xiàn)了WebAsyncTask這個(gè)新玩意，給大家來(lái)科普科普，不是那么的深入，不喜勿噴!
SpringBoot中同異步調(diào)用的使用
異步請(qǐng)求的處理。除了異步請(qǐng)求，一般上我們用的比較多的應(yīng)該是異步調(diào)用。通常在開(kāi)發(fā)過(guò)程中，會(huì)遇到一個(gè)方法是和實(shí)際業(yè)務(wù)無(wú)關(guān)的，沒(méi)有緊密性的。比如記錄日志信息等業(yè)務(wù)。這個(gè)時(shí)候正常就是啟一個(gè)新線(xiàn)程去做一些業(yè)務(wù)處理，讓主線(xiàn)程異步的執(zhí)行其他業(yè)務(wù)。
- 同步請(qǐng)求
- 異步請(qǐng)求
SprinBoot中@Async異步方法
異步的好處是，可以提高程序吞吐量，一個(gè)任務(wù)，讓耗時(shí)的異步處理，并繼續(xù)同步處理后面的任務(wù)，異步任務(wù)可以返回結(jié)果，拿到結(jié)果后可結(jié)合同步處理過(guò)程中的變量一起處理計(jì)算
具體的使用
在Spring中，基于@Async標(biāo)注的方法，稱(chēng)之為異步方法;這些方法將在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線(xiàn)程中被執(zhí)行，調(diào)用者無(wú)需等待它的完成，即可繼續(xù)其他的操作。
自定義線(xiàn)程池異步調(diào)用
配置@EnableAsync使@Async生效
- @SpringBootApplication
- @EnableAsync
- public class Application {
- public static void main(String[] args) {
- SpringApplication.run(Application.class, args);
- }
- }
自定義線(xiàn)程池
- @Component
- @Scope //單例
- public class MyExecutePoll {
- @Bean
- public Executor myAsyncPool() {
- ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
- //核心線(xiàn)程池大小
- executor.setCorePoolSize(20);
- //最大線(xiàn)程數(shù)
- executor.setMaxPoolSize(40);
- //隊(duì)列容量
- executor.setQueueCapacity(50);
- // 活躍時(shí)間
- executor.setKeepAliveSeconds(300);
- // 線(xiàn)程名字前綴
- executor.setThreadNamePrefix("MyExecutor-");
- //設(shè)置線(xiàn)程池關(guān)閉的時(shí)候等待所有任務(wù)都完成再繼續(xù)銷(xiāo)毀其他的Bean,使異步線(xiàn)程的銷(xiāo)毀優(yōu)先于Redis等其他處理報(bào)錯(cuò)
- executor.setWaitForTasksToCompleteOnShutdown(true);
- //設(shè)置線(xiàn)程池中任務(wù)的等待時(shí)間，如果超過(guò)這個(gè)時(shí)候還沒(méi)有銷(xiāo)毀就強(qiáng)制銷(xiāo)毀，以確保應(yīng)用最后能夠被關(guān)閉，而不是阻塞住
- executor.setAwaitTerminationSeconds(60);
- // setRejectedExecutionHandler：當(dāng)pool已經(jīng)達(dá)到max size的時(shí)候，如何處理新任務(wù)
- // CallerRunsPolicy：不在新線(xiàn)程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線(xiàn)程來(lái)執(zhí)行
- executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
- executor.initialize();
- return executor;
- }
- }
使用@Async
- @Async("myAsyncPool") //@Async使用默認(rèn)的線(xiàn)程
- public Future
doTask() throws Exception { - //業(yè)務(wù)處理 使用Future返回異步調(diào)用結(jié)果
- return new AsyncResult<>("任務(wù)一完成");
在Spring中運(yùn)用 Async注解 需要注意幾點(diǎn)：
- AsyncTest.java，測(cè)試類(lèi)，調(diào)用異步任務(wù)，同時(shí)執(zhí)行同步方法
- OrderService.java，異步任務(wù)類(lèi)，提供異步方法
- AsyncThreadPoolConfig.java，異步任務(wù)線(xiàn)程池配置類(lèi)，配置異步任務(wù)運(yùn)行的線(xiàn)程池大小等
基于Spring實(shí)現(xiàn)異步請(qǐng)求
Spring可以通過(guò)Callable或者WebAsyncTask等方式實(shí)現(xiàn)異步請(qǐng)求, 我們來(lái)看看，這2種實(shí)現(xiàn)方式!
Callable
Callable是為了異步生成返回值提供基本的支持。簡(jiǎn)單來(lái)說(shuō)就是一個(gè)請(qǐng)求進(jìn)來(lái)，如果你使用了Callable，在沒(méi)有得到返回?cái)?shù)據(jù)之前，DispatcherServlet和所有Filter就會(huì)退出Servlet容器線(xiàn)程，但響應(yīng)保持打開(kāi)狀態(tài)，一旦返回?cái)?shù)據(jù)有了，這個(gè)DispatcherServlet就會(huì)被再次調(diào)用并且處理，以異步產(chǎn)生的方式，向請(qǐng)求端返回值。這么做的好處就是請(qǐng)求不會(huì)長(zhǎng)時(shí)間占用服務(wù)連接池，提高服務(wù)器的吞吐量。
- @GetMapping("/callable")
- public Callable
testCallable() throws InterruptedException { - log.info("主線(xiàn)程開(kāi)始！");
- Callable
result = new Callable () { - @Override
- public String call() throws Exception {
- log.info("副線(xiàn)程開(kāi)始！");
- Thread.sleep(1000);
- log.info("副線(xiàn)程結(jié)束！");
- return "SUCCESS";
- }
- };
- log.info("主線(xiàn)程結(jié)束！");
- return result;
- }
輸出結(jié)果
- 主線(xiàn)程開(kāi)始!
- 主線(xiàn)程結(jié)束!
- 副線(xiàn)程開(kāi)始!
- 副線(xiàn)程結(jié)束!
WebAsyncTask
一個(gè)請(qǐng)求到服務(wù)上，是用的web容器的線(xiàn)程接收的
我們可以使用WebAsyncTask將這個(gè)請(qǐng)求分發(fā)給一個(gè)新的線(xiàn)程去執(zhí)行，容器的線(xiàn)程可以去接收其他請(qǐng)求的處理。一旦WebAsyncTask返回?cái)?shù)據(jù)有了，就會(huì)被再次調(diào)用并且處理，以異步產(chǎn)生的方式，向請(qǐng)求端返回值，但是其實(shí)我覺(jué)得前端的請(qǐng)求rt并不會(huì)說(shuō)變短。
- /**
- * 查詢(xún)
- */
- @RequestMapping(method = RequestMethod.GET, value = "/aysncTask/{testId}")
- @ResponseStatus(HttpStatus.OK)
- public WebAsyncTask
aysncTask(@PathVariable("testId") String testId) { - System.out.println(String.format("/aysncTask/%s 被調(diào)用 thread id is: %s", testId,Thread.currentThread().getName()));
- Callable
callable = () -> { - Thread.sleep(1000L);
- Response response = new Response(true,"異步執(zhí)行成功");
- System.out.println(String.format("/aysncTask/%s 被調(diào)用 thread id is: %s", testId,Thread.currentThread().getName()));
- return response;
- };
- return new WebAsyncTask
(callable); - }
控制臺(tái)打印如下：在執(zhí)行業(yè)務(wù)邏輯之前的線(xiàn)程和具體處理業(yè)務(wù)邏輯的線(xiàn)程不是同一個(gè)，達(dá)到了我們的目的。async-customize-1這個(gè)前綴是我們自定義的下邊會(huì)說(shuō)
- /aysncTask/12348567676 被調(diào)用 thread id is: http-nio-8084-exec-1
- /aysncTask/12348567676 被調(diào)用 thread id is: async-customize-1
其實(shí)WebAsyncTask比起Callable是有以下幾個(gè)優(yōu)點(diǎn)的
官方有這么一句話(huà)，截圖給你：
如果我們需要超時(shí)處理的回調(diào)或者錯(cuò)誤處理的回調(diào)，我們可以使用WebAsyncTask代替Callable
實(shí)際使用中，我并不建議直接使用Callable ，而是使用Spring提供的WebAsyncTask 代替，它包裝了Callable，功能更強(qiáng)大些
總結(jié)
其實(shí)本文就是給大家科普下，一些異步的用法，不至于說(shuō)看到人家這么用很蒙b,多線(xiàn)程的東西還是優(yōu)點(diǎn)東西的，大家一起學(xué)習(xí)。
本文標(biāo)題：項(xiàng)目中發(fā)現(xiàn)了一個(gè)新的玩意WebAsyncTask
網(wǎng)頁(yè)URL：http://www.5511xx.com/article/cojspds.html
