如何在Spring Boot应用程序中测试Quartz作业的正常工作

Question

我想测试我的石英触发器是否在实践中像它假设的那样工作。我的石英配置如下所示：

@Configuration
public class QuartzConfiguration {

  @Bean
  public JobDetail verificationTokenRemoverJobDetails() {
    return
        JobBuilder
            .newJob(VerificationTokenQuartzRemoverJob.class)
            .withIdentity("Job for verification token remover")
            .storeDurably()
            .build();
  }

  @Bean
  public Trigger verificationTokenRemoverJobTrigger(JobDetail jobADetails) {
    return
        TriggerBuilder
            .newTrigger()
            .forJob(jobADetails)
            .withIdentity("Trigger for verification token remover")
            .withSchedule(CronScheduleBuilder.cronSchedule("0 0 0/2 1/1 * ? *"))
            .build();
  }
}

我的工作类看起来像：

@AllArgsConstructor
public class VerificationTokenQuartzRemoverJob implements Job {

  private VerificationTokenRepository verificationTokenRepository;

  @Override
  public void execute(JobExecutionContext context) {
    verificationTokenRepository.deleteAllByCreatedLessThan(LocalDateTime.now().minusMinutes(30));
  }
}

当我在日志中启动Spring Boot应用程序时，我可以意识到作业正在工作并周期性触发，但这不足以确认正确的工作。

这就是为什么我决定创建一个JUnit测试。我发现了一个教程:点击但是一个所有者使用了一个子句while(true ),根据这个主题:点击不是一个更可取的选项。这里出现了一个问题，是否有其他选项来验证作业类名、触发器的身份并检查CRON表达式和具体的作业是否被尽可能频繁地调用？

如果可能的话，我将非常感谢关于如何达到理想效果的建议。

Answer 1

使用SpringBoot，您可以更轻松地执行以下操作

---选项1---

@Configuration
// This is important!
@EnableScheduling
public class Configuration{
 // TODO Change to 0 0 0/2 1/1 * ? *
 @Scheduled(cron = "0 15 10 15 * ?")
 public void scheduleTaskUsingCronExpression() {

    long now = System.currentTimeMillis() / 1000;
     System.out.println(
        "schedule tasks using cron jobs - " + now);
  }      

}

完整示例：https://www.baeldung.com/spring-scheduled-tasks

---选项2-

@Configuration
@EnableScheduling

public class Configuration implements SchedulingConfigurer {
   @Bean(destroyMethod = "shutdown")
   public Executor taskExecutor() {
      return Executors.newScheduledThreadPool(100);
   }

    @Override
            public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
            CronTrigger cronTrigger
            = new CronTrigger("* * * * * *");

                    taskRegistrar.setScheduler(taskExecutor());
                    taskRegistrar.addTriggerTask(
                            new Runnable() {
                                @Override public void run() {
                                    System.out.println("RUN!!!");
                                }
                            },
                            cronTrigger
                    );
                }

}

Answer 2

请不要说上面关于使用Spring调度的答案有一个很大的缺点：如果您只运行应用程序的单个实例，这会很好地工作，但是一旦您扩展到多个实例，它就变得更加复杂：您可能希望在一定的时间间隔内只运行一次作业，但是如果两个节点同时运行，作业可能会在两个节点上运行（所以基本上是两次）。Quartz可以处理这种情况，因为它可以有一个中央数据库，如果作业已经启动，它可以通过该数据库进行协调。使用Spring调度，作业将在两个节点上运行。