Quertz 的 CronTrigger配置格式以及實例

CronTrigger配置格式:

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

通配符說明:
* 表示所有值. 例如:在分的字段上設置 "*",表示每一分鐘都會觸發。
? 表示不指定值。使用的場景為不需要關心當前設置這個字段的值。例如:要在每月的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"前只能設置具體的數字,不允許區間"-").

# 序號(表示每月的第幾個周幾)，例如在周字段上設置"6#3"表示在每月的第三個周六.注意如果指定"#5",正好第五周沒有周六，則不會觸發該配置(用在母親節和父親節再合適不過了)

常用示例:

示例代碼：

DistributeJob 類

public class DistributeJob implements Job {

    private final Logger logger = Logger.getLogger(DistributeJob.class);

    private Integer sendsucess = 2;

    private User currentUser;

    private IEpgScheduleService epgschedule;

    private INodeDeviceService node;

    public DistributeJob() {
        init();
    }

    private void init() {
        epgschedule = (IEpgScheduleService) SpringBeanUtil.getInstance()
                .getBean("epgSchduleServiceProxy");
        node = (INodeDeviceService) SpringBeanUtil.getInstance().getBean(
                "nodeDeviceServiceProxy");
        IProgramTransmitInfoService program = (IProgramTransmitInfoService) SpringBeanUtil
                .getInstance().getBean("programTransmitServiceProxy");

    }

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // TODO Auto-generated method stub
        try {
            logger.info("啟動調度工作，開始分發影片...");
            List epgschedults = epgschedule.getEpgScheduleBySendflag(1);
            String distributeAddress = "";
            List nodeControls = node
                    .getDevicesByDeviceType(NodeDeviceType.NODECONTROL);
            for (int i = 0; i < nodeControls.size(); i++) {
                if (i > 0)
                    distributeAddress += ";";
                NodeDevice node = (NodeDevice) nodeControls.get(i);
                distributeAddress += node.getNodeDeviceIpAdress() + ":"
                        + node.getNodeDeviceCmdPort();
            }

            for (Iterator it = epgschedults.iterator(); it.hasNext();) {
                Epgschedule epg = (Epgschedule) it.next();
                int videoId = epg.getVideoInfo().getId().intValue();
                PCCServer pcc = new PCCServer(VodUtil.getLocalHostIP(),
                        MessageDefines.MSG_PCCSERVER_PORT);
                if (pcc.sendProgramDistributeNotice(videoId, distributeAddress)) {
                    epgschedule.updateEpgScheduleSendflag(epg.getId(),
                            sendsucess);
                    StringBuffer log = new StringBuffer("分發影片 /""
                            + epg.getVideoInfo().getVideoNameCh() + "/"成功");
                    logger.info(log);
                    epgschedule.addLog(currentUser, log);
                } else {
                    logger.info("分發影片ID /"" + videoId + "/"失敗...");
                }
            }
        } catch (IOException ex) {
            ex.printStackTrace();
        } catch (ServiceException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public User getCurrentUser() {
        return currentUser;
    }

    public void setCurrentUser(User currentUser) {
        this.currentUser = currentUser;
    }

}



QuartzManager類



public class QuartzManager {

    private static Logger logger=Logger.getLogger(QuartzManager.class);
    private static SchedulerFactory sf = new StdSchedulerFactory();
    private static String JOB_GROUP_NAME = "group1";
    private static String TRIGGER_GROUP_NAME = "trigger1";

    public static void addJob(String jobName, Job job, String time)
            throws SchedulerException, ParseException {

        String cronExpression = "0 0 12 ? * WEB";

        Scheduler sched = sf.getScheduler();
        JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, job
                .getClass());// 任務名，任務組，任務執行類
        // 觸發器
        CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME,
                cronExpression);// 觸發器名,觸發器組

        sched.scheduleJob(jobDetail, trigger);
        // 啟動
        if (!sched.isShutdown())
            sched.start();
    }

     public static void addJob(String jobName, String jobGroupName,
            String triggerName, String triggerGroupName, Job job, String time)
            throws SchedulerException, ParseException {
        logger.info("啟動了"+jobName+"調度器");
        Scheduler sched = sf.getScheduler();
        JobDetail jobDetail = new JobDetail(jobName, jobGroupName, job
                .getClass());// 任務名，任務組，任務執行類
        // 觸發器
        CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName,time);// 觸發器名,觸發器組
        //trigger.setCronExpression(time);// 觸發器時間設定
        sched.scheduleJob(jobDetail, trigger);
        if (!sched.isShutdown())
            sched.start();
    }

     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);// 刪除任務
    }

    public static void removeJob(String jobName, String jobGroupName,
            String triggerName, String triggerGroupName)
            throws SchedulerException {
        logger.info("移除了"+jobName+"調度器");
        Scheduler sched = sf.getScheduler();
        sched.pauseTrigger(triggerName, triggerGroupName);// 停止觸發器
        sched.unscheduleJob(triggerName, triggerGroupName);// 移除觸發器
        sched.deleteJob(jobName, jobGroupName);// 刪除任務
    }

}





調用處：

            // 增加按時間分發影片調度
            DistributeJob disjob = new DistributeJob();
            disjob.setCurrentUser(getCurrentUser(request));
            StringBuffer cronExpression = new StringBuffer();         
            String[] times = transmitTime.split(":");
            cronExpression.append(times[2] + " " + times[1] + " " + times[0]
                    + " * * ?");
            QuartzManager.addJob(jobName, jobGroupName, triggerName,
                    triggerGroupName, disjob, cronExpression.toString());