[框架]Spring整合Quartz(任务调度框架)

男娘i 2021-08-30 23:09 408阅读 0赞

> 了解了什么是任务调度和任务调度框架的基本使用,我们需要将任务调度框架整合到Spring工厂,简化开发流程,避免复杂的关联关系和依赖关系,降低类和类之间的耦合度.

> `前文推荐`  
> [面试官问:订单的定时提醒支付功能是怎么实现的?我的回答让我拿到了offer!][offer]

# Spring整合Quartz #

## 导入依赖 ##

<dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>4.2.4.RELEASE</version>
            </dependency>
        	<dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-tx</artifactId>
                <version>4.2.4.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.quartz-scheduler</groupId>
                <artifactId>quartz</artifactId>
                <version>2.2.1</version>
            </dependency>

## 定制一个Job ##

package per.leiyu.job;
    
    import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    
    import java.util.Date;
    
    /** * @author 雷雨 * @date 2020/6/28 8:32 */
    public class MyJob implements Job { 
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
            System.out.println("Spring 整合Quartz"+new Date());
    
        }
    }

## 在Spring工厂中配置 ##

>  *  **JobDetail**:`JobDetailFactoryBean`
>  *  **触发器**:`CronTriggerFactoryBean`
>  *  **调度器**:`SchedulerFactoryBean`

> Spring 整合Quartz进行配置遵循下面的步骤:
> 
> 1.  定义工作任务的job
> 2.  定义触发器Trigger,并将触发器和工作任务绑定
> 3.  定义调度器,并将Trigger注册到Scheduler

<?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-3.0.xsd">
    
    
    
        <bean id="lxJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
            
            <property name="name" value="job1"></property>
            
            <property name="group" value="job_group1"></property>
            
            <property name="jobClass" value="per.leiyu.job.MyJob"></property>
        </bean>
    
        
        <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
            
            <property name="name" value="trigger1"/>
            
            <property name="group" value="trigger_group1"/>
            
            <property name="jobDetail" ref="lxJob"/>
            
            <property name="cronExpression" value="*/2 * * * * ?"/>
        </bean>
    
        
        <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
            <property name="triggers">
                <list>
                    <ref bean="cronTrigger"></ref>
                </list>
            </property>
            
            
    
            
            <property name="quartzProperties">
                <value>
                    #名为:quartz.properties ,放置在classpath下,如果没有此配置则按默认配置启动
                    # 指定调度器名称,非实现类
                    org.quarz.scheduler.instanceName=DefaultQuartzScheduler
                    #指定线程池实现类
                    org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
                    #线程池线程数量
                    org.quartz.threadPool.threadCount=10
                    #优先级,默认5
                    org.quartz,threadPool.threadPriority= 5
                    #非持久化job
                    org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
                </value>
            </property>
        </bean>
    </beans>

## 操作 ##

### 启动任务 ###

> 工厂启动,调度器启动,任务调度开始
> 
> 工厂关闭,任务停止

package per.leiyu;
    
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    /** * @author 雷雨 * @date 2020/6/28 8:49 */
    public class TestMyJob { 
        public static void main(String[] args) { 
            ApplicationContext context = new ClassPathXmlApplicationContext("/springcontext.xml");
    
        }
    }

### 任务操作 ###

#### 删除任务 ####

> Job任务还是两秒执行一次,睡眠5秒之后想要将其删除(删除任务)
> 
>  *  deleteJob(Jobkey.jobkey(任务名,任务组别))

<table> 
 <thead> 
  <tr> 
   <th align="center">删除任何执行结果</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center"><img src="https://imgconvert.csdnimg.cn/aHR0cHM6Ly9naXRlZS5jb20vbGVpeXVqaWEvY3Nkbi9yYXcvbWFzdGVyL2ltYWdlLTIwMjAwNjI4MDkxMjE3NDExLnBuZw?x-oss-process=image/format,png" alt="image-20200628091217411"></td> 
  </tr> 
 </tbody> 
</table>

#### 暂停和恢复 ####

public class TestMyJob { 
        public static void main(String[] args) throws InterruptedException, SchedulerException { 
            ApplicationContext context = new ClassPathXmlApplicationContext("/springcontext.xml");
            Thread.sleep(5000);
            Scheduler scheduler = (Scheduler) context.getBean("scheduler");
            //scheduler.deleteJob(JobKey.jobKey("job1","job_group1"));
    		//暂停
            scheduler.pauseJob(JobKey.jobKey("job1","job_group1"));
            Thread.sleep(5000);
            //恢复任务
            scheduler.resumeJob(JobKey.jobKey("job1","job_group1"));
    
        }
    }

<table> 
 <thead> 
  <tr> 
   <th align="center">暂停和恢复执行结果</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center"><img src="https://imgconvert.csdnimg.cn/aHR0cHM6Ly9naXRlZS5jb20vbGVpeXVqaWEvY3Nkbi9yYXcvbWFzdGVyL2ltYWdlLTIwMjAwNjI4MDkxNzA5OTgzLnBuZw?x-oss-process=image/format,png" alt="image-20200628091709983"></td> 
  </tr> 
 </tbody> 
</table>

#### 批量操作 ####

> 因为Job任务是有分组的,可以通过操作同一个组中的任务达到批量操作的目的
> 
>  *  注意暂停和恢复支持批量操作
>  *  但是删除不支持批量操作(删除操作比较敏感)

public class TestMyJob { 
        public static void main(String[] args) throws InterruptedException, SchedulerException { 
            ApplicationContext context = new ClassPathXmlApplicationContext("/springcontext.xml");
            Thread.sleep(5000);
            StdScheduler scheduler = (StdScheduler) context.getBean("scheduler");
            scheduler.pauseJobs(GroupMatcher.groupEquals("job_group1"));
            Thread.sleep(5000);
            scheduler.resumeJobs(GroupMatcher.groupEquals("job_group1"));
    
        }
    }

<table> 
 <thead> 
  <tr> 
   <th align="center">批量操作执行结果</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center"><img src="https://imgconvert.csdnimg.cn/aHR0cHM6Ly9naXRlZS5jb20vbGVpeXVqaWEvY3Nkbi9yYXcvbWFzdGVyL2ltYWdlLTIwMjAwNjI4MDkyNzExMDY2LnBuZw?x-oss-process=image/format,png" alt="image-20200628092711066"></td> 
  </tr> 
 </tbody> 
</table>

> 我是雷雨,一个`普本科`的学生,主要专注于Java后端和大数据开发

> 如果这篇文章有帮助到你,希望你给我一个`大大的赞`  
> 如果有什么问题,希望你能`留言`和我一起`研究`,`学习靠自觉,分享靠自愿`

> 转载注明出处  
> [https://blog.csdn.net/qq\_40742223][https_blog.csdn.net_qq_40742223]

[offer]: https://blog.csdn.net/qq_40742223/article/details/106999570
[https_blog.csdn.net_qq_40742223]: https://blog.csdn.net/qq_40742223