quartz集群

Quartz体系结构
Quartz对任务调度的领域问题进行了高度的抽象，提出了调度器、任务和触发器这3个核心的概念，并在org.quartz通过接口和类对重要的这些核心概念进行描述：
●Job：是一个接口，只有一个方法void execute(JobExecutionContext context)，开发者实现该接口定义运行任务，JobExecutionContext类提供了调度上下文的各种信息。Job运行时的信息保存在JobDataMap实例中。
●JobDetail：Quartz在每次执行Job时，都重新创建一个Job实例，所以它不直接接受一个Job的实例，相反它接收一个Job实现类，以便运行时通过newInstance()的反射机制实例化Job。因此需要通过一个类来描述Job的实现类及其它相关的静态信息，如Job名字、描述、关联监听器等信息，JobDetail承担了这一角色。
通过该类的构造函数可以更具体地了解它的功用：JobDetail(java.lang.String name, java.lang.String group, java.lang.Class jobClass)，该构造函数要求指定Job的实现类，以及任务在Scheduler中的组名和Job名称。
●Trigger：是一个类，描述触发Job执行的时间触发规则。主要有SimpleTrigger和CronTrigger这两个子类。当仅需触发一次或者以固定时间间隔周期执行，SimpleTrigger是最适合的选择；而CronTrigger则可以通过Cron表达式定义出各种复杂时间规则的调度方案：如每早晨9:00执行，周一、周三、周五下午5:00执行等。
●Calendar：org.quartz.Calendar和java.util.Calendar不同，它是一些日历特定时间点的集合（可以简单地将org.quartz.Calendar看作java.util.Calendar的集合——java.util.Calendar代表一个日历时间点，无特殊说明后面的Calendar即指org.quartz.Calendar）。一个Trigger可以和多个Calendar关联，以便排除或包含某些时间点。假设，我们安排每周星期一早上10:00执行任务，但是如果碰到法定的节日，任务则不执行，这时就需要在Trigger触发机制的基础上使用Calendar进行定点排除。针对不同时间段类型，Quartz在org.quartz.impl.calendar包下提供了若干个Calendar的实现类，如AnnualCalendar、MonthlyCalendar、WeeklyCalendar分别针对每年、每月和每周进行定义。
●Scheduler：代表一个Quartz的独立运行容器，Trigger和JobDetail可以注册到Scheduler中，两者在Scheduler中拥有各自的组及名称，组及名称是Scheduler查找定位容器中某一对象的依据，Trigger的组及名称必须唯一，JobDetail的组和名称也必须唯一（但可以和Trigger的组和名称相同，因为它们是不同类型的）。Scheduler定义了多个接口方法，允许外部通过组及名称访问和控制容器中Trigger和JobDetail。
Scheduler可以将Trigger绑定到某一JobDetail中，这样当Trigger触发时，对应的Job就被执行。一个Job可以对应多个Trigger，但一个Trigger只能对应一个Job。可以通过SchedulerFactory创建一个Scheduler实例。Scheduler拥有一个SchedulerContext，它类似于ServletContext，保存着Scheduler上下文信息，Job和Trigger都可以访问SchedulerContext内的信息。SchedulerContext内部通过一个Map，以键值对的方式维护这些上下文数据，SchedulerContext为保存和获取数据提供了多个put()和getXxx()的方法。可以通过Scheduler# getContext()获取对应的SchedulerContext实例。
●ThreadPool：Scheduler使用一个线程池作为任务运行的基础设施，任务通过共享线程池中的线程提高运行效率。
Quartz数据库表
   因为Quartz集群依赖于数据库，所以必须首先创建Quartz数据库表，Quartz包括了所有被支持的数据库平台的SQL脚本。在 quartz-2.2.1-distribution\quartz-2.2.1\docs\dbTables 目录下找到那些SQL脚本选择相应数据库执行,mysql脚本执行以后如下图：




