More servicesWindows Live
HomeHotmailSpacesOneCare
 
MSN
Sign in
 
 
Spaces home  X-SpiritPhotosProfileFriendsBlog Tools Explore the Spaces community

Blog

    • View next 20 entriesView last 20 entries
    September 25

    Quartz调度框架应用总结(续2)

    好,说了这么多,最后让我们来看看如何在Web应用中使用Quartz

     

    由于Scheduler的配置相当的个性化,所以,在Web应用中,我们可以通过一个quartz.properties文件来配置QuartzServlet。不过之前让我们先来看看web.xml中如何配置

     

     

    web.xml

    <servlet>

            <servlet-name>

                 QuartzInitializer

            </servlet-name>

            <display-name>

                 Quartz Initializer Servlet

            </display-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>start-scheduler-on-load</param-name>

                <param-value>true</param-value>

            </init-param>

        </servlet>

     

    这里,load-on-startup是指定QuartzServlet是否随应用启动,-1表示否,正数表示随应用启动,数值越小,则优先权越高。

    初始化参数中,config-file里面可以指定QuartzServlet的配置文件,这里我们用的是quartz.properties

    shutdown-on-unload,表示是否在卸载应用时同时停止调度,该参数推荐true,否则你的tomcat进程可能停不下来。

    start-scheduler-on-load,表示应用加载时就启动调度器,如果为false,则quartz.properties中指定的调度器在用户访问这个Servlet之后才会加载,在此之前,如果你通过ServletContext查找SchedulerFactory是可以找到的,但是要得到具体的Scheduler,那么你一定会发现Jvm抛出了一个NullPointerExcetion

     

    下面就来看看quartz.properties的真面目。

    quartz.properties

    org.quartz.scheduler.instanceName = PushDBScheduler

    org.quartz.scheduler.instanceId = one

     

    org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool

    org.quartz.threadPool.threadCount = 4

    org.quartz.threadPool.threadPriority = 4

     

    org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.JobInitializationPlugin

    org.quartz.plugin.jobInitializer.fileName = quartz_job.xml

     

    我想不用多说,大家都看出来了,首先配置了基本的Scheduler实例名,并分配了ID,然后为这个调度器设定了线程池,后面是初始化插件。初始化插件是Quartz非常实用的功能,你可以用这个功能来实现Quartz的扩展性。这里配置的插件是读取job XML文件,让调度器自动载入Job。这个插件现在支持读取多个job XML文件,但是我现在还没有试过,感兴趣的读者可以自己尝试。另外就是有一个scanInterval属性,表示每隔几秒自动扫描一次job XML文件,我现在也没有试过,感兴趣的读者可以自己试验一下。注意,该参数设定为0表示不扫描。

     

    最后,我们来看看job XML文件,这里以quartz_job.xml为例

    quartz_job.xml

    <quartz>

        <job> 

            <job-detail> 

                <name>ScanItemsInDB</name> 

                <group>Scanning</group> 

                <job-class>com.testquartz.ScanDB</job-class>

                <job-data-map allows-transient-data="true">

                     <entry>

                      <key>testmode</key>

                      <value>true</value>

                     </entry>

                </job-data-map>

            </job-detail> 

            <trigger> 

                <cron> 

                    <name>t1</name> 

                    <group> Scanning </group> 

                    <job-name> ScanItemsInDB </job-name> 

                    <job-group> Scanning </job-group> 

                    <cron-expression>0 0/5 * * * ?</cron-expression> 

                </cron> 

            </trigger> 

        </job> 

    </quartz>

     

    这个文件真是非常显而易见了,我就不多说了,大家自己研究吧。

    然后你只要自己写一下ScanDB这个类就可以了。

    ScanDB.java

    public class ScanDB implements Job {

         public void execute(JobExecutionContext context) throws JobExecutionException {

              //你的代码

         }

    }

     

    注意JobExecutionContext这个类。这个类是用来存取任务执行时的相关信息的,从中我们可以获取当前作业的TriggerSchedulerJobDataMap等等。

    当然,Scheduler也有对应的SchedulerContext,具体的用途很像ServletContext。有兴趣的读者自己研究吧。

     

    另外就是可以提供一个提示:在一个作业执行的时候,你就可以设定另外一个调度器,去执行另一个Job,这样你可以每个一段时间扫描一下数据库,然后看一看数据库里有没有下一个时间段待发的邮件,然后调用一个新的调度器实例,以便在指定的发送时间将其发送出去。

     

    好了,Quartz的相关知识就总结到这里。谢谢大家。

    上一篇 Quartz调度框架应用总结(续1)

    Quartz调度框架应用总结(续1)

    三.触发器

           Trigger是一个抽象类,它有三个子类:SimpleTriggerCronTriggerNthIncludedDayTrigger。前两个比较常用。

    1SimpleTrigger:这是一个非常简单的类,我们可以定义作业的触发时间,并选择性的设定重复间隔和重复次数。

    2CronTrigger:这个触发器的功能比较强大,而且非常灵活,但是你需要掌握有关Cron表达式的知识。如果你是一个Unix系统爱好者,你很可能已经具备这种知识,但是如果你不了解Cron表达式,请看下面的Cron详解:

     

    Cron表达式由67个由空格分隔的时间字段组成,如表1所示:

    1 Cron表达式时间字段

    位置

    时间域名

    允许值

    允许的特殊字符

    1

    0-59

    , - * /

    2

    分钟

    0-59

    , - * /

    3

    小时

    0-23

    , - * /

    4

    日期

    1-31

    , - * ? / L W C

    5

    月份

    1-12

    , - * /

    6

    星期

    1-7

    , - * ? / L C #

    7

    (可选)

    空值1970-2099

    , - * /

     

    Cron表达式的时间字段除允许设置数值外,还可使用一些特殊的字符,提供列表、范围、通配符等功能,细说如下:

    星号(*):可用在所有字段中,表示对应时间域的每一个时刻,例如,*在分钟字段时,表示每分钟

    问号(?):该字符只在日期和星期字段中使用,它通常指定为无意义的值,相当于点位符;

    减号(-):表达一个范围,如在小时字段中使用“10-12”,则表示从1012点,即10,11,12

    逗号(,):表达一个列表值,如在星期字段中使用“MON,WED,FRI”,则表示星期一,星期三和星期五;

    斜杠(/)x/y表达一个等步长序列,x为起始值,y为增量步长值。如在分钟字段中使用0/15,则表示为0,15,3045秒,而5/15在分钟字段中表示5,20,35,50,你也可以使用*/y,它等同于0/y

    L:该字符只在日期和星期字段中使用,代表“Last”的意思,但它在两个字段中意思不同。L在日期字段中,表示这个月份的最后一天,如一月的31号,非闰年二月的28号;如果L用在星期中,则表示星期六,等同于7。但是,如果L出现在星期字段里,而且在前面有一个数值X,则表示这个月的最后X,例如,6L表示该月的最后星期五;

     

    W:该字符只能出现在日期字段里,是对前导日期的修饰,表示离该日期最近的工作日。例如15W表示离该月15号最近的工作日,如果该月15号是星期六,则匹配14号星期五;如果15日是星期日,则匹配16号星期一;如果15号是星期二,那结果就是15号星期二。但必须注意关联的匹配日期不能够跨月,如你指定1W,如果1号是星期六,结果匹配的是3号星期一,而非上个月最后的那天。W字符串只能指定单一日期,而不能指定日期范围;

     

    LW组合:在日期字段可以组合使用LW,它的意思是当月的最后一个工作日;

    井号(#):该字符只能在星期字段中使用,表示当月某个工作日。如6#3表示当月的第三个星期五(6表示星期五,#3表示当前的第三个),而4#5表示当月的第五个星期三,假设当月没有第五个星期三,忽略不触发;

    C:该字符只在日期和星期字段中使用,代表“Calendar”的意思。它的意思是计划所关联的日期,如果日期没有被关联,则相当于日历中所有日期。例如5C在日期字段中就相当于日历5日以后的第一天。1C在星期字段中相当于星期日后的第一天。Cron表达式对特殊字符的大小写不敏感,对代表星期的缩写英文大小写也不敏感。表2下面给出一些完整的Cron表示式的实例:

    2 Cron表示式示例

    表示式

    说明

    "0 0 12 * * ? "

    每天12点运行

    "0 15 10 ? * *"

    每天10:15运行

    "0 15 10 * * ?"

    每天10:15运行

    "0 15 10 * * ? *"

    每天10:15运行

    "0 15 10 * * ? 2008"

    2008年的每天1015运行

    "0 * 14 * * ?"

    每天14点到15点之间每分钟运行一次,开始于14:00,结束于14:59

    "0 0/5 14 * * ?"

    每天14点到15点每5分钟运行一次,开始于14:00,结束于14:55

    "0 0/5 14,18 * * ?"

    每天14点到15点每5分钟运行一次,此外每天18点到19点每5钟也运行一次。

    "0 0-5 14 * * ?"

    每天14:00点到14:05,每分钟运行一次。

    "0 10,44 14 ? 3 WED"

    3月每周三的14:10分到14:44,每分钟运行一次。

    "0 15 10 ? * MON-FRI"

    每周一,二,三,四,五的10:15分运行。

    "0 15 10 15 * ?"

    每月1510:15分运行。

    "0 15 10 L * ?"

    每月最后一天10:15分运行。

    "0 15 10 ? * 6L"

    每月最后一个星期五10:15分运行。

    "0 15 10 ? * 6L 2007-2009"

    2007,2008,2009年每个月的最后一个星期五的10:15分运行。

    "0 15 10 ? * 6#3"

    每月第三个星期五的10:15分运行。

     

    上一篇 Quartz调度框架应用总结   下一篇 Quartz调度框架应用总结(续2)

    XMLConfiguration使用手记

    XMLConfiguration是apache工具集里的一个用于对XML文件进行读写的东东,使用起来很方便。下面我将简单的举几个使用例子。
    1,读
    这里是我们的XML文件:unit.xml
    <?xml version="1.0" encoding="utf-8"?>
    <tree>
    <unit id="root" type="root">
    <back-ground>/root/Desktop/image/4.jpg </back-ground>
    <unit id="1" type="alarm">
    <back-ground>/root/Desktop/image/5.jpg </back-ground>
    <father>root </father>
    <position>x=250:y=225 </position>
    </unit>
    </unit>
    </tree>
    下面是java代码:
    //创建XMLConfiguration
    private static XMLConfiguration getConfiguration(File file) {
    if (file == null || !file.exists())
    return null;
    XMLConfiguration config = null;
    try {
    config = new XMLConfiguration(file);
    } catch (ConfigurationException e) {
    e.printStackTrace();
    }
    config.setEncoding("utf-8");//设置编码
    return config;
    }
    .........
    XMLConfiguration tool = getConfiguration("/home/dx/unit.xml");
    //获取节点值
    String rootBackGround = tool.getString("unit.back-ground");//这里获取的值是/root/Desktop/image/4.jpg
    String alarmBackGround = tool.getString("unit.unit.back-ground");//这里获取的值是/root/Desktop/image/5.jpg
    //获取节点属性
    String rootID = tool.getString("unit[@id]");//这里获取的值是root
    String alarmID = tool.getString("unit.unit[@id]");//这里获取的值是1
    //获取重复节点值
    如果有两个以上并级的节点如何区分呢?比如在第一级unit下有两个并列的unit:
    ......................................
    <unit id="root" type="root">
    <back-ground>/root/Desktop/image/4.jpg </back-ground>
    <unit id="1" type="alarm">
    <back-ground>/root/Desktop/image/5.jpg </back-ground>
    <father>root </father>
    <position>x=250:y=225 </position>
    </unit>
    <unit id="2" type="alarm">
    <back-ground>/root/Desktop/image/6.jpg </back-ground>
    <father>root </father>
    <position>x=300:y=270 </position>
    </unit>
    </unit>
    ...............................
    String firstID = tool.getString("unit.unit(0)[@id]");//这里获取的值是1
    String secondID = tool.getString("unit.unit(1)[@id]");//这里获取的值是2
    写操作基本基本更读的代码差不多(请先看上一篇:XMLConfiguration使用手记(1 读)) 只是这里我们用addProperty或setProperty
    config.setProperty("unit.unit(0)[@id]", "0");
    config.setProperty("unit.unit(1)[@id]", "1");
    当然还是更读一样 要首先有个xml文件(空的也可以 但必须有根节点,其他节点会自动生成,当然也可以修改指定节点,方法还是一样的)。
    这里要注意 XMLConfiguration默认情况下以','为分割符如果一个节点值里出现逗号 他会把他分开成两个节点例如:
    config.setProperty("unit.unit", "a,b");
    我们想要的结果是
    ...............................
    <unit>
        a,b
    </unit>
    .....................
    可结果会变成
    ...............................
    <unit>
        a
    </unit>
    <unit>
        b
    </unit>
    .....................
    如果想要使用逗号 可以设置XMLConfiguration的delimiter例如
    XMLConfiguration.setDelimiter(' ');//设置空格为分割符.
    别望了写完save一下.
    config.save();

    September 22

    Quartz调度框架应用总结

    前一段时间项目需要做一个定时发送消息的功能,该功能依附于Web应用上,即当Web应用启动时,该应用就开始作用。起先决定使用java.util.Timerjava.util.TimerTask来实现,但是研究了一下以后发现Java Timer的功能比较弱,而且其线程的范围不受Web应用的约束。后来发现了Quartz这个开源的调度框架,非常有趣。

    首先我们要得到Quartz的最新发布版。目前其最新的版本是1.6。我们可以从以下地址获得它的完整下载包,包中可谓汤料十足,不仅有我们要的quartz.jar,更包含多个例程和详细的文档,从API到配置文件的XSD一应俱全。感兴趣的朋友也可以在src目录下找到该项目的源码一看究竟。

    废话少说,下面就来看一看这个东东是怎么在Java Web Application中得以使用的。

    首先不得不提出的是Quartz的三个核心概念:调度器、触发器、作业。让我们来看看他们是如何工作的吧。

    一.作业总指挥——调度器

    1. Scheduler接口

    该接口或许是整个Quartz中最最上层的东西了,它提携了所有触发器和作业,使它们协调工作。每个Scheduler都存有JobDetailTrigger的注册,一个Scheduler中可以注册多个JobDetail和多个Trigger,这些JobDetailTrigger都可以通过group name和他们自身的name加以区分,以保持这些JobDetailTrigger的实例在同一个Scheduler内不会冲突。所以,每个Scheduler中的JobDetail的组名是唯一的,本身的名字也是唯一的(就好像是一个JobDetailID)。Trigger也是如此。

    Scheduler实例由SchedulerFactory产生,一旦Scheduler实例生成后,我们就可以通过生成它的工厂来找到该实例,获取它相关的属性。下面的代码为我们展示了如何从一个Servlet中找到SchedulerFactory并获得相应的Scheduler实例,通过该实例,我们可以获取当前作业中的testmode属性,来判断该作业是否工作于测试模式。

    //从当前Servlet上下文中查找StdSchedulerFactory

                ServletContext ctx=request.getSession().getServletContext();

                StdSchedulerFactory factory = (StdSchedulerFactory) ctx.getAttribute("org.quartz.impl.StdSchedulerFactory.KEY");

               

                Scheduler sch = null;

                try {

                    //获取调度器

                    sch = factory.getScheduler("SchedulerName");

                    //通过调度器实例获得JobDetail,注意领会JobDetailNameGroupName的用法

                    JobDetail jd=sch.getJobDetail("JobDetailName", "GroupName");

                    Map jobmap1=jd.getJobDataMap();

                    istest=jobmap1.get("testmode")+"";

                } catch (Exception se) {

                    //如果得不到当前作业,则从配置文件中读取testmode

                    ReadXML("job.xml").get(“job.testmode”);

                }

     

    Scheduler实例生成后,它处于"stand-by"模式,需要调用其start方法来使之投入运作。

    public class SendMailShedule{

        //设置标准SchedulerFactory

        static SchedulerFactory schedFact = new org.quartz.impl.StdSchedulerFactory();

        static Scheduler sched;

       

        public static void run()throws Exception{

            //生成Scheduler实例

                 sched = schedFact.getScheduler();

            //创建一个JobDetail实例,对应的Job实现类是SendMailJob

                 JobDetail jobDetail = new JobDetail("myJob",sched.DEFAULT_GROUP,SendMailJob.class);

            //设置CronTrigger,利用Cron表达式设定触发时间

            CronTrigger trigger = new CronTrigger("myTrigger","test","0 0 8 1 * ?");

            sched.scheduleJob(jobDetail, trigger);

            sched.start();