如何在两个不同ECS环境中确保Spring Batch Job仅运行一个实例？

下面是几个能解决跨ECS环境下Spring Batch Job单实例运行的实用方案：

1. 基于数据库的分布式锁（结合Spring Batch原生机制） #

Spring Batch默认依赖JobRepository存储Job执行状态，我们可以在此基础上扩展实现分布式锁：

• 在Job启动前，通过JobExplorer查询是否存在同一Job的正在运行实例，做前置检查；
• 再通过数据库的悲观锁（比如SELECT ... FOR UPDATE）或唯一约束实现原子性抢占：创建一张job_lock表，包含job_name、instance_id、status、create_time字段，启动Job时尝试插入一条status=RUNNING的记录（job_name设为唯一键），或者更新对应Job的记录并加锁，只有操作成功的节点才能启动Job；
• Job执行完成（无论成功失败），更新status为FINISHED或FAILED释放锁资源；
• 额外处理：定时清理超时的RUNNING状态记录，避免Job异常崩溃导致锁永久占用。

2. 基于Redis/ZooKeeper的分布式锁 #

借助成熟的分布式锁组件实现跨节点互斥：

• Redis方案：用Redisson的可重入锁，以Job名称为锁键，启动Job前调用lock()抢占锁，获取成功后执行Job逻辑，完成后调用unlock()释放；配置锁超时时间并启用看门狗自动续期，避免Job执行时长超过锁超时导致提前释放；
• ZooKeeper方案：用Curator的InterProcessMutex，以Job名为锁路径，抢占到锁的节点才能启动Job；ZooKeeper的临时节点特性可自动处理节点崩溃后的锁释放；
• 优势：相比数据库锁，性能更高，锁的过期、释放机制更成熟。

3. 借助Spring Cloud Task实现任务状态管控 #

如果已集成Spring Cloud Task，可利用其任务跟踪能力实现单实例控制：

• 配置共享的TaskRepository（存储到数据库或Redis），让所有ECS节点的任务状态写入同一存储；
• 在Job启动前，通过TaskExplorer查询当前是否有同一Job的活跃任务实例（状态为RUNNING），仅当不存在活跃实例时才启动Job；
• Spring Cloud Task会自动记录任务的启动、结束状态，无需手动维护锁表，适合Spring Cloud生态场景。

4. 基于ECS调度中心的集中管控 #

若Job通过调度器触发（如Quartz、XXL-Job），可将调度逻辑收拢到独立调度中心：

• 部署单实例或集群化的调度中心，由它统一负责触发Job；
• 调度中心触发前先检查是否有同一Job正在运行，仅空闲时才触发到任意ECS节点执行；
• 这种方式把单实例控制逻辑集中到调度层，避免每个ECS节点自行判断，降低复杂度。

内容的提问来源于stack exchange，提问作者Karthikeyan Govindaraj