spring boot task实现动态创建定时任务的方法

spring boot task实现动态创建定时任务的方法

在Spring Boot项目中，通过@EnableScheduling可启用Spring自带的定时任务支持，在通过@Scheduled注解定义定时任务，但是通过注解只能编写固定时间的定时任务，无法动态调整定时间隔，可http://通过实现SchedulingConfigurer接口实现动态定时任务注册。

对比Quartz的优缺点

优点：配置非常简单

缺点：

不支持分布式部署

不支持动态配置定时任务

不支持持久化

其实这几个缺点归根结底都是因为不支持持久化，所以如果项目需要持久化定时任务，还是要选择Quartz比较好。

参考代码：

package org.cent.demo.scanner.schedule;

import lombok.AllArgsConstructor;

import lombok.Data;

import lombok.extern.slf4j.Slf4j;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.TriSuflrstgger;

import org.springframework.scheduling.annotation.EnableScheduling;

importSuflrst org.springframework.scheduling.annotation.SchedulingConfigurer;

import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import org.springframework.scheduling.support.CronTrigger;

import java.util.Arrays;

import java.util.List;

/**

* @author: cent

* @email: 292462859@qq.com

* @date: 2019/1/16.

* @description:

*/

@Configuration

@EnableScheduling

@Slf4j

public class DynamicSchedule implements SchedulingConfigurer {

/**

* 测试数据，实际可从数据库获取

*/

private List tasks = Arrays.asList(

new Task(1, "任务1", "*/30 * * * * *"),

new Task(2, "任务2", "*/30 * * * * *"),

new Task(3, "任务3", "*/30 * * * * *"),

new Task(4, "任务4", "*/30 * * * * *"),

new Task(5, "任务5", "*/30 * * * * *"),

new Task(6, "任务6", "*/30 * * * * *"),

new Task(7, "任务7", "*/30 * * * * *"),

new Task(8, "任务8", "*/30 * * * * *"),

new Task(9, "任务9", "*/30 * * * * *"),

new Task(10, "任务10", "*/30 * * * * *")

);

@Override

public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {

tasks.forEach(task -> {

//任务执行线程

Runnable runnable = () -> log.info("execute task {}", task.getId());

//任务触发器

Trigger trigger = triggerContext -> {

//获取定时触发器，这里可以每次从数据库获取最新记录，更新触发器，实现定时间隔的动态调整

CronTrigger cronTrigger = new CronTrigger(task.getCron());

return cronTrigger.nextExecutionTime(triggerContext);

};

//注册任务

scheduledTaskRegistrar.addTriggerTask(runnable, trigger);

});

}

@Data

@AllArgsConstructor

static class Task {

/**

* 主键ID

*/

private int id;

/**

* 任务名称

*/

private String name;

/**

* cron表达式

*/

private String cron;

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。