如何限制Spring Batch Job同时运行多个实例

以下是3种可直接落地的实现方案，可根据你的部署场景、业务需求选择：

方案1：使用Spring Batch原生校验机制（适用单机/集群通用场景） #

Spring Batch框架本身默认禁止同一Job名称+相同识别参数的实例重复运行，不需要额外引入第三方依赖：

• 在Rest接口触发Job时，传入一个固定的标识参数，比如run.id=1作为Job的识别参数
• 框架会自动校验JOB_INSTANCE系统表中是否存在相同Job名+相同参数的实例，如果当前有运行中的执行记录，会直接抛出JobExecutionAlreadyRunningException
• 你只需要在接口层捕获该异常，直接返回“任务正在运行中，请稍后再试”的响应即可

示例代码片段：

@PostMapping("/triggerYourJob")
public String triggerYourJob() {
    try {
        JobParameters params = new JobParametersBuilder()
                // 固定id作为识别参数，重复触发会被拦截
                .addLong("run.id", 1L) 
                .toJobParameters();
        jobLauncher.run(yourCustomJob, params);
        return "任务启动成功";
    } catch (JobExecutionAlreadyRunningException e) {
        return "任务正在运行，请勿重复触发";
    } catch (Exception e) {
        return "任务启动失败：" + e.getMessage();
    }
}

如果需要支持Job运行成功后下次可重新触发，只需要把run.id的值替换为自增数值即可，比如用数据库/Redis存储当前id值，每次Job运行成功后id+1，仅当实例运行中时相同id会被拦截。

方案2：分布式锁控制（适用集群部署、性能要求高的场景） #

如果你的服务是多节点集群部署，希望减少Spring Batch系统表的查询压力，可搭配分布式锁实现：

• 用Redis、ZooKeeper等组件实现分布式锁，锁的key固定为你的Job名称
• Rest接口收到触发请求后，首先尝试获取锁，获取失败直接返回运行中提示
• 拿到锁之后再执行Job启动逻辑，Job执行完成（成功/失败）之后释放锁
• 必须给锁设置超时时间，避免服务宕机导致锁永久不释放

示例Redis锁伪代码：

@PostMapping("/triggerYourJob")
public String triggerYourJob() {
    String lockKey = "batch:job:yourCustomJob:lock";
    // 锁超时时间根据你的Job最大执行时长调整
    boolean lockSuccess = redisTemplate.opsForValue().setIfAbsent(lockKey, "locked", 60, TimeUnit.MINUTES);
    if (!lockSuccess) {
        return "任务正在运行，请勿重复触发";
    }
    try {
        JobParameters params = new JobParametersBuilder()
                .addLong("timestamp", System.currentTimeMillis())
                .toJobParameters();
        jobLauncher.run(yourCustomJob, params);
        return "任务启动成功";
    } catch (Exception e) {
        return "任务启动失败：" + e.getMessage();
    } finally {
        // 可增加逻辑判断Job确实执行完成再释放锁，也可依赖超时自动释放兜底
        redisTemplate.delete(lockKey);
    }
}

方案3：自定义状态校验（适用有特殊业务逻辑的场景） #

如果上述两种方案不能匹配你的特殊需求，可自行维护Job的运行状态：

• 在数据库或者Redis中存储当前Job的运行状态枚举：运行中/空闲
• Rest接口收到触发请求时先查询状态，如果为运行中直接拒绝请求
• Job启动前将状态修改为运行中，Job执行完成（成功/失败）后改回空闲，同样需要增加超时兜底机制，避免服务异常中断导致状态一直为运行中

内容的提问来源于stack exchange，提问作者Srinivas Atluri