- 调度任务，@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本身的后台任务方便，不过也能够接受，只须要简单的配置就可使用了。