SpringBoot2 task scheduler 定时任务调度器四种方式
使用@EnableScheduling方式
@Component @Configurable @EnableScheduling public class Task1 { private static Log logger = LogFactory.getLog(Task1.class); @Scheduled(cron = "0/2 * * * * * ") public void execute() { logger.info("Task1>>" + new Date()); } }
xml配置方式
application 启动加入读取 xml 文件
@SpringBootApplication @ImportResource(value = { "classpath:applicationContext*.xml" }) public class Springboot2TaskApplication { public static void main(String[] args) { SpringApplication.run(Springboot2TaskApplication.class, args); } }
<context:component-scan base-package="com.chenyingjun.task.schedual"></context:component-scan> <task:scheduler id="appScheduler" pool-size="2" /> <!-- 调整定时任务 --> <task:scheduled-tasks> <task:scheduled ref="task2" method="method2" cron="0/10 * * * * ?"/> </task:scheduled-tasks>
@Service public class Task2 { private static Log logger = LogFactory.getLog(Task2.class); public void method2() { logger.info("Task2----method2>>>>" + new Date()); } }
bean创建工厂方式
使用到的 jar 包
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> </dependency> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.3.0</version> </dependency>
新建 SchedledConfiguration.java
文件
@Configuration public class SchedledConfiguration { /** * attention: * Details:配置定时任务 */ @Bean(name = "jobDetail") public MethodInvokingJobDetailFactoryBean detailFactoryBean(Task3 task) {// TestTask为需要执行的任务 MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean(); /* * 是否并发执行 * 例如每5s执行一次任务,但是当前任务还没有执行完,就已经过了5s了, * 如果此处为true,则下一个任务会执行,如果此处为false,则下一个任务会等待上一个任务执行完后,再开始执行 */ jobDetail.setConcurrent(false); // 设置任务的名字 jobDetail.setName("jobDetailName"); // 设置任务的分组,这些属性都可以存储在数据库中,在多任务的时候使用 jobDetail.setGroup("jobDetailGroup"); /* * 为需要执行的实体类对应的对象 */ jobDetail.setTargetObject(task); /* * 通过这几个配置,告诉JobDetailFactoryBean我们需要执行定时执行ScheduleTask类中的task方法 */ jobDetail.setTargetMethod("task"); return jobDetail; } /** * Details:配置定时任务的触发器,也就是什么时候触发执行定时任务 */ @Bean(name = "jobTrigger") public CronTriggerFactoryBean cronJobTrigger(JobDetail jobDetail) { CronTriggerFactoryBean tigger = new CronTriggerFactoryBean(); tigger.setJobDetail(jobDetail); // 初始时的cron表达式,可以改成从数据库中获取 tigger.setCronExpression("0/2 * * * * ?"); // trigger的name tigger.setName("tiggerName"); return tigger; } /** * Details:定义quartz调度工厂 */ @Bean(name = "scheduler") public SchedulerFactoryBean schedulerFactory(Trigger trigger) { SchedulerFactoryBean bean = new SchedulerFactoryBean(); // 用于quartz集群,QuartzScheduler 启动时更新己存在的Job bean.setOverwriteExistingJobs(true); // 延时启动,应用启动1秒后 bean.setStartupDelay(1); // 注册触发器 bean.setTriggers(trigger); return bean; } }
新建Task任务
@Service public class Task3 { @Resource(name = "jobTrigger") private CronTrigger cronTrigger; @Resource(name = "scheduler") private Scheduler scheduler; private static Log logger = LogFactory.getLog(Task3.class); public void task() { logger.info("Task3---------" + new Date()); } /** * 设置cron并重启定时器 * @param cron cron值 */ public void setCron(String cron) { try { // 表达式调度构建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron); // 按新的cronExpression表达式重新构建trigger CronTrigger trigger = (CronTrigger) scheduler.getTrigger(cronTrigger.getKey()); trigger = trigger.getTriggerBuilder().withIdentity(cronTrigger.getKey()) .withSchedule(scheduleBuilder).build(); // 按新的trigger重新设置job执行 scheduler.rescheduleJob(cronTrigger.getKey(), trigger); } catch (SchedulerException e) { logger.info("cron表达式错误"); } } }
其中 setCron
方法可以进行重新设定任务调度时间
ThreadPoolTaskScheduler Runnable方式
public class Task4 implements Runnable { private ThreadPoolTaskScheduler threadPoolTaskScheduler; private static Log logger = LogFactory.getLog(Task4.class); @Override public void run() { logger.info("Task4================" + new Date()); } /** * 设置cron并启动 * @param cronExp cron值 */ public void reStart(String cronExp) { if (null != this.threadPoolTaskScheduler) { ScheduledExecutorService scheduledExecutorService = this.threadPoolTaskScheduler.getScheduledExecutor(); if (!scheduledExecutorService.isShutdown()) { scheduledExecutorService.shutdownNow(); } this.threadPoolTaskScheduler.destroy(); } if (null != cronExp && cronExp.trim().length() > 0) { this.threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); this.threadPoolTaskScheduler.setThreadNamePrefix("task4"); this.threadPoolTaskScheduler.initialize(); this.threadPoolTaskScheduler.schedule(this, new CronTrigger(cronExp)); } } }
其中reStart可以进行任务启动和重新设置任务调度时间,调用方式如下所示
/** * 初始化task4 * 这里的代码不应该写在rest层上, 应该写在service层上 */ @PostConstruct private void initTask4() { //初始化task4任务调度器cron,可以从数据库中查询到cron值 setTask4Cron("0/3 * * * * ?"); } /** * 改变task4的cron * @param cron cron值 * @return 成功标志 */ @RequestMapping(value = { "/setTask4Cron" }, method = RequestMethod.GET) @ResponseBody public String setTask4Cron(String cron) { if (null == task4) { task4 = new Task4(); } task4.reStart(cron); return "success"; }
initTask4 方法加了 @PostConstruct '注解,可以在项目启动时自动根据cron来启动任务, setTask4Cron 方法可以重新调置任务时间
四个任务的效果如下:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
- SpringTask实现定时任务方法讲解
- SpringBoot ScheduledTaskRegistrar解决动态定时任务思路详解
- SpringBoot定时任务动态扩展ScheduledTaskRegistrar详解
- Spring动态管理定时任务之ThreadPoolTaskScheduler解读
- 使用spring-task定时任务动态配置修改执行时间
- Spring Task定时任务每天零点执行一次的操作
- spring boot task实现动态创建定时任务的方法
- java 中Spring task定时任务的深入理解
- Spring Task定时任务的配置和使用详解
- SpringTask-Timer实现定时任务的详细代码
相关文章
Springboot MultipartFile文件上传与下载的实现示例
在Spring Boot项目中,可以使用MultipartFile类来处理文件上传和下载操作,本文就详细介绍了如何使用,具有一定的参考价值,感兴趣的可以了解一下2023-08-08阿里资深技术专家:在各阶段中3年经验的java程序员应该具备哪些技术能力
这篇文章主要介绍了阿里资深技术专家:在各阶段中3年经验的java程序员应该具备哪些技术能力,本文给大家列举了一些内容,大家可以根据自己需要有方法的掌握,感兴趣的朋友跟随小编一起看看吧2020-07-07java、spring、springboot中整合Redis的详细讲解
这篇文章主要介绍了java、spring、springboot中整合Redis的详细讲解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2021-04-04
最新评论