微服务多实例下Timer未来任务重复执行问题咨询

你的核心问题是多实例各自独立调度任务，重启后从数据库加载并重复触发同一任务，先提个代码里的小bug：newTask()中你先初始化了一个timerTask并设置属性，但实际调度的是全新的CustomizedTimerTask()，这会导致数据库保存的和实际运行的任务对象不一致，先修复这个问题：

public void newTask() {
    // 补全毫秒转换与语法错误
    Date startedAt = new Date(new Date().getTime() + 5 * 60 * 60 * 1000);
    
    CustomizedTimerTask timerTask = new CustomizedTimerTask();
    timerTask.setSender("sender");
    timerTask.setReceiver("receiver"); // 修正拼写错误：reciver→receiver
    timerTask.setMessage("Hi, nice to meet you");
    timer.schedule(timerTask, startedAt); // 调度已配置好属性的实例
    
    // save timerTask to Database
}

针对多实例重复调度的问题，给出三个可行解决方案：

方案1：数据库状态锁+乐观锁控制 #

给任务表新增字段：

• status：任务状态（待调度/已调度/已执行）
• version：乐观锁版本号
• scheduled_instance：记录调度任务的实例ID（可选）

修改initAfterStartOn()逻辑：

1. 查询所有status=待调度且执行时间晚于当前时间的任务
2. 对每个任务，用乐观锁尝试更新状态为已调度
3. 只有更新成功的任务，才在当前实例进行调度
4. 任务执行完成后，更新状态为已执行

代码片段示例：

public void initAfterStartOn() {
    List<CustomizedTimerTask> tasks = taskRepository.findByStatusAndDueDateAfter("待调度", new Date());
    // 实例唯一标识，可从配置/环境变量读取，无需每次生成
    String instanceId = System.getenv("INSTANCE_ID");
    for (CustomizedTimerTask task : tasks) {
        // 乐观锁更新：仅当version匹配时才会更新成功
        int updatedRows = taskRepository.updateStatusAndInstanceIdById(
            task.getId(), "已调度", instanceId, task.getVersion()
        );
        if (updatedRows > 0) {
            timer.schedule(task, task.getDueDate());
        }
    }
}

方案2：分布式锁控制单实例调度 #

借助Redis/ZooKeeper实现分布式锁，加载任务时，每个任务只有拿到锁的实例才能调度：

public void initAfterStartOn() {
    List<CustomizedTimerTask> tasks = taskRepository.findByDueDateAfter(new Date());
    String instanceId = System.getenv("INSTANCE_ID");
    RedisLock redisLock = new RedisLock(); // 自行实现Redis锁逻辑
    for (CustomizedTimerTask task : tasks) {
        String lockKey = "task_lock:" + task.getId();
        // 锁过期时间需大于任务预估执行时长，避免锁提前释放
        if (redisLock.tryLock(lockKey, instanceId, 60 * 60 * 1000)) {
            // 二次检查数据库状态，防止其他实例已完成调度
            CustomizedTimerTask dbTask = taskRepository.findById(task.getId()).orElse(null);
            if (dbTask != null && "待调度".equals(dbTask.getStatus())) {
                timer.schedule(task, task.getDueDate());
                taskRepository.updateStatusById(task.getId(), "已调度");
            }
            redisLock.unlock(lockKey, instanceId);
        }
    }
}

方案3：替换为分布式任务调度框架 #

如果任务场景复杂，直接用成熟框架是最省心的选择，比如Quartz、XXL-Job：

• Quartz支持集群模式，通过数据库锁自动协调任务，同一任务只会被一个节点执行
• XXL-Job自带调度中心，可视化管理任务，集群部署自动完成分片与执行协调

以Quartz为例，只需将CustomizedTimerTask适配成Quartz的Job，配置好JobDetail和Trigger，集群环境下无需额外处理即可避免重复执行。

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