java - 在运行时重新调度 Quartz

Question

我们是我项目中的 Quartz 新手，正在编写我们的第一个 Quartz 任务。我们的任务正在运行，但显然我们想了解如何管理它们。我们在 Spring 中像这样配置它们:

<bean name="enoteExpirationTask"    class="org.springframework.scheduling.quartz.JobDetailBean">
    <property name="jobClass" value="gov.usdoj.afms.enote.job.DailyExpirationJob" />
    <property name="jobDataAsMap">
        <map>
            <entry key="messageService" value-ref="enoteMessageService" />
            <entry key="logicalDeleteAge" value="${expiryProcess.logical.age}" />
            <entry key="physicalDeleteAge" value="${expiryProcess.physical.age}" />
        </map>
    </property>
</bean>
<bean id="cronEnoteExpirationTaskTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="enoteExpirationTask" />
    <property name="cronExpression" value="0 0 7 * * ?" />
</bean>

问题 1:我可以让 Quartz 重新读取这个配置，这样如果我在运行时改变它，它就会改变它的调度吗？这将是最简单的解决方案，但我们没有看到任何东西。我希望我们错过了什么。

问题 2:如果没有，我知道应该有第三方工具可以做到这一点，Teracotta 就是其中之一。是否有任何开源或免费软件实用程序可以让您非常简单地更改日程安排？

问题 3:如果不是，编写一个小的 Java 实用程序来完成它涉及什么？值得写一个吗？或者 Teracotta 是否有足够的附加值，您会推荐购买它？如果是这样，我可以卖给管理层的功能有哪些不同？

Answer 1

我的实现(Spring 3.0.6，Quartz 2.2.1):

public interface SchedulerService {

    void register( Class<? extends Job> jobClass, String cronExpression );

    void reschedule( Class<? extends Job> jobClass, String cronExpression );

}

@Service
public class SchedulerServiceImpl implements SchedulerService {

    private Scheduler scheduler;

    @PostConstruct
    void init() {
        try {
            scheduler = StdSchedulerFactory.getDefaultScheduler();
            scheduler.start();
        } catch ( Exception e ) {
            // handle exception
        }
    }

    @PreDestroy
    void destroy() {
        try {
            scheduler.shutdown();
        } catch ( Exception e ) {
            // handle exception
        }
    }

    @Override
    public void register( Class<? extends Job> jobClass, String cronExpression ) {
        try {
            String name = jobClass.getSimpleName();
            CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule( cronExpression );

            JobDetail jobDetail = JobBuilder.newJob( jobClass ).withIdentity( name ).build();
            CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity( name ).withSchedule( cronScheduleBuilder ).build();

            scheduler.scheduleJob( jobDetail, cronTrigger );
        } catch ( Exception e ) {
            // handle exception
        }
    }

    @Override
    public void reschedule( Class<? extends Job> jobClass, String cronExpression ) {
        try {
            String name = jobClass.getSimpleName();
            CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule( cronExpression );

            CronTrigger newCronTrigger = TriggerBuilder.newTrigger().withIdentity( name ).withSchedule( cronScheduleBuilder ).build();

            scheduler.rescheduleJob( TriggerKey.triggerKey( name ), newCronTrigger );
        } catch ( Exception e ) {
            // handle exception
        }
    }

}

使用示例:

@Service
public class MyServiceImpl implements MyService {

    @Autowired
    SchedulerService schedulerService;

    @PostConstruct
    void init() {
        schedulerService.register( MyJob.class, "0 10 * * * ?" );
    }

    @Override
    public void reschedule( String cronExpression ) {
        schedulerService.reschedule( MyJob.class, cronExpression );
    }

    @DisallowConcurrentExecution
    public static class MyJob implements Job {

        @Override
        public void execute( JobExecutionContext context ) throws JobExecutionException {
            // ...
        }

    }

}