修改

Author: ToQuery

pom.xml

@@ -19,10 +19,6 @@
     </properties>
 
     <dependencies>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-webflux</artifactId>
-        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-quartz</artifactId>

src/main/java/io/github/toquery/example/quartz/AppJobListener.java

@@ -0,0 +1,32 @@
+package io.github.toquery.example.quartz;
+
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.JobListener;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+public class AppJobListener implements JobListener {
+
+    @Override
+    public String getName() {
+        return "App Listener";
+    }
+
+    @Override
+    public void jobToBeExecuted(JobExecutionContext context) {
+        log.info("Job to be executed {}", context.getJobDetail().getKey().getName());
+    }
+
+    @Override
+    public void jobExecutionVetoed(JobExecutionContext context) {
+        log.info("Job execution vetoed {}", context.getJobDetail().getKey().getName());
+    }
+
+    @Override
+    public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
+        log.info("Job was executed {} {}", context.getJobDetail().getKey().getName(), (jobException != null ? ", with error" : ""));
+    }
+}

src/main/java/io/github/toquery/example/quartz/ExampleQuartzApplication.java

@@ -2,7 +2,13 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+import javax.sql.DataSource;
+
+// @EnableScheduling
 @SpringBootApplication
 public class ExampleQuartzApplication {
 

src/main/java/io/github/toquery/example/quartz/JobSpringQuartz.java

@@ -0,0 +1,23 @@
+package io.github.toquery.example.quartz;
+
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.DisallowConcurrentExecution;
+import org.quartz.Job;
+import org.quartz.JobDataMap;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.PersistJobDataAfterExecution;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+//@PersistJobDataAfterExecution
+@DisallowConcurrentExecution
+@Component
+public class JobSpringQuartz extends QuartzJobBean implements Job {
+
+    @Override
+    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        log.info(" Job Spring Quartz ");
+    }
+}

src/main/java/io/github/toquery/example/quartz/JobTwo.java

@@ -0,0 +1,21 @@
+package io.github.toquery.example.quartz;
+
+import org.quartz.DisallowConcurrentExecution;
+import org.quartz.Job;
+import org.quartz.JobDataMap;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.PersistJobDataAfterExecution;
+import org.springframework.stereotype.Component;
+
+@PersistJobDataAfterExecution
+@DisallowConcurrentExecution
+@Component
+public class JobTwo implements Job {
+    @Override
+    public void execute(JobExecutionContext context) throws JobExecutionException {
+        JobDataMap data = context.getTrigger().getJobDataMap();
+        String invokeParam = (String) data.get("invokeParam");
+        //在这里实现业务逻辑
+    }
+}

src/main/java/io/github/toquery/example/quartz/QuartzSchedulerConfig.java

@@ -0,0 +1,28 @@
+package io.github.toquery.example.quartz;
+
+import org.quartz.JobDetail;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.quartz.CronTriggerFactoryBean;
+import org.springframework.scheduling.quartz.JobDetailFactoryBean;
+
+@Configuration
+public class QuartzSchedulerConfig {
+
+    @Bean
+    public CronTriggerFactoryBean job1Trigger(JobDetail jobDetail) {
+        CronTriggerFactoryBean cronTriggerFactoryBean = new CronTriggerFactoryBean();
+        cronTriggerFactoryBean.setJobDetail(jobDetail);
+        cronTriggerFactoryBean.setCronExpression("0/15 * * * * ?");
+        return cronTriggerFactoryBean;
+    }
+
+    @Bean
+    public JobDetailFactoryBean job1Detail() {
+        JobDetailFactoryBean jobDetailFactoryBean = new JobDetailFactoryBean();
+        jobDetailFactoryBean.setJobClass(JobSpringQuartz.class);
+        jobDetailFactoryBean.setDurability(true);
+        return jobDetailFactoryBean;
+    }
+}

src/main/java/io/github/toquery/example/quartz/ScheduledTask.java

@@ -11,22 +11,12 @@ public class ScheduledTask {
 
 
     private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-    private Integer count0 = 1;
-    private Integer count1 = 1;
-    private Integer count2 = 1;
+    private Integer count = 1;
 
-    @Scheduled(fixedRate = 5000)
-    public void reportCurrentTime() throws InterruptedException {
-        System.out.println(String.format("reportCurrentTime第%s次执行，当前时间为：%s", count0++, dateFormat.format(new Date())));
-    }
 
-    @Scheduled(fixedDelay = 5000)
-    public void reportCurrentTimeAfterSleep() throws InterruptedException {
-        System.out.println(String.format("reportCurrentTimeAfterSleep第%s次执行，当前时间为：%s", count1++, dateFormat.format(new Date())));
+    @Scheduled(cron = "0/5 * * * * ?")
+    public void reportCurrentTime() throws InterruptedException {
+        System.out.println(String.format(" reportCurrentTime 第 %s 次执行，当前时间为：%s", count++, dateFormat.format(new Date())));
     }
 
-    @Scheduled(cron = "0 0 1 * * *")
-    public void reportCurrentTimeCron() throws InterruptedException {
-        System.out.println(String.format("reportCurrentTimeCron第%s次执行，当前时间为：%s", count2++, dateFormat.format(new Date())));
-    }
 }

src/main/resources/application.yml

@@ -1,3 +1,5 @@
+server:
+  port: 0
 
 spring:
   application:
@@ -25,9 +27,10 @@ spring:
     jdbc:
       initialize-schema: ALWAYS
     scheduler-name: example-quartz
-#    properties:
-#      org.quartz.scheduler.instanceName: quartz-demo-app
-#      org.quartz.scheduler.instanceId: AUTO
+    properties:
+      org.quartz.jobStore.isClustered: true
+      #      org.quartz.scheduler.instanceName: quartz-demo-app
+      org.quartz.scheduler.instanceId: AUTO
 #      # org.quartz.scheduler.instanceIdGenerator.class: com.helixz.quartz.demo.component.CustomQuartzInstanceIdGenerator
 #      # 并发数
 #      org.quartz.threadPool.threadCount: 20
@@ -52,3 +55,4 @@ spring:
 #============================================================================# 配置ThreadPool#============================================================================# 线程池的实现类（一般使用SimpleThreadPool即可满足几乎所有用户的需求）org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
 # 指定线程数，一般设置为1-100直接的整数，根据系统资源配置org.quartz.threadPool.threadCount = 5
 # 设置线程的优先级(可以是Thread.MIN_PRIORITY（即1）和Thread.MAX_PRIORITY（这是10）之间的任何int 。默认值为Thread.NORM_PRIORITY（5）。)org.quartz.threadPool.threadPriority = 5
+