安科网

spring集成quartz持久化简单应用

melonjj

melonjj

2016-01-13

关注 关注


最近在做定时跑批任务的时候用开始接触quartz，写了一个简单的demo，由于经验不足，原理还没有深入理解，有什么不对之处还请各位博友加以指正

首先，quartz在与spring集成是是有版本匹配问题的：quartz-1.x与spring3.1之前的版本对应，而quartz2.x与spring3.1之后的版本对应，quartz1和quartz2是有很大区别的。
如下是quartz1.8.6数据库表结构和quartz2.2.1数据库表结构，根据需求构建数据库，见附件
集成spring与quartz：
一、spring3.1之前版本和quartz1.x集成
1、pom依赖（spring和quartz版本自行匹配）
<properties>
    <spring.version>3.2.9.RELEASE</spring.version>
    <!--<spring.version>3.0.6.RELEASE</spring.version>-->
    <!--<spring.version>3.2.2.RELEASE</spring.version>-->
    <!--<spring.version>4.0.0.RELEASE</spring.version>-->
    <quartz.version>2.2.1</quartz.version>
    <!--<quartz.version>1.8.6</quartz.version>-->
</properties>


<dependencies>

    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context-support</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-web</artifactId>
        <version>${spring.version}</version>
    </dependency>

    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-tx</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>${spring.version}</version>
    </dependency>

    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>${spring.version}</version>
        <scope>test</scope>
    </dependency>

    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.11</version>
        <scope>test</scope>
    </dependency>

    <!-- quartz -->
    <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>${quartz.version}</version>
    </dependency>

    <!-- mysql begin  -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.30</version>
    </dependency>
    <!-- end of mysql -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.0.16</version>
    </dependency>

</dependencies>
 2、定义job，实现序列化（内存方式不必实现）：（quartz1.x版本）
public class HelloJob implements Serializable{

    private static final long serialVersionUID = -2348136105841790133L;

    public void execute(){
        System.out.println("============================");
    }
}
 
3、spring配置：
3.1 数据源配置（内存方式忽略此配置）
jdbc.driverClassName=com.mysql.jdbc.Driver
#quartz1.x数据库
#jdbc.url=jdbc:mysql://127.0.0.1:3306/quartz-test?useUnicode=true
#quartz2.x数据库
jdbc.url=jdbc:mysql://127.0.0.1:3306/quartz2?useUnicode=true
jdbc.username=root
jdbc.password=maidou
jdbc.initialSize=15
jdbc.maxActive=20
jdbc.maxIdle=20
jdbc.minIdle=5
 
<context:property-placeholder location="classpath:properties/*.properties"/>

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
      destroy-method="close">
    <property name="driverClassName" value="${jdbc.driverClassName}" />
    <property name="url" value="${jdbc.url}" />
    <property name="username" value="${jdbc.username}" />
    <property name="password" value="${jdbc.password}" />
    <!--initialSize: 初始化连接 -->
    <property name="initialSize" value="${jdbc.initialSize}" />
    <!--maxActive: 最大连接数量 -->
    <property name="maxActive" value="${jdbc.maxActive}" />
    <!--maxIdle: 最大空闲连接 -->
    <!--<property name="maxIdle" value="${jdbc.maxIdle}" />-->
    <!--minIdle: 最小空闲连接 -->
    <property name="minIdle" value="${jdbc.minIdle}" />
    <property name="defaultAutoCommit" value="true" /><!--这里一定要设置为true，否则在启动项目quartz事务不会自动提交，导致job不能持久化到数据库，抛出异常，正常的程序数据源此项要设置为false，自行控制事务-->

    <property name="validationQuery" value="SELECT 1 " />
</bean>
 3.2 quartz配置（quartz1.x）：其中jobDetail bean配置的class 需要自己实现序列化，spring 的MethodInvokingJobDetailFactoryBean没有实现序列化，故需要如下两个java文件，见附件
