quartz 创建任务时指定 TriggerState

Quartz 中创建任务时可以通过指定 Trigger 的状态来实现。Trigger 的状态可以是 "NORMAL"、"PAUSED" 或 "COMPLETE"。

在创建 Trigger 时，可以使用以下方法来指定状态：

- TriggerBuilder.withIdentity(name, group).startAt(startTime).withSchedule(SimpleScheduleBuilder.simpleSchedule()).build();

- TriggerBuilder.withIdentity(name, group).startAt(startTime).withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)).build();

在这里,name 和 group 分别为触发器的名称和组,startTime 是触发器开始时间, cronExpression 是 Cron 表达式。

如果要暂停或恢复触发器，可以使用 Scheduler 的 pauseTrigger(TriggerKey triggerKey) 和 resumeTrigger(TriggerKey triggerKey) 方法。

如果要完成触发器,可以使用 Scheduler 的 unscheduleJob(TriggerKey triggerKey) 方法.

相关问题

quartz如何监听TriggerState

Quartz 提供了 TriggerListener 接口，可以通过实现该接口来监听 Trigger 的状态变化。TriggerListener 接口包含了以下几个方法：

1. triggerFired(Trigger trigger, JobExecutionContext context): 当一个 Trigger 触发时，该方法被调用。

2. vetoJobExecution(Trigger trigger, JobExecutionContext context): 在 Job 执行之前，该方法被调用。如果该方法返回 true，Job 将不会执行。

3. triggerMisfired(Trigger trigger): 当一个 Trigger 被错过时，该方法被调用。

4. triggerComplete(Trigger trigger, JobExecutionContext context, Trigger.CompletedExecutionInstruction triggerInstructionCode): 当一个 Trigger 完成时，该方法被调用。其中参数 triggerInstructionCode 可以是一个枚举类型，表示下一步应该执行的指令。

在实现 TriggerListener 接口后，需要将其注册到 Quartz 调度器中，以便监听 Trigger 状态的变化。

示例代码如下：

public class MyTriggerListener implements TriggerListener {

    @Override
    public String getName() {
        return "MyTriggerListener";
    }

    @Override
    public void triggerFired(Trigger trigger, JobExecutionContext context) {
        System.out.println("Trigger fired: " + trigger.getKey());
    }

    @Override
    public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context) {
        // 返回 true 表示不执行 Job
        return false;
    }

    @Override
    public void triggerMisfired(Trigger trigger) {
        System.out.println("Trigger misfired: " + trigger.getKey());
    }

    @Override
    public void triggerComplete(Trigger trigger, JobExecutionContext context, Trigger.CompletedExecutionInstruction triggerInstructionCode) {
        System.out.println("Trigger completed: " + trigger.getKey());
    }
}

注册 TriggerListener：

scheduler.getListenerManager().addTriggerListener(new MyTriggerListener());

quartz根据TRIGGER_STATE查询

你可以使用Quartz的JobStore来查询trigger的状态。以下是一个示例查询所有状态为“PAUSED”的trigger的代码片段：

Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
List<TriggerKey> pausedTriggerKeys = new ArrayList<>();

for (String groupName : scheduler.getTriggerGroupNames()) {
    for (TriggerKey triggerKey : scheduler.getTriggerKeys(GroupMatcher.triggerGroupEquals(groupName))) {
        Trigger.TriggerState triggerState = scheduler.getTriggerState(triggerKey);
        if (triggerState == Trigger.TriggerState.PAUSED) {
            pausedTriggerKeys.add(triggerKey);
        }
    }
}

for (TriggerKey triggerKey : pausedTriggerKeys) {
    System.out.println("Paused Trigger Key: " + triggerKey);
}

这将遍历Quartz Scheduler中的所有trigger，获取每个trigger的状态，并将状态为“PAUSED”的trigger的TriggerKey添加到pausedTriggerKeys列表中。最后，你可以遍历pausedTriggerKeys并打印出每个trigger的key。

你也可以使用其他TriggerState枚举值来查询不同状态的trigger，例如Trigger.TriggerState.BLOCKED来查询状态为“BLOCKED”的trigger。