登录
首页 >  数据库 >  MySQL

springboot整合quarzt实现动态定时任务

来源:SegmentFault

时间:2023-02-24 18:12:57 254浏览 收藏

小伙伴们对数据库编程感兴趣吗?是否正在学习相关知识点?如果是,那么本文《springboot整合quarzt实现动态定时任务》,就很适合你,本篇文章讲解的知识点主要包括MySQL、Java、Linux、spring、intellij-idea。在之后的文章中也会多多分享相关知识点,希望对大家的知识积累有所帮助!

实现定时任务的几种方式:

1.使用linux的crontab

@Configuration
public class SchedulerConfig {

    /**
     * attention:
     * Details:定义quartz调度工厂
     */
    @Bean(name = "scheduler")
    public SchedulerFactoryBean schedulerFactory() {
        SchedulerFactoryBean bean = new SchedulerFactoryBean();
        // 用于quartz集群,QuartzScheduler 启动时更新己存在的Job
        bean.setOverwriteExistingJobs(true);
        // 延时启动,应用启动1秒后
        bean.setStartupDelay(1);
        return bean;
    }
}

3.具体任务类job,必须实现quartz的job类,这个也可以去实现spring的QuartJobBean(spring对job类的实现)是一样的,或者还有一种方式就是MethodInvokingJobDetailFactoryBean,这个类里面可以设置什么类的什么方法来执行这个任务,会更灵活一些:

@Slf4j
public class ScheduleTaskJob implements Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        log.info("任务执行了......");
    }
}

4.http的接口来触发该调度程序:

@Slf4j
@RestController
public class Controller {

    @Resource(name = "scheduler")
    private Scheduler scheduler;

    @PostMapping(value = "/api/executeTask")
    public String executeTask(TaskVO taskVO) {
        // job类
        JobDetail jobDetail = JobBuilder.newJob(ScheduleTaskJob.class)
               .withIdentity(taskVO.getJobName(), taskVO.getJobGroupName())
                .build();
        // 触发器类
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity(taskVO.getTriggerName(), taskVO.getTriggerGroupName())
                .startNow()
                .withSchedule(cronSchedule(taskVO.getCronExpression()))
                .build();
        try {
            // 执行任务
            scheduler.scheduleJob(jobDetail, trigger);
        } catch (SchedulerException e) {
            log.error("任务执行异常", e);
        }
        return "success";
    }
}

5.http接口传入的值对象,其实就是用来指定job和triger的name和groupName,__name相同的话会失败,必须是唯一的__,
6.执行程序看看效果:
我传入的参数:
jobName:job1
jobGroupName:jobGroup1
triggerName:trigger1
triggerGroupName:triggerGroup1
cronExpression:0/1 ?

jobName:job2
jobGroupName:jobGroup1
triggerName:trigger2
triggerGroupName:triggerGroup1
cronExpression:0/1 ?

图片描述

图中红色方框上部是只有一个定时任务,每一秒执行一次,下部因为又加入了一个新的任务所以回答引出两个任务的执行结果。

遇到的坑:

1.java.lang.NoSuchMethodError: org.springframework.boot.SpringApplication.run(Ljava/lang/Object;[Ljava/lang/String;)Lorg/springframework/context/ConfigurableApplicationContext;
解决方式:这个是因为springboot2不兼容的问题,所以使用springboot1.5是不会出现这个错误的。

2.Caused by: java.lang.ClassNotFoundException: org.springframework.transaction.PlatformTransactionManager

at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[na:1.8.0_162]
at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_162]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338) ~[na:1.8.0_162]
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_162]
39 common frames omitted
启动的时候如果报这个错的话,要引入一个spring-tx事物的包

 org.springframeworkgithub源码地址,朋友们觉得写得还行的帮忙star个,follower下,23333,感谢~

参考资料:

[1]https://blog.csdn.net/liuchua...
[2]https://www.w3cschool.cn/quar...
[3]https://www.ibm.com/developer...
[4]http://www.quartz-scheduler.org/

终于介绍完啦!小伙伴们,这篇关于《springboot整合quarzt实现动态定时任务》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布数据库相关知识,快来关注吧!

声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>