SpringBoot开启定时任务、异步任务.md

Edited on In , , ,

定时任务

  • 使用注解@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消息推送

异步使用实例

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 @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;
    }

判断是否执行结束

1
2
Future<String> f = Future<String>(1);
f.isDone()

也可以使用多线程和MQ实现异步任务。

最后

一般来说，实际项目中，为了提高服务的响应能力，我们一般会通过负载均衡的方式，或者反向代理多个节点的方式来进行。 如果我们将定时任务写在我们的项目中，那么在同一个时间点，定时任务会一起执行，也就是会执行多次，这样很可能会导致我们的业务出现错误。

建议使用逻辑分离的方式来解决这个问题。就是我们将真正要定时任务处理的逻辑，写成rest或者rpc服务， 然后我们可以新建一个单独的定时任务项目，这个项目应该是没有任何的业务代码的，他纯粹只有定时任务功能， 几点启动，或者每隔多少时间启动。启动后，通过rest或者rpc的方式，调用真正处理逻辑的服务。 摘自：SpringBoot系列 - 定时任务

本文地址：https://www.jianshu.com/p/f45bac4131ce

本文地址： https://github.com/maxzhao-it/blog/post/29880/