quartz定时任务原理-石英定时器工作原理深度解析：从底层机制到生产实践

# 线程池配置
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10  # 核心线程数
org.quartz.threadPool.threadPriority = 5

# 启用集群模式
org.quartz.jobStore.isClustered = true
# 节点唯一标识（需各节点不同）
org.quartz.scheduler.instanceId = AUTO

CronScheduleBuilder.cronSchedule("0 0 12   ?")
    .withMisfireHandlingInstructionDoNothing() // 错过则跳过
    .withMisfireHandlingInstructionFireAndProceed() // 错过则立即执行一次

线程池大小 ≈ 任务总量 × 单任务平均耗时 / 时间片长度

QRTZ_JOB_DETAILS    # 任务详细信息
QRTZ_TRIGGERS       # 基础触发器信息
QRTZ_SIMPLE_TRIGGERS # SimpleTrigger扩展
QRTZ_CRON_TRIGGERS  # CronTrigger扩展
QRTZ_BLOB_TRIGGERS  # 二进制触发器数据
QRTZ_FIRED_TRIGGERS # 已触发任务记录
QRTZ_PAUSED_TRIGGER_GRPS # 暂停的触发器组
QRTZ_SCHEDULER_STATE # 调度器状态（集群用）
QRTZ_LOCKS          # 分布式锁表
QRTZ_CALENDARS      # 日历排除规则
QRTZ_PYTHON_TRIGGERS # Python任务支持（3.x新增）

# 数据源配置
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.dataSource = myDS
# 数据源连接池（HikariCP）
org.quartz.dataSource.myDS.driver = com.mysql.cj.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/quartz
org.quartz.dataSource.myDS.user = root
org.quartz.dataSource.myDS.password = 123456
org.quartz.dataSource.myDS.maxConnections = 10

import org.quartz.;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class CancelExpiredOrderJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 获取任务数据
        JobDataMap dataMap = context.getJobDetail().getJobDataMap();
        long timeoutMinutes = dataMap.getLong("timeoutMinutes");
        // 获取触发器信息
        TriggerKey triggerKey = context.getTrigger().getKey();
        System.out.println("触发器: " + triggerKey + " 执行订单超时检查");
        // 执行业务逻辑
        try {
            OrderService orderService = new OrderService();
            int canceledCount = orderService.cancelExpiredOrders(timeoutMinutes);
            // 记录日志
            System.out.println("取消订单数: " + canceledCount);
            // 更新任务状态（模拟）
            context.getScheduler().setJobDataMap(
                context.getJobDetail().getKey(),
                new JobDataMap().put("lastRun", new Date())
            );
        } catch (Exception e) {
            throw new JobExecutionException("订单取消失败", e, true); // true 表示重新调度
        }
    }
}

import org.quartz.;
import org.quartz.impl.StdSchedulerFactory;
public class QuartzScheduler {
    public static void main(String[] args) throws Exception {
        // 创建调度器
        SchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        // 定义任务
        JobDetail job = JobBuilder.newJob(CancelExpiredOrderJob.class)
            .withIdentity("cancelJob", "orderGroup")
            .usingJobData("timeoutMinutes", 30) // 30分钟超时
            .build();
        // 定义触发器：每10分钟执行一次
        Trigger trigger = TriggerBuilder.newTrigger()
            .withIdentity("cancelTrigger", "orderGroup")
            .startNow()
            .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                .withIntervalInMinutes(10)
                .repeatForever())
            .build();
        // 注册任务与触发器
        scheduler.scheduleJob(job, trigger);
        // 启动调度器
        scheduler.start();
        // 监听器注册（可选）
        scheduler.getListenerManager().addJobListener(
            new OrderJobListener(),
            Matcher.anyJob()
        );
        // 优雅关闭
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            System.out.println("正在关闭调度器...");
            scheduler.shutdown();
        }));
    }
}

import org.quartz.;
public class OrderJobListener implements JobListener {
    @Override
    public String getName() {
        return "orderJobListener";
    }
    @Override
    public void jobToBeExecuted(JobExecutionContext context) {
        System.out.println("[INFO] 任务即将执行: " + context.getJobDetail().getKey());
    }
    @Override
    public void jobExecutionVetoed(JobExecutionContext context) {
        System.out.println("[WARN] 任务被拦截: " + context.getJobDetail().getKey());
    }
    @Override
    public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
        if (jobException != null) {
            System.err.println("[ERROR] 任务执行失败: " + context.getJobDetail().getKey());
            System.err.println("原因: " + jobException.getMessage());
        } else {
            System.out.println("[SUCCESS] 任务完成: " + context.getJobDetail().getKey());
        }
    }
}

# HikariCP 配置示例
org.quartz.dataSource.myDS.connectionTimeout = 30000
org.quartz.dataSource.myDS.idleTimeout = 600000
org.quartz.dataSource.myDS.maxLifetime = 1800000
org.quartz.dataSource.myDS.maximumPoolSize = 15

# 集群心跳间隔（毫秒）
org.quartz.scheduler.instanceId = AUTO
org.quartz.jobStore.clusterCheckinInterval = 20000
# 节点故障检测超时
org.quartz.jobStore.misfireThreshold = 60000

JobDataMap dataMap = new JobDataMap();
dataMap.put("startId", 10000);
dataMap.put("endId", 20000);
// 创建分片任务...