<!--集成quartz-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-quartz</artifactId>
            <version>2.3.12.RELEASE</version>
        </dependency>

       <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--mysql依賴-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!--util工具類-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.8.1</version>
        </dependency>

spring:
  datasource:
    name: db_quartz
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db_quartz?useSSL=false&serverTimezone=Asia/Shanghai&characterEncoding=UTF8&rewriteBatchedStatements=true
    username: root
    password: 123456
  #quartz配置
  quartz:
    #數(shù)據(jù)存儲(chǔ)方式 默認(rèn)是 MEMORY（內(nèi)存方式）
    job-store-type: jdbc
    properties:
      org:
        quartz:
          scheduler:
            #調(diào)度標(biāo)識(shí)名
            instanceName: clusteredScheduler
            #ID設(shè)置為自動(dòng)獲取 每一個(gè)必須不同
            instanceId: AUTO
          jobStore:
            #數(shù)據(jù)保存方式為持久化
            class: org.quartz.impl.jdbcjobstore.JobStoreTX
            #數(shù)據(jù)庫平臺(tái)
            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
            #表的前綴
            tablePrefix: QRTZ_
            #加入集群
            isClustered: false
            #調(diào)度實(shí)例失效的檢查時(shí)間間隔
            clusterCheckinInterval: 10000
            #設(shè)置為TRUE不會(huì)出現(xiàn)序列化非字符串類到 BLOB 時(shí)產(chǎn)生的類版本問題
            useProperties: false
          threadPool:
            #ThreadPool 實(shí)現(xiàn)的類名
            class: org.quartz.simpl.SimpleThreadPool
            #線程數(shù)量
            threadCount: 5
            #線程優(yōu)先級(jí)
            threadPriority: 5
            #自創(chuàng)建父線程
            threadsInheritContextClassLoaderOfInitializingThread: true

@RestController
@RequestMapping("/quartz")
public class QuartzController {
    @Autowired
    private QuartzService quartzService;
    /**
     * 新增任務(wù)
     */
    @PostMapping("/insert")
    @ApiOperation(value = "新增任務(wù)", notes = "新增任務(wù)")
    public Boolean insertTask(@RequestBody QuartzModel quartzModel) {
        return quartzService.addJob(quartzModel);
    }
    /**
     * 暫停任務(wù)
     */
    @PostMapping("/pause")
    @ApiOperation(value = "暫停任務(wù)", notes = "暫停任務(wù)")
    public Boolean pauseTask(@RequestBody OperationModel operationModel) {
        return quartzService.pauseJob(operationModel);
    }
    /**
     * 恢復(fù)任務(wù)
     */
    @PostMapping("/resume")
    @ApiOperation(value = "恢復(fù)任務(wù)", notes = "恢復(fù)任務(wù)")
    public Boolean resumeTask(@RequestBody OperationModel operationModel) {
        return quartzService.resumeJob(operationModel);
    }
    /**
     * 刪除任務(wù)
     */
    @PostMapping("/delete")
    @ApiOperation(value = "刪除任務(wù)", notes = "刪除任務(wù)")
    public Boolean deleteTask(@RequestBody OperationModel operationModel) {
        return quartzService.deleteJob(operationModel);
    }
    /**
     * 查看所有定時(shí)任務(wù)
     */
    @GetMapping("/query-all-job")
    @ApiOperation(value = "查看所有定時(shí)任務(wù)", notes = "查看所有定時(shí)任務(wù)")
    public List<Map<String, Object>> queryAllJob() {
        return quartzService.queryAllJob();
    }
    /**
     * 查看正在運(yùn)行的任務(wù)
     */
    @GetMapping("/query-all-running-job")
    @ApiOperation(value = "查看正在執(zhí)行的任務(wù)", notes = "查看正在執(zhí)行的任務(wù)")
    public List<Map<String, Object>> queryAllRunningJob() {
        return quartzService.queryAllRunningJob();
    }
}

