美文网首页
springboot 框架集成定时框架(傻瓜式直接使用版,不需要

springboot 框架集成定时框架(傻瓜式直接使用版,不需要

作者: 我想放假休息 | 来源:发表于2021-01-29 14:41 被阅读0次

    引入依赖

            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-quartz</artifactId>
            </dependency>
    
    
    import com.example.quartz.bean.QuartzBean;
    import lombok.Data;
    import org.quartz.*;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    /**
     * @author HQLD
     * @description
     * @date 2021-01-29 14:30
     */
    @Service
    public class QuartzService {
        /**
         * 注入任务调度
         */
        @Autowired
        private Scheduler scheduler;
    
    
        /**
         * 创建定时任务 定时任务创建之后默认启动状态
         *
         * @param quartzBean 定时任务信息类
         */
        public void createScheduleJob(QuartzBean quartzBean) {
            try {
                //获取到定时任务的执行类  必须是类的绝对路径名称
                //定时任务类需要是job类的具体实现 QuartzJobBean是job的抽象类。
                Class<? extends Job> jobClass = (Class<? extends Job>) Class.forName(quartzBean.getJobClass());
                // 构建定时任务信息
                JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(quartzBean.getJobName()).build();
                // 设置定时任务执行方式
                CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzBean.getCronExpression());
                // 构建触发器trigger
                CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(quartzBean.getJobName()).withSchedule(scheduleBuilder).build();
                scheduler.scheduleJob(jobDetail, trigger);
            } catch (ClassNotFoundException e) {
                System.out.println("定时任务类路径出错:请输入类的绝对路径");
            } catch (SchedulerException e) {
                System.out.println("创建定时任务出错:" + e.getMessage());
            }
        }
    
        /**
         * 根据任务名称暂停定时任务
         *
         * @param jobName 定时任务名称
         */
        public void pauseScheduleJob(String jobName) {
            JobKey jobKey = JobKey.jobKey(jobName);
            try {
                scheduler.pauseJob(jobKey);
            } catch (SchedulerException e) {
                System.out.println("暂停定时任务出错:" + e.getMessage());
            }
        }
    
        /**
         * 根据任务名称恢复定时任务
         *
         * @param jobName 定时任务名称
         */
        public void resumeScheduleJob(String jobName) {
            JobKey jobKey = JobKey.jobKey(jobName);
            try {
                scheduler.resumeJob(jobKey);
            } catch (SchedulerException e) {
                System.out.println("启动定时任务出错:" + e.getMessage());
            }
        }
    
        /**
         * 根据任务名称立即运行一次定时任务
         *
         * @param jobName 定时任务名称
         */
        public void runOnce(String jobName) {
            JobKey jobKey = JobKey.jobKey(jobName);
            try {
                scheduler.triggerJob(jobKey);
            } catch (SchedulerException e) {
                System.out.println("运行定时任务出错:" + e.getMessage());
            }
        }
    
        /**
         * 更新定时任务
         *
         * @param quartzBean 定时任务信息类
         */
        public void updateScheduleJob(QuartzBean quartzBean) {
            try {
                //获取到对应任务的触发器
                TriggerKey triggerKey = TriggerKey.triggerKey(quartzBean.getJobName());
                //设置定时任务执行方式
                CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzBean.getCronExpression());
                //重新构建任务的触发器trigger
                CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
                trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
                //重置对应的job
                scheduler.rescheduleJob(triggerKey, trigger);
            } catch (SchedulerException e) {
                System.out.println("更新定时任务出错:" + e.getMessage());
            }
        }
    
        /**
         * 根据定时任务名称从调度器当中删除定时任务
         *
         * @param jobName 定时任务名称
         */
        public void deleteScheduleJob(String jobName) {
            JobKey jobKey = JobKey.jobKey(jobName);
            try {
                scheduler.deleteJob(jobKey);
            } catch (SchedulerException e) {
                System.out.println("删除定时任务出错:" + e.getMessage());
            }
        }
    
        @Data
        public class QuartzBean {
            /**
             * 任务id
             */
            private String id;
    
            /**
             * 任务名称
             */
            private String jobName;
    
            /**
             * 任务执行类
             */
            private String jobClass;
    
            /**
             * 任务状态 启动还是暂停
             */
            private Integer status;
    
            /**
             * 任务运行时间表达式
             */
            private String cronExpression;
            //省略getter setter
        }
    }
    
    

    使用例子

        @Autowired
        QuartzService quartzService;
    
        @RequestMapping("/createJob")
        public String  createJob(QuartzBean quartzBean)  {
            try {
                //进行测试所以写死
                quartzBean.setJobClass("com.example.quartz.bean.MyTask1");
                quartzBean.setJobName("test1");
                quartzBean.setCronExpression("*10/ * * * * ?");
                quartzService.createScheduleJob(quartzBean);
            } catch (Exception e) {
                return "创建失败";
            }
            return "创建成功";
        }
    
    package com.example.quartz.bean;
    
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    import org.springframework.scheduling.quartz.QuartzJobBean;
    
    import java.util.Date;
    
    public class MyTask1 extends QuartzJobBean {
        @Override
        protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
            //TODO 这里写定时任务的执行逻辑
            System.out.println("动态的定时任务执行时间:"+new Date().toLocaleString());
        }
    }
    

    相关文章

      网友评论

          本文标题:springboot 框架集成定时框架(傻瓜式直接使用版,不需要

          本文链接:https://www.haomeiwen.com/subject/smvqtltx.html