那些年，咱们用过的“定时调度”

时间  2019-12-09
标签 那些年 咱们 用过 定时 调度 繁體版
原文   原文链接

定时调度

做为后端开发人员，咱们总会遇到这样的业务场景：每周同步一批数据；每半个小时检查一遍服务器运行情况；天天早上八点给用户发送一份包含今日待办事项的邮件，等等。java

这些场景中都离不开“定时器”，就像一个定好时间规则的闹钟，它会在指定时间触发，执行咱们想要定义的调度任务。那么咱们今天就来数一下，那些年咱们用过的“定时调度”。linux

1. job (oracle)

从刚工做就一直使用oracle数据库，最先接触的定时任务就是oracle数据库的job。job有定时执行的功能，能够在指定的时间点或天天的某个时间点自行执行任务。 并且oracle从新启动后，job会继续运行，不用从新启动。spring

并且job的机制很是完备，能够查询相关的表或视图，查询job的定时规则和执行状况。缺点是做为oracle数据库层面的工具，自定义功能扩展，二次开发的难度比较大。shell

1.1 建立job数据库

DECLARE
  job NUMBER;
BEGIN
    sys.dbms_job.submit(job => job,

    what => 'prc_name;',                          --执行的存储过程的名字

    next_date => to_date('22-11-2013 09:09:41', 'dd-mm-yyyy hh24:mi:ss'), --下一次执行时间

    interval =>'sysdate+1/24');            --天天24小时，即每小时运行prc_name过程一次
END;

-- job参数是输出参数，由submit()过程返回的binary_ineger，这个值用来惟一标识一个工做。通常定义一个变量接收，能够去user_jobs视图查询job值。
-- what参数是将被执行的PL/SQL代码块，存储过程名称等。
-- next_date参数指识什么时候将运行这个工做。
-- interval参数什么时候这个工做将被重执行

1.2 删除jobsegmentfault

DECLARE
BEGIN
  dbms_job.remove(1093);  -- 1093为当前须要删除的 job 值
  COMMIT;
END;

1.3 查询jobwindows

-- 查询当前用户的job
select * from user_jobs;
-- 查询全部job
select * from dba_jobs;
-- 查询全部运行中的job
select * from dba_jobs_running;

2. crontab (linux)

crond 是linux下用来周期性的执行某种任务或等待处理某些事件的一个守护进程，与windows下的计划任务相似，当安装完成操做系统后，默认会安装此服务 工具，而且会自动启动crond进程，crond进程每分钟会按期检查是否有要执行的任务，若是有要执行的任务，则自动执行该任务。后端

cron是服务名称，crond是后台进程，crontab则是定制好的计划任务表。大部分linux系统默认都安装了cron，能够检查一下。centos

-- 检查Crontab工具是否安装
crontab -l
-- 检查crond服务是否启动
service crond status

-- centos安装
yum install vixie-cron
yum install crontabs

crontab基本操做命令springboot

-- 列出某个用户cron服务的详细内容
crontab -l
-- 编辑某个用户的cron服务
crontab -e

crontab表达式格式

{minute} {hour} {day-of-month} {month} {day-of-week} {full-path-to-shell-script}

 minute: 区间为 0 – 59
 hour: 区间为0 – 23
 day-of-month: 区间为0 – 31
 month: 区间为1 – 12. 1 是1月. 12是12月
 Day-of-week: 区间为0 – 7. 周日能够是0或7.

在以上各个字段中，还可使用如下特殊字符：
星号（*）：表明全部可能的值，例如month字段若是是星号，则表示在知足其它字段的制约条件后每个月都执行该命令操做。
逗号（,）：能够用逗号隔开的值指定一个列表范围，例如，“1,2,5,7,8,9”
中杠（-）：能够用整数之间的中杠表示一个整数范围，例如“2-6”表示“2,3,4,5,6”
正斜线（/）：能够用正斜线指定时间的间隔频率，例如“0-23/2”表示每两小时执行一次。同时正斜线能够和星号一块儿使用，例如*/10，若是用在minute字段，表示每十分钟执行一次。

推荐一个crontab表达式的校验网站（https://tool.lu/crontab/）

3. Timer和ScheduledExecutorService (java)

Timer是jdk中提供的一个定时器工具，使用的时候会在主线程以外起一个单独的线程执行指定的计划任务，能够指定执行一次或者反复执行屡次。

//只执行一次
public void schedule(TimerTask task, long delay);
public void schedule(TimerTask task, Date time);
//循环执行
// 在循环执行类别中根据循环时间间隔又能够分为两类
public void schedule(TimerTask task, long delay, long period) ;
public void schedule(TimerTask task, Date firstTime, long period) ;
 
public void scheduleAtFixedRate(TimerTask task, long delay, long period)
public void scheduleAtFixedRate(TimerTask task, Date firstTime, long period)

TimerTask是一个实现了Runnable接口的抽象类，表明一个能够被Timer执行的任务。TimerTask类是一个抽象类，由Timer 安排为一次执行或重复执行的任务。它有一个抽象方法run()方法，该方法用于执行相应计时器任务要执行的操做。所以每个具体的任务类都必须继承TimerTask，而后重写run()方法。
另外它还有两个非抽象的方法

