spring-task定時任務動態配置修改執行時間
因項目需要，幾個定時任務需要人為動態設置執行時間，于是乎吧，就查閱相關資料，是可以動態設置的，廢話不多說，直接上代碼，一目了然。
|
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
38
39
40
41
42
43
44
45
46
|
package com.seckill.quartz;import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;import java.util.Date; /** * Created by loup on 2017/11/11. */@Component@EnableSchedulingpublic class DynamicScheduledTask implements SchedulingConfigurer { //時間表達式 每2秒執行一次 private String cron = "0/2 * * * * ?"; private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); @Override public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { scheduledTaskRegistrar.addTriggerTask(new Runnable() { @Override public void run() { //任務邏輯 System.out.println("---------------start-------------------"); System.out.println("動態修改定時任務參數，時間表達式cron為：" + cron); System.out.println("當前時間為：" + sdf.format(new Date())); System.out.println("----------------end--------------------"); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { CronTrigger cronTrigger = new CronTrigger(cron); Date nextExecDate = cronTrigger.nextExecutionTime(triggerContext); return nextExecDate; } }); } public void setCron(String cron) { this.cron = cron; }} |
這個是定時任務調度執行器，采用的是注解的方式。首先要動態配置，要設置為@EnableScheduling，這是確保能夠動態，然后實現SchedulingConfigurer，重寫configureTasks方法，接下來就是這個的相關spring配置文件，要引入下面這個task，不然識別不了啊，配置文件就是這么簡單
http://www.springframework.org/schema/task
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:task="http://www.springframework.org/schema/task" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> <context:component-scan base-package="com.seckill.quartz"/> <task:annotation-driven /> </beans> |
接下來就是寫測試類，測試可不可行啊
|
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
|
package com.seckill.quartz;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import java.io.IOException; /** * Created by loup on 2017/11/11. */@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration({"classpath*:/conf/spring-quartz.xml"})public class QuartzTest { @Autowired private DynamicScheduledTask dynamicScheduledTask; @Test public void test1(){ try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } dynamicScheduledTask.setCron("0/10 * * * * ?"); try { System.in.read(); } catch (IOException e) { e.printStackTrace(); } }} |
運行測試類，查看結果，達到效果，親測可用
spring schedule 動態配置執行時間
之前saas平臺實現動態修改定時任務的時間，都是通過xx-job這樣的框架來實現，這樣我們可以單獨一個服務來管理我們整個saas平臺的定時任務，但是最近給銀行做的一個小項目，需要本地化部署，所以我不想弄很多的服務，并且他們并沒有要求修改以后即時生效，所以我直接采用了 spring schedule結合mysql動態配置執行時間。
之前我們用的schedule通過注解的方式，只能用靜態的corn表達式，如果想實現動態的需要實現SchedulingConfigurer，并且通過注解@EnableScheduling。如下：
|
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
package com.zqf.marketing.task; import com.zqf.db.marketingrobot.sys.model.RobotSysSwitch;import com.zqf.marketing.sys.service.SwitchService;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Lazy;import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Service; import java.util.Date; /** * @author zhenghao * @description * @date 2019/1/22 21:50 */ @Lazy(false)@Service@EnableSchedulingpublic class TestTaskService implements SchedulingConfigurer { private static Logger log = LoggerFactory.getLogger(TestTaskService.class); @Autowired private SwitchService switchService; private String SpringDynamicCronTask() { String cron = "0/5 * * * * ?"; //從數據庫獲得配置的corn表達式 RobotSysSwitch switchById = switchService.getSwitchById(5L); cron = switchById.getSwitchFlag(); log.info(cron); return cron; } @Override public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { scheduledTaskRegistrar.addTriggerTask(new Runnable() { @Override public void run() { // 任務邏輯 log.info("task_task_tak"); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { String s = SpringDynamicCronTask(); // 任務觸發，可修改任務的執行周期 CronTrigger trigger = new CronTrigger(s); Date nextExec = trigger.nextExecutionTime(triggerContext); return nextExec; } }); }} |
這樣我們就可以動態的修改task的執行時間，生效時間為，上一個任務的執行周期，也可以滿足我們現在需求，這樣就可以實習項目更加的靈活！
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/ll840768874/article/details/78507286
