Spring boot中怎么利用WebAsyncTask實現(xiàn)異步任務(wù)編程

今天就跟大家聊聊有關(guān)Spring boot中怎么利用WebAsyncTask實現(xiàn)異步任務(wù)編程，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

1、處理線程

處理線程屬于web服務(wù)器，負(fù)責(zé)處理用戶請求，采用線程池管理

2、異步線程

異步線程屬于用戶自定義的線程，可采用線程池管理

spring中提供了對異步任務(wù)的支持，采用 WebAsyncTask 類即可實現(xiàn)異步任務(wù)，同時我們也可以對異步任務(wù)設(shè)置相應(yīng)的回調(diào)處理，如當(dāng)任務(wù)超時、拋出異常怎么處理等。異步任務(wù)通常非常實用，比如我們想讓一個可能會處理很長時間的操作交給異步線程去處理，又或者當(dāng)一筆訂單支付完成之后，開啟異步任務(wù)查詢訂單的支付結(jié)果。

一、正常異步任務(wù)

為了演示方便，異步任務(wù)的執(zhí)行采用 Thread.sleep(long) 模擬，現(xiàn)在假設(shè)用戶請求以下接口 :

http://localhost:7000/demo/getUserWithNoThing.json

異步任務(wù)接口定義如下：

/**
 * 測試沒有發(fā)生任何異常的異步任務(wù)
 */
@RequestMapping(value = "getUserWithNoThing.json", method = RequestMethod.GET)
public WebAsyncTask<String> getUserWithNoThing() {
 // 打印處理線程名
 System.err.println("The main Thread name is " + Thread.currentThread().getName());
 
 // 此處模擬開啟一個異步任務(wù),超時時間為10s
 WebAsyncTask<String> task1 = new WebAsyncTask<String>(10 * 1000L, () -> {
 	System.err.println("The first Thread name is " + Thread.currentThread().getName());
 	// 任務(wù)處理時間5s,不超時
 	Thread.sleep(5 * 1000L);
 	return "任務(wù)1順利執(zhí)行成功！任何異常都沒有拋出！";
 });
 
 // 任務(wù)執(zhí)行完成時調(diào)用該方法
 task1.onCompletion(() -> {
 	System.err.println("任務(wù)1執(zhí)行完成啦！");
 });
 
 System.err.println("task1繼續(xù)處理其他事情！");
 return task1;
}

控制臺打印如下：

The main Thread name is http-nio-7000-exec-1
task1繼續(xù)處理其他事情！
The first Thread name is MvcAsync1
任務(wù)1執(zhí)行完成啦！

瀏覽器結(jié)果如下：

二、拋異常異步任務(wù)

接口調(diào)用 ： http://localhost:7000/demo/getUserWithError.json

/**
 * 測試發(fā)生error的異步任務(wù)
 * @return
 */
@RequestMapping(value = "getUserWithError.json", method = RequestMethod.GET)
public WebAsyncTask<String> getUserWithError() {
	System.err.println("The main Thread name is " + Thread.currentThread().getName());

	// 此處模擬開啟一個異步任務(wù)
	WebAsyncTask<String> task3 = new WebAsyncTask<String>(10 * 1000L, () -> {
		System.err.println("The second Thread name is " + Thread.currentThread().getName());
		// 此處拋出異常
		int num = 9 / 0;
		System.err.println(num);
		return "";
	});

	// 發(fā)生異常時調(diào)用該方法
	task3.onError(() -> {
		System.err.println("====================================" + Thread.currentThread().getName()
				+ "==============================");
		System.err.println("任務(wù)3發(fā)生error啦！");
		return "";
	});
	// 任務(wù)執(zhí)行完成時調(diào)用該方法
	task3.onCompletion(() -> {
		System.err.println("任務(wù)3執(zhí)行完成啦！");
	});

	System.err.println("task3繼續(xù)處理其他事情！");
	return task3;
}

控制臺輸出如下：