表名 描述
QRTZ_BLOG_TRIGGERS Trigger作为Blob类型存储(用于Quartz用户用JDBC创建他们自己定制的Trigger类型，JobStore 并不知道如何存储实例的时候)
QRTZ_CALENDARS 以Blob类型存储Quartz的Calendar信息
QRTZ_CRON_TRIGGERS 存储Cron Trigger，包括Cron表达式和时区信息
QRTZ_FIRED_TRIGGERS 存储与已触发的Trigger相关的状态信息，以及相联Job的执行信息
QRTZ_JOB_DETAILS 存储每一个已配置的Job的详细信息
QRTZ_LOCKS 存储程序的非观锁的信息(假如使用了悲观锁)
QRTZ_PAUSED_TRIGGER_GRPS 存储已暂停的Trigger组的信息
QRTZ_SCHEDULER_STATE 存储少量的有关 Scheduler的状态信息，和别的 Scheduler 实例(假如是用于一个集群中)
QRTZ_JOB_LISTENERS 存储有关已配置的 JobListener的信息
QRTZ_SIMPLE_TRIGGERS 存储简单的 Trigger，包括重复次数，间隔，以及已触的次数
QRTZ_SIMPROP_TRIGGERS  
QRTZ_TRIGGERS 存储已配置的 Trigger的信息
 
JOB类实现
import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SimpleJob implements Job {

    private static final Logger LOGGER = LoggerFactory.getLogger(SimpleJob.class);

    public SimpleJob() {
    }

    public void execute(JobExecutionContext context) throws JobExecutionException {
        System.err.println("Hello world");
    }
}
 
JOB配置文件XML
注：2.2.1版本给定例子是version=1.8如引用必须修改为2.0 
jobXML
<?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_2_0.xsd"
                      version="2.0">
      
       <schedule>
           <job>
               <name>SimpleJob</name>
               <group>SimpleJobGroup</group>
               <description>djob</description>
               <job-class>com.fangdd.channel.SimpleJob</job-class>
               <durability>true</durability>
               <recover>false</recover>
           </job>
           <trigger>
               <cron>
                   <name>SimpleJobCronGroup</name>
                   <group>SimpleGroupCron</group>
                   <job-name>SimpleJob</job-name>
                   <job-group>SimpleJobGroup</job-group>
                   <misfire-instruction>MISFIRE_INSTRUCTION_FIRE_ONCE_NOW</misfire-instruction>
                   <cron-expression>0/10 * * * * ?</cron-expression>
               </cron>
           </trigger>
       </schedule>
</job-scheduling-data>
说明：
<job>
    name: 集群中job的名字,该名字用户自己可以随意定制,无强行要求。
   group: 集群中job的所属组的名字,该名字用户自己随意定制,无强行要求。
   job-class:集群中job实现类的完全包名,quartz就是根据这个路径到classpath找到该job类的。
  durability:是否持久化,把该属性设置为true，quartz会把job持久化到数据库中
<trigger>
    name:  trigger的名字,该名字用户自己可以随意定制,无强行要求
    group:  trigger所属组的名字,该名字用户自己随意定制,无强行要求
   job_name:    对应Job name
   job_group:     对应job group
  cron-expression:   触发器类型,使用cron表达式
   misfire-instruction:如果设置MISFIRE_INSTRUCTION_DO_NOTHING，则不对misfire的任务做特殊处理，只从当前时间之后的下一次正常调度时间开始执行
Quartz配置文件说明
默认文件名称quartz.properties，通过设置"org.quartz.jobStore.isClustered"属性为"true"来激活集群特性。在集群中的每一个实例都必须有一个唯一的"instance id" ("org.quartz.scheduler.instanceId" 属性), 但是应该有相同的"scheduler instance name" ("org.quartz.scheduler.instanceName")，也就是说集群中的每一个实例都必须使用相同的quartz.properties 配置文件。
除了以下几种例外，配置文件的内容其他都必须相同：
a.不同的线程池大小。
b.不同的"org.quartz.scheduler.instanceId"属性值（这个可以很容易做到，设定为"AUTO"即可）。
注意：
1、永远不要在不同的机器上运行集群，除非他们的时钟是使用某种形式的同步服务（守护）非常有规律的运行（时钟必须在一分一秒内）来达到同步。
2、永远不要触发一个非集群的实例，如果其他的实例正在同一个数据库表上运行。你将使你的数据严重腐蚀，出现非预期行为。
配置文件quartz
#============================================================================
# Configure Main Scheduler Properties 
#在集群中每个实例都必须有一个唯一的instanceId，但是应该有一个相同的instanceName
#============================================================================

org.quartz.scheduler.instanceName: TestScheduler
org.quartz.scheduler.instanceId: AUTO

