2. 程式人生 > >springboot整合Quartz實現動態配置定時任務

springboot整合Quartz實現動態配置定時任務

阿新 • • 發佈：2018-08-05
打印 uil xtra serve mail evel .com 指定 obs

前言

在我們日常的開發中，很多時候，定時任務都不是寫死的，而是寫到數據庫中，從而實現定時任務的動態配置，下面就通過一個簡單的示例，來實現這個功能。

一、新建一個springboot工程，並添加依賴

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

    <dependency><!-- 為了方便測試，此處使用了內存數據庫 -->
        <groupId>com.h2database</groupId>
        <artifactId>h2</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>

    <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.1</version>
        <exclusions>
            <exclusion>
                <artifactId>slf4j-api</artifactId>
                <groupId>org.slf4j</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency><!-- 該依賴必加，裏面有sping對schedule的支持 -->
                   <groupId>org.springframework</groupId>
                   <artifactId>spring-context-support</artifactId>
    </dependency>

二、配置文件application.properties

服務器端口號
server.port=7902
是否生成ddl語句
spring.jpa.generate-ddl=false
是否打印sql語句
spring.jpa.show-sql=true
自動生成ddl，由於指定了具體的ddl，此處設置為none
spring.jpa.hibernate.ddl-auto=none
使用H2數據庫
spring.datasource.platform=h2
指定生成數據庫的schema文件位置
spring.datasource.schema=classpath:schema.sql

指定插入數據庫語句的腳本位置
spring.datasource.data=classpath:data.sql
配置日誌打印信息
logging.level.root=INFO
logging.level.org.hibernate=INFO
logging.level.org.hibernate.type.descriptor.sql.BasicBinder=TRACE
logging.level.org.hibernate.type.descriptor.sql.BasicExtractor=TRACE
logging.level.com.itmuch=DEBUG

三、Entity類

package com.chhliu.springboot.quartz.entity;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

@Entity
public class Config {@Id
br/>@Id
private Long id;

  @Column
  private String cron;

/**
 * @return the id
 */
public Long getId() {
    return id;
}
    ……此處省略getter和setter方法……

}

四、任務類

package com.chhliu.springboot.quartz.entity;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.stereotype.Component;

@Configuration
@Component // 此註解必加
@EnableScheduling // 此註解必加
public class ScheduleTask {
private static final Logger LOGGER = LoggerFactory.getLogger(ScheduleTask.class);
public void sayHello(){
LOGGER.info("Hello world, i‘m the king of the world!!!");
}
}

五、Quartz配置類

由於springboot追求零xml配置，所以下面會以配置Bean的方式來實現

package com.chhliu.springboot.quartz.entity;

import org.quartz.Trigger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.CronTriggerFactoryBean;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

@Configuration
public class QuartzConfigration {
/**

  • attention:

  • Details：配置定時任務
    /
    @Bean(name = "jobDetail")
    public MethodInvokingJobDetailFactoryBean detailFactoryBean(ScheduleTask task) {// ScheduleTask為需要執行的任務
    MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
    /

    • 是否並發執行
    • 例如每5s執行一次任務，但是當前任務還沒有執行完，就已經過了5s了，

    • 如果此處為true，則下一個任務會執行，如果此處為false，則下一個任務會等待上一個任務執行完後，再開始執行
      */
      jobDetail.setConcurrent(false);

      jobDetail.setName("srd-chhliu");// 設置任務的名字
      jobDetail.setGroup("srd");// 設置任務的分組，這些屬性都可以存儲在數據庫中，在多任務的時候使用

      /*

    • 為需要執行的實體類對應的對象
      */
      jobDetail.setTargetObject(task);

      /*

    • sayHello為需要執行的方法
    • 通過這幾個配置，告訴JobDetailFactoryBean我們需要執行定時執行ScheduleTask類中的sayHello方法
      */
      jobDetail.setTargetMethod("sayHello");
      return jobDetail;
      }

    /**

  • attention:

  • Details：配置定時任務的觸發器，也就是什麽時候觸發執行定時任務
    /
    @Bean(name = "jobTrigger")
    public CronTriggerFactoryBean cronJobTrigger(MethodInvokingJobDetailFactoryBean jobDetail) {
    CronTriggerFactoryBean tigger = new CronTriggerFactoryBean();
    tigger.setJobDetail(jobDetail.getObject());
    tigger.setCronExpression("0 30 20     * ?");// 初始時的cron表達式
    tigger.setName("srd-chhliu");// trigger的name
    return tigger;

    }

    /**

  • attention:
  • Details：定義quartz調度工廠
    */
    @Bean(name = "scheduler")
    public SchedulerFactoryBean schedulerFactory(Trigger cronJobTrigger) {
    SchedulerFactoryBean bean = new SchedulerFactoryBean();
    // 用於quartz集群,QuartzScheduler 啟動時更新己存在的Job
    bean.setOverwriteExistingJobs(true);
    // 延時啟動，應用啟動1秒後
    bean.setStartupDelay(1);
    // 註冊觸發器
    bean.setTriggers(cronJobTrigger);
    return bean;
    }
    }

    六、定時查庫，並更新任務

    package com.chhliu.springboot.quartz.entity;

