@scheduled cron动态修改_spring boot实现动态增删启停定时任务
作者:jessehua
来源:https://www.jianshu.com/p/0f68936393fd
在spring boot项目中,可以通过@EnableScheduling注解和@Scheduled注解实现定时任务,也可以通过SchedulingConfigurer接口来实现定时任务。但是这两种方式不能动态添加、删除、启动、停止任务。要实现动态增删启停定时任务功能,比较广泛的做法是集成Quartz框架。但是本人的开发原则是:在满足项目需求的情况下,尽量少的依赖其它框架,避免项目过于臃肿和复杂。查看spring-context这个jar包中org.springframework.scheduling.ScheduledTaskRegistrar这个类的源代码,发现可以通过改造这个类就能实现动态增删启停定时任务功能。
定时任务列表页
定时任务执行日志
添加执行定时任务的线程池配置类
@Configurationpublic class SchedulingConfig { @Bean public TaskScheduler taskScheduler() { ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); // 定时任务执行线程池核心线程数 taskScheduler.setPoolSize(4); taskScheduler.setRemoveOnCancelPolicy(true); taskScheduler.setThreadNamePrefix("TaskSchedulerThreadPool-"); return taskScheduler; }}
添加ScheduledFuture的包装类。ScheduledFuture是ScheduledExecutorService定时任务线程池的执行结果。
public final class ScheduledTask {
volatile ScheduledFuture> future;
/** * 取消定时任务 */ public void cancel() { ScheduledFuture> future = this.future; if (future != null) { future.cancel(true); } }}
添加Runnable接口实现类,被定时任务线程池调用,用来执行指定bean里面的方法。
public class SchedulingRunnable implements Runnable {
private static final Logger logger = LoggerFactory.getLogger(SchedulingRunnable.class);
private String beanName;
private String methodName;
private String params;
public SchedulingRunnable(String beanName, String methodName) { this(beanName, methodName, null); }
public SchedulingRunnable(String beanName, String methodName, String params) { this.beanName = beanName; this.methodName = methodName; this.params = params; }
@Override public void run() { logger.info("定时任务开始执行 - bean:{},方法:{},参数:{}", beanName, methodName, params); long startTime = System.currentTimeMillis();
try { Object target = SpringContextUtils.getBean(beanName);
Method method = null; if (StringUtils.isNotEmpty(params)) { method = target.getClass().getDeclaredMethod(methodName, String.class); } else { method = target.getClass().getDeclaredMethod(methodName); }
ReflectionUtils.makeAccessible(method); if (StringUtils.isNotEmpty(params)) { method.invoke(target, params); } else { method.invoke(target); } } catch (Exception ex) { logger.error(String.format("定时任务执行异常 - bean:%s,方法:%s,参数:%s ", beanName, methodName, params), ex); }
long times = System.currentTimeMillis() - startTime; logger.info("定时任务执行结束 - bean:{},方法:{},参数:{},耗时:{} 毫秒", beanName, methodName, params, times); }
@Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; SchedulingRunnable that = (SchedulingRunnable) o; if (params == null) { return beanName.equals(that.beanName) && methodName.equals(that.methodName) && that.params == null; }
return beanName.equals(that.beanName) && methodName.equals(that.methodName) && params.equals(that.params); }
@Override public int hashCode() { if (params == null) { return Objects.hash(beanName, methodName); }
return Objects.hash(beanName, methodName, params); }}
添加定时任务注册类,用来增加、删除定时任务。
@Componentpublic class CronTaskRegistrar implements DisposableBean {
private final Map scheduledTasks = new ConcurrentHashMap<>(16);@Autowiredprivate TaskScheduler taskScheduler;public TaskScheduler getScheduler() {return this.taskScheduler; }public void addCronTask(Runnable task, String cronExpression) { addCronTask(new CronTask(task, cronExpression)); }public void addCronTask(CronTask cronTask) {if (cronTask != null) { Runnable task = cronTask.getRunnable();if (this.scheduledTasks.containsKey(task)) { removeCronTask(task); }this.scheduledTasks.put(task, scheduleCronTask(cronTask)); } }public void removeCronTask(Runnable task) { ScheduledTask scheduledTask = this.scheduledTasks.remove(task);if (scheduledTask != null) scheduledTask.cancel(); }public ScheduledTask scheduleCronTask(CronTask cronTask) { ScheduledTask scheduledTask = new ScheduledTask(); scheduledTask.future = this.taskScheduler.schedule(cronTask.getRunnable(), cronTask.getTrigger());return scheduledTask; }@Overridepublic void destroy() {for (ScheduledTask task : this.scheduledTasks.values()) { task.cancel(); }this.scheduledTasks.clear(); }}
添加定时任务示例类
@Component("demoTask")public class DemoTask { public void taskWithParams(String params) { System.out.println("执行有参示例任务:" + params); }
public void taskNoParams() { System.out.println("执行无参示例任务"); }}
定时任务数据库表设计
定时任务数据库表设计
添加定时任务实体类
public class SysJobPO { /** * 任务ID */ private Integer jobId; /** * bean名称 */ private String beanName; /** * 方法名称 */ private String methodName; /** * 方法参数 */ private String methodParams; /** * cron表达式 */ private String cronExpression; /** * 状态(1正常 0暂停) */ private Integer jobStatus; /** * 备注 */ private String remark; /** * 创建时间 */ private Date createTime; /** * 更新时间 */ private Date updateTime;
public Integer getJobId() { return jobId; }
public void setJobId(Integer jobId) { this.jobId = jobId; }
public String getBeanName() { return beanName; }
public void setBeanName(String beanName) { this.beanName = beanName; }
public String getMethodName() { return methodName; }
public void setMethodName(String methodName) { this.methodName = methodName; }
public String getMethodParams() { return methodParams; }
public void setMethodParams(String methodParams) { this.methodParams = methodParams; }
public String getCronExpression() { return cronExpression; }
public void setCronExpression(String cronExpression) { this.cronExpression = cronExpression; }
public Integer getJobStatus() { return jobStatus; }
public void setJobStatus(Integer jobStatus) { this.jobStatus = jobStatus; }
public String getRemark() { return remark; }
public void setRemark(String remark) { this.remark = remark; }
public Date getCreateTime() { return createTime; }
public void setCreateTime(Date createTime) { this.createTime = createTime; }
public Date getUpdateTime() { return updateTime; }
public void setUpdateTime(Date updateTime) { this.updateTime = updateTime; }
}
新增定时任务
新增定时任务
boolean success = sysJobRepository.addSysJob(sysJob);if (!success) return OperationResUtils.fail("新增失败");else { if (sysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal())) { SchedulingRunnable task = new SchedulingRunnable(sysJob.getBeanName(), sysJob.getMethodName(), sysJob.getMethodParams()); cronTaskRegistrar.addCronTask(task, sysJob.getCronExpression()); }}
return OperationResUtils.success();
修改定时任务,先移除原来的任务,再启动新任务
boolean success = sysJobRepository.editSysJob(sysJob);if (!success) return OperationResUtils.fail("编辑失败");else { //先移除再添加 if (existedSysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal())) { SchedulingRunnable task = new SchedulingRunnable(existedSysJob.getBeanName(), existedSysJob.getMethodName(), existedSysJob.getMethodParams()); cronTaskRegistrar.removeCronTask(task); }
if (sysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal())) { SchedulingRunnable task = new SchedulingRunnable(sysJob.getBeanName(), sysJob.getMethodName(), sysJob.getMethodParams()); cronTaskRegistrar.addCronTask(task, sysJob.getCronExpression()); }}
return OperationResUtils.success();
删除定时任务
boolean success = sysJobRepository.deleteSysJobById(req.getJobId());if (!success) return OperationResUtils.fail("删除失败");else{ if (existedSysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal())) { SchedulingRunnable task = new SchedulingRunnable(existedSysJob.getBeanName(), existedSysJob.getMethodName(), existedSysJob.getMethodParams()); cronTaskRegistrar.removeCronTask(task); }}
return OperationResUtils.success();
定时任务启动/停止状态切换
if (existedSysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal())) { SchedulingRunnable task = new SchedulingRunnable(existedSysJob.getBeanName(), existedSysJob.getMethodName(), existedSysJob.getMethodParams()); cronTaskRegistrar.addCronTask(task, existedSysJob.getCronExpression());} else { SchedulingRunnable task = new SchedulingRunnable(existedSysJob.getBeanName(), existedSysJob.getMethodName(), existedSysJob.getMethodParams()); cronTaskRegistrar.removeCronTask(task);}
添加实现了CommandLineRunner接口的SysJobRunner类,当spring boot项目启动完成后,加载数据库里状态为正常的定时任务。
@Servicepublic class SysJobRunner implements CommandLineRunner {
private static final Logger logger = LoggerFactory.getLogger(SysJobRunner.class);
@Autowired private ISysJobRepository sysJobRepository;
@Autowired private CronTaskRegistrar cronTaskRegistrar;
@Override public void run(String... args) { // 初始加载数据库里状态为正常的定时任务 List jobList = sysJobRepository.getSysJobListByStatus(SysJobStatus.NORMAL.ordinal());if (CollectionUtils.isNotEmpty(jobList)) {for (SysJobPO job : jobList) { SchedulingRunnable task = new SchedulingRunnable(job.getBeanName(), job.getMethodName(), job.getMethodParams()); cronTaskRegistrar.addCronTask(task, job.getCronExpression()); } logger.info("定时任务已加载完毕..."); } }}
工具类SpringContextUtils,用来从spring容器里获取bean
@Componentpublic class SpringContextUtils implements ApplicationContextAware {
private static ApplicationContext applicationContext;
@Override public void setApplicationContext(ApplicationContext applicationContext)throws BeansException { SpringContextUtils.applicationContext = applicationContext; }
public static Object getBean(String name) { return applicationContext.getBean(name); }
public static T getBean(Class requiredType) {return applicationContext.getBean(requiredType); }public static T getBean(String name, Class requiredType) {return applicationContext.getBean(name, requiredType); }public static boolean containsBean(String name) {return applicationContext.containsBean(name); }public static boolean isSingleton(String name) {return applicationContext.isSingleton(name); }public static Class extends Object> getType(String name) {return applicationContext.getType(name); }}
@scheduled cron动态修改_spring boot实现动态增删启停定时任务相关推荐
- 告别硬编码,SpringBoot实现动态增删启停定时任务
在spring boot项目中,可以通过@EnableScheduling注解和@Scheduled注解实现定时任务,也可以通过SchedulingConfigurer接口来实现定时任务.但是这两种方 ...
- 不再写死,SpringBoot实现动态增删启停定时任务
在spring boot项目中,可以通过@EnableScheduling注解和@Scheduled注解实现定时任务,也可以通过SchedulingConfigurer接口来实现定时任务.但是这两种方 ...
- Spring Boot实现定时任务的动态增删启停
欢迎关注方志朋的博客,回复"666"获面试宝典 作者 | jessehua 来源 | https://www.jianshu.com/p/0f68936393fd 在spring ...
- Spring Boot 实现定时任务的动态增删启停
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 来源:jianshu.com/p/0f68936393fd 添加执 ...
- 实践:SpringBoot实现定时任务的动态增删启停
点击上方"Java知音",选择"置顶公众号" 技术文章第一时间送达! 作者:jessehua www.jianshu.com/p/0f68936393fd 在s ...
- spring schedule 配置多任务动态 cron 【增删启停】
一.背景 之前公司经常会遇到配置定时任务,简单的任务可以直接依赖spring. 简单任务直接使用 @scheduled 注解配合@EnableScheduling. 但是如何实现简单的动态cron呢? ...
- mysql双数据源动态切换_Spring boot+Mybatis多数据源动态切换
通过重写AbstractRoutingDataSource类中方法determineTargetDataSource,determineCurrentLookupKey,afterProperties ...
- @scheduled注解配置时间_Spring Boot中使用@Scheduled创建定时任务
我们在编写Spring Boot应用中经常会遇到这样的场景,比如:我需要定时地发送一些短信.邮件之类的操作,也可能会定时地检查和监控一些标志.参数等. 创建定时任务 在Spring Boot中编写定时 ...
- @scheduled 执行一次_Spring Boot 定时任务 @Scheduled
项目开发中经常需要执行一些定时任务,比如在每天凌晨,需要从 implala 数据库拉取产品功能活跃数据,分析处理后存入到 MySQL 数据库中.类似这样的需求还有许多,那么怎么去实现定时任务呢,有以下 ...
最新文章
- .ipynb文件怎么打开
- redis 内存不足 排查_redis莫名数据被清问题排查记录
- 大量的 TIME_WAIT 状态 TCP 连接,对业务有什么影响?
- macbook图形化编程_如何判断MacBook使用的是哪种图形芯片(并进行切换)
- java语言50到100之间素数和_用JAVA语言编写一程序,求100以内的所有素数
- 鸿蒙os什么时候用到手机,鸿蒙OS何时用在手机上?余承东称明年会有
- 管家婆辉煌版软件的使用方法_管家婆软件进销存的使用方法,管家婆软件使用教程_双全科技...
- 街头人手一件加拿大鹅?店员道出真相:90%都是假货
- java oracle的2种分页方法
- 嵌入式工具 | 嵌入式开发常用几款的代码编辑器
- Python数据分析案例-多因素方差分析
- android+表情雨,微信8.0.1掉落表情雨2021下载
- 【hadoop】进阶篇一:MapReduce之Job的提交
- 阿里云直播服务开通配置流程
- 输入方向的流量控制 --ifb
- 1128_AURIX_TC275的基本参数了解
- LeetCode#546. 移除盒子 (Python解法+详细分析)
- 盘点世界上奇怪的 6 种编程语言
- FreeSWITCH 呼入系统的简要设计
- PHP Framework YII的里的gii设置。