<!-- 调度器 -->
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
     <property name="dataSource" ref="dataSource" />
    <property name="configLocation" value="classpath:properties/quartz.properties" />
    <property name="autoStartup" value="true" />
    <property name="applicationContextSchedulerContextKey" value="applicationContext" />
    <property name="startupDelay" value="20" />
    <property name="overwriteExistingJobs" value="true" />
    <property name="triggers">
        <list>
            <!-- 触发器列表 -->
            <ref bean="helloJobTrigger" />
        </list>
    </property>
</bean>

<bean id="helloJobBean" class="com.maidou.job.HelloJob"/>

<!-- 触发器 -->
<bean id="helloJobTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="helloJobDetail" />
    <property name="cronExpression" value="0/5 * * * * ?" />
</bean>

<bean id="helloJobDetail"
        class="com.maidou.factory.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject" ref="helloJobBean" />
    <property name="targetMethod" value="execute" />
    <property name="concurrent" value="false" />
    <property name="durable" value="true"/>
    <!--<property name="volatility" value="true"/>-->
    <property name="shouldRecover" value="true" />
</bean>

<import resource="spring-db.xml"/>
 4、写quartz.properties覆盖原有quartz.properties；如下
#============================================================================
# Configure Main Scheduler Properties
#============================================================================

org.quartz.scheduler.instanceName = MY_JOB_SCHEDULER
org.quartz.scheduler.instanceId = AUTO

org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false


#============================================================================
# Configure ThreadPool
#============================================================================

org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

#============================================================================
# Configure JobStore
#============================================================================

org.quartz.jobStore.misfireThreshold = 60000
#内存方式
#org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
#数据库持久化
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties=false
org.quartz.jobStore.maxMisfiresToHandleAtATime=1
#数据库表名称前缀
org.quartz.jobStore.tablePrefix=QRTZ_
#集群
org.quartz.jobStore.isClustered=false

#============================================================================
# Other Example Delegates
#============================================================================
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.CloudscapeDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.DB2v6Delegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.DB2v7Delegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.DriverDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.HSQLDBDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.MSSQLDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.PointbaseDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.WebLogicDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.oracle.WebLogicOracleDelegate

#============================================================================
# Configure Datasources
#============================================================================

#org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
#org.quartz.dataSource.myDS.URL = jdbc:mysql://10.1.221.118/invest?useUnicode=true&amp;characterEncoding=utf-8
#org.quartz.dataSource.myDS.user = invest
#org.quartz.dataSource.myDS.password = invest
#org.quartz.dataSource.myDS.maxConnections = 5
#org.quartz.dataSource.myDS.validationQuery=

#============================================================================
# Configure Plugins
#============================================================================

#org.quartz.plugin.shutdownHook.class = org.quartz.plugins.management.ShutdownHookPlugin
#org.quartz.plugin.shutdownHook.cleanShutdown = true


#org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin
 
二、spring3.1之后版本和quartz2.x集成
1、pom文件依赖如上pom依赖（自行匹配spring和quartz版本）
2、定义job，继承 QuartzJobBean：（quartz2.x版本）
public class HelloJob extends QuartzJobBean {
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println("============================");
    }
}
 
3、spring配置：
3.1 数据源配置如上数据源配置
3.2 quartz配置（quartz2.x）配置，可以自定义Listener监听Job和Trigger的执行，分别实现JobListener和TriggerListener接口，如下，见附件
<!--<bean id="myJobListener" class="com.maidou.listener.MyJobListener"/>-->
<!--<bean id="myTriggerListener" class="com.maidou.listener.MyTriggerListener"/>-->

