【Quartz】——与spring整合

2022-11-26 107

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 【Quartz】——与spring整合

引言

像这样的比较常用的技术，肯定是被我们spring这个大神进行整合过的，因为这些东西一旦和sprig 整合之后，我们自己编写的代码就比较少了，提高了开发效率，下面看整合的过程。

引入依赖

  <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context-support</artifactId>
      <version>4.0.6.RELEASE</version>
    </dependency>

这个包的作用是什么呢？这个jar 文件包含支持UI模版（Velocity，FreeMarker，JasperReports），邮件服务，脚本服务(JRuby)，缓存Cache（EHCache），任务计划Scheduling（uartz）方面的类。

外部依赖spring-context, (spring-jdbc, Velocity, FreeMarker, JasperReports, BSH, Groovy, JRuby, Quartz, EHCache

编写Job代码

package cn.itcast.quartz;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.quartz.QuartzJobBean;
/**
 * 
 * 
 */
public class MyJob extends QuartzJobBean {
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println("myJob 执行了............." + context.getTrigger().getKey().getName());
        ApplicationContext applicationContext = (ApplicationContext) context.getJobDetail().getJobDataMap()
                .get("applicationContext");
        System.out.println("获取到的Spring容器是： " + applicationContext);
    }
}

和入门程序对比，这个job中的代码显然少了很多，其中我们需要关注的一点就是，我们继承了一个QuartzJobBean,这个是spring 给我提供的包中的一个类，我们只需要重写里面的一个executeInternal即可。

spirng配置文件的编写

  <!-- 定义任务bean -->
  <bean name="myJobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <!-- 指定具体的job类 -->
    <property name="jobClass" value="cn.itcast.quartz.MyJob" />
    <!-- 指定job的名称 -->
    <property name="name" value="myJob" />
    <!-- 指定job的分组 -->
    <property name="group" value="jobs" />
    <!-- 必须设置为true，如果为false，当没有活动的触发器与之关联时会在调度器中删除该任务  -->
    <property name="durability" value="true"/>
    <!-- 指定spring容器的key，如果不设定在job中的jobmap中是获取不到spring容器的 -->
    <property name="applicationContextJobDataKey" value="applicationContext"/>
  </bean>
  <!-- 定义触发器 -->
  <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="myJobDetail" />
    <!-- 每一分钟执行一次 -->
    <property name="cronExpression" value="0/5 * * * * ?" />
  </bean>
  <!-- 定义触发器 -->
  <!-- 演示：一个job可以有多个trigger； -->
  <!-- <bean id="cronTrigger2" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="myJobDetail" />
    每一分钟执行一次
    <property name="cronExpression" value="0 */1 * * * ?" />
  </bean> -->
  <!-- 定义调度器 -->
  <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
      <property name="triggers">
          <list>
              <ref bean="cronTrigger" />
             <!--  <ref bean="cronTrigger2" /> -->
          </list>
      </property>
  </bean>

入口类编写

package cn.itcast.quartz;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Main {
  //初始化spring容器
  public static void main(String[] args) {
    new ClassPathXmlApplicationContext("classpath:applicationContext-scheduler.xml");
  }
}