当前位置：首页 > news >正文

SpringBoot分布式定时任务实战：告别重复执行的烦恼

news 来源：原创 2025/5/21 4:27:54

场景再现：你刚部署完基于SpringBoot的集群服务，凌晨3点突然收到监控告警——优惠券发放量超出预算两倍！检查日志发现，两个节点同时执行了定时任务。这种分布式环境下的定时任务难题，该如何彻底解决？

本文将手把手带你攻克这些难题：

剖析传统@Scheduled注解在分布式环境失效的根源
实战演示三种主流分布式定时任务方案
生产环境避坑指南与性能优化建议

一、为什么单机方案在分布式环境下失效？

当我们的服务以集群方式部署时，每个节点的定时任务都会独立运行。这会导致：

重复任务执行导致业务异常（如重复扣款）
数据库被多个节点同时操作引发锁冲突
无法实现任务的动态扩容缩容

二、五大分布式定时任务方案选型

方案	实现难度	可靠性	功能丰富度	适用场景
数据库锁	★★☆☆☆	★★☆☆☆	★☆☆☆☆	小型项目快速实现
Redis分布式锁	★★★☆☆	★★★☆☆	★★☆☆☆	轻量级任务调度
Zookeeper选举	★★★★☆	★★★★☆	★★☆☆☆	强一致性场景
Quartz集群	★★★★☆	★★★★☆	★★★★★	企业级复杂调度
Elastic-Job	★★★☆☆	★★★★★	★★★★★	互联网高并发场景

结论：推荐Elastic-Job（功能强大）或Spring Scheduler + Redis分布式锁（轻量快速）

三、方案一：Elastic-Job + SpringBoot实战

3.1 引入Maven依赖

<!-- ElasticJob-Lite -->
<dependency>
    <groupId>org.apache.shardingsphere.elasticjob</groupId>
    <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
    <version>3.0.3</version>
</dependency>

3.2 配置Zookeeper注册中心

elasticjob:
  reg-center:
    server-lists: localhost:2181
    namespace: elasticjob-demo

3.3 实现定时任务类

public class OrderTimeoutJob implements SimpleJob {
    
    @Override
    public void execute(ShardingContext context) {
        // 获取当前分片参数
        int shardIndex = context.getShardingItem();
        
        // 分片策略示例：按订单ID取模分片
        List<Long> orderIds = fetchTimeoutOrders(shardIndex);
        orderIds.forEach(this::cancelOrder);
    }
    
    private List<Long> fetchTimeoutOrders(int shard) {
        // 实现分片查询逻辑
        return orderRepository.findTimeoutOrders(shard);
    }
}

关键配置参数：

jobs:
  orderTimeoutJob:
    elasticJobClass: com.example.OrderTimeoutJob
    cron: 0 0/5 * * * ?
    shardingTotalCount: 3
    overwrite: true

四、方案二：Spring Scheduler + Redis分布式锁

4.1 实现Redis锁工具类

public class RedisDistributedLock {

    private static final String LOCK_PREFIX = "schedule:lock:";
    private static final int LOCK_EXPIRE = 30;

    @Autowired
    private StringRedisTemplate redisTemplate;

    public boolean tryLock(String lockKey) {
        String key = LOCK_PREFIX + lockKey;
        return redisTemplate.opsForValue()
                .setIfAbsent(key, "locked", LOCK_EXPIRE, TimeUnit.SECONDS);
    }

    public void unlock(String lockKey) {
        redisTemplate.delete(LOCK_PREFIX + lockKey);
    }
}

4.2 定时任务增强实现

@Component
public class CouponExpireJob {

    @Autowired
    private RedisDistributedLock redisLock;

    @Scheduled(cron = "0 0 3 * * ?")
    public void processExpiredCoupons() {
        if (!redisLock.tryLock("couponJob")) {
            return;
        }
        
        try {
            // 真正的业务逻辑
            couponService.processExpired();
        } finally {
            redisLock.unlock("couponJob");
        }
    }
}