欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 财经 > 创投人物 > Quartz修仙指南:从定时任务萌新到调度大能的终极奥义

Quartz修仙指南:从定时任务萌新到调度大能的终极奥义

2025/4/12 18:27:12 来源:https://blog.csdn.net/wang543203/article/details/147156346  浏览:    关键词:Quartz修仙指南:从定时任务萌新到调度大能的终极奥义

各位被Thread.sleep()ScheduledExecutorService折磨的道友们!今天要解锁的是Java界任务调度至尊法宝——Quartz!这货能让你像玉皇大帝安排天庭日程一样,精确控制每个任务的执行时机!准备好告别蹩脚的手动定时器了吗? ⏰


一、筑基篇:初识Quartz

1.1 法宝祭炼(添加依赖)
<!-- Spring Boot集成版(推荐) -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId>
</dependency><!-- 原生使用版 -->
<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.2</version>
</dependency>
1.2 核心概念三件套
  • Job:要执行的任务(如:“发送仙丹提醒”)
  • Trigger:触发时机(如:“每月初一子时”)
  • Scheduler:调度中心(天庭的日程总管)

二、金丹篇:基础任务调度

2.1 定义Job(编写仙术)
public class SendPillJob implements Job {@Overridepublic void execute(JobExecutionContext context) {// 获取传递的参数JobDataMap dataMap = context.getJobDetail().getJobDataMap();String userName = dataMap.getString("user");System.out.println(LocalDateTime.now() + ":给" + userName + "发送仙丹提醒!");}
}
2.2 配置Trigger(天时安排)
// 简单触发器(每30秒执行一次)
Trigger trigger = TriggerBuilder.newTrigger().withIdentity("pillTrigger").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(30).repeatForever()).build();// Cron触发器(每天上午8点执行)
Trigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("morningTrigger").withSchedule(CronScheduleBuilder.dailyAtHourAndMinute(8, 0)).build();
2.3 启动调度(开坛做法)
// 创建任务详情
JobDetail job = JobBuilder.newJob(SendPillJob.class).withIdentity("sendPillJob").usingJobData("user", "张无忌") // 传参.build();// 创建调度器
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.scheduleJob(job, trigger);
scheduler.start();

三、元婴篇:Spring Boot集成

3.1 自动配置(偷懒大法)
@Configuration
public class QuartzConfig {@Beanpublic JobDetail morningPillJobDetail() {return JobBuilder.newJob(SendPillJob.class).withIdentity("morningPillJob").storeDurably().build();}@Beanpublic Trigger morningPillTrigger() {return TriggerBuilder.newTrigger().forJob(morningPillJobDetail()).withIdentity("morningPillTrigger").withSchedule(CronScheduleBuilder.cronSchedule("0 0 8 * * ?")).build();}
}
3.2 注入Service(灵力融合)
public class SendPillJob implements Job {@Autowired // 通过SpringBeanJobFactory注入private PillService pillService;@Overridepublic void execute(JobExecutionContext context) {pillService.sendReminder();}
}

四、化神篇:高级特性

4.1 持久化存储(渡劫不丢数据)
# application.yml
spring:quartz:job-store-type: jdbc # 使用数据库存储jdbc:initialize-schema: always # 自动建表properties:org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTXorg.quartz.jobStore.driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegateorg.quartz.jobStore.tablePrefix: QRTZ_
4.2 集群模式(分身协作)
spring:quartz:properties:org.quartz.jobStore.isClustered: trueorg.quartz.scheduler.instanceId: AUTO # 自动生成实例IDorg.quartz.jobStore.acquireTriggersWithinLock: true
4.3 监听器(天眼通)
public class JobListener implements org.quartz.JobListener {@Overridepublic String getName() { return "globalJobListener"; }@Overridepublic void jobToBeExecuted(JobExecutionContext context) {System.out.println("任务即将执行:" + context.getJobDetail().getKey());}
}// 注册监听器
scheduler.getListenerManager().addJobListener(new JobListener());

五、大乘篇:最佳实践

5.1 异常处理(渡劫护盾)
public class RetryJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {try {// 业务代码...} catch (Exception e) {// 失败后重试JobExecutionException e2 = new JobExecutionException(e);e2.setRefireImmediately(true);throw e2;}}
}
5.2 动态调度(天机可变)
@Autowired
private Scheduler scheduler;// 动态添加任务
public void addDynamicJob(String jobName, String cron) throws SchedulerException {Trigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName + "Trigger").withSchedule(CronScheduleBuilder.cronSchedule(cron)).build();JobDetail job = JobBuilder.newJob(DynamicJob.class).withIdentity(jobName).usingJobData("param", "value").build();scheduler.scheduleJob(job, trigger);
}

六、渡劫警示(常见天劫)

  1. 时区问题

    // 明确指定时区
    CronScheduleBuilder.cronSchedule("0 0 12 * * ?").inTimeZone(TimeZone.getTimeZone("Asia/Shanghai"))
    
  2. 任务阻塞

    • 使用@DisallowConcurrentExecution禁止并发执行同一Job
    • 长时间任务考虑拆分
  3. 内存泄漏

    • 及时调用scheduler.shutdown()
    • 避免在Job中创建大量临时对象

飞升指南:调度策略

场景推荐Trigger示例
简单定时循环SimpleTrigger每30秒执行一次
固定时间点CronTrigger每天8:00执行
延迟单次任务SimpleTrigger.withRepeatCount(0)5分钟后执行一次
工作日调度CronTrigger + 特殊日历周一到周五9:00执行

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

热搜词