集群环境中的Spring Scheduler

Question

我使用Spring调度程序，使用@调度注释来调度运行文件生成服务的作业。应用程序部署在集群环境中Tomcat的5个单独节点上，用于负载平衡和故障转移。正因为如此，服务被调度了5次，这是不可能的。有没有办法将调度程序配置为仅在当前节点上运行？

有一种方法使用数据库找出当前活动节点，并在这里调用该特定实例的调度器

另一种方法是使用石英调度器

由于我无法对部署的应用程序进行重大更改，是否有简单的解决方案？请告知。

Answer 1

您还可以使用 dlock 在多个节点上仅执行一次计划任务。您可以简单地执行以下操作。

@Scheduled(cron = "30 30 3 * * *")
@TryLock(name = "jobLock", owner = SERVER_NAME, lockFor = THREE_MINUTES)
public void runJobsOnce() {
  List<Job> jobs = jobService.getJobs();
  for(Job job: jobs){
    runJob(job);
  }
}

请参阅有关使用它的文章。

Answer 2

您可以使用ShedLock项目。您只需注释执行时应锁定的任务

@Scheduled( ... )
@SchedulerLock(name = "scheduledTaskName")
public void scheduledTask() {
   // do something
}

配置 Spring 和 LockProvider（目前支持 SQL 和 Mongo）

@Bean
public TaskScheduler taskScheduler(LockProvider lockProvider) {
   return SpringLockableTaskSchedulerFactory
             .newLockableTaskScheduler(poolSize, lockProvider);
}