Quartz 是一个 Java 库,用于在应用程序中执行定时任务。要实现 Quartz 表达式的动态调度,你需要遵循以下步骤:
- 添加 Quartz 依赖项
在你的项目中添加 Quartz 库的依赖项。如果你使用 Maven,可以在 pom.xml
文件中添加以下依赖项:
org.quartz-scheduler quartz 2.3.2
- 创建 Job 类
创建一个实现 org.quartz.Job
接口的类。这个类将包含要执行的任务逻辑。例如:
import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class MyJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("Hello, Quartz!"); } }
- 配置 Scheduler
创建一个 org.quartz.Scheduler
实例,并配置相关参数。例如:
import org.quartz.Scheduler; import org.quartz.SchedulerFactory; import org.quartz.impl.StdSchedulerFactory; public class QuartzScheduler { private static Scheduler scheduler; public static void init() throws Exception { SchedulerFactory schedulerFactory = new StdSchedulerFactory(); scheduler = schedulerFactory.getScheduler(); scheduler.start(); } public static void main(String[] args) throws Exception { init(); } }
- 动态调度任务
在需要动态调度任务的地方,使用 scheduler.scheduleJob()
方法来调度任务。例如:
import org.quartz.*; public class DynamicScheduler { public static void scheduleJob(String cronExpression) throws Exception { // 创建 JobDetail JobDetail jobDetail = JobBuilder.newJob(MyJob.class) .withIdentity("myJob", "group1") .build(); // 创建 Trigger Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("myTrigger", "group1") .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)) .build(); // 调度任务 QuartzScheduler.scheduler.scheduleJob(jobDetail, trigger); } public static void main(String[] args) throws Exception { QuartzScheduler.init(); String cronExpression = "0/5 * * * * ?"; // 每 5 秒执行一次 scheduleJob(cronExpression); } }
在这个例子中,我们创建了一个名为 DynamicScheduler
的类,其中包含一个 scheduleJob()
方法。这个方法接受一个 cron 表达式作为参数,并使用该表达式创建一个新的 Trigger。然后,我们使用 scheduler.scheduleJob()
方法将任务添加到调度器中。
现在,你可以根据需要动态地调度任务,只需传入不同的 cron 表达式即可。