quartz+Spring实现动态配置定时任务

2019-01-12  本文已影响0人  减肥是不可能减肥的温

1. 引入jar包:quartz-jobs-2.2.3.jar,quartz-2.2.3.jar

2. 添加配置文件quartz.xml

3. 创建QuartzManager定时任务管理工具类

4. 创建定时任务实现类,将业务写在execute( )方法中

5. 根据业务需求管理定时任务

quartz.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
    
    <!-- 这个类用来做需要完成的业务-->
    <bean id="blankJob" class="***.***.***.BlankJob"/>
    <bean id="springContextUtil" class="***.***.***.SpringContextUtil"></bean>

    <!-- 定时任务 -->
    <!-- 定义调用对象和调用对象的方法,这个配置和普通的一样的,id是JobDetail的名字  -->
    <bean id="jobtask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <!-- 调用的类  -->
        <property name="targetObject" ref="blankJob" />
        <!-- 调用类中的方法  -->
        <property name="targetMethod" value="doNothing" />
        <!-- 是否并发  -->
        <property name ="concurrent" value ="false"  />
    </bean>

    <!-- 定义触发时间和定时任务实现类-->
    <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean ">
        <property name="jobDetail" ref="jobtask" />
        <!-- cron表达式  -->
        <property name="cronExpression" value="0 0 0 * * ?" />
    </bean>

    <!-- 总管理类 如果将lazy-init='false'那么容器启动就会执行调度程序  -->
    <bean id="startQuertz" lazy-init="true" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <!-- 手动配置定时任务,根据需要配置 -->
                <!-- <ref bean="cronTrigger" /> -->
            </list>
        </property>
    </bean>

    <!--这个类是用来设置触发时间的, startJobs方法启动调度容器 -->
    <bean id="quartzManager" class="***.***.***.QuartzManager" lazy-init="false" init-method="startJobs" >
        <!--这个对象一定要注入,这样类才能进行管理,还有在类型要用get set方法,不然会报错。-->
        <property name="scheduler" ref="startQuertz" />
    </bean>
</beans>

QuartzManager.java

import java.util.List;

import javax.annotation.Resource;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;


public class QuartzManager {
    @Resource
    private ScenarioMapper scenarioMapper;
    
    private Scheduler scheduler;

    public Scheduler getScheduler() {
        return scheduler;
    }

    public void setScheduler(Scheduler scheduler) {
        this.scheduler = scheduler;
    }

    /**
     * 功能: 添加一个定时任务
     * @param jobName 任务名
     * @param jobGroupName  任务组名
     * @param triggerName 触发器名
     * @param triggerGroupName 触发器组名
     * @param jobClass  任务的类类型  eg:TimedMassJob.class
     * @param cron   时间设置 表达式,参考quartz说明文档
     */
    public void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class jobClass, String cron,Object...objects) {
        try {
            // 任务名,任务组,任务执行类
            JobDetail jobDetail= JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();
            // 触发器
            if(objects!=null){
                for (int i = 0; i < objects.length; i++) {
                    //该数据可以通过Job中的JobDataMap dataMap = context.getJobDetail().getJobDataMap();来进行参数传递值
                    jobDetail.getJobDataMap().put("data"+(i+1), objects[i]);
                }
            }
            TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
            // 触发器名,触发器组
            triggerBuilder.withIdentity(triggerName,triggerGroupName);
            triggerBuilder.startNow();
            // 触发器时间设定
            triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));
            // 创建Trigger对象
            CronTrigger trigger = (CronTrigger) triggerBuilder.build();
            // 调度容器设置JobDetail和Trigger
            scheduler.scheduleJob(jobDetail, trigger);
            // 启动
            /*if (!scheduler.isShutdown()) {
                scheduler.start();
            }*/
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 功能:修改一个任务的触发时间
     * @param jobName
     * @param jobGroupName
     * @param triggerName 触发器名
     * @param triggerGroupName 触发器组名
     * @param cron   时间设置,参考quartz说明文档
     */
    public void modifyJobTime(String jobName, String jobGroupName, String triggerName, String triggerGroupName, String cron) {
        try {
            TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName);
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            if (trigger == null) {
                return;
            }
            String oldTime = trigger.getCronExpression();
            if (!oldTime.equalsIgnoreCase(cron)) {
                // 触发器
                TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger();
                // 触发器名,触发器组
                triggerBuilder.withIdentity(triggerName, triggerGroupName);
                triggerBuilder.startNow();
                // 触发器时间设定
                triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));
                // 创建Trigger对象
                trigger = (CronTrigger) triggerBuilder.build();
                // 方式一 :修改一个任务的触发时间
                scheduler.rescheduleJob(triggerKey, trigger);
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 功能: 移除一个任务
     * @param jobName
     * @param jobGroupName
     * @param triggerName
     * @param triggerGroupName
     */
    public void removeJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName) {
        try {
            TriggerKey triggerKey = TriggerKey.triggerKey(triggerName,triggerGroupName);
            // 停止触发器
            scheduler.pauseTrigger(triggerKey);
            // 移除触发器
            scheduler.unscheduleJob(triggerKey);
            // 删除任务
            scheduler.deleteJob(JobKey.jobKey(jobName,jobGroupName));
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    /**
     *
     * 功能:启动所有定时任务,可以在这里初始化数据库中的定时任务
     */
    public void startJobs() {
        try {
            scheduler.start();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
    /**
     * 功能:关闭所有定时任务
     */
    public void shutdownJobs() {
        try {
            if (!scheduler.isShutdown()) {
                scheduler.shutdown();
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}

cron格式转化工具类

import java.text.DecimalFormat;
public class QuartzCronDateUtils {
    /***
     *根据自己的需要编写转化方法即可  * * * * * ?:秒 分 时 日 月 星期(日和星期冲突,需把一个设为?)
     * @param  time  HH:mm:ss
     * @param  weekdays 星期(bit0:周日;bit1:周一;...;bit6:周六)
     * @return
     */
    public static String getCron(String time,int weekdays){
        String[] str = time.split(":");
        String second = str[2];
        String minute = str[1];
        String hour = str[0];
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append(second).append(" ").append(minute).append(" ").append(hour).append(" ? * ");
        String week = Integer.toBinaryString(weekdays);
        DecimalFormat df = new DecimalFormat("0000000");
        week = df.format(Integer.parseInt(week));
        for (int i = 6; i >= 0; i--) {
            if (Integer.valueOf(week.substring(i, i+1)) == 1) {
                stringBuffer.append((7-i) + ",");
            }
        }
        String cron = stringBuffer.toString();
        return cron.substring(0, cron.length()-1);
    }
}

定时任务实现类TaskJob.java

import java.util.List;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.springframework.context.ApplicationContext;
//实现Job接口的execute方法
public class TaskJob implements Job {
    
    private int taskId;
    
    public TaskJob(int taskId) {
        this.taskId = taskId;
    }
    
    public TaskJob() {
    }
    
    public int getTaskId() {
        return taskId;
    }
    
    @Override
    public void execute(JobExecutionContext arg0) {
      //可根据argo参数,获取定时任务的相关属性
          JobDataMap jobDataMap = arg0.getMergedJobDataMap();
          TaskJob jobDemo = (TaskJob)jobDataMap.get("data1");
          System.out.println(jobDemo.taskId);
    }   
}
上一篇下一篇

猜你喜欢

热点阅读