更新quartz的使用方式

Author: JavaCodeMing

Spring-Boot-Quartz/src/main/java/com/example/quartz/config/SchedulerConfig.java

@@ -48,6 +48,5 @@ public QuartzInitializerListener initializerListener() {
     @Bean("scheduler")
     public Scheduler scheduler() throws IOException {
         return schedulerFactoryBean().getScheduler();
-
     }
 }

Spring-Boot-Quartz/src/main/java/com/example/quartz/entity/JobAndTrigger.java

@@ -67,7 +67,7 @@ public void setTriggerGroup(String triggerGroup) {
     }
 
     public Date getStartTime() {
-        return startTime;
+        return startTime != null ? startTime : new Date();
     }
 
     public void setStartTime(Date startTime) {

Spring-Boot-Quartz/src/main/java/com/example/quartz/job/BaseJob.java

@@ -1,13 +1,10 @@
 package com.example.quartz.job;
 
-import org.quartz.Job;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
+import org.springframework.scheduling.quartz.QuartzJobBean;
 
 /**
  * Created by dengzhiming on 2019/8/1
  */
-public interface BaseJob extends Job {
-    @Override
-    void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException;
+public abstract class BaseJob extends QuartzJobBean {
+
 }

Spring-Boot-Quartz/src/main/java/com/example/quartz/job/HelloJob.java

@@ -10,15 +10,11 @@
 /**
  * Created by dengzhiming on 2019/8/1
  */
-public class HelloJob implements BaseJob {
+public class HelloJob extends BaseJob {
 
     private static Logger logger = LoggerFactory.getLogger(HelloJob.class);
-
-    public HelloJob() {
-    }
-
     @Override
-    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
         logger.info("HelloJob执行时间: " + new Date());
     }
 }

Spring-Boot-Quartz/src/main/java/com/example/quartz/job/NewJob.java

@@ -10,15 +10,11 @@
 /**
  * Created by dengzhiming on 2019/8/1
  */
-public class NewJob implements BaseJob {
+public class NewJob extends BaseJob {
 
     private static Logger logger = LoggerFactory.getLogger(NewJob.class);
-
-    public NewJob() {
-    }
-
     @Override
-    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
         logger.info("NewJob执行的时间: " + new Date());
     }
 }

Spring-Boot-Quartz/src/main/resources/application.properties

@@ -2,6 +2,8 @@ server:
   port: 8080
 
 spring:
+  application:
+    name: springboot-quartz
   datasource:
     druid:
       type: com.alibaba.druid.pool.DruidDataSource
@@ -62,7 +64,18 @@ spring:
         wall:
           config:
             multi-statement-allow: true
-
+  quartz:
+    #数据库方式
+    job-store-type: jdbc
+    #scheduler执行器的名称
+    scheduler-name: ${spring.application.name}
+    #是否覆盖已存在的任务
+    overwrite-existing-jobs: off
+    #延迟启动时间
+    startup-delay: 500ms
+    #初始化表结构
+    jdbc:
+      initialize-schema: never
 
 mybatis:
   # mapper xml实现扫描路径
@@ -74,4 +87,4 @@ mybatis:
     #   1.logging.level.yourdaoclasspackagename=debug (指定某个包下的SQL打印出来)
     #   2.mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
     #     (所有包下的SQL都会打印出来)
-    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

Spring-Boot-Quartz/src/main/resources/application.yml

@@ -1,33 +1,37 @@
-# ThreadPool实现的名称(Quartz附带的线程池是"org.quartz.simpl.SimpleThreadPool")
+# ThreadPool实现的名称(Quartz自带线程池是"org.quartz.simpl.SimpleThreadPool")
 org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
 # threadCount和threadPriority将以setter的形式注入ThreadPool实例
 # 可用于并发执行作业的线程数(只有1到100之间的数字是非常实用的)
 org.quartz.threadPool.threadCount=5
 # 线程的优先级,默认值为5
 org.quartz.threadPool.threadPriority=5
-#是否继承初始化线程的上下文加载器类,默认为false。
+#是否继承初始化线程的上下文加载器类,默认为false
 org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread=true
-#调度程序在被认为是"misfired"之前将"容忍"触发器到下一次触发时间的毫秒数(默认60000)
-org.quartz.jobStore.misfireThreshold=5000
+
 # 默认存储在内存中,RAMJobStore快速轻便,但是当进程终止时,所有调度信息都会丢失
 #org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
-#持久化
+# 持久化
 org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
-#您需要为JobStore选择一个DriverDelegate才能使用。DriverDelegate负责执行特定数据库可能需要的任何JDBC工作。
-# StdJDBCDelegate是一个使用“vanilla”JDBC代码（和SQL语句）来执行其工作的委托,用于完全符合JDBC的驱动程序
+# DriverDelegate负责执行特定数据库可能需要的任何JDBC工作,需为JobStore选择一个DriverDelegate才能使用
+# StdJDBCDelegate是一个使用“vanilla”JDBC代码(和SQL语句)来执行其工作的委托,用于完全符合JDBC的驱动程序
 org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
-#可以将“org.quartz.jobStore.useProperties”配置参数设置为“true”(默认为false)以指示JDBCJobStore将JobDataMaps中的所有值都作为字符串,
-# 因此可以作为名称 - 值对存储而不是在BLOB列中以其序列化形式存储更多复杂的对象
+# 调度程序在被认为是"misfired"之前将"容忍"触发器到下一次触发时间的毫秒数(默认60000)
+org.quartz.jobStore.misfireThreshold=5000
+# 将该配置参数设置为“true”(默认为false)用以指示JDBCJobStore将JobDataMaps中的所有值都作为字符串
 org.quartz.jobStore.useProperties=true
-#表前缀
+# 表前缀
 org.quartz.jobStore.tablePrefix=QRTZ_
-#设置JobStore使用哪个DataSource
+# 设置为"true"以打开群集功能;若有多个Quartz实例使用同一组数据库表,则此属性必须设置为"true"
+#org.quartz.jobStore.isClustered=false
+#org.quartz.jobStore.clusterCheckinInterval:10000
+
+# 设置JobStore使用哪个DataSource
 org.quartz.jobStore.dataSource=qzDS
 org.quartz.dataSource.qzDS.driver=com.mysql.cj.jdbc.Driver
 org.quartz.dataSource.qzDS.URL=jdbc:mysql://localhost:3306/quartz?serverTimezone=GMT%2B8
 org.quartz.dataSource.qzDS.user=root
 org.quartz.dataSource.qzDS.password=root
 org.quartz.dataSource.qzDS.maxConnections=10
-#设置为“true”以打开群集功能;如果您有多个Quartz实例使用同一组数据库表,则此属性必须设置为“true”
-#org.quartz.jobStore.isClustered=false
-#配置集群参见:  https://www.w3cschool.cn/quartz_doc/quartz_doc-3x7u2doc.html
+
+
+#配置集群参见:  https://www.w3cschool.cn/quartz_doc/quartz_doc-3x7u2doc.html