初始quartz（spring和quartz整合）

周杰伦本人

发布于 2023-10-12 14:31:30

3170

发布于 2023-10-12 14:31:30

文章被收录于专栏：同步文章

初识quartz

quartz是完全由java开发的一个开源的任务日程管理系统，“任务进度管理器”就是一个在预先确定（被纳入日程）的时间到达时，负责执行（或者通知）其他软件组件的系统。

1.quartz有两种存储方式：

RAM存储和JDBC存储，显然ram存储就是存的缓存里面，而JDBC存储就是存到数据库中。

2.JDBC插入表顺序

主要的JDBC操作类，执行sql顺序。 Simple_trigger ：插入顺序 qrtz_job_details —> qrtz_triggers —> qrtz_simple_triggers qrtz_fired_triggers Cron_Trigger：插入顺序 qrtz_job_details —> qrtz_triggers —> qrtz_cron_triggers qrtz_fired_triggers 3.触发器（定时器）主要有两种 SimpleTrigger 简单的触发：用来触发只需要执行一次货在给定时间触发并重复N次的任务并每次执行有一定间隔的任务 CronTrigger 表达式触发：像日历那样按日程来触发任务，而不是像SimpleTrigger那样每隔特定的间隔时间触发 CronTrigger比SimpleTrigger更有用。 Cron表达式被用来配置CronTrigger实例。不会写有表达式生成器。。 一个job可以被多个Trigger 绑定，但是一个Trigger只能绑定一个job！

废话少说直接来代码。。

定义job类：

package com.xiepanpan.job;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

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

/**
 * describe:
 *
 * @author xiepanpan
 * @date 2018/10/25
 */
public class HelloWorldJob implements Job {

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

    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        logger.info("Job start.. ");
        logger.info("hello quartz .."+new SimpleDateFormat("yyy-MM-dd HH:mm:ss")
                .format(new Date()));
        logger.info("Job end.. ");
    }
}

RAM存储的Quart测试类：

package com.xiepanpan.job;

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

import java.util.Date;

/**
 * describe:
 *
 * @author xiepanpan
 * @date 2018/10/25
 */
public class RAMQuartzTest {

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

    public static void main(String[] args) throws SchedulerException {
        //1.创建Scheduler的工厂
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();

        Scheduler scheduler = schedulerFactory.getScheduler();

        JobDetail jobDetail = JobBuilder.newJob(HelloWorldJob.class)
                .withDescription("this is ram job")
                .withIdentity("ramJob", "ramGroup")
                .build();

        //任务开始运行时间  当前时间3秒后执行
        long time = System.currentTimeMillis() + 3 * 1000L;

        Date startTime = new Date(time);

        Trigger trigger = TriggerBuilder.newTrigger()
                .withDescription("")
                .withIdentity("ramTrigger", "ramTriggerGroup")
                .startAt(startTime)
//                .withSchedule(SimpleScheduleBuilder.simpleSchedule()
//                        .withIntervalInSeconds(3).withRepeatCount(5))//设定每3秒执行一次 执行5次
                .startAt(startTime)
                .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?"))//每两秒执行一次
                .build();

        //注册任务和定时器
        scheduler.scheduleJob(jobDetail,trigger);

        //启动调度时间
        scheduler.start();
        logger.info("启动时间："+new Date());
    }
}

JDBC存储的和这差不多我就不说了。。

进入主题：quartz与spring进行整合！！

第一种：ram存储的quartz

测试类(主要起到加载配置文件的作用)：

package com.xiepanpan.spring;

import org.quartz.Scheduler;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * describe:
 *
 * @author xiepanpan
 * @date 2018/10/25
 */
public class SpringQuartzTest {

    private static Scheduler scheduler;

    public static void main(String[] args) {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring_quartz.xml");
//        applicationContext.getBean("schedulerFactoryBean");
    }
}

