手动触发 Quartz 作业

Question

我们的应用程序中配置了多个 Quartz 作业。在开发过程中，我们让石英调度程序处于待机状态 - 但是，我们有时想要手动启动作业（出于开发目的）。如果我调用 fireTrigger，它会告诉我需要启动调度程序。但是，如果我启动调度程序，它也会立即调度所有其他作业，这不是我想要的（因为它们可能会在我调试手动触发的作业时触发）。

我可以在启动调度程序时暂停所有触发器，但随后我必须处理失火指令等。

是否有一种简单的方法可以手动启动作业，而无需处理暂停和失火（即即使调度程序处于待机状态也可以工作的 fireTrigger）？

Answer 1

所有在 Quartz Scheduler 中注册的 Job 都由一个由 name 和 group 组成的 JobKey 唯一标识。您可以通过调用调度程序实例的triggerJob(JobKey jobKey) 立即触发具有给定 JobKey 的作业。

// Create a new Job 
JobKey jobKey = JobKey.jobKey("myNewJob", "myJobGroup");
JobDetail job = JobBuilder.newJob(MyJob.class).withIdentity(jobKey).storeDurably().build();

// Register this job to the scheduler
scheduler.addJob(job, true);

// Immediately fire the Job MyJob.class
scheduler.triggerJob(jobKey);

注意：

scheduler 是整个应用程序中使用的调度程序实例。它的 start() 方法应该在创建后就已经被调用了。

该作业是不能附加任何触发器或 cron 的持久作业。它只能通过调用 `triggerJob(JobKey jobKey)` 以编程方式触发。

Answer 2

这是手动触发作业所需的循环：

SchedulerFactory stdSchedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = stdSchedulerFactory.getScheduler();

// loop jobs by group
for (String groupName : scheduler.getJobGroupNames()) {
    // get jobkey
    for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) {
        String jobName = jobKey.getName();
        String jobGroup = jobKey.getGroup();
        scheduler.triggerJob(jobName, jobGroup);
    }
}

Answer 3

不需要start-time 和end-time。

<trigger>
      <cron>
        <name>TestTrigger</name>
        <group>CronSampleTrigger</group>
        <description>CronSampleTrigger</description>
        <job-name>TestJob</job-name>
        <job-group>jobGroup1</job-group>    

    <!--<start-time>1982-06-28T18:15:00.0Z</start-time>
        <end-time>2020-05-04T18:13:51.0Z</end-time>-->

        <cron-expression>0 0/1 * * * ?</cron-expression>
      </cron>
 </trigger>

Answer 4

您可以尝试在调度程序中添加触发器过滤器

this.scheduler.addGlobalTriggerListener(new DebugExecutionFilter());

当执行不是易失性（未计划立即运行）并且您处于调试模式时，调试执行过滤器将添加否决权。

这是一个实现示例：

private static class DebugExecutionFilter implements TriggerListener
{

    public DebugExecutionFilter()
    {
    }

    @Override
    public String getName()
    {
        return "Task execution filter";
    }

    @Override
    public void triggerFired(Trigger trigger, JobExecutionContext context)
    {
        // Do nothing
    }

    /* (non-Javadoc)
     * 
     * @see org.quartz.TriggerListener#vetoJobExecution(org.quartz.Trigger, org.quartz.JobExecutionContext) */
    @Override
    @SuppressWarnings("unchecked")
    /**
     * A veto is added if :
     *  - For non volatile trigger if we are in debug mode
     */
    public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context)
    {

        try
        {
            // 
            if ( !trigger.isVolatile() && isDebugMode() )
            {
                return true;
            }

            //task is run by scheduler.triggerJobWithVolatileTrigger() for immediate schedule
            //or task is schedule and we are not in debugMode
            return false;
    }


    @Override
    public void triggerMisfired(Trigger trigger)
    {
        // do nothing
    }

    @Override
    public void triggerComplete(Trigger trigger, JobExecutionContext context, int triggerInstructionCode)
    {
        // do nothing
    }

}