• SpringBoot整合Quartz示例

    数据表  加不加无所谓,如果需要重启服务器后重新执行所有JOB就把sql加上

    如果不加表  将application.properties中的quartz数据库配置去掉 

    自己执行自己的逻辑来就好,大不了每次启动之后重新加载自己的逻辑

    链接：https://pan.baidu.com/s/1KqOPYMfI4eHcEMxt5BmtYg 
    提取码：o9ql 
    --来自百度网盘超级会员V4的分享

    SpringBoot工程

    pom依赖

    1.  <dependencies>
    2.         <dependency>
    3.             <groupId>com.alibaba</groupId>
    4.             <artifactId>fastjson</artifactId>
    5.             <version>2.0.26</version>
    6.         </dependency>
    7.         <dependency>
    8.             <groupId>org.springframework.boot</groupId>
    9.             <artifactId>spring-boot-starter-web</artifactId>
    10.         </dependency>
    11.         <dependency>
    12.             <groupId>com.baomidou</groupId>
    13.             <artifactId>mybatis-plus-boot-starter</artifactId>
    14.             <version>3.4.3</version>
    15.         </dependency>
    16.         <dependency>
    17.             <groupId>com.alibaba</groupId>
    18.             <artifactId>druid-spring-boot-starter</artifactId>
    19.             <version>1.2.16</version>
    20.         </dependency>
    21.         <dependency>
    22.             <groupId>mysql</groupId>
    23.             <artifactId>mysql-connector-java</artifactId>
    24.             <scope>runtime</scope>
    25.         </dependency>
    26.         <dependency>
    27.             <groupId>org.projectlombok</groupId>
    28.             <artifactId>lombok</artifactId>
    29.             <optional>true</optional>
    30.         </dependency>
    31.         <dependency>
    32.             <groupId>org.springframework.boot</groupId>
    33.             <artifactId>spring-boot-starter-test</artifactId>
    34.             <scope>test</scope>
    35.         </dependency>
    36.  
    37. <!--        <dependency>-->
    38. <!--            <groupId>org.springframework.boot</groupId>-->
    39. <!--            <artifactId>spring-boot-devtools</artifactId>-->
    40. <!--        </dependency>-->
    41.  
    42.  
    43.         <!--解决加了@ConfigurationProperties注解 类上的提示-->
    44.         <dependency>
    45.             <groupId>org.springframework.boot</groupId>
    46.             <artifactId>spring-boot-configuration-processor</artifactId>
    47.         </dependency>
    48.  
    49.         <dependency>
    50.             <groupId>org.springframework.boot</groupId>
    51.             <artifactId>spring-boot-starter-quartz</artifactId>
    52.         </dependency>
    53.  
    54.         <dependency>
    55.             <groupId>org.projectlombok</groupId>
    56.             <artifactId>lombok</artifactId>
    57.             <optional>true</optional>
    58.         </dependency>
    59.         <dependency>
    60.             <groupId>org.springframework.boot</groupId>
    61.             <artifactId>spring-boot-starter-test</artifactId>
    62.             <scope>test</scope>
    63.         </dependency>
    64.     </dependencies>
    65.  
    66.     <build>
    67.         <plugins>
    68.             <plugin>
    69.                 <groupId>org.springframework.boot</groupId>
    70.                 <artifactId>spring-boot-maven-plugin</artifactId>
    71.                 <configuration>
    72.                     <image>
    73.                         <builder>paketobuildpacks/builder-jammy-base:latest</builder>
    74.                     </image>
    75.                     <excludes>
    76.                         <exclude>
    77.                             <groupId>org.projectlombok</groupId>
    78.                             <artifactId>lombok</artifactId>
    79.                         </exclude>
    80.                     </excludes>
    81.                 </configuration>
    82.             </plugin>
    83.         </plugins>
    84.     </build>

    application.properties

    1. spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
    2. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    3. spring.datasource.url=jdbc:mysql://localhost:3306/job3?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=false&rewriteBatchedStatements=true
    4. spring.datasource.username=root
    5. spring.datasource.password=123456
    6. #
    7. #
    8.  
    9. #
    10. #mybatis-plus.configuration.map-underscore-to-camel-case=true
    11. #
    12. #mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
    13. #
    14. #
    15. #mybatis-plus.global-config.db-config.table-prefix=tbl_
    16. #
    17. #
    18. #mybatis-plus.global-config.db-config.id-type=auto
    19.  
    20.  
    21. # 定时任务Quartz的数据源配置
    22. spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.URL=jdbc:mysql://localhost:3306/job3?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=false
    23. spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.driver=com.mysql.cj.jdbc.Driver
    24. spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.maxConnections=5
    25. spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.username=root
    26. spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.password=123456
    27. spring.quartz.properties.org.quartz.dataSource.globalJobDataSource.provider=hikaricp
    28.  
    29. # Quartz调度器配置
    30. spring.quartz.properties.org.quartz.scheduler.instanceName=globalScheduler
    31. spring.quartz.properties.org.quartz.scheduler.instanceId=AUTO
    32. spring.quartz.properties.org.quartz.scheduler.type=com.alibaba.druid.pool.DruidDataSource
    33.  
    34. # Quartz作业存储配置
    35. spring.quartz.properties.org.quartz.jobStore.dataSource=globalJobDataSource
    36. spring.quartz.properties.org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
    37. spring.quartz.properties.org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
    38. spring.quartz.properties.org.quartz.jobStore.tablePrefix=QRTZ_
    39. spring.quartz.properties.org.quartz.jobStore.misfireThreshold=100
    40. spring.quartz.properties.org.quartz.jobStore.isClustered=true
    41.  
    42. # Quartz线程池配置
    43. spring.quartz.properties.org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
    44. spring.quartz.properties.org.quartz.threadPool.threadCount=10
    45. spring.quartz.properties.org.quartz.threadPool.threadPriority=5

    包结构

    实体类

    1. package com.example.springbootquartz.pojo;
    2.  
    3. import lombok.AllArgsConstructor;
    4. import lombok.Data;
    5. import lombok.NoArgsConstructor;
    6. import lombok.experimental.Accessors;
    7.  
    8. /**
    9.  * @author hrui
    10.  * @date 2023/11/16 22:57
    11.  */
    12. @Data
    13. @NoArgsConstructor
    14. @AllArgsConstructor
    15. @Accessors(chain = true)
    16. public class JobInfo {
    17.  
    18.     /**
    19.      * 任务名称
    20.      */
    21.     private String jobName;
    22.     /**
    23.      * 任务组
    24.      */
    25.     private String jobGroup;
    26.     /**
    27.      * 触发器名称
    28.      */
    29.     private String triggerName;
    30.     /**
    31.      * 触发器组
    32.      */
    33.     private String triggerGroup;
    34.     /**
    35.      * cron表达式
    36.      */
    37.     private String cron;
    38.     /**
    39.      * 类名
    40.      */
    41.     private String className;
    42.     /**
    43.      * 状态
    44.      */
    45.     private String status;
    46.     /**
    47.      * 下一次执行时间
    48.      */
    49.     private String nextTime;
    50.     /**
    51.      * 上一次执行时间
    52.      */
    53.     private String prevTime;
    54.     /**
    55.      * 配置信息(data)
    56.      */
    57.     private String config;
    58.  
    59. }
    1. package com.example.springbootquartz.job;
    2.  
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.example.springbootquartz.pojo.JobInfo;
    5. import org.quartz.*;
    6.  
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.stereotype.Component;
    9.  
    10. import javax.annotation.Resource;
    11. import java.util.List;
    12. import java.util.Objects;
    13.  
    14. /**
    15.  * @author hrui
    16.  * @date 2023/11/16 23:10
    17.  */
    18. @Component
    19. public class SchedulerManage {
    20.  
    21.     @Autowired
    22.     private Scheduler scheduler;
    23.  
    24.     /**
    25.      * 添加任务
    26.      */
    27.     @SuppressWarnings("unchecked")
    28.     public void addJob(JobInfo jobInfo) throws SchedulerException, ClassNotFoundException {
    29.         Objects.requireNonNull(jobInfo, "任务信息不能为空");
    30.  
    31.         // 生成job key
    32.         JobKey jobKey = JobKey.jobKey(jobInfo.getJobName(), jobInfo.getJobGroup());
    33.         // 当前任务不存在才进行添加
    34.         if (!scheduler.checkExists(jobKey)) {
    35.             Class<Job> jobClass = (Class<Job>)Class.forName(jobInfo.getClassName());
    36.             // 任务明细
    37.             JobDetail jobDetail = JobBuilder
    38.                     .newJob(jobClass)
    39.                     .withIdentity(jobKey)
    40.                     .withIdentity(jobInfo.getJobName(), jobInfo.getJobGroup())
    41.                     .withDescription(jobInfo.getJobName())
    42.                     .build();
    43.             // 配置信息
    44.             jobDetail.getJobDataMap().put("config", jobInfo.getConfig());
    45.             // 定义触发器
    46.             TriggerKey triggerKey = TriggerKey.triggerKey(jobInfo.getTriggerName(), jobInfo.getTriggerGroup());
    47.             // 设置任务的触发机制
    48.             Trigger trigger = TriggerBuilder.newTrigger()
    49.                     .withIdentity(triggerKey)
    50.                     .withSchedule(CronScheduleBuilder.cronSchedule(jobInfo.getCron()).withMisfireHandlingInstructionDoNothing())
    51.                     .build();
    52.             scheduler.scheduleJob(jobDetail, trigger);
    53.         } else {
    54.             throw new SchedulerException(jobInfo.getJobName() + "任务已存在，无需重复添加");
    55.         }
    56.     }
    57.  
    58.     /**
    59.      * 任务暂停
    60.      */
    61.     public void pauseJob(String jobGroup, String jobName) throws SchedulerException {
    62.         JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    63.         if (scheduler.checkExists(jobKey)) {
    64.             scheduler.pauseJob(jobKey);
    65.         }
    66.     }
    67.  
    68.     /**
    69.      * 继续任务
    70.      */
    71.     public void continueJob(String jobGroup, String jobName) throws SchedulerException {
    72.         JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    73.         if (scheduler.checkExists(jobKey)) {
    74.             scheduler.resumeJob(jobKey);
    75.         }
    76.     }
    77.  
    78.     /**
    79.      * 删除任务
    80.      */
    81.     public boolean deleteJob(String jobGroup, String jobName) throws SchedulerException {
    82.         JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    83.         if (scheduler.checkExists(jobKey)) {
    84.             // 这里还需要先删除trigger相关
    85.             //TriggerKey triggerKey = TriggerKey.triggerKey(jobInfo.getTriggerName(), jobInfo.getTriggerGroup());
    86.             //scheduler.getTrigger()
    87.             //scheduler.rescheduleJob()
    88.             return scheduler.deleteJob(jobKey);//不需要删除trigger 一个job可以有多个trigger 删除job同时源码底层会删除对应trigger
    89.         }
    90.         return false;
    91.     }
    92.  
    93.     /**
    94.      * 获取任务信息
    95.      */
    96.     public JobInfo getJobInfo(String jobGroup, String jobName) throws SchedulerException {
    97.         JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    98.         if (!scheduler.checkExists(jobKey)) {
    99.             return null;
    100.         }
    101.         List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
    102.         if (Objects.isNull(triggers)) {
    103.             throw new SchedulerException("未获取到触发器信息");
    104.         }
    105.         TriggerKey triggerKey = triggers.get(0).getKey();
    106.         Trigger.TriggerState triggerState = scheduler.getTriggerState(triggerKey);
    107.         JobDetail jobDetail = scheduler.getJobDetail(jobKey);
    108.  
    109.         JobInfo jobInfo = new JobInfo();
    110.         jobInfo.setJobName(jobGroup);
    111.         jobInfo.setJobGroup(jobName);
    112.         jobInfo.setTriggerName(triggerKey.getName());
    113.         jobInfo.setTriggerGroup(triggerKey.getGroup());
    114.         jobInfo.setClassName(jobDetail.getJobClass().getName());
    115.         jobInfo.setStatus(triggerState.toString());
    116.  
    117.         if (Objects.nonNull(jobDetail.getJobDataMap())) {
    118.             jobInfo.setConfig(JSONObject.toJSONString(jobDetail.getJobDataMap()));
    119.         }
    120.  
    121.         CronTrigger theTrigger = (CronTrigger) triggers.get(0);
    122.         jobInfo.setCron(theTrigger.getCronExpression());
    123.         return jobInfo;
    124.     }
    125.  
    126. }

    1. package com.example.springbootquartz.job;
    2.  
    3. import org.quartz.DisallowConcurrentExecution;
    4. import org.quartz.JobExecutionContext;
    5. import org.quartz.PersistJobDataAfterExecution;
    6. import org.springframework.boot.context.properties.ConfigurationProperties;
    7. import org.springframework.scheduling.quartz.QuartzJobBean;
    8.  
    9. import java.text.DateFormat;
    10. import java.text.SimpleDateFormat;
    11. import java.time.LocalDateTime;
    12. import java.util.Date;
    13.  
    14. /**
    15.  * @author hrui
    16.  * @date 2023/11/16 22:58
    17.  */
    18. @DisallowConcurrentExecution//避免并发执行
    19. @PersistJobDataAfterExecution//Job状态
    20. public class QuartzJob1 extends QuartzJobBean {
    21.  
    22.     @Override
    23.     protected void executeInternal(JobExecutionContext context) {
    24.         System.out.println("QuartzJob1正在执行..."+getTime());
    25.  
    26.     }
    27.  
    28.     private String getTime(){
    29.         DateFormat dateFormat=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss:SSS");
    30.         return dateFormat.format(new Date());
    31.     }
    32.  
    33. }

    控制器

    1. package com.example.springbootquartz.controller;
    2.  
    3. import com.example.springbootquartz.job.SchedulerManage;
    4. import com.example.springbootquartz.pojo.JobInfo;
    5. import org.quartz.*;
    6. import org.quartz.impl.StdScheduler;
    7. import org.quartz.impl.matchers.GroupMatcher;
    8. import org.springframework.beans.factory.annotation.Autowired;
    9. import org.springframework.scheduling.quartz.SchedulerFactoryBean;
    10. import org.springframework.web.bind.annotation.*;
    11.  
    12. import javax.annotation.Resource;
    13. import java.util.ArrayList;
    14. import java.util.List;
    15. import java.util.Set;
    16.  
    17. /**
    18.  * @author hrui
    19.  * @date 2023/11/16 23:13
    20.  */
    21. @RestController
    22. @RequestMapping("/job")
    23. public class QuartzController {
    24.  
    25.     @Autowired
    26.     private SchedulerManage schedulerManage;
    27.     @Autowired
    28.     private Scheduler scheduler;
    29.     //StdScheduler
    30.     @Autowired
    31.     private SchedulerFactoryBean SchedulerFactoryBean;
    32.     /**
    33.      * 查询所有的任务
    34.      */
    35.     @RequestMapping("/all")
    36.     public List list() throws SchedulerException {
    37.         List jobInfos = new ArrayList<>();
    38.         List triggerGroupNames = scheduler.getTriggerGroupNames();
    39.         for (String triggerGroupName : triggerGroupNames) {
    40.             Set triggerKeySet = scheduler
    41.                     .getTriggerKeys(GroupMatcher.triggerGroupEquals(triggerGroupName));
    42.             for (TriggerKey triggerKey : triggerKeySet) {
    43.                 Trigger trigger = scheduler.getTrigger(triggerKey);
    44.                 JobKey jobKey = trigger.getJobKey();
    45.                 JobInfo jobInfo = schedulerManage.getJobInfo(jobKey.getGroup(), jobKey.getName());
    46.                 jobInfos.add(jobInfo);
    47.             }
    48.         }
    49.         return jobInfos;
    50.     }
    51.  
    52.     /**
    53.      * 添加任务
    54.      */
    55.     @PostMapping("/add")
    56.     public JobInfo addJob(@RequestBody JobInfo jobInfo) throws SchedulerException, ClassNotFoundException {
    57.         schedulerManage.addJob(jobInfo);
    58.         return jobInfo;
    59.     }
    60.  
    61.     /**
    62.      * 暂停任务
    63.      */
    64.     @RequestMapping("/pause")
    65.     public void pauseJob(@RequestParam("jobGroup") String jobGroup, @RequestParam("jobName") String jobName)
    66.             throws SchedulerException {
    67.         schedulerManage.pauseJob(jobGroup, jobName);
    68.     }
    69.  
    70.     /**
    71.      * 继续任务
    72.      */
    73.     @RequestMapping("/continue")
    74.     public void continueJob(@RequestParam("jobGroup") String jobGroup, @RequestParam("jobName") String jobName)
    75.             throws SchedulerException {
    76.         schedulerManage.continueJob(jobGroup, jobName);
    77.     }
    78.  
    79.     /**
    80.      * 删除任务
    81.      */
    82.     @RequestMapping("/delete")
    83.     public boolean deleteJob(@RequestParam("jobGroup") String jobGroup, @RequestParam("jobName") String jobName)
    84.             throws SchedulerException {
    85.         return schedulerManage.deleteJob(jobGroup, jobName);
    86.     }
    87.  
    88. }

    {

        "jobName":"job1",

        "jobGroup":"group1",

        "triggerName":"trigger1",

        "triggerGroup":"tGroup1",

        "cron":"*/5 * * * * ?",

        "className":"com.example.springbootquartz.job.QuartzJob1"

    }

  • 相关阅读:
    电脑技巧：Win7、Win10、Win11如何选择，看完你就懂了
    GoLang设计模式21 - 装饰模式
    Qt实战案例（55）——利用QDir删除选定文件目录下的空文件夹
    Python Wordcloud报错：Only supported for TrueType fonts，多种解决方案
    （经验贴）怎么对HTML文件进行分析
    Java学习笔记——Iterator
    Kafka学习之：mac 上基础使用 python 来使用 kafka 的生产者和消费者进行数据处理
    这8种算法——程序员必会
    Java基础实现加油站圈存机系统
    Kata3.0.0 x LifseaOS x 龙蜥内核三管齐下！带你体验最新的安全容器之旅
  • 原文地址：https://blog.csdn.net/tiantiantbtb/article/details/134454167