java - springboot定时任务服务，现在是单节点，用的@Scheduled，要改成多节点的，有没有简单的改造方案？

Question

还使用@Scheduled的情况下，如何避免任务重复执行？

Answer 1

在Spring Boot中，使用@Scheduled注解创建的定时任务默认是单节点的，即它们会在应用中的单个实例上执行。当应用扩展到多个节点时，如果不进行任何配置，每个节点上的任务都会独立执行，这可能导致任务重复执行。

要避免在多节点环境中重复执行定时任务，有几种策略可以考虑：

1. 使用分布式锁：
   你可以使用分布式锁（如Redis锁、Zookeeper锁等）来确保同一时间只有一个节点可以执行定时任务。在任务执行前，节点尝试获取锁；如果获取成功，则执行任务；如果获取失败（即锁已被其他节点持有），则不执行任务。
2. 使用数据库状态标记：
   在执行定时任务前，先检查数据库中某个状态标记。如果状态表示任务正在执行，则当前节点不执行任务；否则，更新状态并开始执行任务。这种方法需要确保数据库操作的原子性，以避免并发问题。
3. 使用Spring Cloud Scheduler：
   如果你使用的是Spring Cloud，可以考虑使用Spring Cloud Scheduler来管理分布式定时任务。Spring Cloud Scheduler提供了基于消息队列（如RabbitMQ、Kafka）的任务调度机制，可以确保任务在集群中的唯一执行。
4. 使用外部调度服务：
   你还可以使用外部调度服务（如Quartz Scheduler的集群模式、XXL-JOB等）来管理定时任务。这些服务通常提供了分布式调度的功能，可以确保任务在集群中的唯一执行。

在继续使用@Scheduled注解的情况下，要实现避免任务重复执行的功能，最简单的方法是结合上述策略中的分布式锁。下面是一个使用Redis作为分布式锁的简单示例：

import org.springframework.scheduling.annotation.Scheduled;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.ValueOperations;import org.springframework.stereotype.Component;import java.util.concurrent.TimeUnit;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;@Componentpublic class ScheduledTaskService {    private static final String LOCK_KEY = "scheduledTaskLock";    private static final Long LOCK_TIMEOUT = 10L; // 锁的过期时间，防止死锁    private final RedisTemplate<String, Object> redisTemplate;    private final Lock localLock = new ReentrantLock();    @Autowired    public ScheduledTaskService(RedisTemplate<String, Object> redisTemplate) {        this.redisTemplate = redisTemplate;    }    @Scheduled(fixedDelay = 10000) // 每10秒执行一次任务    public void performScheduledTask() {        try {            // 尝试获取分布式锁            if (tryAcquireLock()) {                try {                    // 执行任务逻辑                    performTaskLogic();                } finally {                    // 释放锁                    releaseLock();                }            } else {                // 未能获取到锁，不执行任务                System.out.println("Task skipped due to lock being held by another node.");            }        } catch (InterruptedException e) {            Thread.currentThread().interrupt();            // 处理中断异常        }    }    private boolean tryAcquireLock() throws InterruptedException {        // 使用本地锁确保只有一个线程尝试获取分布式锁        localLock.lock();        try {            ValueOperations<String, Object> operations = redisTemplate.opsForValue();            // 尝试设置锁，如果设置成功则返回true，否则返回false            Boolean result = operations.setIfAbsent(LOCK_KEY, "locked", LOCK_TIMEOUT, TimeUnit.SECONDS);            return result != null && result;        } finally {            localLock.unlock();        }    }    private void releaseLock() {        // 删除锁，释放资源        redisTemplate.delete(LOCK_KEY);    }    private void performTaskLogic() {        // 在这里编写你的任务逻辑        System.out.println("Scheduled task is running...");    }}

在这个示例中，我们使用了Redis作为分布式锁的存储。tryAcquireLock方法尝试在Redis中设置一个键作为锁，如果设置成功（即该键之前不存在），则获取到锁并执行任务逻辑；否则，说明锁已被其他节点持有，当前节点不执行任务。releaseLock方法用于在任务执行完毕后释放锁。需要注意的是，为了防止死锁，我们给锁设置了一个过期时间。同时，我们使用了一个本地锁localLock来确保同一时间只有一个线程尝试获取