zoukankan      html  css  js  c++  java
  • quartz的使用 Mr

    quartz.properties

    #---------调度器属性----------------
    org.quartz.scheduler.instanceName = TestScheduler
    org.quartz.scheduler.instanceId = one
    #---------线程配置---------------
    org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
    org.quartz.threadPool.threadCount = 2
    org.quartz.threadPool.threadPriority = 4
    #---------作业存储设置------------
    org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
    #---------插件配置-------------
    org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.JobInitializationPlugin
    org.quartz.plugin.jobInitializer.fileName = quartz_job.xml
    org.quartz.plugin.jobInitializer.overWriteExistingJobs = false
    org.quartz.plugin.jobInitializer.failOnFileNotFound = true
    
    org.quartz.plugin.shutdownhook.class = org.quartz.plugins.management.ShutdownHookPlugin
    org.quartz.plugin.shutdownhook.cleanShutdown = true
    

     quartz_job.xml

    <?xml version="1.0" encoding="UTF-8"?>
    <quartz>
    <!-- 报表生成 -->
        <job>
            <job-detail>
                <name>ReportGenerate</name>
                <group>ReportGenerateGroup</group>
                <job-class>com.ultrapower.weekly.job.ReportGenerateJob</job-class>
            </job-detail>
            <trigger>
                <cron>
                    <name>Job_ReportGenerate</name>
                    <group>Job_ReportGenerateGroup</group>
                    <job-name>ReportGenerate</job-name>
                    <job-group>ReportGeneratetGroup</job-group>
                    <cron-expression>0 0 1 ? * ? *</cron-expression>
                </cron>
            </trigger>
        </job>
    </quartz>

    java代码

    package com.ultrapower.weekly.job;
    
    import java.io.File;
    import java.sql.ResultSet;
    import java.sql.ResultSetMetaData;
    import java.sql.SQLException;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    import org.jdom.Element;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    
    import com.ultrapower.weekly.bean.Data;
    import com.ultrapower.weekly.bean.ReportGenerate;
    import com.ultrapower.weekly.bean.Template;
    import com.ultrapower.weekly.servlet.Constants;
    import com.ultrapower.weekly.util.DataAdapter;
    import com.ultrapower.weekly.util.StringUtil;
    import com.ultrapower.weekly.util.XMLAnalyse;
      
    /**     
     * xml报表自动生成执行类 ,该类在初始化时调用,定时调用
     * @author zhangxuegang       
     * @version 1.0     
     * @created 2012-7-31 下午01:59:02    
     */
    
    public class ReportGenerateJob {
          
        /**     
         * 定时器默认执行方法 
         * @param context
         * @throws JobExecutionException     
         */
        public void execute(JobExecutionContext context) throws JobExecutionException {
            String configReportPath = Constants.rootPath+"WebRoot" + File.separator + "templete" + File.separator + "config" + File.separator + "报表生成.xml";
            ReportGenerateJob reg  = new ReportGenerateJob();
            reg.reportGernerate(configReportPath);
        }
        
        /**     
         * 报表生成
         * @param configReportPath     
         */
        
        public void reportGernerate(String configReportPath){
            XMLAnalyse configAnalyse = new XMLAnalyse(configReportPath);
            //业务数据配置
            List<Element> dataElements = configAnalyse.getElementList("BusinessData");
            Map<String,Data> allData = new HashMap<String,Data>();
            for (int j = 0; j < dataElements.size(); j++) {
                Element element = dataElements.get(j);
                ReportGenerate reportGenerate = new ReportGenerate();
                reportGenerate.setSqlStr(element.getChildText("SheetSql"));
                //fileName
                reportGenerate.setFileName(element.getName());
                //sheetName
                reportGenerate.setSheetName(element.getChildText("SheetName"));
                //sheetTime
                reportGenerate.setSheetTime(element.getChildText("SheetTime"));
                DataAdapter dataAdapter = new DataAdapter();
                ResultSet rs=dataAdapter.executeQuery(reportGenerate.getSqlStr());
                
                try {
                    ResultSetMetaData metaData = rs.getMetaData();
                    while(rs.next()){
                        for (int i = 0; i < metaData.getColumnCount(); i++) {
                            String result = StringUtil.Obj2Str(rs.getString(i+1),"");
                  //excel写入操作...
                  System.out.println(result);
    } } }
    catch (SQLException e) { e.printStackTrace(); } } } }

     意义说明:

    [java]
    package com.test; 
     
    import org.quartz.Job; 
    import org.quartz.JobExecutionContext; 
    import org.quartz.JobExecutionException; 
     
    public class CallGirl implements Job { 
         
        public void execute(JobExecutionContext context) 
                throws JobExecutionException { 
            System.out.println("正在打电话给女友..."); 
            System.out.println("getTrigger().getName():" 
                    + context.getTrigger().getName()); 
     
        } 

    [java]
    package com.test; 
     
    import java.text.ParseException; 
    import java.util.Date; 
     
    import org.quartz.CronTrigger; 
    import org.quartz.JobDetail; 
    import org.quartz.Scheduler; 
    import org.quartz.SchedulerException; 
    import org.quartz.SimpleTrigger; 
    import org.quartz.impl.StdSchedulerFactory; 
     
    public class QuartzMainer { 
        public static void main(String[] args) throws SchedulerException, 
                ParseException { 
     
            Scheduler handsomeMan = new StdSchedulerFactory().getScheduler(); 
     
            // CallGirl.class 回调类 
            JobDetail concerneGirl = new JobDetail("任务的名称", "group1", 
                    CallGirl.class); 
            JobDetail tt = new JobDetail("任务的名称1", "group2", CallGirl.class); 
     
            // 10 重复次数,2000L 周期 
            SimpleTrigger momentTrigger = new SimpleTrigger("trigger1", "group1", 
                    new Date(), null, 10, 1000L); 
     
            CronTrigger t = new CronTrigger("trigger2", "group2", 
                    "0 24 13 * * ? * "); 
     
            // way 2 
            // 若时间到,即使重复100000000次也没有用 
            long startTime = System.currentTimeMillis(); 
            SimpleTrigger momentTrigger2 = new SimpleTrigger("trigger2", "group1"); 
            momentTrigger2.setStartTime(new Date(startTime)); 
            momentTrigger2.setEndTime(new Date(startTime + 6000L)); 
            momentTrigger2.setRepeatCount(10); 
            momentTrigger2.setRepeatInterval(1000L); 
     
            // 帅哥通过时刻Trigger来调度关心女友这个job 
            handsomeMan.scheduleJob(concerneGirl, momentTrigger); 
            handsomeMan.scheduleJob(tt, t); 
     
            // 开始 
            handsomeMan.start(); 
        } 

    CronTrigger配置格式:

    格式: [秒] [分] [小时] [日] [月] [周] [年]

    序号 说明  是否必填  允许填写的值 允许的通配符
     1  秒  是  0-59    , - * /
     2  分  是  0-59   , - * /
     3 小时  是  0-23   , - * /
     4  日  是  1-31   , - * ? / L W
     5  月  是  1-12 or JAN-DEC   , - * /
     6  周  是  1-7 or SUN-SAT   , - * ? / L #
     7  年  否  empty 或 1970-2099  , - * /

    通配符说明:
    * 表示所有值. 例如:在分的字段上设置 "*",表示每一分钟都会触发。
    ? 表示不指定值。使用的场景为不需要关心当前设置这个字段的值。例如:要在每月的10号触发一个操作,但不关心是周几,所以需要周位置的那个字段设置为"?" 具体设置为 0 0 0 10 * ?
    - 表示区间。例如 在小时上设置 "10-12",表示 10,11,12点都会触发。
    , 表示指定多个值,例如在周字段上设置 "MON,WED,FRI" 表示周一,周三和周五触发
    / 用于递增触发。如在秒上面设置"5/15" 表示从5秒开始,每增15秒触发(5,20,35,50)。 在月字段上设置'1/3'所示每月1号开始,每隔三天触发一次。
    L 表示最后的意思。在日字段设置上,表示当月的最后一天(依据当前月份,如果是二月还会依据是否是润年[leap]), 在周字段上表示星期六,相当于"7"或"SAT"。如果在"L"前加上数字,则表示该数据的最后一个。例如在周字段上设置"6L"这样的格式,则表示“本月最后一个星期五"
    W 表示离指定日期的最近那个工作日(周一至周五). 例如在日字段上设置"15W",表示离每月15号最近的那个工作日触发。如果15号正好是周六,则找最近的周五(14号)触发, 如果15号是周未,则找最近的下周一(16号)触发.如果15号正好在工作日(周一至周五),则就在该天触发。如果指定格式为 "1W",它则表示每月1号往后最近的工作日触发。如果1号正是周六,则将在3号下周一触发。(注,"W"前只能设置具体的数字,不允许区间"-").
    小提示 
    'L'和 'W'可以一组合使用。如果在日字段上设置"LW",则表示在本月的最后一个工作日触发(一般指发工资)
    # 序号(表示每月的第几个周几),例如在周字段上设置"6#3"表示在每月的第三个周六.注意如果指定"#5",正好第五周没有周六,则不会触发该配置(用在母亲节和父亲节再合适不过了)
    小提示 
    周字段的设置,若使用英文字母是不区分大小写的 MON 与mon相同.

           
    常用示例:
     
    0 0 12 * * ? 每天12点触发
    0 15 10 ? * * 每天10点15分触发
    0 15 10 * * ? 每天10点15分触发
    0 15 10 * * ? * 每天10点15分触发
    0 15 10 * * ? 2005 2005年每天10点15分触发
    0 * 14 * * ? 每天下午的 2点到2点59分每分触发
    0 0/5 14 * * ? 每天下午的 2点到2点59分(整点开始,每隔5分触发)
    0 0/5 14,18 * * ? 每天下午的 2点到2点59分(整点开始,每隔5分触发)
    每天下午的 18点到18点59分(整点开始,每隔5分触发)
    0 0-5 14 * * ? 每天下午的 2点到2点05分每分触发
    0 10,44 14 ? 3 WED 3月分每周三下午的 2点10分和2点44分触发
    0 15 10 ? * MON-FRI 从周一到周五每天上午的10点15分触发
    0 15 10 15 * ? 每月15号上午10点15分触发
    0 15 10 L * ? 每月最后一天的10点15分触发
    0 15 10 ? * 6L 每月最后一周的星期五的10点15分触发
    0 15 10 ? * 6L 2002-2005 从2002年到2005年每月最后一周的星期五的10点15分触发
    0 15 10 ? * 6#3 每月的第三周的星期五开始触发
    0 0 12 1/5 * ? 每月的第一个中午开始每隔5天触发一次
    0 11 11 11 11 ? 每年的11月11号 11点11分触发(光棍节)

    Mr-sniper
    北京市海淀区
    邮箱:rafx_z@hotmail.com
  • 相关阅读:
    第一节,Django+Xadmin打造上线标准的在线教育平台—创建用户app,在models.py文件生成3张表,用户表、验证码表、轮播图表
    Tensorflow 错误:Unknown command line flag 'f'
    Python 多线程总结
    Git 强制拉取覆盖本地所有文件
    Hive常用函数 傻瓜学习笔记 附完整示例
    Linux 删除指定大小(范围)的文件
    Python 操作 HBase —— Trift Trift2 Happybase 安装使用
    梯度消失 梯度爆炸 梯度偏置 梯度饱和 梯度死亡 文献收藏
    Embedding 文献收藏
    深度学习在CTR预估中的应用 文献收藏
  • 原文地址:https://www.cnblogs.com/rafx/p/quartz.html
Copyright © 2011-2022 走看看