<!-- 调度器 -->
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
     <property name="dataSource" ref="dataSource" />
    <property name="configLocation" value="classpath:properties/quartz.properties" />
    <property name="autoStartup" value="true" />
    <property name="applicationContextSchedulerContextKey" value="applicationContext" />
    <property name="startupDelay" value="20" />
    <property name="overwriteExistingJobs" value="true" />
    <!-- 可以实现自定义的listener，监听JobListener和TriggerListener，同时自定义的也需要分别实现这两个接口-->
    <!--<property name="globalJobListeners" ref="myJobListener"/>-->
    <!--<property name="globalTriggerListeners" ref="myTriggerListener"/>-->

    <property name="triggers">
        <list>
            <!-- 触发器列表 -->
            <ref bean="helloJobTrigger" />
        </list>
    </property>
</bean>

<bean id="helloJobBean" class="com.maidou.job.HelloJob"/>

<!-- 触发器 -->
<bean id="helloJobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="helloJobDetail" />
    <property name="cronExpression" value="0/5 * * * * ?" />
    <!--<property name="group" value="group1"/>-->
    <!--<property name="name" value="helloJobTrigger"/>-->
</bean>

<bean id="helloJobDetail"
        class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass" value="com.maidou.job.HelloJob"/>
    <property name="group" value="group1"/>
    <property name="name" value="helloJobDetail"/>
    <property name="durability" value="true"/>
</bean>

<import resource="spring-db.xml"/>
 
4、写quartz.properties覆盖原有quartz.properties；同上
注意：数据源的配置一定要配置成自动提交，默认quartz用的数据库连接池是c3p0，我用的是alibaba的druid。
 
测试一下
编写测试类：
public class test {
    private static volatile boolean running = true;
    public static void main(String[] args) {
        ClassPathXmlApplicationContext cxt = new ClassPathXmlApplicationContext("classpath:application-context.xml");
        synchronized (test.class) {
            while (running) {
                try {
                    test.class.wait();
                } catch (Throwable e) {
                }
            }
        }
    }
}
 欢迎留言或到我的csdn博客讨论：http://blog.csdn.net/lingyundouer/article/details/50513194

quartz 持久化 spring原理

melonjj

melonjj

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

Spring Boot Quartz 动态配置，持久化

//数据库SQL查询每次连接返回执行到连接池，以确保它仍然是有效的。

melonjj 2019-11-02

SpringBoot之整合Quartz调度框架-基于Spring Boot2.0.2版本