import javax.annotation.Resource;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.chhliu.springboot.quartz.repository.ConfigRepository;

@Configuration@EnableScheduling
br/>@EnableScheduling
public class ScheduleRefreshDatabase {@Autowired
br/>@Autowired

@Resource(name = "jobDetail")
private JobDetail jobDetail;

@Resource(name = "jobTrigger")
private CronTrigger cronTrigger;

@Resource(name = "scheduler")
private Scheduler scheduler;

@Scheduled(fixedRate = 5000) // 每隔5s查庫，並根據查詢結果決定是否重新設置定時任務
public void scheduleUpdateCronTrigger() throws SchedulerException {
    CronTrigger trigger = (CronTrigger) scheduler.getTrigger(cronTrigger.getKey());
    String currentCron = trigger.getCronExpression();// 當前Trigger使用的
    String searchCron = repository.findOne(1L).getCron();// 從數據庫查詢出來的
    System.out.println(currentCron);
    System.out.println(searchCron);
    if (currentCron.equals(searchCron)) {
        // 如果當前使用的cron表達式和從數據庫中查詢出來的cron表達式一致，則不刷新任務
    } else {
        // 表達式調度構建器
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(searchCron);
        // 按新的cronExpression表達式重新構建trigger
        trigger = (CronTrigger) scheduler.getTrigger(cronTrigger.getKey());
        trigger = trigger.getTriggerBuilder().withIdentity(cronTrigger.getKey())
                .withSchedule(scheduleBuilder).build();
        // 按新的trigger重新設置job執行
        scheduler.rescheduleJob(cronTrigger.getKey(), trigger);
        currentCron = searchCron;
    }
}

}

七、相關腳本

1、data.sql

insert into config(id,cron) values(1,‘0 0/2 * ?‘); # 每2分鐘執行一次定時任務
2、schema.sql
drop table config if exists;
create table config(
id bigint generated by default as identity,
cron varchar(40),
primary key(id)
);

八、運行測試

測試結果如下：(Quartz默認的線程池大小為10)

0 30 20 ?
0 0/2 * ?
2017-03-08 18:02:00.025 INFO 5328 --- [eduler_Worker-1] c.c.s.quartz.entity.ScheduleTask : Hello world, i‘m the king of the world!!!
2017-03-08 18:04:00.003 INFO 5328 --- [eduler_Worker-2] c.c.s.quartz.entity.ScheduleTask : Hello world, i‘m the king of the world!!!
2017-03-08 18:06:00.002 INFO 5328 --- [eduler_Worker-3] c.c.s.quartz.entity.ScheduleTask : Hello world, i‘m the king of the world!!!
2017-03-08 18:08:00.002 INFO 5328 --- [eduler_Worker-4] c.c.s.quartz.entity.ScheduleTask : Hello world, i‘m the king of the world!!!

總結：

從上面的日誌打印時間來看，我們實現了動態配置，最初的時候，任務是每天20:30執行，後面通過動態刷新變成了每隔2分鐘執行一次。
雖然上面的解決方案沒有使用Quartz推薦的方式完美，但基本上可以滿足我們的需求，當然也可以采用觸發事件的方式來實現，例如當前端修改定時任務的觸發時間時，異步的向後臺發送通知，後臺收到通知後，然後再更新程序，也可以實現動態的定時任務刷新

springboot整合Quartz實現動態配置定時任務

相關推薦

springboot整合Quartz實現動態配置定時任務

打印 uil xtra serve mail evel .com 指定 obs 前言 在我們日常的開發中，很多時候，定時任務都不是寫死的，而是寫到數據庫中，從而實現定時任務的動態配置，下面就通過一個簡單的示例，來實現這個功能。 一、新建一個springboot工程，並添加依

SpringBoot系列5-定時任務-springboot整合quartz實現動態定時任務

springboot有自帶的定時任務為什麼還要使用quartz 使用springboot自帶的定時任務可以很簡單很方便的完成一些簡單的定時任務，但是我們想動態的執行我們的定時任務就比較困難了。然而使用quartz卻可以很容易的管理我們的定時任務，很容易動態的操作定時任務。下面我們就講解下

springboot-整合quartz：做分散式定時任務

springboot-整合quartz：做分散式定時任務 文章目錄 springboot-整合quartz：做分散式定時任務 1.quartz應用場景 2配置 3.測試 完

Spring+Quartz實現動態新增定時任務（一）

