序言：創(chuàng)建定時任務(wù)非常簡單，主要有兩種創(chuàng)建方式：一、基于注解(@scheduled) 二、基于接口（schedulingconfigurer）. 前者相信大家都很熟悉，但是實際使用中我們往往想從數(shù)據(jù)庫中讀取指定時間來動態(tài)執(zhí)行定時任務(wù)，這時候基于接口的定時任務(wù)就大派用場了。
一、靜態(tài)定時任務(wù)（基于注解）
基于注解來創(chuàng)建定時任務(wù)非常簡單，只需幾行代碼便可完成。
@scheduled 除了支持靈活的參數(shù)表達式cron之外，還支持簡單的延時操作，例如 fixeddelay ，fixedrate 填寫相應(yīng)的毫秒數(shù)即可。
|
1
2
3
4
5
6
7
8
9
|
@configuration //1.主要用于標記配置類，兼?zhèn)鋍omponent的效果。@enablescheduling // 2.開啟定時任務(wù)public class simplescheduleconfig { //3.添加定時任務(wù) @scheduled(cron = "0/5 * * * * ?") private void configuretasks() { system.err.println("執(zhí)行定時任務(wù)1: " + localdatetime.now()); }} |
cron表達式參數(shù)分別表示：
秒（0~59） 例如0/5表示每5秒
分（0~59）
時（0~23）
月的某天（0~31） 需計算
月（0~11）
周幾（ 可填1-7 或 sun/mon/tue/wed/thu/fri/sat）
啟動應(yīng)用，可以看到控制臺的信息如下：
誠然，使用scheduled 確實很方便，但缺點是當我們調(diào)整了執(zhí)行周期的時候，需要重啟應(yīng)用才能生效，這多少有些不方便。為了達到實時生效的效果，可以使用接口來完成定時任務(wù)。
二、動態(tài)定時任務(wù)（基于接口）
為了演示效果，這里選用 mysql數(shù)據(jù)庫 和 mybatis 來查詢和調(diào)整定時任務(wù)的執(zhí)行周期，然后觀察定時任務(wù)的執(zhí)行情況。
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.添加數(shù)據(jù)庫記錄
在navicat 連接本地數(shù)據(jù)庫，隨便打開查詢窗口，然后執(zhí)行腳本內(nèi)容，如下：
|
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 添加數(shù)據(jù)源：
#application.yml 配置如下：
|
1
2
3
4
5
|
spring: datasource: url: jdbc:mysql://localhost:3306/socks?usessl=false username: root password: root |
3.創(chuàng)建定時器
數(shù)據(jù)庫準備好數(shù)據(jù)之后，我們編寫定時任務(wù)，注意這里添加的是triggertask，目的是循環(huán)讀取我們在數(shù)據(jù)庫設(shè)置好的執(zhí)行周期，以及執(zhí)行相關(guān)定時任務(wù)的內(nèi)容。具體代碼如下：
|
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; /** * 執(zhí)行定時任務(wù). */ @override public void configuretasks(scheduledtaskregistrar taskregistrar) { taskregistrar.addtriggertask( //1.添加任務(wù)內(nèi)容(runnable) () -> system.out.println("執(zhí)行定時任務(wù)2: " + localdatetime.now().tolocaltime()), //2.設(shè)置執(zhí)行周期(trigger) triggercontext -> { //2.1 從數(shù)據(jù)庫獲取執(zhí)行周期 string cron = cronmapper.getcron(); //2.2 合法性校驗. if (stringutils.isempty(cron)) { // omitted code .. } //2.3 返回執(zhí)行周期(date) return new crontrigger(cron).nextexecutiontime(triggercontext); } ); }} |
4. 動態(tài)修改執(zhí)行周期
啟動應(yīng)用后，查看控制臺，打印時間是我們預(yù)期的每5秒一次：
這時候打開navicat ，將執(zhí)行周期修改為每1秒執(zhí)行一次，然后觀察控制臺打印效果：
可以清楚看到執(zhí)行周期已經(jīng)改變，并且不需要我們重啟應(yīng)用，十分方便。
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：http://www.jianshu.com/p/d160f2536de7?utm_source=tuicool&utm_medium=referral