@Service
public interface QuartzService {
    /**
     * 新增定時(shí)任務(wù)
     */
    Boolean addJob(QuartzModel quartzModel);
    /**
     * 暫停定時(shí)任務(wù)
     */
    Boolean pauseJob(OperationModel operationModel);
    /**
     * 繼續(xù)定時(shí)任務(wù)
     */
    Boolean resumeJob(OperationModel operationModel);
    /**
     * 刪除定時(shí)任務(wù)
     */
    Boolean deleteJob(OperationModel operationModel);
    /**
     * 查詢所有計(jì)劃中的任務(wù)列表
     */
    List<Map<String, Object>> queryAllJob();
    /**
     * 查看正在運(yùn)行的任務(wù)
     */
    List<Map<String, Object>> queryAllRunningJob();
}

 
/**
 * 定時(shí)任務(wù)執(zhí)行器
 */
@Slf4j
public class TaskDistributor extends QuartzJobBean {
    /**
     * 根據(jù)不同的jobDetail攜帶的type參數(shù)區(qū)分,執(zhí)行不同業(yè)務(wù)
     */
    @Override
    protected void executeInternal(JobExecutionContext context) {
        synchronized (this) {
            log.info("開始執(zhí)行定時(shí)任務(wù)...............");
            try {
                //獲取job中攜帶的內(nèi)容并轉(zhuǎn)成jobDetailModel對(duì)象
                JobDetailModel jobDetailModel = (JobDetailModel) context.getJobDetail().getJobDataMap().get("jobDetailModel");
                Integer type = jobDetailModel.getType();
                String content = jobDetailModel.getContent();
                //根據(jù)type執(zhí)行不同的業(yè)務(wù)邏輯
                switch (type) {
                    case 1:
                        System.out.println("task1即將被執(zhí)行，content:" + content);
                        //模擬處理邏輯
                        Thread.sleep(5000);
                        log.info("---------task1定時(shí)任務(wù)執(zhí)行結(jié)束----------");
                        break;
                    case 2:
                        System.out.println("task2即將被執(zhí)行，content:" + content);
                        //模擬處理邏輯
                        Thread.sleep(5000);
                        log.info("----------task2定時(shí)任務(wù)結(jié)束---------");
                        break;
                    default:
                        log.info("---------定時(shí)任務(wù)執(zhí)行開始----------");
                        log.info("---------定時(shí)任務(wù)執(zhí)行結(jié)束----------");
                        break;
                }
            } catch (Throwable t) {
                log.error(t.getMessage(), t);
            }
            log.info("定時(shí)任務(wù)執(zhí)行結(jié)束...............");
        }
    }
}

