package org.fh.util; import java.util.Map; import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.Job; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; import org.quartz.SchedulerFactory; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; import org.quartz.impl.StdSchedulerFactory;
/ * *
FH Admin from: fhadmin.org */ public class QuartzManager {
private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory(); // Create a SchedulerFactory factory instance private static String JOB_GROUP_NAME = “FH_JOBGROUP_NAME”; Private static String TRIGGER_GROUP_NAME = “fh_group_name “; // Trigger group
/** Add a scheduled task, using the default task group name, trigger name, trigger group name
- @param jobName Specifies the task name
- @ param CLS task
- @param time Time Settings. Refer to the Quartz documentation
*/ public static void addJob(String jobName, Class
cls, String time) { try { Scheduler sched = gSchedulerFactory.getScheduler(); // Use the SchedulerFactory to build the Scheduler object JobDetail JobDetail = JobBuilder.newJob(cls).withIdentity(jobName,JOB_GROUP_NAME).build(); // Static information for Job implementation classes and others, CronTrigger Trigger = (CronTrigger) triggerBuilder.newTrigger () // Create a new TriggerBuilder to normalize a trigger .withIdentity(jobName, TRIGGER_GROUP_NAME) / / to trigger a name and group name. The withSchedule (CronScheduleBuilder. CronSchedule (time). The build (); sched.scheduleJob(jobDetail, trigger); if (! sched.isShutdown()) { sched.start(); }} catch (Exception e) {throw new RuntimeException(e); }}
/** Add a scheduled task using the default task group name, trigger name, trigger group name (with parameters)
- @param jobName Specifies the task name
- @ param CLS task
- @param time Time Settings. Refer to the Quartz documentation
*/ public static void addJob(String jobName, Class
cls, String time, Map
parameter) { try { Scheduler sched = gSchedulerFactory.getScheduler(); // Use the SchedulerFactory to build the Scheduler object JobDetail JobDetail = JobBuilder.newJob(cls).withIdentity(jobName,JOB_GROUP_NAME).build(); Jobdetail.getjobdatamap ().put(“parameterList”, parameter); jobdetail.getJobDatamap ().put(“parameterList”); CronTrigger Trigger = (CronTrigger) triggerBuilder.newTrigger () // Create a new TriggerBuilder to normalize a trigger .withIdentity(jobName, TRIGGER_GROUP_NAME) / / to trigger a name and group name. The withSchedule (CronScheduleBuilder. CronSchedule (time). The build (); sched.scheduleJob(jobDetail, trigger); if (! sched.isShutdown()) { sched.start(); }} catch (Exception e) {throw new RuntimeException(e); }}
/** Add a scheduled task
- @param jobName Specifies the task name
- @param jobGroupName Specifies the task group name
- @param triggerName triggerName
- @param triggerGroupName triggerGroupName
- @ param jobClass task
- @param time Time Settings. Refer to the Quartz documentation
*/ public static void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class
jobClass, String time) { try { Scheduler sched = gSchedulerFactory.getScheduler(); JobDetail jobDetail= JobBuilder.newJob(jobClass).withIdentity(jobName,jobGroupName).build(); // Task name, task group, CronTrigger trigger = (CronTrigger) TriggerBuilder // trigger.newtrigger ().withidentity (triggerName, triggerGroupName) .withSchedule(CronScheduleBuilder.cronSchedule(time)) .build(); sched.scheduleJob(jobDetail, trigger); if (! sched.isShutdown()) { sched.start(); }} catch (Exception e) {throw new RuntimeException(e); }}
/** Add a scheduled task (with parameters)
- @param jobName Specifies the task name
- @param jobGroupName Specifies the task group name
- @param triggerName triggerName
- @param triggerGroupName triggerGroupName
- @ param jobClass task
- @param time Time Settings. Refer to the Quartz documentation
*/ public static void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class
jobClass, String time, Map
parameter) { try { Scheduler sched = gSchedulerFactory.getScheduler(); JobDetail jobDetail= JobBuilder.newJob(jobClass).withIdentity(jobName,jobGroupName).build(); GetJobDataMap (). Put (“parameterList”, parameter); // Task name, task group, task execution class jobdetail.getJobDatamap (). // CronTrigger trigger = (CronTrigger) TriggerBuilder // trigger.newtrigger ().withidentity (triggerName, triggerGroupName) .withSchedule(CronScheduleBuilder.cronSchedule(time)) .build(); sched.scheduleJob(jobDetail, trigger); if (! sched.isShutdown()) { sched.start(); }} catch (Exception e) {throw new RuntimeException(e); }}
/** Change the trigger time of a task (use the default task group name, trigger name, trigger group name)
- @param jobName Specifies the task name
- @param time New time setting
*/ public static void modifyJobTime(String jobName, String time) { try { Scheduler sched = gSchedulerFactory.getScheduler(); TriggerKey = triggerKey. TriggerKey (jobName,TRIGGER_GROUP_NAME); // Get TriggerKey CronTrigger trigger = (CronTrigger)sched.getTrigger(TriggerKey); // Get CronTrigger from TriggerKey if (trigger == null) {return; } String oldTime = trigger.getCronExpression(); if (! oldTime.equalsIgnoreCase(time)) { JobKey jobKey = JobKey.jobKey(jobName, JOB_GROUP_NAME); JobDetail = sched.getJobDetail(JobKey); Class
objJobClass = jobDetail.getJobClass(); removeJob(jobName); addJob(jobName, objJobClass, time); } } catch (Exception e) { throw new RuntimeException(e); }}
/** Change the trigger time of a task
- @param triggerName Task name
- @param triggerGroupName The task name that is passed
- @param time Updated time rule
*/ public static void modifyJobTime(String triggerName, String triggerGroupName, String time) { try { Scheduler sched = gSchedulerFactory.getScheduler(); / / by SchedulerFactory construct objects Scheduler TriggerKey TriggerKey = TriggerKey. TriggerKey (triggerName, triggerGroupName); // Get TriggerKey CronTrigger trigger = (CronTrigger)sched.getTrigger(TriggerKey); // Get CronTrigger if (trigger == null) return by TriggerKey; CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(trigger.getCronExpression()); String oldTime = trigger.getCronExpression(); if (! OldTime. EqualsIgnoreCase (time)) {trigger = (CronTrigger) trigger. GetTriggerBuilder ()/page/rebuild the trigger .withIdentity(triggerKey) .withSchedule(scheduleBuilder) .withSchedule(CronScheduleBuilder.cronSchedule(time)) .build(); sched.rescheduleJob(triggerKey, trigger); }} Catch (Exception e) {throw new RuntimeException(e); }}
/** Remove a task (use the default task group name, trigger name, trigger group name)
- @param jobName Indicates the task name
*/ public static void removeJob(String jobName) { try { Scheduler sched = gSchedulerFactory.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(jobName,www.pizei.comTRIGGER_GROUP_NAME); JobKey JobKey = jobkey. JobKey (jobName, JOB_GROUP_NAME); // Get JobKey sched.pauseTrigger(triggerKey) by task name and group name; // Stop trigger sched.unscheduleJob(triggerKey); // Remove trigger sched.deleteJob(jobKey); } catch (Exception e) {throw new RuntimeException(e); }}
/** Remove a task
- @param jobName Specifies the task name
- @param jobGroupName Specifies the task group name
- @param triggerName triggerName
- @param triggerGroupName triggerGroupName
*/ public static void removeJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName) { try { Scheduler sched = gSchedulerFactory.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(triggerName,triggerGroupName); JobKey = jobkey. JobKey (jobName, jobGroupName); // Get JobKey sched.pauseTrigger(triggerKey) by task name and group name; // Stop trigger sched.unscheduleJob(triggerKey); // Remove trigger sched.deleteJob(jobKey); } catch (Exception e) {throw new RuntimeException(e); }}
/ * *
- Example Start all scheduled tasks
If relative electron has more intuitive understanding, it can also refer to its format as follows:
www.pizei.com */ public static void startJobs() { try { Scheduler sched = gSchedulerFactory.getScheduler(); sched.start(); } catch (Exception e) { throw new RuntimeException(e); }} 2. Create a new pager database
/ * *
- None example Disable all scheduled tasks
*/ public static void shutdownJobs() { try { Scheduler sched = gSchedulerFactory.getScheduler(); if (! sched.isShutdown()) { sched.shutdown(); } } catch (Exception e) { throw new RuntimeException(e); }}}