org.quartz.scheduler.skipUpdateCheck: true

#============================================================================
# Configure ThreadPool 
#定义线程池，SimpleThreadPool这个线程池只是简单地在它的池中保持固定数量的线程，不增长也不缩小。
#但是它非常健壮且经过良好的测试，差不多每个Quartz用户都使用这个池。
#threadCount最多3个
#============================================================================

org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 3
org.quartz.threadPool.threadPriority: 5

#============================================================================
# Configure JobStore 
#配置数据存储的方式
#一个触发器被认定为“misfired”之前，调度器所能容忍的毫秒数
#============================================================================

org.quartz.jobStore.misfireThreshold: 60000
#所有的Quartz数据,例如Job和Trigger的细节信息被存储在内存（数据库）
#配置事务。JobStoreTX来让Quartz帮你管理事务（这是最普遍的选择）。
#如果想让Quartz同其他的事务协同工作（例如：J2EE应用服务器中的事务），那么你需要使用JobStoreCMT，这样，Quartz就会让应用服务器容器来管理事务
#org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX
#DriverDelegate负责做指定数据库的所有JDBC工作.  如果数据库没有其他指定的代理，那么就试用代理StdJDBCDelegate
org.quartz.jobStore.driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
#为了指示JDBCJobStore所有的JobDataMaps中的值都是字符串，
#并且能以“名字-值”对的方式存储而不是以复杂对象的序列化形式存储在BLOB字段中，应设置值为”true”(这是缺省的方式)
org.quartz.jobStore.useProperties: false
#配置数据源源的名数、据库表前前缀
org.quartz.jobStore.dataSource: myDS
org.quartz.jobStore.tablePrefix: QRTZ_
#配置数据源源的名数、据库表前前缀
org.quartz.jobStore.isClustered: true

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

org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc\:mysql\://localhost\:3306/quartz_tables?useUnicode\=true&characterEncoding\=utf-8
org.quartz.dataSource.myDS.user = root
org.quartz.dataSource.myDS.password = 123456
#如果Scheduler非常忙（比如，执行的任务数量差不多和线程池的数量相同，那么你需要正确地配置DataSource的连接数量为线程池数量+1）
org.quartz.dataSource.myDS.maxConnections = 10

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

org.quartz.plugin.triggHistory.class: org.quartz.plugins.history.LoggingJobHistoryPlugin
#1.8以前org.quartz.plugin.jobInitializer,1.8以后org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin
org.quartz.plugin.jobInitializer.class: org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin
org.quartz.plugin.jobInitializer.fileNames: quartz_job.xml
org.quartz.plugin.jobInitializer.failOnFileNotFound: true
org.quartz.plugin.jobInitializer.scanInterval: 120
org.quartz.plugin.jobInitializer.wrapInUserTransaction: false
Web文件中加载quartz两种方式：
 通过servlet
servlet标签
<servlet>
         <servlet-name>QuartzInitializer</servlet-name>
         <servlet-class>org.quartz.ee.servlet.QuartzInitializerServlet</servlet-class>
         <load-on-startup>1</load-on-startup>
         <init-param>
             <param-name>config-file</param-name>
             <param-value>quartz.properties</param-value>
         </init-param>
       <init-param>
             <param-name>shutdown-on-unload</param-name>
             <param-value>true</param-value>
         </init-param>
         <init-param> 
             <param-name>wait-on-shutdown</param-name> 
             <param-value>true</param-value> 
         </init-param> 
         <init-param> 
             <param-name>start-scheduler-on-load</param-name> 
             <param-value>true</param-value> 
         </init-param>
        
     </servlet>
    通过listener
listener标签
<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>
     <context-param>
     <param-name>start-scheduler-on-load</param-name>
     <param-value>true</param-value>
     </context-param>
    
     <listener>
     <listener-class>org.quartz.ee.servlet.QuartzInitializerListener</listener-class>
     </listener>
注：自己通过实现ServletContextListener也可以
  public void contextDestroyed(ServletContextEvent servletContextEvent) {
        try {
            StdSchedulerFactory.getDefaultScheduler().shutdown();
        } catch (SchedulerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        // TODO Auto-generated method stub
    }
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        try {
            StdSchedulerFactory.getDefaultScheduler().start();
          
        } catch (SchedulerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
具体例子实现jfinal1.8+quartzy2.2.1