Activiti多实例运行：K8s扩缩容下定时任务重复触发与分布式锁方案

1. 扩缩容时是否会出现重复触发？ #

会。Activiti默认的JobExecutor是每个节点独立轮询数据库的ACT_RU_JOB表，当集群存在多节点（包括扩缩容新增/移除节点的过程），多个JobExecutor可能同时抢占同一个定时任务或触发器任务，导致重复执行。数据库层面的乐观锁（REV_版本号）无法完全避免高并发下的抢任务场景。

2. Activiti是否内置相关机制？ #

分版本情况：

• Activiti 7及以上：内置了分布式JobExecutor，支持基于Zookeeper或Redis的集群协调，能通过分布式锁机制确保同一任务仅被一个节点执行，无需自行实现。
• Activiti 5.x及更早版本：默认无分布式集群支持，需要自行处理重复触发问题。

3. 实现方案与建议 #

方案一：使用Activiti内置分布式JobExecutor（推荐） #

如果使用Activiti 7，直接配置集群化JobExecutor即可：

1. 选择Zookeeper或Redis作为协调器（以Redis为例）
2. 在配置文件中添加：

   activiti:
     job-executor:
       enabled: true
       cluster:
         type: redis
         redis:
           host: your-redis-host
           port: 6379
           password: your-redis-password # 若有密码
   

3. 原理：集群协调器会统一调度任务分配，通过分布式锁确保同一时间仅一个节点的JobExecutor处理特定任务，从根源避免重复触发。

方案二：自定义分布式锁（针对旧版本或无法使用内置集群的场景） #

基于Redis实现分布式锁

利用Redis的SETNX命令实现排他锁，锁键绑定任务ID，避免不同任务冲突：

@Autowired
private StringRedisTemplate redisTemplate;

private static final String LOCK_PREFIX = "activiti:job:lock:";
private static final long LOCK_EXPIRE = 30; // 锁过期时间（秒，根据任务执行时长调整）

public boolean tryAcquireLock(String jobId) {
    String lockKey = LOCK_PREFIX + jobId;
    // 原子性设置锁，避免并发问题
    return Boolean.TRUE.equals(redisTemplate.opsForValue()
            .setIfAbsent(lockKey, InetAddress.getLocalHost().getHostName(), LOCK_EXPIRE, TimeUnit.SECONDS));
}

public void executeJob(String jobId) {
    if (!tryAcquireLock(jobId)) {
        // 未抢到锁，直接返回，由其他节点处理
        return;
    }
    try {
        // 执行Activiti任务逻辑
        managementService.executeJob(jobId);
    } finally {
        // 释放锁
        redisTemplate.delete(LOCK_PREFIX + jobId);
    }
}

注意：若任务执行时间可能超过锁过期时间，需添加锁续期逻辑（比如用定时线程每隔10秒刷新锁的过期时间）。

基于数据库实现分布式锁

利用数据库行级锁或唯一约束实现：

1. 行级锁方式：查询任务时加排他锁，跳过已被锁定的任务

   SELECT * FROM ACT_RU_JOB 
   WHERE ID_ = #{jobId} AND LOCK_OWNER_ IS NULL 
   FOR UPDATE SKIP LOCKED;
   

   查询成功后，更新LOCK_OWNER_为当前节点ID，执行完成后清空该字段。
2. 唯一约束方式：创建锁表ACT_LOCK_JOB，字段JOB_ID（唯一键）、LOCK_TIME、NODE_ID，执行任务前尝试插入记录：

   INSERT INTO ACT_LOCK_JOB (JOB_ID, LOCK_TIME, NODE_ID)
   VALUES (#{jobId}, NOW(), #{nodeId})
   ON DUPLICATE KEY UPDATE LOCK_TIME = NOW();
   

   插入成功则获取锁，失败则放弃执行。

K8s部署额外建议 #

• 扩缩容时配置优雅停机钩子，避免节点停止过程中抢任务：

  spec:
    containers:
    - name: activiti-service
      lifecycle:
        preStop:
          exec:
            command: ["/bin/sh", "-c", "curl -X POST http://localhost:8080/activiti/api/job-executor/stop"]
  

• 合理设置定时任务的执行间隔，避免短时间内大量任务堆积加剧锁竞争。

内容的提问来源于stack exchange，提问作者Din Reddy