`
hondaufo
  • 浏览: 5831 次
  • 性别: Icon_minigender_1
  • 来自: 上海
最近访客 更多访客>>
社区版块
存档分类
最新评论

结合Spring使用Quartz编写定时任务两种方式

quartzSpringDB2JavaBean 
阅读更多

　   最近需要用到Quartz进行定时任务功能，通过近期研究发现，spring已经很好的集成Quartz,它主要是屏蔽了Quartz底层一些配置，使开发人员可以几乎不受到任何限制就能够利用Quartz进行定时任务的工作，这里主要是通过实例的方式对利用Spring进行Quartz定时开发的两种方式进行讲解。

１、功能需求

　　需要每个３０秒对系统指定目录进行扫描，把符合条件的文件进行解析入库工作，这里只提取出有关顶事任务的内容

２、研究一下Spring+Quartz结合方式，大体有两种方式可以达到定时任务功能

2.1 借助于Spring的org.springframework.scheduling.quartz.JobDetailBean的类功能，继承Spring封装Quartz的org.springframework.scheduling.quartz.QuartzJobBean类,要实现executeInternal方法，并把其中涉及到需要定时任务处理的功能放入其中


Spring配置如下：

 1    
 2        <bean id="saveProjectJob"
 3        class="org.springframework.scheduling.quartz.JobDetailBean">
 4        <property name="jobClass">
 5        <value>
 6        com.gresoft.components.fileupload.service.ParseFileQuartz
 7        </value>
 8        </property>
 9        <property name="jobDataAsMap">
10        <map>
11        <entry key="readXmlService">
12        <ref bean="readXmlService" />
13        </entry>
14        </map>
15        </property>
16        </bean>
17        <bean id="saveCron"
18        class="org.springframework.scheduling.quartz.CronTriggerBean">
19        <property name="jobDetail">
20            <ref local="saveProjectJob" />
21        </property>
22        <property name="cronExpression">
23            <value>0/30 * * * * ?</value>
24        </property>
25    </bean>
26    <bean id="scheduler"
27        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
28        <property name="triggers">
29            <ref local="saveCron" />
30        </property>
31    </bean>


注意上述红色字体<map>结点，这里主要是为了在定时任务需要使用到Bean,通过Spring给注入进来，如果不写明，就会报
java.lang.NullPointerException错误，主要是因为没有注入Bean


方法代码如下:

 1package com.gresoft.components.fileupload.service;
 2
 3import org.quartz.JobExecutionContext;
 4import org.quartz.JobExecutionException;
 5import org.springframework.scheduling.quartz.QuartzJobBean;
 6
 7public class ParseFileQuartz extends QuartzJobBean {
 8    private readXmlService readXmlService;
 9
10    @Override
11    protected void executeInternal(JobExecutionContext jobexecutioncontext)
12            throws JobExecutionException {
13        // TODO Auto-generated method stub
14        // System.out.println(genderManager.get(1).getGenderName());
15        readXmlService.refreshFileList("D:/tomcat/webapps/sanitation/upload");
16    }
17
18    public void setReadXmlService(readXmlService readXmlService) {
19        this.readXmlService = readXmlService;
20    }
21}
22



2.2 借助于Spring 的org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean类，使用此方法使开发人员对Quartz完全透明，需要实现定时任务的方法只是一个普通方法

Spring配置文件如下：

 1<?xml version="1.0" encoding="UTF-8"?>
 2<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN" "http://www.springframework.org/dtd/spring-beans-2.0.dtd">
 3<beans>
 4
 5    <bean id="saveProjectJob"
 6        class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
 7        <property name="targetObject">
 8            <ref local="parseQuartz" />
 9
10        </property>
11        <property name="targetMethod">
12            <value>execute</value>
13        </property>
14
15
16    </bean>
17    <bean id="parseQuartz" class="com.gresoft.components.fileupload.service.ParseFileQuartzOther">
18        <property name="readXmlService" ref="readXmlService" />
19    </bean>    
20<bean id="saveCron"
21        class="org.springframework.scheduling.quartz.CronTriggerBean">
22        <property name="jobDetail">
23            <ref local="saveProjectJob" />
24        </property>
25        <property name="cronExpression">
26            <value>0/30 * * * * ?</value>
27        </property>
28    </bean>
29    <bean id="scheduler"
30        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
31        <property name="triggers">
32            <ref local="saveCron" />
33        </property>
34    </bean>
35


业务代码如下：

 1package com.gresoft.components.fileupload.service;
 2
 3public class ParseFileQuartzOther {
 4    private readXmlService readXmlService;
 5
 6
 7    public void execute(){
 8        // TODO Auto-generated method stub
 9        // System.out.println(genderManager.get(1).getGenderName());
10        readXmlService.refreshFileList("D:/tomcat/webapps/sanitation/upload");
11    }
12
13    public void setReadXmlService(readXmlService readXmlService) {
14        this.readXmlService = readXmlService;
15    }
16}
17


注意：在Spring配置和Quartz集成内容时，有两点需要注意
１、在<Beans>中不能够设置default-lazy-init="true",否则定时任务不触发，如果不明确指明default-lazy-init的值，默认是false。
２、在<Beans>中不能够设置default-autowire="byName"的属性，否则后台会报org.springframework.beans.factory.BeanCreationException错误，这样就不能通过Bean名称自动注入，必须通过明确引用注入。

比如上例中的parseQuartz就是明确声明注入的方式

1<bean id="parseQuartz" class="com.gresoft.components.fileupload.service.ParseFileQuartzOther">
2        <property name="readXmlService" ref="readXmlService" />
3    </bean>


具体错误信息如下：

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'scheduler' defined in file [D:\workspace1\sanitation\web\WEB-INF\classes\spring\quartz.xml]: Invocation of init method failed; nested exception is org.quartz.SchedulerConfigException: Failure occured during job recovery. [See nested exception: org.quartz.impl.jdbcjobstore.LockException: Failure obtaining db row lock: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS [See nested exception: com.ibm.db2.jcc.b.SqlException: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS]]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1362)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:540)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:485)
    at java.security.AccessController.doPrivileged(Native Method)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:455)
    at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:251)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:169)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:248)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:170)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:407)
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:735)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:369)
    at org.springframework.web.context.ContextLoader.createWebApplicationContext(ContextLoader.java:251)
    at org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:190)
    at org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:45)
    at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:3764)
    at org.apache.catalina.core.StandardContext.start(StandardContext.java:4216)
    at org.apache.catalina.core.ContainerBase.start(ContainerBase.java:1014)
    at org.apache.catalina.core.StandardHost.start(StandardHost.java:736)
    at org.apache.catalina.core.ContainerBase.start(ContainerBase.java:1014)
    at org.apache.catalina.core.StandardEngine.start(StandardEngine.java:443)
    at org.apache.catalina.startup.Embedded.start(Embedded.java:822)
    at EmbeddedTomcat.startTomcat(EmbeddedTomcat.java:85)
    at EmbeddedTomcat.main(EmbeddedTomcat.java:102)
Caused by: org.quartz.SchedulerConfigException: Failure occured during job recovery. [See nested exception: org.quartz.impl.jdbcjobstore.LockException: Failure obtaining db row lock: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS [See nested exception: com.ibm.db2.jcc.b.SqlException: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS]]
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.initialize(JobStoreSupport.java:557)
    at org.quartz.impl.jdbcjobstore.JobStoreCMT.initialize(JobStoreCMT.java:144)
    at org.springframework.scheduling.quartz.LocalDataSourceJobStore.initialize(LocalDataSourceJobStore.java:133)
    at org.quartz.impl.StdSchedulerFactory.instantiate(StdSchedulerFactory.java:1204)
    at org.quartz.impl.StdSchedulerFactory.getScheduler(StdSchedulerFactory.java:1355)
    at org.springframework.scheduling.quartz.SchedulerFactoryBean.createScheduler(SchedulerFactoryBean.java:687)
    at org.springframework.scheduling.quartz.SchedulerFactoryBean.afterPropertiesSet(SchedulerFactoryBean.java:582)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1390)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1359)
     23 more
Caused by: org.quartz.impl.jdbcjobstore.LockException: Failure obtaining db row lock: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS [See nested exception: com.ibm.db2.jcc.b.SqlException: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS]
    at org.quartz.impl.jdbcjobstore.StdRowLockSemaphore.executeSQL(StdRowLockSemaphore.java:112)
    at org.quartz.impl.jdbcjobstore.DBSemaphore.obtainLock(DBSemaphore.java:112)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInNonManagedTXLock(JobStoreSupport.java:3655)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInNonManagedTXLock(JobStoreSupport.java:3624)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.cleanVolatileTriggerAndJobs(JobStoreSupport.java:693)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.initialize(JobStoreSupport.java:555)
     31 more
Caused by: com.ibm.db2.jcc.b.SqlException: DB2 SQL error: SQLCODE: -204, SQLSTATE: 42704, SQLERRMC: DB2ADMIN.QRTZ_LOCKS
    at com.ibm.db2.jcc.b.fg.e(fg.java:1596)
    at com.ibm.db2.jcc.b.fg.a(fg.java:1206)
    at com.ibm.db2.jcc.a.gb.g(gb.java:140)
    at com.ibm.db2.jcc.a.gb.a(gb.java:39)
    at com.ibm.db2.jcc.a.w.a(w.java:34)
    at com.ibm.db2.jcc.a.vb.g(vb.java:139)
    at com.ibm.db2.jcc.b.fg.n(fg.java:1177)
    at com.ibm.db2.jcc.b.gg.eb(gg.java:1862)
    at com.ibm.db2.jcc.b.gg.d(gg.java:2295)
    at com.ibm.db2.jcc.b.gg.V(gg.java:424)
    at com.ibm.db2.jcc.b.gg.executeQuery(gg.java:407)
    at org.apache.commons.dbcp.DelegatingPreparedStatement.executeQuery(DelegatingPreparedStatement.java:92)
    at org.quartz.impl.jdbcjobstore.StdRowLockSemaphore.executeSQL(StdRowLockSemaphore.java:92)
     36 more



以上就是结合Spring使用Quartz编写定时任务两种方式，Spring很好的封装使用Quartz的细节，第一种方式是利用SPring封装的Quartz类进行特定方法的实现，第二种是通过透明的使用Quartz达到定时任务开发的目的，总体说第二种对开发人员更方便！

分享到：
spring利用javamail，quartz定时发送邮件
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    基于spring和quartz的定时任务案例

    Spring框架和Quartz库结合使用，可以构建出强大且灵活的定时任务系统。下面将详细介绍如何利用Spring与Quartz实现这一功能。 首先，Spring框架是Java企业级应用的事实标准，它提供了丰富的功能，包括依赖注入（DI）...

    Spring中定时任务

    首先，Spring提供了两种主要的定时任务实现：`Spring Task`（也称为Spring自己的任务调度器）和`Quartz Scheduler`。`Spring Task`相对简单，适用于轻量级的定时需求，而`Quartz`则功能强大，适合复杂的调度场景。 ...

    Spring+Quartz2

    Spring 和 Quartz2 的结合使用，使得我们可以轻松地在 Spring 应用中创建和管理复杂的定时任务，而且通过 Cron 表达式可以方便地调整任务的执行周期。这种灵活性和强大功能使得它们在企业级应用中得到广泛应用。 在...

    spring定时器(内含TimerTask实现和Quartz实现两种方式)

    本篇文章将详细探讨两种实现Spring定时任务的方法：基于Java内置的`TimerTask`和第三方库Quartz Scheduler。 首先，让我们看看如何使用`TimerTask`来实现Spring中的定时任务。`TimerTask`是Java的标准库类，它提供...

    spring quartz 任务调度

    Spring通过`org.springframework.scheduling`包提供了定时任务的支持，主要分为两种方式：基于Java的定时器（@Scheduled注解）和基于XML配置的定时器。@Scheduled注解允许开发者在方法上直接声明定时任务，而XML配置...

    springQuartz.zip

    这个项目的核心在于如何使用Spring管理Quartz定时任务的配置和执行。让我们深入了解一下相关知识点： 1. **Quartz简介**：Quartz是开源的作业调度框架，它允许应用程序定义和调度任务，以便在特定的时间点或按照...

    两种方式通过spring实现定时执行任务操作

    本文将详细讲解两种通过Spring实现定时任务的方法：Spring的`TimerTask`和`Spring Batch`的`Tasklet`。我们将涵盖这两种方法的基本原理、配置以及使用源码，确保你能全面理解如何在实际项目中应用。 ### 一、Spring...

    spring集成quartz所需文件

    在描述中提到 "spring和quartz1.x及quartz2.x集成"，这意味着我们要关注的是两种不同版本的 Quartz。Quartz 1.x 是较早的版本，而 Quartz 2.x 是后续的更新，增加了许多新特性，提升了性能和稳定性。集成时需要注意...

    Spring下使用Quartz任务调度

    Spring框架结合Quartz库提供了一种高效且灵活的任务调度解决方案。这篇博客“Spring下使用Quartz任务调度”将深入探讨如何在Spring环境中集成并使用Quartz进行任务管理。 Quartz是一个开源的作业调度框架，它可以被...

    quarz分布式定时任务

    其中，前三种方案均不支持集群环境下的定时任务，而第四种方案即Spring结合Quartz支持数据库的方式，能够很好地解决上述问题。 ### Quartz框架简介 Quartz是一款完全由Java编写的开源作业调度框架。它不仅支持简单...

    spring2.0学习笔记+spring定时任务

    定时任务在任何企业级应用中都扮演着重要角色，Spring提供了两种主要的方式来实现定时任务：一是使用`org.springframework.scheduling.timer.TimerTask`，二是使用`org.springframework.scheduling.quartz....

    spring-quartz-02

    总的来说，"spring-quartz-02" 这个 demo 提供了一个完整的示例，演示了如何在 Spring 环境下利用 Quartz 创建并管理定时任务，使用 Cron 表达式进行灵活的调度。这对于任何需要在 Java 应用中实现定时功能的开发者...

    Spring普通定时任务和动态设置定时任务

    对于这类需求，Spring 提供了一种简单且灵活的方式来实现定时任务：通过集成 Quartz 调度器。Quartz 是一个开源的作业调度库，能够触发在Java环境中编写的应用程序。Spring 通过提供一系列的抽象层来简化 Quartz 的...

    spring定时任务

    首先，Spring 提供了两种内置的定时任务解决方案：Spring Task（也称为Spring Scheduler）和Quartz Scheduler。Spring Task适用于简单场景，而Quartz则更为强大，适合需要复杂调度逻辑的情况。在本案例中，我们关注...

    使用SpringBoot编写的定时任务代码

    首先，Spring Boot提供了对Quartz和Spring Task两种定时任务库的支持。在这个案例中，我们使用的是Spring Task，它简化了在Spring应用中配置和运行定时任务的过程。要启用Spring Task，只需要在`pom.xml`或`build....

    spring-quartz

    下面将详细解释如何在Spring中集成Quartz以及如何使用Cron表达式来配置定时任务。 首先，为了引入Quartz到Spring项目中，你需要在`pom.xml`（如果你使用的是Maven）或者`build.gradle`（如果你使用的是Gradle）中...

    java定时任务

    下面我们将深入探讨Java定时任务的实现方式以及这两个文件可能涉及的概念。 1. **Java定时任务框架** Java提供了一些内置的API来创建定时任务，如`java.util.Timer`和`java.util.concurrent....

    spring定时器-quartz开发的步骤

    Spring提供了两种定时任务框架：`java.util.Timer`和`@Scheduled`注解。然而，对于复杂的企业级应用，Quartz更具有优势，因为它支持集群、灵活的调度策略和丰富的API。 1. **引入依赖**： 要使用Quartz与Spring...

    使用多线程开启定时任务(注解版)

    而`quartz`或`Spring Framework`中的`@Scheduled`注解则提供了一种更加优雅的方式来创建定时任务。 `@Scheduled`是Spring框架提供的一个强大注解，它可以让我们在不编写额外调度代码的情况下，直接在方法上标注以...

    Spring实现任务调度

    首先，Spring提供了两种主要的任务调度机制：Spring内置的`TaskExecution`和`TaskScheduling`以及与Quartz Scheduler的集成。`TaskExecution`和`TaskScheduling`是Spring框架的基础任务调度API，它们允许开发者创建...

Magicbox
Global site tag (gtag.js) - Google Analytics