spring_quartz.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!--
		Spring整合Quartz进行配置遵循下面的步骤：
		1：定义工作任务的Job
		2：定义触发器Trigger，并将触发器与工作任务绑定
		3：定义调度器，并将Trigger注册到Scheduler
	 -->
    <!--使用JobDetailFactoryBean调用定义任务的Bean 也可以使用MethodInvokingJobDetailFactoryBean-->
    <bean name="helloworldJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <!---->
        <property name="name" value="helloWorldJob"/>
        <property name="group" value="helloWorldGroup"/>
        <!--指定具体的job类-->
        <property name="jobClass" value="com.xiepanpan.job.HelloWorldJob"/>
        <!-- 必须设置为true，如果为false，当没有活动的触发器与之关联时会在调度器中会删除该任务  -->
        <property name="durability" value="true"/>
        <!-- 指定spring容器的key，如果不设定在job中的jobmap中是获取不到spring容器的 -->
        <property name="applicationContextJobDataKey" value="applicationContext"/>
    </bean>

    <!-- 2.2：定义触发器Cron的Trigger，一个触发器只能和一个任务进行绑定 -->
    <bean id="cronTriggerFactoryBean" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="name" value="helloWorldTrigger"/>
        <property name="group" value="helloWorldGroup"/>
        <!--指定Trigger绑定的job-->
        <property name="jobDetail" ref="helloworldJob"/>
        <property name="cronExpression" value="0/1 * * * * ?"/>
    </bean>
    <!--3.定义调度器 将Trigger注册到调度器中-->
    <bean name="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="cronTriggerFactoryBean"/>
            </list>
        </property>
    </bean>
</beans>

这就完事了

效果：

第二种：jdbc存儲的quartz

當然需要数据库咯：数据库用的mysql数据库数据库名：quartz_test 需要执行表的sql见的项目：quartz_test.sql https://github.com/xiepanpan/quartz_spring

主要测试类(同样只是为了加载配置文件用)：

package com.xiepanpan.spring;

import org.quartz.Scheduler;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * describe: Jdbc存储方式的Job
 *
 * @author xiepanpan
 * @date 2018/10/25
 */
public class SpringQuartzJdbcTest {

    private static Scheduler scheduler;

    public static void main(String[] args) {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring_quartz_jdbc.xml");
//        applicationContext.getBean("schedulerFactoryBean");
    }
}

spring_quartz_jdbc.xml :

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!--
		Spring整合Quartz进行配置遵循下面的步骤：
		1：定义工作任务的Job
		2：定义触发器Trigger，并将触发器与工作任务绑定
		3：定义调度器，并将Trigger注册到Scheduler
	 -->
    <!--使用JobDetailFactoryBean调用定义任务的Bean 也可以使用MethodInvokingJobDetailFactoryBean-->
    <bean name="helloworldJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <!---->
        <property name="name" value="helloWorldJob"/>
        <property name="group" value="helloWorldGroup"/>
        <!--指定具体的job类-->
        <property name="jobClass" value="com.xiepanpan.job.HelloWorldJob"/>
        <!-- 必须设置为true，如果为false，当没有活动的触发器与之关联时会在调度器中会删除该任务  -->
        <property name="durability" value="true"/>
        <!-- 指定spring容器的key，如果不设定在job中的jobmap中是获取不到spring容器的 -->
        <!--<property name="applicationContextJobDataKey" value="applicationContext"/>-->
    </bean>

    <!-- 2.2：定义触发器Cron的Trigger，一个触发器只能和一个任务进行绑定 -->
    <bean id="cronTriggerFactoryBean" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="name" value="helloWorldTrigger"/>
        <property name="group" value="helloWorldGroup"/>
        <!--指定Trigger绑定的job-->
        <property name="jobDetail" ref="helloworldJob"/>
        <property name="cronExpression" value="0/1 * * * * ?"/>
    </bean>
    <!--3.定义调度器 将Trigger注册到调度器中-->
    <bean name="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="cronTriggerFactoryBean"/>
            </list>
        </property>
        <property name="applicationContextSchedulerContextKey" value="applicationContextKey"/>
        <property name="configLocation" value="classpath:quartz.properties"/>
    </bean>
</beans>

对应的quartz.properties

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#

#============================================================================
# Configure Main Scheduler Properties
#============================================================================
org.quartz.scheduler.instanceName: xiepanpan_test
org.quartz.scheduler.instanceId = AUTO

org.quartz.scheduler.rmi.export: false
org.quartz.scheduler.rmi.proxy: false
org.quartz.scheduler.wrapJobExecutionInUserTransaction: false
#============================================================================
# Configure ThreadPool
#============================================================================
org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 2
org.quartz.threadPool.threadPriority: 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true

org.quartz.jobStore.misfireThreshold: 60000
#============================================================================
# Configure JobStore
#============================================================================

#default config
#org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
#持久化配置
org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties:false

#============================================================================
#havent cluster spring
#============================================================================
org.quartz.jobStore.isClustered = false  

#数据库表前缀
org.quartz.jobStore.tablePrefix:qrtz_
org.quartz.jobStore.dataSource:qzDS

#============================================================================
# Configure Datasources
#============================================================================
#JDBC驱动
org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartz_test
org.quartz.dataSource.qzDS.user:root
org.quartz.dataSource.qzDS.password:root
org.quartz.dataSource.qzDS.maxConnection:10

效果：