SpringBoot整合quartz

川长思鸟来 2022-03-21 20:20 200阅读 0赞

### 配置额外的xml文件(spring-quartz.xml的xml) ###

在启动类中配置读取文件的注解
    @SpringBootApplication
    @ImportResource("spring-quartz.xml")

### 石英钟quartz ###

#### 4个核心组件 ####

1 JobDetail : 管理一个/一组/多组真正执行的任务;
    2 Job:我们需要编写的真正任务的执行代码
    3 Trigger: 触发器,根据配置的时间表达式完成各种任务的定时触发,绑定管理触发的jobDetail实现通过触发,执行job代码的能力
    	时间表达式使用cron字符串表达逻辑
    	秒
    	分
    	时
    	每月的天
    	月
    	周中的天
    	年
    	* * * * * ? * 表示时刻都是定时触发
    	以秒为例
    	25,50 * * * * * 表示秒的定时,每分钟25秒,和50秒各执行一次
    	5/5 * * * * * 表示从第五秒开始,每隔5秒执行一次(1/5,6/2..)
    	1-2 * * * * * 从第1秒到第二秒,一直在执行
    	定义一个每分钟都执行的任务,时间表达式(从0分钟开始,每1分钟执行一次)
    	0 0/1 * * * ? *
    
    4 scheduler 调度器,为每个需要触发器的jobDetail创建触发器

#### 引入Quartz ####

<dependency>
    			<groupId>org.quartz-scheduler</groupId>
    			<artifactId>quartz</artifactId>
    			<version>2.2.1</version>
    		</dependency>

#### 配置spring-quartz.xml ####

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" 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-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">
    
    	
    	<bean name="paymentOrderJobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    		
    		<property name="jobClass" value="com.jt.easymall.job.OrderOTJob" />
    		
    		<property name="name" value="paymentOrder" />
    		
    		<property name="group" value="Order" />
    		
    		<property name="durability" value="true"/>
    		
    		<property name="applicationContextJobDataKey" value="applicationContext"/>
    	</bean>
    	
    	
    	<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    		<property name="jobDetail" ref="paymentOrderJobDetail" />
    		
    		<property name="cronExpression" value="0 0/1 * * * ?" />
    	</bean>
    	
    	
    	<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    	    <property name="triggers">
    	        <list>
    	            <ref bean="cronTrigger" />
    	        </list>
    	    </property>
    	</bean>
    
    </beans>

#### 创建OrderOTJob 类，删除过去一天的订单 ####

package com.jt.easymall.job;
    
    import java.util.Date;
    
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.scheduling.quartz.QuartzJobBean;
    
    import com.jt.easymall.mapper.OrderMapper;
    
    public class OrderOTJob extends QuartzJobBean{ 
    
    	@Override
    	protected void executeInternal(JobExecutionContext context) throws JobExecutionException { 
    		//通过与spring整合的context对象,获取操作spring的权限
    		ApplicationContext applicationContext = 
    			(ApplicationContext) context.getJobDetail().
    			getJobDataMap().
    		get("applicationContext");
    		//利用applicationContext这个spring的环境对象,获取执行数据库逻辑的mapper
    		//对象,传递一个超时订单的判断参数
    		//准备一个date参数,值是当前时间-1天
    		//做个打桩
    		System.out.println("开始定时任务");
    		Date param=new Date(new Date().getTime()-1000*60*60*24);
    		applicationContext.getBean(OrderMapper.class)
    		.deleteOTOrders(param);//传递参数为当前时间-1天的date值
    		System.out.println("定时任务完毕");
    	}
    
    }