多个实例上的Spring任务和计划任务

Question

我们有一个Spring Boot应用程序，并有计划的任务。

我们希望在多个服务器上部署我们的应用程序，因此将有多个应用程序实例。

如何将 Spring 配置为仅在指定的服务器上运行计划任务？

Answer 1

最好的选择之一-使用带有集群的Quartz调度程序。很简单，只是：

implementation("org.springframework.boot:spring-boot-starter-quartz")

并为带Spring的石英配置作业（请参阅教程）

application.yaml中的群集配置:

spring:
  datasource: ... # define jdbc datasource
  quartz:
    job-store-type: jdbc # Database Mode
    jdbc:
      initialize-schema: never # For clustering do not initialize table structure
    properties:
      org.quartz:
          scheduler:
            instanceId: AUTO #Default hostname and timestamp generate instance ID, which can be any string, but must be the only corresponding qrtz_scheduler_state INSTANCE_NAME field for all dispatchers
            #instanceName: clusteredScheduler #quartzScheduler
          jobStore:
            class: org.quartz.impl.jdbcjobstore.JobStoreTX #Persistence Configuration
            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate #We only make database-specific proxies for databases
            useProperties: true #Indicates that JDBC JobStore stores all values in JobDataMaps as strings, so more complex objects can be stored as name-value pairs rather than serialized in BLOB columns.In the long run, this is safer because you avoid serializing non-String classes to BLOB class versions.
            tablePrefix: QRTZ_  #Database Table Prefix
            misfireThreshold: 60000 #The number of milliseconds the dispatcher will "tolerate" a Trigger to pass its next startup time before being considered a "fire".The default value (if you do not enter this property in the configuration) is 60000 (60 seconds).
            clusterCheckinInterval: 5000 #Set the frequency (in milliseconds) of this instance'checkin'* with other instances of the cluster.Affects the speed of detecting failed instances.
            isClustered: true #Turn on Clustering
          threadPool: #Connection Pool
            class: org.quartz.simpl.SimpleThreadPool
            threadCount: 10
            threadPriority: 5
            threadsInheritContextClassLoaderOfInitializingThread: true

注意initialize模式：永远不要-您需要自己为集群模式初始化它

查看官方脚本： https://github.com/quartz-scheduler/quartz/tree/master/quartz-core/src/main/resources/org/quartz/impl/jdbcjobstore
您可以通过 liquibase/flyway/等使用它，但删除 DROP ... 查询！这就是为什么在集群中我们不会自动初始化架构的原因。

参见quartz文档
参见spring boot文档quartz
查看文章和示例

Answer 2

Spring - ShedLock项目就是专门为实现这一目标而创建的。

依赖性-

<groupId>net.javacrumbs.shedlock</groupId>
<artifactId>shedlock-spring</artifactId>    

配置-

@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")

实施-

@Scheduled(cron = "0 0/15 * * * ?")
@SchedulerLock(name = "AnyUniqueName", 
  lockAtLeastForString = "PT5M", lockAtMostForString = "PT10M")
public void scheduledTask() {
    // ...
}

该设置将确保只有一个实例运行计划任务。

如果您只需要一个特定实例，则应运行调度程序任务，

您需要配置您的调度程序来使用属性文件，并像这样控制调度程序开关

@ConditionalOnProperty(
  value = "scheduling.enabled", havingValue = "true", matchIfMissing = true
)
@Configuration
@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
public class SchedulingConfig {

现在，您需要在 application.properties 文件中为要从中运行 Schedular 的实例提供一个属性调度.enabled = true。

点击此链接以完成实施。

Answer 3

这是一个非常广泛的话题。有很多选择可以实现这一目标。

>

您可以将应用程序配置为具有多个配置文件。例如，使用另一个配置文件“cron”。并使用此配置文件仅在一台服务器上启动应用程序。例如，在一个生产环境中，您有三台服务器（S1、S2、S3），然后您可以在S1上运行prod和cron（-Dspring.profiles.active=prod，cron）。在S2和S3上，只需使用prod profile（-Dspring.profiles.active=prod）。

在代码中，您可以在调度程序类上使用@Profile（“cron”）。这样，它只会在 cron 配置文件处于活动状态时执行

使用分布式锁。如果您的环境中有Zoo将，您可以使用它来实现分布式锁定系统。

您可以使用一些数据库（mysql）并创建一个示例代码来获取其中一个表的锁并添加一个条目。无论哪个实例获得锁，都将在此数据库中创建一个条目并执行cron作业。您需要在代码中进行检查，如果getLock（）成功，则继续执行。MySQL有LOCK TABLES等实用程序，您可以使用它来摆脱并发读/写。

就我个人而言，选项2是最好的。