序言：創建定時任務非常簡單，主要有兩種創建方式：一、基于注解(@scheduled) 二、基于接口（schedulingconfigurer）. 前者相信大家都很熟悉，但是實際使用中我們往往想從數據庫中讀取指定時間來動態執行定時任務，這時候基于接口的定時任務就大派用場了。
一、靜態定時任務（基于注解）
基于注解來創建定時任務非常簡單，只需幾行代碼便可完成。
@scheduled 除了支持靈活的參數表達式cron之外，還支持簡單的延時操作，例如 fixeddelay ，fixedrate 填寫相應的毫秒數即可。
|
1
2
3
4
5
6
7
8
9
|
@configuration //1.主要用于標記配置類，兼備component的效果。@enablescheduling // 2.開啟定時任務public class simplescheduleconfig { //3.添加定時任務 @scheduled(cron = "0/5 * * * * ?") private void configuretasks() { system.err.println("執行定時任務1: " + localdatetime.now()); }} |
cron表達式參數分別表示：
秒（0~59） 例如0/5表示每5秒
分（0~59）
時（0~23）
月的某天（0~31） 需計算
月（0~11）
周幾（ 可填1-7 或 sun/mon/tue/wed/thu/fri/sat）
啟動應用，可以看到控制臺的信息如下：
誠然，使用scheduled 確實很方便，但缺點是當我們調整了執行周期的時候，需要重啟應用才能生效，這多少有些不方便。為了達到實時生效的效果，可以使用接口來完成定時任務。
二、動態定時任務（基于接口）
為了演示效果，這里選用 mysql數據庫 和 mybatis 來查詢和調整定時任務的執行周期，然后觀察定時任務的執行情況。
1.引入依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
<!--依賴管理 --><dependencies> <dependency><!--添加web依賴 --> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <dependency><!--添加mybatis依賴 --> <groupid>org.mybatis.spring.boot</groupid> <artifactid>mybatis-spring-boot-starter</artifactid> <version>1.3.1</version> </dependency> <dependency><!--添加mysql依賴 --> <groupid>mysql</groupid> <artifactid>mysql-connector-java</artifactid> <scope>runtime</scope> </dependency> <dependency><!--添加test依賴 --> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-test</artifactid> <scope>test</scope> </dependency></dependencies> |
2.添加數據庫記錄
在navicat 連接本地數據庫，隨便打開查詢窗口，然后執行腳本內容，如下：
|
1
2
3
4
5
6
7
8
9
|
drop database if exists `socks`;create database `socks`;use `socks`;drop table if exists `cron`;create table `cron` ( `cron_id` varchar(30), `cron` varchar(30) );insert into `cron` values ('1', '0/5 * * * * ?'); |
然后在項目中的application.yml 添加數據源：
#application.yml 配置如下：
|
1
2
3
4
5
|
spring: datasource: url: jdbc:mysql://localhost:3306/socks?usessl=false username: root password: root |
3.創建定時器
數據庫準備好數據之后，我們編寫定時任務，注意這里添加的是triggertask，目的是循環讀取我們在數據庫設置好的執行周期，以及執行相關定時任務的內容。具體代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
@configuration@enableschedulingpublic class completescheduleconfig implements schedulingconfigurer { @mapper public interface cronmapper { @select("select cron from cron limit 1") string getcron(); } @autowired @suppresswarnings("all") cronmapper cronmapper; /** * 執行定時任務. */ @override public void configuretasks(scheduledtaskregistrar taskregistrar) { taskregistrar.addtriggertask( //1.添加任務內容(runnable) () -> system.out.println("執行定時任務2: " + localdatetime.now().tolocaltime()), //2.設置執行周期(trigger) triggercontext -> { //2.1 從數據庫獲取執行周期 string cron = cronmapper.getcron(); //2.2 合法性校驗. if (stringutils.isempty(cron)) { // omitted code .. } //2.3 返回執行周期(date) return new crontrigger(cron).nextexecutiontime(triggercontext); } ); }} |
4. 動態修改執行周期
啟動應用后，查看控制臺，打印時間是我們預期的每5秒一次：
這時候打開navicat ，將執行周期修改為每1秒執行一次，然后觀察控制臺打印效果：
可以清楚看到執行周期已經改變，并且不需要我們重啟應用，十分方便。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：http://www.jianshu.com/p/d160f2536de7?utm_source=tuicool&utm_medium=referral
