Quarkus多Pod场景下定时任务单Pod执行方案咨询

为什么concurrentExecution = SKIP无效 #

concurrentExecution = SKIP仅作用于单个应用实例内部，用来控制同一定时任务是否允许并发执行——当任务还在运行时，跳过下一次触发。它完全不涉及多实例之间的调度控制，所以对你的场景不起作用。

解决方案：启用Quarkus调度器的集群模式 #

Quarkus调度器支持集群化部署，通过分布式锁机制确保同一时间只有一个Pod执行定时任务，主要有两种实现方案：

1. 基于数据库的分布式锁（适合已有数据库的场景） #

• 添加JDBC调度器扩展依赖：

  <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-scheduler-jdbc</artifactId>
  </dependency>
  

• 确保所有Pod连接同一个数据库实例，然后在定时任务方法上添加@Clustered注解：

  import io.quarkus.scheduler.Scheduled;
  import io.quarkus.scheduler.clustered.Clustered;
  
  @ApplicationScoped
  public class MyScheduledTask {
  
      @Clustered
      @Scheduled(every = "10m")
      public void executeTask() {
          // 编写你的定时任务逻辑
      }
  }
  

• 工作原理：Quarkus会自动在数据库中创建锁表（默认表名quarkus_scheduler_locks），每次任务触发时，只有成功获取锁的Pod会执行任务，其他Pod会自动跳过。

2. 基于Redis的分布式锁（适合Redis集群场景） #

• 添加Redis调度器扩展依赖：

  <dependency>
      <groupId>io.quarkus</groupId>
      <artifactId>quarkus-scheduler-redis</artifactId>
  </dependency>
  

• 配置所有Pod指向同一个Redis实例/集群，同样在定时任务方法上添加@Clustered注解：

  @ApplicationScoped
  public class MyScheduledTask {
  
      @Clustered
      @Scheduled(every = "10m")
      public void executeTask() {
          // 编写你的定时任务逻辑
      }
  }
  

• 工作原理：借助Redis的分布式锁特性，确保同一时间只有一个Pod能获取锁并执行任务。

额外配置注意事项 #

• 建议显式设置集群ID，避免不同集群的应用相互干扰：

  quarkus.scheduler.cluster.id=my-app-scheduler-cluster
  

• 使用数据库锁时，需确保数据库用户具备表创建权限，Quarkus初始化时会自动生成锁表结构。

内容的提问来源于stack exchange，提问作者Divya K