2. 程式人生 > >SpringBoot+Quartz學習實現定時任務控制Trigger的增加、啟用、刪除、休眠

SpringBoot+Quartz學習實現定時任務控制Trigger的增加、啟用、刪除、休眠

阿新 • • 發佈：2018-11-12

SpringBoot+Quartz學習實現定時任務控制Trigger的增加、啟用、刪除、休眠

標籤（空格分隔）： SpringBoot Quartz

文章目錄

SpringTask

SpringBoot主類加入@EnableScheduling註解，啟用定時任務的配置
固定等待時間@Scheduled(fixedDelay = 時間間隔)


固定間隔時間@Scheduled(fixedRate = 時間間隔)
第一次執行延遲時間，配合上面兩個使用@Scheduled(initialDelay = 1000 * 10,fixedDelay = 1000 * 2) Cron表示式@Scheduled(cron = cron表示式)`

Cron表示式

s m h d M W Y(年可選)

| 欄位 | 值 | 允許符號 |
|:
| 秒（s）| 0-59 | ,-*/
| 分（m）| 0-59 | ,-*/
| 時（h）| 0-23 | ,-*/
| 日（d）| 1-31 | ,-*/?LW
| 月（M）| 1-12或JAN-DEC | ,-*/
| 星期（W）| 1-7或SUN-SAT | ,-*/?L#
| 年（Y）| 1970-2099 | ,-*/

|符號 | 含義 |
|:
| * | 表示任意值 |
| ? | 只能用於d和W兩個域,未說明的值 |
| - | 表示範圍 |
| / | 表示頻度 |
| , | 表示列出列舉值 |
| L | 表示最後，用於M和W
| W | 用於M，表示工作日，並在最近的工作日觸發
| LW | 表示某月最後一個工作日
| # | 用於W域，確定這個月第幾個周幾

例子：

*/5 * * * * ? 每隔5秒執行一次
0 0 5-15 * * ? 每天5-15點整點觸發
0 0/5 14,18 * * ? 在每天下午2點到2:55期間和下午6點到6:55期間的每5分鐘觸發
0 0 23 L * ? 每月最後一天23點執行一次
0 15 10 ? * 6L 每月的最後一個星期五上午10:15觸發
0 15 10 LW * ?" 每個月最後一個工作日的10點15分0秒觸發任務
0 15 10 ? * 5#3" 每個月第三週的星期四的10點15分0秒觸發任務

表示式生成網頁

Spring Quartz實現定時任務

  1. pom.xml新增依賴
<!-- quartz -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
  1. 配置yml
spring:
  # Quartz
  quartz:
    properties:
      org:
        quartz:
          scheduler:
            instanceName: myScheduler
            instanceId: AUTO
          jobStore:
            isClustered: false
          threadPool:
            class: org.quartz.simpl.SimpleThreadPool
            threadCount: 10
            threadPriority: 5
            threadsInheritContextClassLoaderOfInitializingThread: true
    #job-store方式
    job-store-type: jdbc
  # datasource
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/etmptest?useUnicode=true&characterEncoding=utf8&autoReconnect=true&failOverReadOnly=false&useSSL=false
    username: root
    password: ${dev-db-passwd}
    druid:
      connection-properties: config.decrypt=true;config.decrypt.key=${dev-db-passwd-publickey}
  1. 編寫Job類
@DisallowConcurrentExecution
public class DefaultJob extends QuartzJobBean {

    private static final Logger logger = LoggerFactory.getLogger(DefaultJob.class);
    
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        Trigger trigger = context.getTrigger();
        String triggerName = trigger.getKey().getName();
        logger.info("開始定時任務：{}，開始時間{}", triggerName, new Date());
        //Todo trigger要做什麼任務
        logger.info("結束定時任務：{}，結束時間{}", triggerName, new Date());
    }

}
  1. 編寫Quartz工具類
@Component
@Transactional(rollbackFor = Exception.class)
public class QuartzManager {

    private static final Logger logger = LoggerFactory.getLogger(QuartzManager.class);

    /**
     * 注入任務排程器
     */
    @Autowired
    private Scheduler scheduler;

    //注入DefaultJob類
    @Bean
    public JobDetail jobDetail() {
        return JobBuilder.newJob(DefaultJob.class).withIdentity("defaultJob").storeDurably().build();
    }
    
    /** 
     * 新增SimpleTrigger
     */
    public void addSimppleTrigger(String triggerName,Date startDate, Long repeatInterval, Long repeatCount){
        try {
            // 觸發器
            TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
            // 觸發器名,觸發器組
            triggerBuilder.withIdentity(triggerName, Scheduler.DEFAULT_GROUP);
            //triggerBuilder.startNow();
            // 觸發器時間設定
            triggerBuilder.withSchedule(simpleSchedule()
                    .withIntervalInSeconds(repeatInterval.intValue())
                    .withRepeatCount(repeatCount.intValue()))
                    .startAt(startDate);
            triggerBuilder.forJob(jobDetail());
            // 建立Trigger物件
            SimpleTrigger trigger = (SimpleTrigger) triggerBuilder.build();
            scheduler.addJob(jobDetail(), true);
            // 排程容器設定JobDetail和Trigger
            scheduler.scheduleJob(trigger);
        }catch (Exception e) {
            logger.error("新增Simple定時器失敗!", e);
            throw new OccurLocationAwareException("新增Simple定時器失敗!",e);
        }
        logger.info("新增Simple定時器成功!");
    }

    /**
     * 新增CronTrigger
     */
    public void addCronTrigger(String triggerName, String cron) {
        try {
            // 觸發器
            TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
            // 觸發器名,觸發器組
            triggerBuilder.withIdentity(triggerName, Scheduler.DEFAULT_GROUP);
            triggerBuilder.startNow();
            // 觸發器時間設定
            triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));
            triggerBuilder.forJob(jobDetail());
            // 建立Trigger物件
            CronTrigger trigger = (CronTrigger) triggerBuilder.build();
            scheduler.addJob(jobDetail(), true);
            // 排程容器設定JobDetail和Trigger
            scheduler.scheduleJob(trigger);
        } catch (Exception e) {
            logger.error("新增cron定時器失敗!", e);
            throw new OccurLocationAwareException("新增cron定時器失敗!",e);
        }
        logger.info("新增cron定時器成功!");


    }

    /**
     * 暫停Trigger
     */
    public void pauseTrigger(String triggerName) {
        try {
            logger.info("休眠定時器:" + triggerName);
            TriggerKey triggerKey = new TriggerKey(triggerName, Scheduler.DEFAULT_GROUP);
            //停止觸發器
            scheduler.pauseTrigger(triggerKey);
        } catch (Exception e) {
            logger.info("休眠定時器失敗!");
            throw new OccurLocationAwareException("休眠定時器失敗!",e);
        }
        logger.info("休眠定時器成功!");
    }

    /**
     * 恢復Trigger
     *
     * @param triggerName
     * @throws Exception
     */
    public void resumeTrigger(String triggerName) {
        try {
            logger.info("啟用定時器:" + triggerName);
            TriggerKey triggerKey = new TriggerKey(triggerName, Scheduler.DEFAULT_GROUP);
            //重啟觸發器
            scheduler.resumeTrigger(triggerKey);
        } catch (Exception e) {
            logger.info("啟用定時器失敗!");
            throw new OccurLocationAwareException("啟用定時器失敗!",e);
        }
        logger.info("啟用定時器成功!");

    }

    /**
     * 刪除Trigger
     */
    public boolean removeTrigger(String triggerName) {
        try {
            logger.info("移除定時器:" + triggerName);
            TriggerKey triggerKey = new TriggerKey(triggerName, Scheduler.DEFAULT_GROUP);
            //停止觸發器
            scheduler.pauseTrigger(triggerKey);
            //移除觸發器
            return scheduler.unscheduleJob(triggerKey);
        } catch (Exception e) {
            logger.error("移除定時器失敗!", e);
            throw new OccurLocationAwareException("移除定時器失敗!",e);
        }


    }
}
  1. Controller呼叫
@RestController
@RequestMapping("/trigger")
public class TriggerController {

    @Autowired
    private QuartzManager manager;

    /** 
     * @desc 新增SimpleTrigger
     */
    @PostMapping("/addSimple")
    public ResultBody addSimpleTrigger(@Valid @RequestBody TriggerParam triggerParam) {
            manager.addSimppleTrigger(triggerParam.getTriggerName(),triggerParam.getStartDate(),triggerParam.getRepeatInterval(), triggerParam.getRepeatCount());
        return new ResultBody<String>();
    }
    
    /** 
     * @desc 新增CronTrigger
     */
    @PostMapping("/addCron")
    public ResultBody addCronTrigger(@Valid @RequestBody TriggerParam triggerParam {
            manager.addCronTrigger(triggerParam.getTriggerName(), triggerParam.getCronExpression());
        return new ResultBody<String>();
    }
    
    /** 
     * @desc 啟用Trigger
     */
    @PostMapping("/resume")
    public ResultBody resume(@Valid @RequestBody TriggerParam triggerParam) {
        String triggerName = triggerParam.getTriggerName();
        manager.resumeTrigger(triggerName);
        return new ResultBody<String>();
    }
    
    /** 
     * @desc 暫停Trigger
     */
    @PostMapping("/pause")
    public ResultBody pause(@Valid @RequestBody TriggerParam triggerParam) {
        String triggerName = triggerParam.getTriggerName();
        manager.pauseTrigger(triggerName);
        return new ResultBody<String>();
    }
    
    /** 
     * @desc 刪除Trigger
     */
    @PostMapping("/delete")
    public ResultBody delete(@Valid @RequestBody TriggerParam triggerParam) {
        String triggerName = triggerParam.getTriggerName();
        manager.removeTrigger(triggerName);
        return new ResultBody<String>();
    }
}

如何用Quartz呼叫Trigger先這樣，後面有時間再整理從前端到後端如何實現自定義Job和Trigger的控制

相關推薦

SpringBoot+Quartz學習實現定時任務控制Trigger的增加、啟用、刪除、休眠

SpringBoot+Quartz學習實現定時任務控制Trigger的增加、啟用、刪除、休眠 標籤（空格分隔）： SpringBoot Quartz 文章目錄 SpringBoot+Quartz學習實現定時任務控制Trigger的增加、啟用、刪除、休眠

Spring+Quartz框架實現定時任務（集群，分布式）

log cor alt 放置 這一 表達 mod 建數據庫 strac 1、定時任務的必要性：定時任務在應用中的重要性不言而喻，大多是應用，特別是金融應用更是離不開定時任務，能用定時任務來處理異常訂單，完成跑批，定時活動（雙11）等。在初期應用的訪問量並不是那麽大，

Spring整合Quartz框架實現定時任務跑批（Maven完整版）

觸發器 delay cut www 方法 lin job 定時任務 任務調度 Quartz 介紹Quartz is a full-featured, open source job scheduling service that can be integrated with

spring boot 2.0 quartz 輕鬆實現定時任務和作業排程

    最近在做一個彩票相關的專案，主要涉及到不定時開獎，不定時封盤，原本打算使用spring boot 自帶的Schedule進行這一系列的工作，由於不能自動的新增定時任務，所以使用quartz，spring boot 2.0集成了quartz，所以決定嘗試下quartz用

Spring 3整合Quartz 2實現定時任務三：動態暫停 恢復 修改和刪除任務

前面我們已經完成了spring 3和quartz 2的整合以及動態新增定時任務，我們接著來完善它，使之能支援更多的操作，例如暫停、恢復、修改等。 在動態新增定時任務中其實已經涉及到了其中的一些程式碼，這裡我們再來細化的理一理。先來看一下我們初步要實現的目標效果圖，這裡

基於springboot ThreadPoolTaskScheduler類實現定時任務動態新增修改

需求:有不定個的定時任務模板需要建立,定時任務在執行過程中,激發時間等屬性可能發生修改. import org.springframework.beans.factory.annotation.Autowired; import org.springframework.b

SpringMVC整合quartz，實現定時任務

首先，我用的是maven下載jar包 <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artif

springboot整合quartz定時器實現定時任務詳解

最近需要 做一個按照時間，定時初始化一些資訊的功能，研究了一下quartz，也簡單瞭解一下TimerTask，廢話不多說。 quartz和TimerTask的區別： timer是jdk自帶的（可想而知，肯定是不怎麼好用）。 Quartz可以通過cron表示式精確到特定時間執行，而T

SpringBoot整合quartz動態建立定時任務實現以及踩過的坑

需要了解一下quartz有Job,Scheduler,Trigger等概念,在此就不詳細說明 首先說一下功能需求場景 該提醒可以在頁面上進行配置多個,比如可以配置一個提醒:在每天的12點,傳送郵件給某個人,可以繼續配置另外一個提醒:在每個月的10號,給某個人

SpringBoot+quartz實現定時任務

首先明白Quartz核心概念會變得很容易理解配置. 1、Job 表示一個工作，要執行的具體內容。此介面中只有一個方法 void execute(JobExecutionContext context) 2、JobDetail JobDetail表示一個具體的可執行的排程程式，Jo

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

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

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

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

springboot+quartz以持久化的方式實現定時任務

# springboot+quartz以持久化的方式實現定時任務 > 篇幅較長，耐心的人總能得到最後的答案 > 小生第一次用quartz做定時任務，不足之處多多諒解。 ### 首先 在springboot專案裡做定時任務是比較簡單的，最簡單的實現方式是使用**@Scheduled**註解， 然後

Spring與Quartz的整合實現定時任務調度

java代碼 content sta 一個bug next 小時 change nsa 發現 Spring與Quartz的整合實現定時任務調度 博客分類： Java Web SpringQuartz任務調度定時任務 最近在研究Spring中的定時任務功能，最好的

Spring+Quartz實現定時任務的配置方法

detail 包含 範例 empty beans ref tail 可選 creat 1、Scheduler的配置 <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"&g

使用quartz.jar 、quartz-jobs.jar 實現定時任務 。實現 定時采集 接口數據

art map() t對象 obd class 調用 ssi tail 方式 前言 　　定時任務管理，在java中有很多種的方式 ，有java自帶的註解方式@Scheduled 等 ，現在我要說的是一種也是使用比較廣泛的一種quartz管理　　使用此類 需要的加jar

.Net Core小技巧 - Hosted Services + Quartz實現定時任務調度

TBase 觸發 控制 soft ghost .so 不錯 什麽 ora 背景 　　之前一直有朋友問，.Net Core + Linux環境有沒有類似Windows服務的東西。其實是有的，我了解的方法有兩種： 　　#1 創建一個ASP.Net Core的Web項目

springboot專案整合分散式定時任務Quartz

springboot中整合分散式定時任務Quartz的模本範例。參考這個配置，十分簡便 兩個bean配置，一個properties檔案，一個sql檔案，使用的為mysql. QRTZ_tables_mysql_innodb.sql # # In your Quartz properties

java+Quartz實現定時任務

1、首先：匯入quartz相關的jar包，這裡我用的是maven構建的專案，pom.xml檔案匯入如下： <dependency> <groupId>org.quartz-scheduler</groupId> <artifactI

java spring-quartz定時器實現定時任務

Quartz是一個大名鼎鼎的Java版開源定時排程器，功能強悍，使用方便,下面我們看看如何使用它 一、核心概念 Quartz的原理不是很複雜，只要搞明白幾個概念，然後知道如何去啟動和關閉一個排程程式即可。 1、Job 表示一個工作，要執行的具體內容。此介面中只有一個方法 vo