title: SpringBoot开启定时任务、异步任务.md
date: 2019-05-21
author: maxzhao
tags:
- JAVA
- SpringBoot
- 定时任务
- 异步任务
categories:
- SpringBoot
定时任务
使用注解
@EnableScheduling启动定时任务定义
Component让任务被扫描到@Scheduled(fixedRate = 5000)：上一次开始执行时间点之后5秒再执行@Scheduled(fixedDelay = 5000)：上一次执行完毕时间点之后5秒再执行@Scheduled(initialDelay=1000, fixedRate=5000)：第一次延迟1秒后执行，之后按fixedRate的规则每5秒执行一次@Scheduled(cron="*/5 * * * * *")：通过 cron 表达式定义规则
异步任务
- 使用注解
@EnableAsync - 定义
Component让异步任务被扫描到，@Async定义在方法上，作为异步方法。 - 异步任务的调用是同时执行的。
异步任务使用场景
- 发送短信、邮件
- App消息推送
异步使用实例
@Async
public void dealNoReturnTask() {
logger.info("返回值为void的异步调用开始" + Thread.currentThread().getName());
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info("返回值为void的异步调用结束" + Thread.currentThread().getName());
}
// Future<String> 回调函数
@Async
public Future<String> dealHaveReturnTask(int i) {
logger.info("asyncInvokeReturnFuture, parementer=" + i);
Future<String> future;
try {
Thread.sleep(1000 * i);
future = new AsyncResult<String>("success:" + i);
} catch (InterruptedException e) {
future = new AsyncResult<String>("error");
}
return future;
}
判断是否执行结束
Future<String> f = Future<String>(1);
f.isDone()
也可以使用多线程和MQ实现异步任务。
最后
一般来说，实际项目中，为了提高服务的响应能力，我们一般会通过负载均衡的方式，或者反向代理多个节点的方式来进行。 如果我们将定时任务写在我们的项目中，那么在同一个时间点，定时任务会一起执行，也就是会执行多次，这样很可能会导致我们的业务出现错误。
建议使用逻辑分离的方式来解决这个问题。就是我们将真正要定时任务处理的逻辑，写成rest或者rpc服务， 然后我们可以新建一个单独的定时任务项目，这个项目应该是没有任何的业务代码的，他纯粹只有定时任务功能， 几点启动，或者每隔多少时间启动。启动后，通过rest或者rpc的方式，调用真正处理逻辑的服务。 摘自：SpringBoot系列 - 定时任务
