spring框架使用Quartz执行定时任务实例详解-阿里云开发者社区

spring框架使用Quartz执行定时任务实例详解

2018-05-20 1226

版权

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

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS MySQL，集群系列 2核4GB

云数据库 RDS PostgreSQL，集群系列 2核4GB

Quartz简介

　　１．Quartz，是一个完全由java编写的开源作业调度框架。它包含了调度器监听、作业和触发器监听，而我们在项目中最常用到的就是它可以作为一个定时器，可以随时配置监听、触发任务进行作业。
　　２．在Spring的框架里，Quartz已经被很好地集成，我们只需要在xml文件里面配一下定时时间就可以自动执行任务了。
　　３．本博客主要介绍的是一个quartz项目的完整的搭建、配置以及成功运行的过程，里面包含了多个定时器的配置以及多个数据库的配置方法，非常适合新手去接触和掌握quartz的使用而且还附有完整的quartz定时器项目实例下载，项目下载地址：QuartzTask定时器项目实例

项目实例详解

　　１．首先我们看一下整个项目的结构，最基本的spring架构：
　这里写图片描述
　　２．接下来我们将逐个步骤去搭建、配置以及运行这个项目，每个步骤在项目里面我都配有详细的说明，
　　 （1）首先，我们看一下web.xml配置：　

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">
  <listener>
    <listener-class>org.springframework.web.util.Log4jConfigListener</listener-class>
  </listener>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>

  <!-- 加载spring配置文件 -->
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath*:applicationContext*.xml</param-value>
  </context-param>
  <context-param>
    <param-name>log4jConfigLocation</param-name>
    <param-value>classpath:log4j.properties</param-value>
  </context-param>
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
</web-app>

　　 （2）其次，我们看一下加载的spring配置文件applicationContext.xml配置：　

    <!-- 加载配置属性文件，数据库文件 -->
    <context:property-placeholder ignore-unresolvable="true" location="classpath:/jdbc.properties" />

    <!-- 使用Annotation自动注册Bean -->
    <context:component-scan base-package="com.hqc"><!-- base-package 如果多个，用“,”分隔 -->
        <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>

    <!-- 数据源可自行配置添加多个，这里只演示postgresql和mysql数据源示例，需要哪些可自行添加测试，都是经过实践成功的-->
    <!-- Postgresql数据库连接配置 -->
    <bean id="postgresqlDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="org.postgresql.Driver"></property>
        <property name="url" value="jdbc:postgresql://localhost:2345/jftest"></property>
        <property name="username" value="postgres"></property>
        <property name="password" value="1234"></property>
        <property name="initialSize" value="20"></property>
        <property name="maxActive" value="20"></property>
        <property name="defaultAutoCommit" value="true"></property>
    </bean>

    <!-- Mysql数据库连接配置-->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"  destroy-method="close">
      <property name="driverClassName" value="${jdbc.driver}" /> 
      <property name="url" value="${jdbc.url}" /> 
      <property name="username" value="${jdbc.username}" />       
      <property name="password" value="${jdbc.password}" />
    </bean>

    <!-- oracle数据库连接配置, 使用 BoneCP数据库连接池 
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> 
        <property name="driverClassName" value="${jdbc.driver}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
        <property name="initialSize" value="${jdbc.pool.init}" />
        <property name="minIdle" value="${jdbc.pool.minIdle}" /> 
        <property name="maxActive" value="${jdbc.pool.maxActive}" />
        <property name="maxWait" value="60000" />
        <property name="timeBetweenEvictionRunsMillis" value="60000" />
        <property name="minEvictableIdleTimeMillis" value="300000" />
        <property name="validationQuery" value="${jdbc.testSql}" />
        <property name="testWhileIdle" value="true" />
        <property name="testOnBorrow" value="false" />
        <property name="testOnReturn" value="false" />
        <property name="filters" value="stat" /> 
    </bean>-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
    </bean>

    <!-- Greenplum数据库连接配置 
    <bean id="postgresqlDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="com.pivotal.jdbc.GreenplumDriver"></property>
        <property name="url" value="jdbc:pivotal:greenplum://localhost:2345;DatabaseName=jftest"></property>
        <property name="username" value="greenplum"></property>
        <property name="password" value="1234"></property>
        <property name="initialSize" value="20"></property>
        <property name="maxActive" value="20"></property>
        <property name="defaultAutoCommit" value="true"></property>
    </bean>-->

    <!-- 定时器1 -->
    <bean id="taskTrigger1" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <bean
                class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
                <property name="targetObject">
                    <bean class="com.hqc.service.DataStaticService"></bean><!--目标类-->
                </property>
                <property name="targetMethod" value="testMethod1" /><!--目标方法-->
                <property name="concurrent" value="false" />
            </bean>
        </property>
        <property name="cronExpression">
            <!-- 秒、分、时、日期、月份、星期、年 -->
            <!-- 具体的更多的写法可以参照：https://blog.csdn.net/alan_liuyue/article/details/80222565 -->
            <value>0/5 * * * * ? </value>  <!-- 每五秒执行一次 -->
        </property>
    </bean>

    <!-- 定时器2-->
    <bean id="taskTrigger2" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
                <property name="targetObject">
                    <bean class="com.hqc.service.DataStaticService"></bean>
                </property>
                <property name="targetMethod" value="testMethod2" />
                <property name="concurrent" value="false" />
            </bean>
        </property>
        <property name="cronExpression">
             <value>0 0 0/1 * * ?</value> <!-- 每一小时执行一次 -->
        </property>
    </bean>



    <!-- 总调度用于启动Spring定时器，可以启动多个，需要启动哪一个就去掉注释即可-->
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="taskTrigger1" /> <!--调度第一个定时任务 -->
                <ref bean="taskTrigger2" /> <!--调度第二个定时任务 -->
            </list>
        </property>
    </bean>

