Java Quartz如何控制定时器启动与停止

以下内容基于Spring4.X、quartz1.6.6。大致想法是。通过Spring注入工厂对象，获取Scheduler。通过JobFactory解决执行类无法使用注入注解的问题。

QuartzManager封装了定时器常用操作方法

package framework.basic.quartz;

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.text.ParseException;

/**
 * @Description: 定时任务管理类
 * 该类可管理XML配置的定时器（quartzManagerSchedulerFactoryBean）
 *      默认任务组名为（Scheduler.DEFAULT_GROUP）
 *      任务名为JobDetail的beanId
 *      默认触发器组名为（Scheduler.DEFAULT_GROUP）
 *      触发器名为CronTriggerBean的BeanId
 * 可在代码中定义创建定时器
 *      该类方法时 执行类需要继承org.quartz.Job接口 复写execute方法
 * @ClassName: QuartzManager
 */
public class QuartzManager {
    private static final Logger logger = LoggerFactory.getLogger(QuartzManager.class);

    public QuartzManager() {
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        try {
            setScheduler(schedulerFactory.getScheduler());
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

    /**
     * 通过构造器注入Spring所管理的工厂对象
     * @param scheduler
     */
    public QuartzManager(Scheduler scheduler) {
        setScheduler(scheduler);
    }

    private Scheduler scheduler;

    public Scheduler getScheduler() {
        return scheduler;
    }

    public void setScheduler(Scheduler scheduler) {
        this.scheduler = scheduler;
    }


    /**
     * @param jobName          任务名
     * @param jobGroupName     任务组名
     * @param triggerName      触发器名
     * @param triggerGroupName 触发器组名
     * @param jobClass         任务
     * @param time             时间设置，参考quartz说明文档
     * @Description: 添加一个定时任务
     */
    @SuppressWarnings("unchecked")
    public void addJob(String jobName, String jobGroupName,
                       String triggerName, String triggerGroupName, Class jobClass,
                       String time) {
        try {
            JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass);// 任务名，任务组，任务执行类
            // 触发器
            CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 触发器名,触发器组
            trigger.setCronExpression(time);// 触发器时间设定
            scheduler.scheduleJob(jobDetail, trigger);
        } catch (SchedulerException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        }
    }



    /**
     * 暂停一个job
     *
     * @param jobName
     * @param jobGroupName
     */
    public void pauseJob(String jobName, String jobGroupName) {
        try {
            scheduler.pauseJob(jobName, jobGroupName);
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

    /**
     * 恢复一个job 恢复定时器时立刻先执行一次定时器的任务 然后再按计划执行
     *
     * @param jobName
     * @param jobGroupName
     */
    public void resumeJob(String jobName, String jobGroupName) {
        try {
            scheduler.resumeJob(jobName, jobGroupName);
        } catch (SchedulerException e) {
            logger.error("恢复定时器异常:jobName[{}],jobGroupName[{}]",jobName,jobGroupName);
            e.printStackTrace();
        }
    }

    /**
     * @param jobName
     * @param jobGroupName
     * @param triggerName
     * @param triggerGroupName
     * @Description: 移除一个任务
     */
    public void removeJob(String jobName, String jobGroupName,
                          String triggerName, String triggerGroupName) {
        try {
            scheduler.pauseTrigger(triggerName, triggerGroupName);// 停止触发器
            scheduler.unscheduleJob(triggerName, triggerGroupName);// 移除触发器
            scheduler.deleteJob(jobName, jobGroupName);// 删除任务
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }



    /**
     * @param triggerName
     * @param triggerGroupName
     * @param time
     * @Description: 修改一个任务的触发时间
     */
    public void modifyJobTime(String triggerName,
                              String triggerGroupName, String time) {
        try {
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerName, triggerGroupName);
            if (trigger == null) {
                return;
            }
            String oldTime = trigger.getCronExpression();
            if (!oldTime.equalsIgnoreCase(time)) {
                CronTrigger ct = (CronTrigger) trigger;
                // 修改时间
                ct.setCronExpression(time);
                // 重启触发器
                scheduler.resumeTrigger(triggerName, triggerGroupName);
            }
        } catch (SchedulerException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        }
    }


    /**
     * @param triggerName
     * @param triggerGroup
     * @Description: 获取触发器状态
     *
     * @return
     *       STATE_BLOCKED 4 阻塞
     *       STATE_COMPLETE 2 完成
     *       STATE_ERROR 3 错误
     *       STATE_NONE -1 不存在
     *       STATE_NORMAL 0 正常
     *       STATE_PAUSED 1 暂停
     */
    public int getTriggerState(String triggerName, String triggerGroup ){
        try {
            return scheduler.getTriggerState(triggerName,triggerGroup);
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return 3;
    }

    /**
     * @Description:启动所有定时任务
     */
    public void startJobs() {
        try {
            scheduler.start();
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

    /**
     * @Description:关闭所有定时任务
     */
    public void shutdownJobs() {
        try {
            if (!scheduler.isShutdown()) {
                scheduler.shutdown();
            }
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

}

JobFactory对象注入类

package framework.basic.job;

import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.scheduling.quartz.AdaptableJobFactory;

public class JobFactory extends AdaptableJobFactory {
    @Autowired
    private AutowireCapableBeanFactory capableBeanFactory;

    @Override
    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
        //调用父类的方法
        Object jobInstance = super.createJobInstance(bundle);
        //进行注入
        capableBeanFactory.autowireBean(jobInstance);
        return jobInstance;
    }
}

WorkScheduledJod 执行类，该类需要继承org.quartz.Job，定时器通过程序控制的情况下，默认执行execute方法

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationContext;

import javax.annotation.Resource;

public class WorkScheduledJod implements Job {

    Logger logger = LoggerFactory.getLogger(WorkScheduledJod.class);

    @Resource
    private ApplicationContext context;

    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        logger.info("context[{}]",context);
    }
}

QuartzService用于对外提供服务

package framework.basic.quartz.impl;

import cn.bthhotels.omplan.service.impl.WorkScheduledJod;
import framework.basic.quartz.QuartzManager;
import org.quartz.Scheduler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.annotation.Resource;

public class QuartzService  {

    @Resource
    private QuartzManager quartzManager;


    private static final Logger logger = LoggerFactory.getLogger(QuartzService.class);


    @Override
    public void startAllJod() {
        logger.info("开启定时器");
        quartzManager.addJob(WorkScheduledJod.JOD_ID, Scheduler.DEFAULT_GROUP, WorkScheduledJod.TRIGGER_ID, Scheduler.DEFAULT_GROUP, WorkScheduledJod.class, WorkScheduledJod.CRON_EXPRESSION);

        logger.info("挂起定时器");
        quartzManager.pauseJob(WorkScheduledJod.JOD_ID, Scheduler.DEFAULT_GROUP);

        logger.info("恢复定时器");
        quartzManager.resumeJob(WorkScheduledJod.JOD_ID, Scheduler.DEFAULT_GROUP);

        logger.info("删除定时器");
        quartzManager.removeJob(WorkScheduledJod.JOD_ID, Scheduler.DEFAULT_GROUP, WorkScheduledJod.TRIGGER_ID, Scheduler.DEFAULT_GROUP);

    }

    public QuartzManager getQuartzManager() {
        return quartzManager;
    }
}

Spring配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:task="http://www.springframework.org/schema/task"
    xsi:schemaLocation="http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
    
    <!-- 用于控制定时器的自动注入 -->
    <bean id="jobFactory" class="framework.basic.job.JobFactory"></bean>

    <!-- QuartzManager管理的总定时器 -->
    <bean id="quartzManagerSchedulerFactoryBean"
          class="org.springframework.scheduling.quartz.SchedulerFactoryBean" autowire="no">
        <property name="jobFactory" ref="jobFactory"></property>
    </bean>

    <!-- 定时器管理工具类 -->
    <bean id="quartzManager" class="framework.basic.quartz.QuartzManager" lazy-init="false"  >
        <constructor-arg name="scheduler" ref="quartzManagerSchedulerFactoryBean"/>
    </bean>

      <!-- 定时器服务 这里仅作启动演示 -->
    <bean id="quartzService" class="framework.basic.quartz.impl.QuartzService"  init-method="startAllJod" >
    </bean>
</beans>

tips:

可以将QuartzManager 改成工具类的方式，将对象里的scheduler，以及方法调整为静态；
因为Quartz版本不同，后续添加方法使用JobKey或TriggerKey；
JobDetail有个getJobDataMap()方法，通过该MAP添加的对象能在执行类execute方法JobExecutionContext对象的getMergedJobDataMap获取。
通过XML配置的定时器默认组名为（Scheduler.DEFAULT_GROUP）

最后编辑于：2019.07.12 15:14:20

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,937评论 6赞 478
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,503评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,712评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,668评论 1赞 276
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,677评论 5赞 366
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,601评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,975评论 3赞 396
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,637评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,881评论 1赞 298
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,621评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,710评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,387评论 4赞 319
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,971评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,947评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,189评论 1赞 260
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 44,805评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,449评论 2赞 342

Java Quartz如何控制定时器启动与停止

推荐阅读更多精彩内容