<?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
     -->

    <!-- 1：定义任务的bean ，这里使用JobDetailFactoryBean,也可以使用MethodInvokingJobDetailFactoryBean ，配置类似-->
    <bean name="lxJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <!-- 指定job的名称 -->
        <property name="name" value="job1"/>
        <!-- 指定job的分组 -->
        <property name="group" value="job_group1"/>
        <!-- 指定具体的job类 -->
        <property name="jobClass" value="com.qf.quartz.MyJob"/>
    </bean>

    <!-- 2：定义触发器的bean，定义一个Cron的Trigger，一个触发器只能和一个任务进行绑定 -->
    <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <!-- 指定Trigger的名称 -->
        <property name="name" value="trigger1"/>
        <!-- 指定Trigger的名称 -->
        <property name="group" value="trigger_group1"/>
        <!-- 指定Tirgger绑定的JobDetail -->
        <property name="jobDetail" ref="lxJob"/>
        <!-- 指定Cron 的表达式 ，当前是每隔5s运行一次 -->
        <property name="cronExpression" value="*/5 * * * * ?" />
    </bean>

    <!-- 3.定义调度器，并将Trigger注册到调度器中 -->
    <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="cronTrigger"/>
            </list>
        </property>
        <!-- 添加 quartz 配置，如下两种方式均可 -->
        <!--<property name="configLocation" value="classpath:quartz.properties"></property>-->
        <property name="quartzProperties">
            <value>
                # 指定调度器名称，实际类型为：QuartzScheduler
                org.quartz.scheduler.instanceName = MyScheduler
                # 指定连接池
                org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
                # 连接池线程数量
                org.quartz.threadPool.threadCount = 11
                # 优先级
                org.quartz.threadPool.threadPriority = 5
                # 不持久化job
                org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
            </value>
        </property>
    </bean>
</beans>

4.4：操作

4.4.1：启动任务

• 工厂启动，调度器启动，任务调度开始.

public static void main(String[] args) throws InterruptedException, SchedulerException {
		// 工厂启动，任务启动，工厂关闭，任务停止
		ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
}

public static void main(String[] args) throws InterruptedException, SchedulerException {
	ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
	System.out.println("=============");
	StdScheduler scheduler = (StdScheduler) context.getBean("scheduler");
	System.out.println(scheduler.getClass());
	Thread.sleep(3000);
	// 删除Job
	scheduler.deleteJob(JobKey.jobKey("job1","job_group1"));
}

public static void main(String[] args) throws InterruptedException, SchedulerException {
	ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
	System.out.println("=============");
	StdScheduler scheduler = (StdScheduler) context.getBean("scheduler");
	System.out.println(scheduler.getClass());
	Thread.sleep(3000);
	// 暂停，恢复工作
	scheduler.pauseJob(JobKey.jobKey("job1","job_group1"));// 暂停工作
	Thread.sleep(3000);
	scheduler.resumeJob(JobKey.jobKey("job1","job_group1"));// 恢复工作
}

public static void main(String[] args) throws InterruptedException, SchedulerException {
	ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
	System.out.println("=============");
	StdScheduler scheduler = (StdScheduler) context.getBean("scheduler");
	System.out.println(scheduler.getClass());
	Thread.sleep(3000);
	GroupMatcher<JobKey> group1 = GroupMatcher.groupEquals("group1");
	scheduler.pauseJobs(group1); // 暂停组中所有工作
	Thread.sleep(2000);
	scheduler.resumeJobs(group1); // 恢复组中所有工作
}