在最近工作中，由於涉及到定時任務特別多，而這些工作又是由下屬去完成的，在生成環境中經常會出現業務邏輯錯誤，分析下來多數是定時任務執行問題，所以就希望把定時任務優化一下，主要實現2個方面1.定時任務動態配置及持久化2.視覺化的管理介面，可以非常清晰的管理自己的所有定時任務首先，

Spring與Quartz實現動態更新定時任務

applicationContext-quartz.xml配置： <!-- 任務排程測試實現一 : 自定義的任務物件com.bocloud.equipment.test.ExampleJob 必須繼承QuartzJobBean類,實現抽象方法executeInter

springboot 整合quartz 建立多個定時任務

1.pom.xml <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId>

springboot動態配置定時任務2種方式，整合Quartz多執行緒併發執行多個定時任務配置

我的專案是採用的idea+gradle+springboot專案構建，下面是springboot實現定時任務所需要的jar包 //定時任務使用 compile group: 'org.quartz-scheduler', name: 'quartz', version:

spring整合quartz實現動態定時任務的前臺網頁配置與管理

在實際專案應用中經常會用到定時任務，可以通過quartz和spring的簡單配置即可完成，但如果要改變任務的執行時間、頻率，廢棄任務等就需要改變配置甚至程式碼需要重啟伺服器，這裡介紹一下如何通過quartz與spring的組合實現動態的改變定時任務的狀態的一個實

SpringBoot整合Elastic-Job，實現動態建立定時任務，任務持久化

SpringBoot使用Elastic-Job-lite，實現動態建立定時任務，任務持久化 Elastic-Job是噹噹開源的一個分散式排程解決方案，由兩個相互獨立的子專案Elastic-Job-Lite和Elastic-Job-Cloud組成。 Elast

Spring-boot整合Quartz，3、動態配置定時任務

通過動態新增JobDetail例項到Scheduler中，實現可配置動態式的定時任務作業 首先實現Job介面的 Myjob，通過包全名（com.example.demo.job.MyJob1），利用反射得到Clazz。 設定JobDetail的名字和組

SpringBoot整合Quartz實現定時任務（單任務、多工)

前言：為了實現如：定時傳送郵件，訂單超時等操作需要使用到任務排程，為了節約自己封裝的時間所以使用Quatrz開源專案來幫助我們實現這些繁雜的操作，Quatrz內部有自己的執行緒池，不需要我們去手動維護執行緒，而且支援cron表示式等，下面我們講解一下使用Springboot2

6. springboot整合quartz實現定時任務

轉載：http://www.cnblogs.com/lic309/p/4089633.html 在做專案時有時候會有定時器任務的功能，比如某某時間應該做什麼，多少秒應該怎麼樣之類的。 spring支援多種定時任務的實現。我們來介紹下使用spring的定時器和使用q

Quartz+Spring Boot實現動態管理定時任務

varchar 設置 ica key equals 修改 lean queryall 觸發器 項目實踐過程中碰到一個動態管理定時任務的需求：針對每個人員進行信息的定時更新，具體更新時間可隨時調整、啟動、暫定等。 思路 將每個人員信息的定時配置保存到數據庫中，這樣實現了任

SpringBoot實現資料庫配置定時任務

spring-boot 2.0.2.RELEASE，將定時任務配置在資料庫，啟動專案的時候，用mybatis讀取資料庫，例項化物件，並設定定時任務。如果需要新增，減少，修改定時任務，僅需要修改資料庫資料，並重啟專案即可，無需改程式碼。 完整原始碼下載  https://download

34. springboot動態配置定時任務（通過資料庫配置）

1、pom.xml檔案 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocat

Spring整合Quartz實現動態定時器

一、版本說明  spring3.1以下的版本必須使用quartz1.x系列，3.1以上的版本才支援quartz 2.x，不然會出錯。  原因：spring對於quartz的支援實現，org.springframework.scheduling.quartz.CronTri

1 springboot之動態配置定時任務

最近專案中有關於springboot中動態配置定時任務的需求，查閱各種資料，最終實現了可以動態的開關定時器，以及配置定時器的時間節點。 網上有很多關於springboot定時任務的介紹，之前專案中也用過quartz，和springboot中自帶的@Schedule相比較,配

springboot整合quartz實現任務排程

quartz 概述 特點 強大的排程功能 靈活的應用方式 分散式和叢集能力 用到的設計模式 Builder 模式 factory模式 元件模式 鏈式寫法 體系結構 排程器 任務

springboot動態配置定時任務時間

springboot 動態配置定時任務時間 需要實現 SchedulingConfigurer 介面 類上新增啟動定時任務註解 @EnableScheduling 新增 @Component 註冊為 bean 例子如下 import org.apa

spring整合Quartz實現動態任務排程

spring整合Quartz跟使用原生的api的區別主要是在於排程物件實現的方式。下面基於上面的原生Quartz動態任務排程實現講下如何整合spring來實現。整合spring,主要就是宣告SchedulerFactoryBean。這個是spring實現的任務排程物件。在sp