spring-boot+quartz实现web页面增删改定时任务

spring-boot集成quartz，支持在web页面中添加任务，暂停任务，继续执行任务，修改任务执行周期，测试任务，删除任务，以及quartz集群模式。

添加的任务需要实现Job接口，并有spring管理bean，例如DemoService,DemoService2

这个项目也集成了spring-data,可以用来写业务。

TaskUtil类实现了任务的增加，删除，修改，以及测试：

package com.htxa.wecare.util;

import com.htxa.wecare.StartWebApplication;
import com.htxa.wecare.model.CronTriggerWithState;
import com.htxa.wecare.model.TaskEntity;
import org.quartz.*;
import org.quartz.impl.StdScheduler;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

/**
 * Description:
 *
 * @author <a href="mailto:[e-mail]">chenhao</a>
 *         Create Time: 2017/8/18 10:56
 */
@Component
public class TaskUtil {

    @Resource
    private StdScheduler stdScheduler;

    public String addTask(TaskEntity taskEntity){
        try {
            JobDataMap map = new JobDataMap();
            map.put("targetObject", taskEntity.getTaskService());
            map.put("targetMethod", "execute");
            JobDetail jobDetail = newJob(DetailQuartzJobBean.class).withIdentity(taskEntity.getTaskService())
                    .usingJobData(map).storeDurably().requestRecovery().build();

            CronTrigger cronTrigger=newTrigger().forJob(jobDetail).withIdentity(taskEntity.getTaskService(), Scheduler.DEFAULT_GROUP)
                    .withDescription(taskEntity.getDescription())
                    .withSchedule(cronSchedule(taskEntity.getCronExpression())).build();
            stdScheduler.scheduleJob(jobDetail,cronTrigger);
            return "SUCCESS";
        } catch (ObjectAlreadyExistsException e) {
            e.printStackTrace();
            return e.getMessage();
        }catch (RuntimeException e) {
            e.printStackTrace();
            return e.getMessage();
        } catch (SchedulerException e) {
            e.printStackTrace();
            return e.getMessage();
        }catch (Exception e){
            e.printStackTrace();
            return e.getMessage();
        }

    }

    public Boolean deleteTask(String triggerName){
        try {
            TriggerKey triggerKey=new TriggerKey(triggerName, null);
            JobKey jobKey=new JobKey(triggerName,null);
            stdScheduler.unscheduleJob(triggerKey);
            stdScheduler.deleteJob(jobKey);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    public String modifySchedule(TaskEntity taskEntity){
        try {
            JobKey jobKey=new JobKey(taskEntity.getTaskService(),null);
            JobDetail jobDetail=stdScheduler.getJobDetail(jobKey);

            CronTrigger cronTrigger=newTrigger().forJob(jobDetail).withIdentity(taskEntity.getTaskService(), Scheduler.DEFAULT_GROUP)
                    .withDescription(taskEntity.getDescription())
                    .withSchedule(cronSchedule(taskEntity.getCronExpression())).build();

            TriggerKey triggerKey=new TriggerKey(taskEntity.getTaskService(), null);
            stdScheduler.rescheduleJob(triggerKey,cronTrigger);
            return "SUCCESS";
        } catch (ObjectAlreadyExistsException e) {
            e.printStackTrace();
            return e.getMessage();
        }catch (RuntimeException e) {
            e.printStackTrace();
            return e.getMessage();
        } catch (SchedulerException e) {
            e.printStackTrace();
            return e.getMessage();
        }catch (Exception e){
            e.printStackTrace();
            return e.getMessage();
        }
    }

    public Boolean pauseTase(String triggerName){
        try {
            TriggerKey triggerKey=new TriggerKey(triggerName, null);
            stdScheduler.pauseTrigger(triggerKey);
            return true;
        } catch (SchedulerException e) {
            e.printStackTrace();
            return false;
        }
    }

    public Boolean resumeTask(String triggerName){
        try {
            TriggerKey triggerKey=new TriggerKey(triggerName, null);
            stdScheduler.resumeTrigger(triggerKey);
            return true;
        } catch (SchedulerException e) {
            e.printStackTrace();
            return false;
        }
    }

    public List<CronTriggerWithState> getAllTask(){
        List<CronTriggerWithState> list=new ArrayList<>();
        try {
            Set<TriggerKey> triggerKeys=stdScheduler.getTriggerKeys(GroupMatcher.anyTriggerGroup());
            for(TriggerKey key:triggerKeys){
                CronTriggerWithState trigger=new CronTriggerWithState();
                trigger.setCronTrigger((CronTrigger) stdScheduler.getTrigger(key));
                trigger.setStateName(stdScheduler.getTriggerState(key).name());
                list.add(trigger);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }

    public Boolean testTask(String taskService){
        try {
            Job job=(Job) StartWebApplication.applicationContext.getBean(taskService);
            job.execute(null);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

}

代码链接：

点击打开链接