@Slf4j
@Service
public class QuartzServiceImpl implements QuartzService {
    @Autowired
    private Scheduler scheduler;
    /**
     * 新增定時(shí)任務(wù)
     */
    @Override
    public Boolean addJob(QuartzModel quartzModel) {
        try {
            String cron = quartzModel.getCron();
            //校驗(yàn)cron是否有效
            boolean valid = CronUtils.isValid(cron);
            if (!valid) {
                return false;
            }
            JobDetail jobDetail = JobBuilder.newJob(TaskDistributor.class)
                    .withIdentity(quartzModel.getJobName(), quartzModel.getJobGroup())
                    .build();
            // 攜帶job內(nèi)容 此處可以攜帶業(yè)務(wù)所需要的執(zhí)行參數(shù)
            JobDetailModel jobDetailModel = quartzModel.getJobData();
            if (!Objects.isNull(jobDetailModel)) {
                jobDetail.getJobDataMap().put("jobDetailModel", jobDetailModel);
            }
            CronTrigger trigger = TriggerBuilder.newTrigger()
                    .withIdentity(quartzModel.getTriggerName(), quartzModel.getTriggerGroup())
                    .startNow()
                    .withSchedule(CronScheduleBuilder.cronSchedule(cron))
                    .build();
            //把作業(yè)和觸發(fā)器注冊(cè)到任務(wù)調(diào)度中
            scheduler.scheduleJob(jobDetail, trigger);
            //啟用調(diào)度
            scheduler.start();
            log.info("---------定時(shí)任務(wù)成功添加進(jìn)quartz隊(duì)列中！----------");
        } catch (Exception e) {
            e.printStackTrace();
        }
        return true;
    }
    /**
     * 暫停定時(shí)任務(wù)
     */
    @Override
    public Boolean pauseJob(OperationModel operationModel) {
        try {
            scheduler.pauseJob(JobKey.jobKey(operationModel.getJobName(), operationModel.getJobGroup()));
            System.out.println("暫停定時(shí)任務(wù)成功");
        } catch (Exception e) {
            e.printStackTrace();
        }
        return true;
    }
    /**
     * 繼續(xù)定時(shí)任務(wù)
     */
    @Override
    public Boolean resumeJob(OperationModel operationModel) {
        try {
            scheduler.resumeJob(JobKey.jobKey(operationModel.getJobName(), operationModel.getJobGroup()));
            System.out.println("恢復(fù)定時(shí)任務(wù)成功");
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return true;
    }
    /**
     * 刪除定時(shí)任務(wù)
     */
    @Override
    public Boolean deleteJob(OperationModel operationModel) {
        try {
            // TriggerKey 定義了trigger的名稱和組別 ，通過任務(wù)名和任務(wù)組名獲取TriggerKey
            TriggerKey triggerKey = TriggerKey.triggerKey(operationModel.getJobName(), operationModel.getJobGroup());
            // 停止觸發(fā)器
            scheduler.resumeTrigger(triggerKey);
            // 移除觸發(fā)器
            scheduler.unscheduleJob(triggerKey);
            scheduler.deleteJob(JobKey.jobKey(operationModel.getJobName(), operationModel.getJobGroup()));
            System.out.println("刪除定時(shí)任務(wù)成功");
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return true;
    }
    /**
     * 查看所有定時(shí)任務(wù)
     *
     * @return
     */
    @Override
    public List<Map<String, Object>> queryAllJob() {
        List<Map<String, Object>> jobList = null;
        try {
            GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();
            Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);
            jobList = new ArrayList<Map<String, Object>>();
            for (JobKey jobKey : jobKeys) {
                List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
                for (Trigger trigger : triggers) {
                    jobList.add(this.buildMap(jobKey, trigger));
                }
            }
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return jobList;
    }
    /**
     * 返回指定的map集合
     */
    private Map<String, Object> buildMap(JobKey jobKey, Trigger trigger) throws SchedulerException {
        Map<String, Object> map = new HashMap<>();
        map.put("jobName", jobKey.getName());
        map.put("jobGroupName", jobKey.getGroup());
        map.put("description", "觸發(fā)器:" + trigger.getKey());
        Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
        map.put("jobStatus", triggerState.name());
        if (trigger instanceof CronTrigger) {
            CronTrigger cronTrigger = (CronTrigger) trigger;
            String cronExpression = cronTrigger.getCronExpression();
            map.put("jobTime", cronExpression);
        }
        return map;
    }
    /**
     * 獲取所有正在運(yùn)行的job
     *
     * @return
     */
    @Override
    public List<Map<String, Object>> queryAllRunningJob() {
        List<Map<String, Object>> jobList = null;
        try {
            List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();
            jobList = new ArrayList<Map<String, Object>>(executingJobs.size());
            for (JobExecutionContext executingJob : executingJobs) {
                JobDetail jobDetail = executingJob.getJobDetail();
                JobKey jobKey = jobDetail.getKey();
                Trigger trigger = executingJob.getTrigger();
                jobList.add(this.buildMap(jobKey, trigger));
            }
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return jobList;
    }
}