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

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系列 - 定时任务

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