SpringBoot集成Quartz如何實現(xiàn)定時任務

<!-- quartz 定時任務 -->
<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-quartz</artifactId>
 <version>2.2.6.RELEASE</version>
</dependency>

# spring的datasource等配置未貼出
spring:
 quartz:
  # 將任務等保存化到數(shù)據(jù)庫
  job-store-type: jdbc
  # 程序結束時會等待quartz相關的內(nèi)容結束
  wait-for-jobs-to-complete-on-shutdown: true
  # QuartzScheduler啟動時更新己存在的Job,這樣就不用每次修改targetObject后刪除qrtz_job_details表對應記錄
  overwrite-existing-jobs: true
  # 這里居然是個map，搞得智能提示都沒有，佛了
  properties:
  org:
   quartz:
   	# scheduler相關
   scheduler:
    # scheduler的實例名
    instanceName: scheduler
    instanceId: AUTO
   # 持久化相關
   jobStore:
    class: org.quartz.impl.jdbcjobstore.JobStoreTX
    driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
    # 表示數(shù)據(jù)庫中相關表是QRTZ_開頭的
    tablePrefix: QRTZ_
    useProperties: false
   # 線程池相關
   threadPool:
    class: org.quartz.simpl.SimpleThreadPool
    # 線程數(shù)
    threadCount: 10
    # 線程優(yōu)先級
    threadPriority: 5
    threadsInheritContextClassLoaderOfInitializingThread: true

/**
 * Quartz的相關配置，注冊JobDetail和Trigger
 * 注意JobDetail和Trigger是org.quartz包下的，不是spring包下的，不要導入錯誤
 */
@Configuration
public class QuartzConfig {

 @Bean
 public JobDetail jobDetail() {
  JobDetail jobDetail = JobBuilder.newJob(StartOfDayJob.class)
    .withIdentity("start_of_day", "start_of_day")
    .storeDurably()
    .build();
  return jobDetail;
 }

 @Bean
 public Trigger trigger() {
  Trigger trigger = TriggerBuilder.newTrigger()
    .forJob(jobDetail())
    .withIdentity("start_of_day", "start_of_day")
    .startNow()
    // 每天0點執(zhí)行
    .withSchedule(CronScheduleBuilder.cronSchedule("0 0 0 * * ?"))
    .build();
  return trigger;
 }
}

@Component
public class StartOfDayJob extends QuartzJobBean {
 private StudentService studentService;

 @Autowired
 public StartOfDayJob(StudentService studentService) {
  this.studentService = studentService;
 }

 @Override
 protected void executeInternal(JobExecutionContext jobExecutionContext)
   throws JobExecutionException {
  // 任務的具體邏輯
 }
}

public class LeaveApplication {
 @TableId(type = IdType.AUTO)
 private Integer id;
 private Long proposerUsername;
 @JsonFormat( pattern = "yyyy-MM-dd HH:mm",timezone="GMT+8")
 private LocalDateTime startTime;
 @JsonFormat( pattern = "yyyy-MM-dd HH:mm",timezone="GMT+8")
 private LocalDateTime endTime;
 private String reason;
 private String state;
 private String disapprovedReason;
 private Long checkerUsername;
 private LocalDateTime checkTime;

 // 省略getter、setter
}

@Service
public class LeaveApplicationServiceImpl implements LeaveApplicationService {
 @Autowired
 private Scheduler scheduler;
 
 // 省略其他方法與其他依賴

 /**
  * 添加job和trigger到scheduler
  */
 private void addJobAndTrigger(LeaveApplication leaveApplication) {
  Long proposerUsername = leaveApplication.getProposerUsername();
  // 創(chuàng)建請假開始Job
  LocalDateTime startTime = leaveApplication.getStartTime();
  JobDetail startJobDetail = JobBuilder.newJob(LeaveStartJob.class)
   	// 指定任務組名和任務名
    .withIdentity(leaveApplication.getStartTime().toString(),
      proposerUsername + "_start")
    // 添加一些參數(shù)，執(zhí)行的時候用
    .usingJobData("username", proposerUsername)
    .usingJobData("time", startTime.toString())
    .build();
  // 創(chuàng)建請假開始任務的觸發(fā)器
  // 創(chuàng)建cron表達式指定任務執(zhí)行的時間，由于請假時間是確定的，所以年月日時分秒都是確定的，這也符合任務只執(zhí)行一次的要求。
  String startCron = String.format("%d %d %d %d %d ? %d",
    startTime.getSecond(),
    startTime.getMinute(),
    startTime.getHour(),
    startTime.getDayOfMonth(),
    startTime.getMonth().getValue(),
    startTime.getYear());
  CronTrigger startCronTrigger = TriggerBuilder.newTrigger()
	   // 指定觸發(fā)器組名和觸發(fā)器名
    .withIdentity(leaveApplication.getStartTime().toString(),
      proposerUsername + "_start")
    .withSchedule(CronScheduleBuilder.cronSchedule(startCron))
    .build();

  // 將job和trigger添加到scheduler里
  try {
   scheduler.scheduleJob(startJobDetail, startCronTrigger);
  } catch (SchedulerException e) {
   e.printStackTrace();
   throw new CustomizedException("添加請假任務失敗");
  }
 }
}

@Component
public class LeaveStartJob extends QuartzJobBean {
 private Scheduler scheduler;
 private SystemUserMapperPlus systemUserMapperPlus;

 @Autowired
 public LeaveStartJob(Scheduler scheduler,
       SystemUserMapperPlus systemUserMapperPlus) {
  this.scheduler = scheduler;
  this.systemUserMapperPlus = systemUserMapperPlus;
 }

 @Override
 protected void executeInternal(JobExecutionContext jobExecutionContext)
   throws JobExecutionException {
  Trigger trigger = jobExecutionContext.getTrigger();
  JobDetail jobDetail = jobExecutionContext.getJobDetail();
  JobDataMap jobDataMap = jobDetail.getJobDataMap();
  // 將添加任務的時候存進去的數(shù)據(jù)拿出來
  long username = jobDataMap.getLongValue("username");
  LocalDateTime time = LocalDateTime.parse(jobDataMap.getString("time"));

  // 編寫任務的邏輯

  // 執(zhí)行之后刪除任務
  try {
   // 暫停觸發(fā)器的計時
   scheduler.pauseTrigger(trigger.getKey());
   // 移除觸發(fā)器中的任務
   scheduler.unscheduleJob(trigger.getKey());
   // 刪除任務
   scheduler.deleteJob(jobDetail.getKey());
  } catch (SchedulerException e) {
   e.printStackTrace();
  }
 }
}