-- 取消此计时器任务
boolean cancel()
-- 返回此任务最近实际执行的安排执行时间
long scheduledExecutionTime()

固然，通常使用Timer的比较少，由于它的缺点比较明显：

  1. 单线程，当多个timer同时运行时，会等上一个执行完成，再执行下一个。
  2. Timer线程是不会捕获异常的，若是TimerTask抛出的了未检查异常则会致使Timer线程终止。

因此通常使用ScheduledExecutorService替代Timer。
ScheduledExecutorService：也是jdk自带的一个基于线程池设计的定时任务类。其每一个调度任务都会分配到线程池中的一个线程执行，因此其任务是并发执行的，互不影响。

4. SpringTask (spring)

Timer和ScheduledExecutorService都是属于jdk层面上实现定时调度的类，功能还不足以让咱们满意，那么如今介绍一个比较完善的定时调度工具 - SpringTask，是Spring提供的，支持注解和配置文件形式，支持crontab表达式，使用简单但功能强大。我我的很是喜欢SpringTask，仅仅是由于支持crontab表达式。

在springboot里面使用方式很是简单：

  1. 启动类添加开启定时调度的注解 @EnableScheduling
  2. 在须要定时执行的方法上，增长注解 @Scheduled(cron ="crontab表达式")

默认的简单的使用步骤只有以上两步，可是SpringTask的默认使用方式也有一些不足：

  1. 默认线程池的poolsize为1，能够理解为Timer相似的单线程模式。
  2. 没法动态修改crontab表达式，修改完只能从新部署后，才能生效。

问题1的解决方式，能够经过自定义 TaskExecutor来修改当前的线程池。问题2，则能够直接使用 threadPoolTaskScheduler类实现自定义的定时调度规则。

附解决两个问题的源码 TaskTimer.class

@Component
public class TaskTimer {

    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;
    @Autowired
    private TaskRepo taskRepo;

    /**
     * ***定时引擎***
     *
     * 实例化一个线程池任务调度类
     * 默认 ThreadPoolTaskScheduler 的 poolSize 为1，相似于newSingleThreadExecutor 单线程模式，只能执行完一个调度，再执行其余调度
     * 须要自定义扩展poolSize，容许必定程度的 多线程并行场景
     *
     * @return
     */
    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
        threadPoolTaskScheduler.setPoolSize(100);
        threadPoolTaskScheduler.setThreadNamePrefix("Thread - ");
        threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);
        threadPoolTaskScheduler.setAwaitTerminationSeconds(60);
        return threadPoolTaskScheduler;
    }

    /**
     * 启动定时调度
     * @param taskCode
     * @param cron
     * @param runnable
     * @return
     */
    public boolean start(String taskCode, String cron,Runnable runnable){
        ScheduledFuture<?> currentFuture=taskRepo.findTask(taskCode);
        //已存在的调度，没法再建立
        if(currentFuture!=null){
            throw  new RuntimeException("调度\""+taskCode+"\"已存在，没法再建立");
        }
        //建立新的调度，并加入 taskMap
        currentFuture = threadPoolTaskScheduler.schedule(runnable,new CronTrigger(cron));
        if (currentFuture!=null){
            this.taskRepo.addTask(taskCode,currentFuture);
            return true;
        }
        throw  new RuntimeException("任务启动失败！！！");
    }

    /**
     * 暂停定时调度
     * @param taskCode
     * @return
     */
    public boolean stop(String taskCode) {
        //taskId 不存在的，没法中止，只能修改
        ScheduledFuture<?> currentFuture=this.taskRepo.findTask(taskCode);
        if(currentFuture!=null){
            return currentFuture.cancel(true);
        }
        return true;
    }

    /**
     * 删除定时调度
     * @param taskCode
     * @return
     */
    public boolean remove(String taskCode){
        ScheduledFuture<?> currentFuture=this.taskRepo.findTask(taskCode);
        if(currentFuture!=null){
             currentFuture.cancel(true);
             taskRepo.removeTask(taskCode);
             return true;
        }
        return false;
    }

    /**
     * 修改定时调度
     * @param taskCode
     * @param cron
     * @param runnable
     * @return
     */
    public boolean update(String taskCode,String cron,Runnable runnable){
        ScheduledFuture<?> currentFuture=this.taskRepo.findTask(taskCode);
        //已存在的定时调度，先中止，再新增，并更新 新的ScheduledFuture
        if(currentFuture!=null) {
            currentFuture.cancel(true);
        }
        currentFuture= threadPoolTaskScheduler.schedule(runnable,new CronTrigger(cron));
        if(currentFuture!=null){
            this.taskRepo.addTask(taskCode,currentFuture);
            return true;
        }
        return false;
    }

}

5. Quartz (其余产品)

Quartz是一个彻底由 Java 编写的开源做业调度框架，为在 Java 应用程序中进行做业调度提供了简单却强大的机制。它是一个功能强大、十分红熟的重量级产品，还支持负载均衡，实现分布式调度。

不过，对于Quartz的安装你要多花点功夫了，从数据库要建哪些表，到应用程序该如何部署。对于这样一个庞大的产品，本篇文章就不附上它的使用说明书了。

参考文档

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程