The main Thread name is http-nio-7000-exec-1
task3繼續(xù)處理其他事情！
The second Thread name is MvcAsync1
2018-06-15 09:40:13.538 ERROR 9168 --- [nio-7000-exec-2] o.a.c.c.C.[.[.[.[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] threw exception

java.lang.ArithmeticException: / by zero
at com.example.demo.controller.GetUserInfoController.lambda$5(GetUserInfoController.java:93) ~[classes/:na]
at org.springframework.web.context.request.async.WebAsyncManager.lambda$startCallableProcessing$4(WebAsyncManager.java:317) ~[spring-web-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_161]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_161]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_161]

2018-06-15 09:40:13.539 ERROR 9168 --- [nio-7000-exec-2] o.a.c.c.C.[.[.[.[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [/demo] threw exception [Request processing failed; nested exception is java.lang.ArithmeticException: / by zero] with root cause

java.lang.ArithmeticException: / by zero
at com.example.demo.controller.GetUserInfoController.lambda$5(GetUserInfoController.java:93) ~[classes/:na]
at org.springframework.web.context.request.async.WebAsyncManager.lambda$startCallableProcessing$4(WebAsyncManager.java:317) ~[spring-web-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_161]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_161]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_161]

====================================http-nio-7000-exec-2==============================
任務(wù)3發(fā)生error啦！
任務(wù)3執(zhí)行完成啦！

當(dāng)然你也可以對上面做一些異常處理，不至于在用戶看來顯得不友好，關(guān)于異常處理，可以查看我的另一篇文章 Spring boot/Spring 統(tǒng)一錯誤處理方案的使用

瀏覽器輸出結(jié)果：

三、超時異步任務(wù)

接口調(diào)用 ： http://localhost:7000/demo/getUserWithTimeOut.json

/**
 * 測試發(fā)生任務(wù)超時的異步任務(wù)
 * @return
 */
@RequestMapping(value = "getUserWithTimeOut.json", method = RequestMethod.GET)
public WebAsyncTask<String> getUserWithTimeOut() {
 System.err.println("The main Thread name is " + Thread.currentThread().getName());
 
 // 此處模擬開啟一個異步任務(wù),超時10s
 WebAsyncTask<String> task2 = new WebAsyncTask<String>(10 * 1000L, () -> {
 	System.err.println("The second Thread name is " + Thread.currentThread().getName());
 	Thread.sleep(20 * 1000L);
 	return "任務(wù)2執(zhí)行超時！";
 });
 
 // 任務(wù)超時調(diào)用該方法
 task2.onTimeout(() -> {
 	System.err.println("====================================" + Thread.currentThread().getName()
 			+ "==============================");
 	return "任務(wù)2發(fā)生超時啦！";
 });
 
 // 任務(wù)執(zhí)行完成時調(diào)用該方法
 task2.onCompletion(() -> {
 	System.err.println("任務(wù)2執(zhí)行完成啦！");
 });
 
 System.err.println("task2繼續(xù)處理其他事情！");
 return task2;
}

控制臺執(zhí)行結(jié)果：

The main Thread name is http-nio-7000-exec-4
task2繼續(xù)處理其他事情！
The second Thread name is MvcAsync2
====================================http-nio-7000-exec-5==============================
任務(wù)2執(zhí)行完成啦！

瀏覽器執(zhí)行結(jié)果：

四、線程池異步任務(wù)

上面的三種情況中的異步任務(wù)默認(rèn)不是采用線程池機(jī)制進(jìn)行管理的，也就是說，一個請求進(jìn)來，雖然釋放了處理線程，但是系統(tǒng)依舊會為每個請求創(chuàng)建一個異步任務(wù)線程，也就是上面我們看到的 MvcAsync 開頭的異步任務(wù)線程，那這樣不行啊，開銷特別大呀！所以我們可以采用線程池進(jìn)行管理，直接在 WebAsyncTask 類構(gòu)造器傳入一個 ThreadPoolTaskExecutor 對象實例即可。

下面我們先看看，當(dāng)對上面第一種情況執(zhí)行并發(fā)請求時會出現(xiàn)什么情況(此處模擬對 http://localhost:7000/demo/getUserWithNoThing.json 進(jìn)行并發(fā)調(diào)用)：

控制臺輸出如下：

The first Thread name is MvcAsync57
The first Thread name is MvcAsync58
The first Thread name is MvcAsync59
The first Thread name is MvcAsync60
The first Thread name is MvcAsync61
The first Thread name is MvcAsync62
The first Thread name is MvcAsync63
The first Thread name is MvcAsync64
The first Thread name is MvcAsync65
The first Thread name is MvcAsync66
The first Thread name is MvcAsync67
The first Thread name is MvcAsync68
The first Thread name is MvcAsync69
The first Thread name is MvcAsync70
The first Thread name is MvcAsync71
The first Thread name is MvcAsync72
The first Thread name is MvcAsync73
The first Thread name is MvcAsync74
The first Thread name is MvcAsync76
The first Thread name is MvcAsync75
The first Thread name is MvcAsync77
The first Thread name is MvcAsync78
The first Thread name is MvcAsync79
The first Thread name is MvcAsync80

由于沒有加入線程池，所以100個請求將開啟100個異步任務(wù)線程，開銷特別大，不推薦。

下面是采用線程池的實現(xiàn) ：

調(diào)用接口 ： http://localhost:7000/demo/getUserWithExecutor.json

/**
 * 測試線程池
 * @return
 */
@RequestMapping(value = "getUserWithExecutor.json", method = RequestMethod.GET)
public WebAsyncTask<String> getUserWithExecutor() {
 System.err.println("The main Thread name is " + Thread.currentThread().getName());
 
 // 此處模擬開啟一個異步任務(wù),此處傳入一個線程池
 WebAsyncTask<String> task1 = new WebAsyncTask<String>(10 * 1000L, executor, () -> {
 	System.err.println("The first Thread name is " + Thread.currentThread().getName());
 	Thread.sleep(5000L);
 	return "任務(wù)4順利執(zhí)行成功！任何異常都沒有拋出！";
 });
 
 // 任務(wù)執(zhí)行完成時調(diào)用該方法
 task1.onCompletion(() -> {
 	System.err.println("任務(wù)4執(zhí)行完成啦！");
 });
 
 System.err.println("task4繼續(xù)處理其他事情！");
 return task1;
}

線程池定義如下：

@Configuration
public class MyExecutor {
 
 @Bean
 public static ThreadPoolTaskExecutor getExecutor() {
 	ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
 	taskExecutor.setCorePoolSize(30);
 	taskExecutor.setMaxPoolSize(30);
 	taskExecutor.setQueueCapacity(50);
 	taskExecutor.setThreadNamePrefix("huang");// 異步任務(wù)線程名以 huang 為前綴
 	return taskExecutor;
 }
}

對上面進(jìn)行并發(fā)測試，可以得出下面結(jié)果 :

看完上述內(nèi)容，你們對Spring boot中怎么利用WebAsyncTask實現(xiàn)異步任務(wù)編程有進(jìn)一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。