背景问题

最近把若依框架的项目部署到两台服务器做负载均衡,结果发现一个严重问题:定时任务在两台服务器上同时执行了!

比如有个每天凌晨统计数据的任务,结果第二天一看,数据被重复统计了两次。这对于业务来说是不可接受的。

问题原因分析

若依框架默认使用的Quartz配置是内存存储(RAMJobStore)模式。在这种模式下:

- 每台服务器各自维护自己的定时任务
- 服务器之间互不知道对方的存在
- 同一时刻,所有节点都会执行同一个定时任务

这就导致了重复执行的问题。

解决方案:Quartz集群模式

要解决这个问题,需要将Quartz的存储方式从内存改为数据库共享(JDBCJobStore),并开启集群模式

第一步:修改application.yml配置

ruoyi-admin模块下的application.yml中添加(或修改)Quartz配置:

spring:
  quartz:
    job-store-type: jdbc           # 使用数据库存储任务
    jdbc:
      initialize-schema: never     # 禁止自动初始化,避免表重复创建冲突
    properties:
      org.quartz.scheduler.instanceName: ruoyiClusterScheduler    # 调度器实例名(集群内必须相同)
      org.quartz.scheduler.instanceId: AUTO                       # 自动生成实例ID(各节点不同)
      org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX
      org.quartz.jobStore.driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
      org.quartz.jobStore.tablePrefix: QRTZ_                      # Quartz表前缀
      org.quartz.jobStore.isClustered: true                       # 开启集群模式(核心配置)
      org.quartz.jobStore.clusterCheckinInterval: 20000           # 节点检入间隔(ms)
      org.quartz.jobStore.misfireThreshold: 60000                 # 任务超时阈值


 

 第二步:启用ScheduleConfig配置类

若依框架的ruoyi-quartz模块下有一个ScheduleConfig.java配置类,默认是被注释掉的。需要取消注释,使其生效

文件路径:`ruoyi-quartz/src/main/java/com/ruoyi/quartz/config/ScheduleConfig.java`

package com.ruoyi.quartz.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import javax.sql.DataSource;
import java.util.Properties;

/**
 * 定时任务配置(单机部署建议删除此类和qrtz数据库表,默认走内存会最高效)
 *
 * @author ruoyi
 */
@Configuration
public class ScheduleConfig
{
    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource)
    {
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        factory.setDataSource(dataSource);

        // quartz参数
        Properties prop = new Properties();
        prop.put("org.quartz.scheduler.instanceName", "RuoyiScheduler");
        prop.put("org.quartz.scheduler.instanceId", "AUTO");
        // 线程池配置
        prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
        prop.put("org.quartz.threadPool.threadCount", "20");
        prop.put("org.quartz.threadPool.threadPriority", "5");
        // JobStore配置
        prop.put("org.quartz.jobStore.class", "org.springframework.scheduling.quartz.LocalDataSourceJobStore");
        // 集群配置
        prop.put("org.quartz.jobStore.isClustered", "true");
        prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");
        prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "10");
        prop.put("org.quartz.jobStore.txIsolationLevelSerializable", "true");

        // sqlserver 启用
        // prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?");
        prop.put("org.quartz.jobStore.misfireThreshold", "12000");
        prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");
        factory.setQuartzProperties(prop);

        factory.setSchedulerName("RuoyiScheduler");
        // 延时启动
        factory.setStartupDelay(1);
        factory.setApplicationContextSchedulerContextKey("applicationContextKey");
        // 可选,QuartzScheduler
        // 启动时更新己存在的Job,这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了
        factory.setOverwriteExistingJobs(true);
        // 设置自动启动,默认为true
        factory.setAutoStartup(true);

        return factory;
    }
}



 

 第三步:导入Quartz数据库表

Quartz集群模式需要数据库表来存储任务和锁信息。若依框架sql脚本下面有。

第四步:配置数据源

确保所有服务器连接的是同一个数据库。各节点的数据源配置指向相同的地址:

spring:
  datasource:
    url: jdbc:mysql://同一IP:3306/同一个库名

第五步:同步服务器时间

这一步非常关键! Quartz集群要求各节点的时间误差不超过1秒。

这里不赘述

验证是否成功

启动各节点后,观察日志:

// 成功加入集群的日志示例
INFO - ClusterManager: ClusterManager: Managing cluster - Instance ID: 节点A
INFO - ClusterManager: ClusterManager: This server is active in the cluster

登录数据库查看`QRTZ_SCHEDULER_STATE`表,应该能看到所有节点的注册信息:

SELECT * FROM QRTZ_SCHEDULER_STATE;

 常见问题排查

 问题1:报错 Table 'xxx.QRTZ_LOCKS' doesn't exist

原因:MySQL区分大小写,表名不匹配。

解决方法(二选一):

-- 方案A:将表名改为大写
RENAME TABLE qrtz_locks TO QRTZ_LOCKS;
RENAME TABLE qrtz_triggers TO QRTZ_TRIGGERS;
RENAME TABLE qrtz_job_details TO QRTZ_JOB_DETAILS;
RENAME TABLE qrtz_cron_triggers TO QRTZ_CRON_TRIGGERS;
RENAME TABLE qrtz_scheduler_state TO QRTZ_SCHEDULER_STATE;
RENAME TABLE qrtz_fired_triggers TO QRTZ_FIRED_TRIGGERS;
RENAME TABLE qrtz_paused_trigger_grps TO QRTZ_PAUSED_TRIGGER_GRPS;
RENAME TABLE qrtz_blob_triggers TO QRTZ_BLOB_TRIGGERS;
RENAME TABLE qrtz_calendars TO QRTZ_CALENDARS;
RENAME TABLE qrtz_simple_triggers TO QRTZ_SIMPLE_TRIGGERS;
RENAME TABLE qrtz_simprop_triggers TO QRTZ_SIMPROP_TRIGGERS;
-- 其他表同理

-- 方案B:修改MySQL配置(仅限5.7及以下)
-- 在my.cnf中添加:lower_case_table_names=1

问题2:JDK 8环境下出现时钟回拨问题

解决方案
- 升级到JDK 11+,或
- 升级Quartz到2.5.x以上版本

问题3:任务仍然重复执行

检查以下几点:
- 各节点`instanceName`是否一致
- `isClustered`是否为`true`
- 各节点时间差是否≤1秒
- 是否共用同一个数据库

完成以上配置后,你的若依定时任务就能在多服务器环境下正常工作了——同一时刻只有一个节点执行,既能实现高可用,又能避免重复执行。

希望这篇文章对你有帮助!如果遇到其他问题,欢迎在评论区交流。

Logo

openEuler 是由开放原子开源基金会孵化的全场景开源操作系统项目,面向数字基础设施四大核心场景(服务器、云计算、边缘计算、嵌入式),全面支持 ARM、x86、RISC-V、loongArch、PowerPC、SW-64 等多样性计算架构

更多推荐