`

Quartz基础使用

 
阅读更多
【quartz应用】
 

1、把quartz-*.jar 包放到lib目录下，他还需要 slf4j-api-*.jar 、 jta-*.jar

2.web.xml

<servlet>
    <servlet-name>QuartzInitializer</servlet-name>
    <servlet-class>org.quartz.ee.servlet.QuartzInitializerServlet</servlet-class>
    <init-param>
      <param-name>shutdown-on-unload</param-name>
      <param-value>true</param-value>
    </init-param>
    <init-param>
     <param-name>config-file</param-name>
     <param-value>quartz.properties</param-value>
    </init-param>
    <load-on-startup>2</load-on-startup>
  </servlet>

 

或者

<servlet>

    <context-param>
    <param-name>config-file</param-name>
    <param-value>/quartz.properties</param-value>
    </context-param>
    <context-param>
    <param-name>shutdown-on-unload</param-name>
    <param-value>true</param-value>
    </context-param>
 </servlet>
<listener>
<listener-class>
org.quartz.ee.servlet.QuartzInitializerListener
</listener-class>
</listener>

3、在src目录下建立 quartz.properties

<1>直接连接数据库

#============================================================
# Configure Main Scheduler Properties
#===========================================================
org.quartz.scheduler.instanceName = MyClusteredScheduler
org.quartz.scheduler.instanceId = AUTO
#===========================================================
# Configure ThreadPool
#===========================================================
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 25
org.quartz.threadPool.threadPriority = 5
#===========================================================
# Configure JobStore
#===========================================================
org.quartz.jobStore.misfireThreshold = 60000

org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.tablePrefix = QRTZ_

org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000

#===========================================================
# Configure Datasources
#===========================================================
org.quartz.dataSource.myDS.driver = oracle.jdbc.driver.OracleDriver
org.quartz.dataSource.myDS.URL = jdbc:oracle:thin:@ip:1521:dbname

org.quartz.dataSource.myDS.user = QRTZ
org.quartz.dataSource.myDS.password = pwd

org.quartz.dataSource.myDS.maxConnections = 5
org.quartz.dataSource.myDS.validationQuery=select 0 from dual

 

<2>使用jndi<NewBMQrtz>连接数据库

 

#============================================================
# Configure Main Scheduler Properties
#===========================================================
org.quartz.scheduler.instanceName = MyClusteredScheduler
org.quartz.scheduler.instanceId = AUTO
#===========================================================
# Configure ThreadPool
#===========================================================
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 25
org.quartz.threadPool.threadPriority = 5
#===========================================================
# Configure JobStore
#===========================================================
org.quartz.jobStore.misfireThreshold = 60000

org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.tablePrefix = QRTZ_

org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000

#===========================================================
# Configure Datasources
#===========================================================
org.quartz.dataSource.myDS.jndiURL = NewBMQrtz

4、在src目录下建立quartz_job.xml

 

 

<?xml version="1.0" encoding="UTF-8"?>  
<job-scheduling-data xmlns="http://www.quartz-scheduler.org/xml/JobSchedulingData"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.quartz-scheduler.org/xml/JobSchedulingData http://www.quartz-scheduler.org/xml/job_scheduling_data_1_8.xsd"
    version="1.8">
    
<pre-processing-commands>
<delete-jobs-in-group>*</delete-jobs-in-group>  <!-- clear all jobs in scheduler -->
<delete-triggers-in-group>*</delete-triggers-in-group> <!-- clear all triggers in scheduler -->
</pre-processing-commands>
<processing-directives>
<!-- if there are any jobs/trigger in scheduler of same name (as in this file), overwrite them -->
<overwrite-existing-data>true</overwrite-existing-data>
<!-- if there are any jobs/trigger in scheduler of same name (as in this file), and over-write is false, ignore them rather then generating an error -->
<ignore-duplicates>false</ignore-duplicates> 
</processing-directives>
<schedule>
<job>
       <name>ParseDataJob</name>
            <group>DataSys</group>
            <description>数据解析job</description>
       <job-class>esmart.datasys.quartzjob.ParseDataJob</job-class>
       <volatility>false</volatility>
            <durability>true</durability>
            <recover>false</recover>
   </job>
   <trigger>
       <cron>
           <name>ParseDataTrigger</name>
           <group>DataSys</group>
           <job-name>ParseDataJob</job-name>
           <job-group>DataSys</job-group>
                <misfire-instruction>MISFIRE_INSTRUCTION_FIRE_ONCE_NOW</misfire-instruction>
           <cron-expression>0/20 * * * * ?</cron-expression>
       </cron>
   </trigger>
</schedule>
</job-scheduling-data>

其中的 <job-class> 是自己定义的实现org.quartz.Job接口，有一个空的构造函数的类

 

【管理使用】

import java.text.ParseException;
import org.quartz.CronTrigger;
import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;

/** *//**
 * @Title:Quartz管理类
 * 
 * @Description:
 * 
 * @Copyright: 
 * @author zz  2008-10-8 14:19:01
 * @version 1.00.000
 *
 */
public class QuartzManager {
   private static SchedulerFactory sf = new StdSchedulerFactory();
   private static String JOB_GROUP_NAME = "group1";
   private static String TRIGGER_GROUP_NAME = "trigger1";
  
   
   /** *//**
    *  添加一个定时任务，使用默认的任务组名，触发器名，触发器组名
    * @param jobName 任务名
    * @param job     任务
    * @param time    时间设置，参考quartz说明文档
    * @throws SchedulerException
    * @throws ParseException
    */
   public static void addJob(String jobName,Job job,String time) 
                               throws SchedulerException, ParseException{
       Scheduler sched = sf.getScheduler();
       JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, job.getClass());//任务名，任务组，任务执行类
       //触发器
       CronTrigger  trigger = 
            new CronTrigger(jobName, TRIGGER_GROUP_NAME);//触发器名,触发器组
       trigger.setCronExpression(time);//触发器时间设定
       sched.scheduleJob(jobDetail,trigger);
       //启动
       if(!sched.isShutdown())
          sched.start();
   }
   
   /** *//**
    * 添加一个定时任务
    * @param jobName 任务名
    * @param jobGroupName 任务组名
    * @param triggerName  触发器名
    * @param triggerGroupName 触发器组名
    * @param job     任务
    * @param time    时间设置，参考quartz说明文档
    * @throws SchedulerException
    * @throws ParseException
    */
   public static void addJob(String jobName,String jobGroupName,
                             String triggerName,String triggerGroupName,
                             Job job,String time) 
                               throws SchedulerException, ParseException{
       Scheduler sched = sf.getScheduler();
       JobDetail jobDetail = new JobDetail(jobName, jobGroupName, job.getClass());//任务名，任务组，任务执行类
       //触发器
       CronTrigger  trigger = 
            new CronTrigger(triggerName, triggerGroupName);//触发器名,触发器组
       trigger.setCronExpression(time);//触发器时间设定
       sched.scheduleJob(jobDetail,trigger);
      if(!sched.isShutdown())
          sched.start();
   }
   
   /** *//**
    * 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名)
    * @param jobName
    * @param time
    * @throws SchedulerException
    * @throws ParseException
    */
   public static void modifyJobTime(String jobName,String time) 
                                  throws SchedulerException, ParseException{
       Scheduler sched = sf.getScheduler();
       Trigger trigger =  sched.getTrigger(jobName,TRIGGER_GROUP_NAME);
       if(trigger != null){
          CronTrigger  ct = (CronTrigger)trigger;
           ct.setCronExpression(time);
           sched.resumeTrigger(jobName,TRIGGER_GROUP_NAME);
       }
   }
   
   /** *//**
    * 修改一个任务的触发时间
    * @param triggerName
    * @param triggerGroupName
    * @param time
    * @throws SchedulerException
    * @throws ParseException
    */
   public static void modifyJobTime(String triggerName,String triggerGroupName,
                                    String time) 
                                  throws SchedulerException, ParseException{
       Scheduler sched = sf.getScheduler();
       Trigger trigger =  sched.getTrigger(triggerName,triggerGroupName);
       if(trigger != null){
           CronTrigger  ct = (CronTrigger)trigger;
           //修改时间
           ct.setCronExpression(time);
           //重启触发器
           sched.resumeTrigger(triggerName,triggerGroupName);
       }
   }
   
   /** *//**
    * 移除一个任务(使用默认的任务组名，触发器名，触发器组名)
    * @param jobName
    * @throws SchedulerException
    */
   public static void removeJob(String jobName) 
                               throws SchedulerException{
       Scheduler sched = sf.getScheduler();
       sched.pauseTrigger(jobName,TRIGGER_GROUP_NAME);//停止触发器
       sched.unscheduleJob(jobName,TRIGGER_GROUP_NAME);//移除触发器
       sched.deleteJob(jobName,JOB_GROUP_NAME);//删除任务
   }
   
   /** *//**
    * 移除一个任务
   * @param jobName
    * @param jobGroupName
    * @param triggerName
    * @param triggerGroupName
    * @throws SchedulerException
    */
   public static void removeJob(String jobName,String jobGroupName,
                                String triggerName,String triggerGroupName) 
                               throws SchedulerException{
       Scheduler sched = sf.getScheduler();
       sched.pauseTrigger(triggerName,triggerGroupName);//停止触发器
       sched.unscheduleJob(triggerName,triggerGroupName);//移除触发器
       sched.deleteJob(jobName,jobGroupName);//删除任务
   }
}

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class TestMGJob implements Job {

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // TODO Auto-generated method stub
        System.out.println("★★★★★★★★★★★");
    }

}

 

public class QuartzTest {

    /** *//**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        TestMGJob job = new TestMGJob();

QuartzManager qmg = new QuartzManager();
        String job_name ="TEST1";
        try {
            System.out.println("【系统启动】");
            qmg .addJob(job_name,job,"0/5 * * * * ?");
           
            Thread.sleep(10000);
            System.out.println("【修改时间】");
            qmg .modifyJobTime(job_name,"0/10 * * * * ?");
            Thread.sleep(20000);
            System.out.println("【移除定时】");
            qmg .removeJob(job_name);
            Thread.sleep(10000);
           
            System.out.println("\n【添加定时任务】");
            qmg .addJob(job_name,job,"0/5 * * * * ?");
           
        }  catch (Exception e) {
            e.printStackTrace();
        }
    }
}

分享到：
| Hook过滤架构搭建，仿照360(转)
评论
发表评论

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

相关推荐

    quartz-2.2.3版本的quartz初始化sql语句

    Quartz是一款广泛使用的开源任务调度框架，它允许开发者在Java应用程序中定义和执行定时任务。在Quartz 2.2.3版本中，初始化数据库是使用Quartz的关键步骤，因为Quartz依赖于一个持久化存储来保存作业和触发器的信息...

    springboot中使用quartz

    首先，让我们了解Spring Boot与Quartz的集成基础。要在Spring Boot项目中引入Quartz，我们需要在`pom.xml`或`build.gradle`文件中添加相应的依赖。对于Maven，你可以添加以下依赖： ```xml &lt;groupId&gt;org.spring...

    Quartz2D使用案例

    Quartz2D是苹果平台上的一个强大的2D图形渲染框架，它被广泛应用于iOS和macOS应用程序开发中，用于创建高质量的图形、图像处理...这些案例涵盖了基础到高级的Quartz2D使用场景，对于提升iOS和macOS开发技能非常有帮助。

    C# quartz 定时使用教程

    强大的调度功能，例如支持丰富多样的调度方法，可以满足各种常规及特殊需求； 灵活的应用方式，例如支持任务和调度的多种组合方式，支持调度...分布式和集群能力，Terracotta 收购后在原来功能基础上作了进一步提升。

    Quartz的使用说明.doc

    在 Web 应用中使用 Quartz，通常需要在 `web.xml` 文件中配置 `QuartzInitializerServlet`，并提供配置文件（如 `quartz.properties` 或 `quartz-job.xml`）来定义 Triggers 和 JobDetails。 通过以上描述，我们...

    quartz使用例子

    ### Quartz使用例子详解 在Java领域，Quartz是一个强大的任务调度框架，被广泛应用于各种应用场景中，例如...通过本文的解析，读者应该能够掌握Quartz的核心概念和实践方法，为进一步探索和应用Quartz奠定坚实的基础。

    Quartz2D的基本使用

    1. CGContext：Quartz2D的核心是图形上下文（CGContext），它是绘制的基础。CGContext负责管理绘图的状态，如颜色、线宽、填充模式等，并接收绘制命令，将它们转换为屏幕上的像素。 2. 矢量图形：Quartz2D支持矢量...

    quartz和spring-quartz

    在提供的文件中，“quartz的入门.doc”可能是Quartz的基础教程，介绍如何创建和调度Job；“spring的quartz应用.txt”可能包含Spring-Quartz的具体使用示例和注意事项；“spring-quartz-demo”可能是一个完整的示例...

    springboot2.3集成quartz定时任务持久化数据库,支持集群

    Spring Boot与Quartz的集成使得我们可以方便地在Spring应用中使用定时任务功能。Spring Boot提供了自动配置，简化了Quartz的设置。 在Spring Boot 2.3中集成Quartz，你需要先添加依赖。在`pom.xml`文件中，引入以下...

    quartz scheduler 入门教程

    Quartz Scheduler 自有集群特性，在数据库持久保存的基础上。Terracotta 对 Quartz 的扩展，实现了一个集群能力，不需要终端数据库的支持。 监听器和组件 监听器和组件可以捕捉到调度器的事件。然后就可以显示或者...

    quartz所需jar包 1.6.0、1.8.5、2.2.1三个版本

    - `quartz-all-1.6.0.jar`包含所有必要的依赖，使得开发者可以直接引入此单一jar包来使用Quartz。 - 此版本可能不包含一些高级特性，如集群支持或更完善的API。 2. **Quartz 1.8.5**： - 作为1.x系列的一个更新...

    springboot整合quartz定时任务yml文件配置方式

    以下将详细介绍如何在Spring Boot应用中使用YAML文件配置Quartz定时任务，以及涉及的Spring Cloud Alibaba、Dubbo和Nacos的相关知识。 首先，我们需要在`pom.xml`中引入相关的依赖。Spring Boot的`spring-boot-...

    一个基础的Quartz定时器案例

    在这个基础的Quartz定时器案例中，我们将探讨如何使用Quartz API来创建、配置和执行定时任务。 首先，Quartz的核心组件包括Job（任务）、Trigger（触发器）和Scheduler（调度器）。Job是实际需要执行的任务，...

    quartz所需要的jar包

    总的来说，这个压缩包提供了开发基于Quartz的定时任务系统所需的全部基础。无论是简单还是复杂的调度需求，Quartz都能提供强大的支持。通过理解Quartz的核心概念和API，开发者可以构建出高效、可靠的自动化工作流，...

    Quartz2D基础绘画

    Quartz2D的基础绘画涉及到以下几个核心概念和技术： 1. **图形上下文（Graphics Context）**：在Quartz2D中，所有绘图操作都发生在图形上下文中。图形上下文就像一个画布，你可以在这个画布上绘制线条、形状、图片...

    Quartz

    - 实现`org.quartz.Job`接口是创建一个Job的基础。该接口中包含一个名为`execute`的方法，用于定义实际的任务逻辑。 - 示例代码： ```java public class MyJob implements Job { @Override public void ...

    Srping Quartz 资料多多

    "Quartz入门与提高1.ppt"可能是一个幻灯片教程，涵盖了从基础到进阶的Quartz使用。"定时任务Test.rar"可能包含了一些测试用例或示例代码，有助于理解实际应用场景。"网站地址.txt"可能提供了更多资源链接，而"quartz...

    springboot+mybatis+shiro+generator+quartz（基础框架）

    综上所述，这个基础框架集合了Spring Boot的便利性、MyBatis的灵活性、Shiro的安全管理、代码生成器的自动化、Quartz的定时任务调度以及Thymeleaf的模板渲染，为开发人员提供了一个全方位的工具链，使得企业级应用的...

    quartz各种数据库的建表语句

    总之，正确地在各种数据库上设置Quartz的表结构是确保任务调度系统正常运行的基础。请务必仔细阅读官方文档，以获取最新的建表语句和配置指南，因为随着Quartz版本的更新，这些信息可能会有所变化。同时，不要忘记在...

    Quartz 2.2.2数据库表格脚本

    `QRTZ_JOB_DETAILS`, `QRTZ_CALENDARS`, `QRTZ_CRON_TRIGGERS`, `QRTZ_SIMPLE_TRIGGERS`, `QRTZ_SIMPROP_TRIGGERS`, `QRTZ_BLOB_TRIGGERS`, 和 `QRTZ_TRIGGER_LISTENERS` 等核心表，它们是Quartz调度系统的基础。...

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