　　（3）然后，就是数据库的配置文件jdbc.properties，这个文件可以将所有的数据库连接属性都写在里面，当然你也可以直接在applicationContext.xml里面直接配置数据库信息，一个项目可以配置多个数据源，相信大家都是没问题的：

##oracle数据库配置
#jdbc.type=oracle
#jdbc.driver=oracle.jdbc.driver.OracleDriver
#jdbc.url=jdbc:oracle:thin:@localhost:1521:testora
#jdbc.username=test
#jdbc.password=test
##pool settings
#jdbc.pool.init=10
#jdbc.pool.minIdle=30
#jdbc.pool.maxActive=50
##jdbc.testSql=SELECT 'x'
#jdbc.testSql=SELECT 'x' FROM DUAL

#mysql数据库配置
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/jftest?useSSL=false&useUnicode=true&characterEncoding=UTF-8
jdbc.username=root
jdbc.password=1234

　　 （4）接下来我们再讲一下项目里面的各个文件的作用，这里直接用一张图给大家进行展示说明：
　　这里写图片描述
　　 （5）我们看一下在配置文件里quartz指定的定时执行的方法：

/**
 * 
 * @author hqc
 * @version 2018年05月20日
 *
 */
public class DataStaticService {
    protected static Logger logger = Logger.getLogger(DataStaticService.class);

    @Autowired
    DataPostgresqlDao dataPostgresqlDao;

    @Autowired
    DataOracleDao dataOracleDao;

    /**
     * 测试定时方法1
     */
    public void testMethod1(){
        Calendar c = Calendar.getInstance();
        String today = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(c.getTime()); 
        System.out.println("定时任务程序运行时间："+today);
        System.out.println("定时查询oracle库t_user表的数据数量："+dataOracleDao.queryTest().size());    
    }

    /**
     * 测试定时方法2
     */
    public void testMethod2(){
        Calendar c = Calendar.getInstance();
        String today = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(c.getTime()); 
        //昨天的当前时间
//      c.add(Calendar.DATE, -1);
//      String yesterday = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(c.getTime());
        System.out.println("定时任务程序运行时间："+today);
        System.out.println("定时查询postgresql库t_user表的数据数量："+dataPostgresqlDao.queryTest().size());

    }

}

　　 （6）最后，我们看一下定时任务执行的效果，这里我设置的是每5秒执行一次：
　　这里写图片描述

总结

　　１．好了，以上就是spring框架使用Quartz执行定时任务完整实例详解，很适合新手去熟悉和掌握quartz；
　　２．实践是认识真理性的唯一标准，通过这一个简单的项目实践，有兴趣的小伙伴们能继续去深入研究，从而形成一套适合自己的定时器项目，在项目中运用的时候就会事半功倍；

spring框架使用Quartz执行定时任务实例详解

Quartz简介

项目实例详解

总结

热门文章

最新文章

相关课程

相关电子书

相关实验场景

探索云世界

热门

云计算

大数据

云原生

人工智能

数据库

开发与运维

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

直播

下载

镜像站

技术资料

spring框架使用Quartz执行定时任务实例详解

Quartz简介

项目实例详解

总结

热门文章

最新文章

相关课程

相关电子书

相关实验场景