<!-- quartz依赖 -->. <artifactId>spring-boot-starter-quartz</artifactId>. System.out.println("start My Job：

qingjiuquan 2020-05-15

Spring Boot集成Spring Scheduler和Quartz Scheduler

Spring Framework提供了简单、易用的Job调度框架Spring Scheduler。@Scheduled支持cron、fixedDelay、fixedRate三种定义方式，方法必须没有参数，返回void类型。默认情况下，Spring无法同步多

Julywhj 2020-01-05

SpringBoot+Quartz+数据库存储

进入quartz的官网http://www.quartz-scheduler.org/，点击Downloads，下载后在目录\docs\dbTables下有常用数据库创建quartz表的脚本，例如：“tables_mysql.sql”。--quartz需要

景泽元的编程 2019-12-03

Spring整合Quartz框架定时任务

最近项目中经常用到队列和定时任务及线程的整合应用，涉及的场景是当多人访问系统时需要回调客户系统处理结果时，如何减少服务器压力并能处理业务需求，这里用到了队列减少服务器压力加入定时任务发送机制，使用的是spring框架整合 Quartz框架实现的定时任务，因

与卿画眉共浮生 2017-07-27

整合Spring和Quartz Scheduler

首先认识明确几个关于Quartz Scheduler的概念。时间可以为一个时间段，也可以为时间点。该类负责在spring容器中创建调度器。还有一个属性为autoStartup,该类指定是否在spring构造该类完成之后开始执行调度。-- 生成的调度器所管理

横云断岭 2012-02-03

java ssm 后台框架平台 项目源码 websocket 即时通讯 IM quartz springmvc

不需要选择物流公司，根据单号自动识别--------

happyfling 2019-09-20

关于集群下quartz在DB2数据库上的应用

由于系统建设，原两台服务器应用增加到了四台，导致死锁频频发生。在以往两台服务器的情况下，一般很少出现，也就没有关注。最近服务器新增导致死锁现象非常频繁。经过几周的测试分析，终于找到了解决方案。现将分析及解决方案附上：。我们系统使用的是quartz1.8.5

fairystepwgl 2016-03-22

Spring Quartz

<property name="cronExpression" value="0 0/5 * ?* *" />. <property name="targetObject" re

longdan0 2018-04-20

quartz集群问题

根据需求，新增一个定时任务，单元测试通过之后，通过本地功能新增调度任务。随后发现一个诡异问题，那就是只执行一次，然后状态成为了error状态。

missshy 2019-03-02

简单修改quartz支持动态修改执行时间和集群架构

简单修改quartz支持动态修改执行时间和集群架构

大新哥Michael 2016-09-30

Spring的Quartz定时器同一时刻重复执行二次的问题解决

最近用Spring的quartz定时器的时候，发现到时间后，任务总是重复执行两次，在tomcat或jboss下都如此。打印出他们的hashcode，发现是不一样的，也就是说，在web容器启动的时候，重复启了两个quartz线程。先把quartz配置信息提取

burning 2016-03-11

quartz集成spring方法

最近在做一个项目需要，定时更新缓存数据，所以就想到用quartz这个框架，在网上看了好多帖子，发现这个做法蛮不错,操作简单，使用方便。-- 定义调用对象和调用对象的方法 -->. -- 定义触发时间 -->. -- 每天凌晨5点执行一次 --&

zhongjcbill 2015-04-21

Spring定时器Quartz

public class QuartzJob { public void work() { SimpleDateFormat sdf = new SimpleDateFormat; Date date = new Date();-- 调用的类 --&g

Holyn 2014-11-21

quartz定时器的使用

除此之外还需要将以下。2.新建一个任务类,需要实现Quartz的Job接口。

菜鸟的脚步 2013-03-23

spring +quartz 配置

-- 定义调用对象和调用对象的方法 -->. -- 定义触发时间 -->. -- 每周星期天凌晨1点实行一次 -->

编程点滴 2013-01-05

Spring结合Quartz实现多任务定时调用配置

Quartz框架提供了丰富的任务调度支持，比如，在何时执行何种任务，它是一个开源的由OpenSymphony维护的项目，开发者能够在Java EE，或单独的Java SE应用中使用它。无论是简单的任务调度，还是复杂的企业级应用，Quartz都能够很好地胜任

MayMatrix 2013-11-03

Mina 高并发短连接导致java.io.IOException: Too many open files解决方案

通过定时触发启动线程模拟高并发短连接测试，测试的服务端有2个，一个是服务有起，一个没起，客户端和服务端均在同一服务器上。执行一段时间后linux主机上通过lsof命令查看，发现有递增的文件句柄，pipe和eventpoll。

chenhualeguan 2013-10-16

关于集群下quartz在DB2数据库上的应用

由于系统建设，原两台服务器应用增加到了四台，导致死锁频频发生。在以往两台服务器的情况下，一般很少出现，也就没有关注。最近服务器新增导致死锁现象非常频繁。经过几周的测试分析，终于找到了解决方案。现将分析及解决方案附上：。我们系统使用的是quartz1.8.5

spprogrammer 2016-03-22

mina高并发短连接导致java.io.IOException: Too many open files解决方案

通过定时触发启动线程模拟高并发短连接测试，测试的服务端有2个，一个是服务有起，一个没起，客户端和服务端均在同一服务器上。执行一段时间后linux主机上通过lsof命令查看，发现有递增的文件句柄，pipe和eventpoll。

bxqybxqy 2012-10-16
melonjj

melonjj

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号