Quartz简介

痛定思痛。 2022-06-16 11:55 125阅读 0赞

# 前言 #

其实关于Quartz我也不太了解，因为最近项目中有这么个需求——执行定时任务，比如新生报到之后需要分班，分学号。。设定是任务就可以在设定的时间执行这些操作，这样登录系统之后就看到分配好的信息。

# 概念 #

是什么？ 官网（ http://www.quartz-scheduler.org/ ）

Quartz是一个功能丰富的开源作业调度库，可以集成到几乎任何Java应用程序中 - 从最小的独立应用程序到最大的电子商务系统。 Quartz可以用来执行作业数十，数百，甚至数万的，成千上万的创建简单或复杂的调度; 任务定义为标准Java组件的任务，可以执行任何可以对其进行编程的任何内容。 Quartz Scheduler包含许多企业级功能，例如支持JTA事务和集群。

下载

进入官网之后大家就应该知道怎么下载了，我就不说了，目前最新的版本是2.2.3，下载之后解压该文件![Center][]

# 示例     #

这是官网上的第一个小例子，两个Java类

HelloJob.java,这是要执行的定时任务

package org.quartz.examples.example1;
    
    import java.util.Date;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    
    
    public class HelloJob implements Job {
    
        private static Logger _log = LoggerFactory.getLogger(HelloJob.class);
    
        /**    
         * 用于作业初始化的空构造函数
         * 
         * Quartz需要一个公共空构造函数
        * 调度程序可以在需要时实例化类
         * 
         */
        public HelloJob() {
        }
    
        //一段时间内由调度器调用与之相关联的触发器触发作业
        public void execute(JobExecutionContext context)
            throws JobExecutionException {
    
            // 打印出Hello World并显示日期
            _log.info("Hello World! - " + new Date());
        }
    
    }

SimpleExample.java

package org.quartz.examples.example1; import static org.quartz.DateBuilder.evenMinuteDate; import static org.quartz.JobBuilder.newJob; import static org.quartz.TriggerBuilder.newTrigger; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerFactory; import org.quartz.Trigger; import org.quartz.impl.StdSchedulerFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.Date; /** * 演示如何启动和关闭Quartz调度程序，以及如何在Quartz中按计划执行 * */ public class SimpleExample { public void run() throws Exception { Logger log = LoggerFactory.getLogger(SimpleExample.class); log.info("------- Initializing ----------------------"); // 得到一个调度程序的引用 SchedulerFactory sf = new StdSchedulerFactory(); Scheduler sched = sf.getScheduler(); log.info("------- Initialization Complete -----------"); // 电脑在下一个分钟的时间执行 Date runTime = evenMinuteDate(new Date()); log.info("------- Scheduling Job -------------------"); // 定义一个job并将其绑定到我们的Hellojob类中 JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build(); // 触发这个job在下一分钟执行 Trigger trigger = newTrigger().withIdentity("trigger1", "group1").startAt(runTime).build(); //让调度器使用触发器执行job sched.scheduleJob(job, trigger); log.info(job.getKey() + " will run at: " + runTime); // 启动调度程序 sched.start(); log.info("------- Started Scheduler -----------------"); // 等待足够长时间，使调度程序有机会运行job log.info("------- Waiting 65 seconds... -------------"); try { // 等待65秒显示工作 Thread.sleep(65L * 1000L); // executing... } catch (Exception e) { // } // 关闭调度器 log.info("------- Shutting Down ---------------------"); sched.shutdown(true); log.info("------- Shutdown Complete -----------------"); } public static void main(String[] args) throws Exception { SimpleExample example = new SimpleExample(); example.run(); } }

好了就先到这里了，你看明白了吗？

# 小结 #

有了一个宏观认识，接下来学习如何应用。

[Center]: /images/20220616/64fb5fb46f7546d7923ec2d58cbc4962.png