手动触发 Quartz 作业

Question

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

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

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

Answer 1

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

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 2

所有在 Quartz Scheduler 中注册的 Job 都由 JobKey 唯一标识，JobKey 由名称和组组成。您可以通过调用 Scheduler 实例的 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 是整个应用程序中使用的 Scheduler 实例。它的 start() 方法应该在创建后就已经被调用。

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

Answer 3

你可以尝试在你的调度程序中添加一个触发过滤器，

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
    }

}

Answer 4

不需要开始时间和结束时间。

<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>