springboot实现分布式定时任务

Spring Boot 实现分布式定时任务通常涉及到保证在多个实例部署的情况下，只有一个实例会执行特定的任务。这避免了同一份代码在不同节点上同时运行导致的数据冲突或其他一致性问题。 ### 一、方案选择 1. **基于数据库锁** 每次调度前先尝试获取全局唯一锁（例如通过更新某条记录），成功则继续执行业务逻辑；失败则跳过本次计划。 2. **Redis 分布式锁** 使用 Redis 的 SETNX 命令创建锁，并设置自动释放时间(TTL)防止死锁发生。这种方式性能较好而且易于配置管理。 3. **XXL-JOB/ElasticJob 等第三方组件** - XXL-JOB 和 ElasticJob 都是由国内开发者维护的支持集群环境下高可用性的作业框架，它们自带图形化界面方便监控和操作。 4. **Quartz + 数据库持久层模式** Quartz是一个功能强大的开源作业调度框架，在其基础上结合数据表可以很好地支持分布式的场景需求，如主从架构下动态分配工作线程等高级特性。 ### 二、简单示例 (采用 Redis 分布式锁) ```java @Service public class DistributedTaskService { @Autowired private StringRedisTemplate redisTemplate; // 定义唯一的key作为标识符用于加解锁 private static final String LOCK_KEY = "DISTRIBUTED_LOCK"; /** * 执行带锁的异步任务 */ @Scheduled(cron="0/5 * * * * ?") public void executeWithLock() { Boolean isLocked = tryGetDistributedLock(); if(isLocked){ try{ System.out.println("开始执行任务..."); Thread.sleep(3000); //模拟耗时任务 System.out.println("结束任务"); } catch(Exception e){ log.error(e.getMessage(),e); } finally{ releaseDistributedLock(); } } else { System.out.println("未能获得锁定，放弃此次任务."); } } /*** * 尝试获取分布式锁 * @return 是否成功获得了锁 */ private boolean tryGetDistributedLock(){ return this.redisTemplate.opsForValue().setIfAbsent( LOCK_KEY, UUID.randomUUID().toString(), Duration.ofSeconds(6) ); } /*** * 解除已持有的分布式锁 */ private void releaseDistributedLock(){ this.redisTemplate.delete(LOCK_KEY); } } ``` 上述例子展示了如何利用`@Scheduled`注解配合自定义的服务类来构建一个简单的分布式环境下的定时任务系统。实际项目中还需要考虑更多细节比如异常处理机制、重试策略以及更复杂的锁竞争条件等问题。