- 調度任務，@Schedule
- 異步任務，@Async
固然，使用這兩個是有條件的，須要在spring應用的上下文中聲明<task:annotation-driven/>固然，若是咱們是基於java配置的，須要在配置哪裏加多EnableScheduling和@EnableAsync 就像下面這樣java
|
1
2
3
4
5
6
|
@EnableScheduling
@EnableAsync
public class WebAppConfig {
....
｝
|
除此以外，仍是有第三方庫能夠調用的，例如Quartz.spring
@Schedule
先看下@Schedule怎麼調用再說框架
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
public final static long ONE_DAY = 24 * 60 * 60 * 1000;
public final static long ONE_HOUR = 60 * 60 * 1000;
public void scheduledTask() {
System.out.println(
" 我是一個每隔一天就會執行一次的調度任務");
}
public void scheduleTask2() {
System.out.println(
" 我是一個執行完後，隔一小時就會執行的任務");
}
public void doSomething() {
// something that should execute periodically
}
public void ScheduledTask3() {
System.out.println(
" 我是一個每隔一分鐘就就會執行的任務");
}
|
須要注意的異步
-
關於最後一個，在指定時間執行的任務，裏面使用的是
Cron表達式，同時咱們看到了兩個不同的面孔fixedDelay&fixedRate，前者fixedDelay表示在指定間隔運行程序，例如這個程序在今晚九點運行程序，跑完這個方法後的一個小時，就會再執行一次，然後者fixedDelay者是指，這個函數每隔一段時間就會被調用（咱們這裏設置的是一天），無論再次調度的時候，這個方法是在運行仍是結束了。而前者就要求是函數運行結束後開始計時的，這就是二者區別。async -
這個還有一個initialDelay的參數，是第一次調用前須要等待的時間，這裏表示被調用後的，推遲一秒再執行，這適合一些特殊的狀況。maven
-
咱們在
serviceImpl類寫這些調度任務時候，也須要在這些咱們定義的serviceInterface的藉口中寫多這個接口，要否則會爆but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface oride
@Async
有時候咱們會調用一些特殊的任務，任務會比較耗時，重要的是，咱們無論他返回的後果。這時候咱們就須要用這類的異步任務啦，調用後就讓他去跑，不堵塞主線程，咱們繼續幹別的。代碼像下面這樣:函數
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
public void AsyncTask(){
public void doSomeHeavyBackgroundTask(int sleepTime) {
try {
Thread.sleep(sleepTime);
}
catch (InterruptedException e) {
e.printStackTrace();
}
}
public Future<String> doSomeHeavyBackgroundTask() {
try {
Thread.sleep(
3000);
}
catch (InterruptedException e) {
e.printStackTrace();
}
return null;
}
public void printLog() {
System.out.println(
" i print a log ,time=" + System.currentTimeMillis());
}
}
|
咱們寫個簡單的測試類來測試下post
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration
@ContextConfiguration(classes = AsycnTaskConfig.class) //要聲明@EnableASync
public class AsyncTaskTest {
@Autowired
AsyncTask asyncTask;
@Test
public void AsyncTaskTest() throws InterruptedException {
if (asyncTask != null) {
asyncTask.doSomeHeavyBackgroundTask(4000);
asyncTask.printLog();
Thread.sleep(5000);
}
}
}
|
這感受比咱們手動開多一個線程方便多了，不想異步的話直接把@Async去掉就能夠了，另外若是你想要返回個結果的，這須要加多個Future<>,關於這個Future，徹底能夠寫多幾篇文章介紹，順便把FutureTask介紹了。若是想修改Spring boot的默認線程池配置，能夠實現AsyncConfigurer.
須要注意的：測試
- 相對於
@scheduled，這個能夠有參數和返回個結果，由於這個是咱們調用的，而調度的任務是spring調用的。 - 異步方法不能內部調用，只能像上面那樣，外部調用，不然就會變成阻塞主線程的同步任務啦！這個坑我竟然跳下去了！例以下面這樣的。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
public void AsyncTask(){
public void fakeAsyncTaskTest(){
doSomeHeavyBackgroundTask(
4000);
printLog();
//你會發現，當你像這樣內部調用的時候，竟然是同步執行的，不是異步的！！
}
public void doSomeHeavyBackgroundTask(int sleepTime) {
try {
Thread.sleep(sleepTime);
}
catch (InterruptedException e) {
e.printStackTrace();
}
}
public void printLog() {
System.out.println(
" i print a log ");
}
}
|
- 另一點就是不要重複的掃描，這也會致使異步無效，具體的能夠看這個stackoveflow的spring-async-not-working Issue。
- 關於異常處理，不免在這個異步執行過程當中有異常發生，對於這個問題，spring提供的解決方案以下,實現 AsyncUncaughtExceptionHandler接口。
|
1
2
3
4
5
6
7
8
9
10
11
|
public class MyAsyncUncaughtExceptionHandler implements
AsyncUncaughtExceptionHandler {
public void handleUncaughtException(Throwable ex,
Method method, Object... params) {
// handle exception
}
}
|
寫好咱們的異常處理後，咱們須要配置一下，告訴spring，這個異常處理就是咱們在運行異步任務時候，拋出錯誤時的異常終結者
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
public class AsyncConfig implements AsyncConfigurer {
public AsyncTask asyncBean() {
return new AsyncTask();
}
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor =
new ThreadPoolTaskExecutor();
executor.setCorePoolSize(
7);
executor.setMaxPoolSize(
42);
executor.setQueueCapacity(
11);
executor.setThreadNamePrefix(
"MyExecutor-");
executor.initialize();
return executor;
}
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new MyAsyncUncaughtExceptionHandler();
}
}
|
Quartz登場
處理這兩個外，還有一個和spring整合的第三方庫叫Quartz
看了下官網的使用簡介，也是挺逗的，如今都習慣用maven，gradle之類來關係這些依賴了，他還叫人下載，也是不知爲什麼，詳情點擊－>
http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start估計有多是由於沒再維護了的緣由吧，看了下，最新版2.2竟然是Sep, 2013更新的…竟然是停更的，不過Quartz做爲一個企業級應用的任務調度框架，仍是一個能夠的候選項目的。這裏不鋪開講，有興趣就去官網看下吧。總體用起來感受是沒有spring本身的後臺任務方便，不過也能夠接受，只須要簡單的配置就可使用了。