美文网首页CodeInventor Group程序员
java调度框架Quartz(二)

java调度框架Quartz(二)

作者: 瑶瑶小仙女 | 来源:发表于2017-02-13 23:50 被阅读233次

上一篇咱们整理学习了Java调度框架Quartz的1+版本,这才咱们看一下Quartz的2+版本和2以下版本的有什么区别。无非就是几个步骤,1.创建调度器,2.创建作业任务,3.创建触发器并设置触发器的出发执行规则,4.开始调度。那么Quartz 2版本有什么区别呢,直接上代码直接一点:
还是那几步,我就不一一罗列了。
首先是Job作业的任务逻辑:实现Job interface

package com.traning.quartz.quartz2_1_7;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * Created by luyang.li on 17/2/8.
 */
public class QuartzTestJob implements Job {
    public void execute(JobExecutionContext context) throws JobExecutionException {
        System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "Quartz 2.1.7 Test");
    }
}

具体的任务:

package com.traning.quartz.quartz2_1_7;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;

/**
 * Created by luyang.li on 17/2/13.
 */
public class QuartzTestApp {
    public static void main(String[] args) throws SchedulerException, InterruptedException {
        //获取 调度器
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = schedulerFactory.getScheduler();
        //获取 任务作业
        JobDetail jobDetail = newJob(QuartzTestJob.class).withIdentity("groupJobName", "group1").build();
        //获取 触发器
        Trigger trigger = newTrigger().withIdentity("triggerName", "group1").startNow().build();
        //绑定
        scheduler.scheduleJob(jobDetail, trigger);
        scheduler.start();

        Thread.sleep(10);

        scheduler.shutdown();
    }
}

咱们直接执行这个方法就可以看见任务执行了,为什么要调用这个

scheduler.shutdown();

方法呢,应为Quartz任务在执行的时候不会显示关闭任务,就算主线程执行完毕了,任务还是在执行中,咱们就直接调用shutdown关闭。
咱们看一下两者的区别就是创建任务和触发器的时候使用的方式不同了在构造作业和触发器的时候都是构造他的 组 和 名,只是使用了不同的方式。来看一下源码:

    public Key(String name, String group) {
        if(name == null)
            throw new IllegalArgumentException("Name cannot be null.");
        this.name = name;
        if(group != null)
            this.group = group;
        else
            this.group = DEFAULT_GROUP;
    }

其实和1+版本的作用都是一样的,构造作业的时候是绑定作业的类,然后构造 组 + 名,构造触发器的手也是同样的构造触发器的 组 + 名。
大家可以执行以下看一下结果,我就不贴结果了。
下面咱们看一下2+版本的SimpleTrigger的构造器的使用:SimpleTrigger上一节咱们说是简单的构造器执行方式
1.和1版本一样来看下这个方法:

 public SimpleScheduleBuilder withIntervalInMinutes(int intervalInMinutes) 

这个方法就是设置执行的间隔,参数是一个int值,再看下他的源码:

    public SimpleScheduleBuilder withIntervalInMinutes(int intervalInMinutes) {
        this.interval = intervalInMinutes * DateBuilder.MILLISECONDS_IN_MINUTE;
        return this;
    }

这个常量是:
  public static final long MILLISECONDS_IN_MINUTE = 60l * 1000l;

我们可以看出来是单位是分钟!!!好了有执行间隔了,执行次数呢:
还有一个函数是设置执行次数:

    public SimpleScheduleBuilder withRepeatCount(int triggerRepeatCount) {
        this.repeatCount = triggerRepeatCount;
        return this;
    }

这个函数就是设置执行次数。
好了直接看下整体的代码:

package com.traning.quartz.quartz2_1_7;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;

/**
 * Created by luyang.li on 17/2/13.
 */
public class QuartzTestApp {
    public static void main(String[] args) throws SchedulerException, InterruptedException {
        //获取 调度器
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = schedulerFactory.getScheduler();
        //获取 任务作业
        JobDetail jobDetail = newJob(QuartzTestJob.class).withIdentity("groupJobName", "group1").build();
        //获取 触发器  !!!!!!
        Trigger trigger = newTrigger().withSchedule(simpleSchedule()
                .withIntervalInMinutes(1) // 1分钟
                .withRepeatCount(20))  // 重复20次
                .startNow()
                .build();

        //绑定
        scheduler.scheduleJob(jobDetail, trigger);
        scheduler.start();

    }
}

这里我把关闭方法去掉了,因为任务要执行20次,不然要睡眠等到任务结束才可以调用关闭,大家自己执行下看看效果。
怎么样简单吧。好了下一节咱们看下 1+ 版本和 2+版本的CronTrigger的使用。

相关文章

  • Quartz.NET 作业调度(一):Test

    Quartz.NET 是一个开源的作业调度框架,是 Java 作业调度框架 Quartz 的.NET 版本,对于...

  • springboot使用quartz集群定时任务

    简介 Quartz是一个完全由java编写的开源作业调度框架。不要让作业调度这个术语吓着你。尽管Quartz框架整...

  • Spring Boot 2.0 quartz简介

    1、 什么是Quartz? Quartz是一个用Java编写的开源作业调度框架。它为Java应用程序中的作业调度提...

  • java调度框架Quartz(二)

    上一篇咱们整理学习了Java调度框架Quartz的1+版本,这才咱们看一下Quartz的2+版本和2以下版本的有什...

  • Quartz 教程

    一、关于 Quartz Quartz 是一个完全由 Java 编写的开源作业调度框架,为在 Java 应用程序中进...

  • Java 定时任务实现--Quartz

    你了解 Quartz 吗? Quartz 是一个完全由 Java 编写的开源作业调度框架,为在 Java 应用程序...

  • Quartz

    一.介绍 Quartz 是一个完全由 Java 编写的开源作业调度框架,为在 Java 应用程序中进行作业调度提供...

  • Quartz 调度器

    一、简介 Quartz是一个开源作业调度框架,框架的核心是调度器,调度器负责管理Quartz应用运行时环境,调度器...

  • 通过quartz实现任务调度

    quartz是java的一个作业调度框架,可以轻松实现定时任务 quartz由以下几个部分构成: job:在exe...

  • Java - Quartz 定时任务

    Quartz是一个完全由Java编写的开源作业调度框架,为在Java应用程序中进行作业调度提供了简单却强大的机制。...

网友评论

    本文标题:java调度框架Quartz(二)

    本文链接:https://www.haomeiwen.com/subject/hrotwttx.html