定时任务调度Quartz实现

public class MyJob implements Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(dateFormat.format(new Date()) + " hello quartz!");
    }
}

public class MyScheduler {
    public static void main(String[] args) throws SchedulerException {
        // 获取调度器实例
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        // 启动调度器
        scheduler.start();
        // 定义任务
        JobDetail job = JobBuilder.newJob(MyJob.class)
                .withIdentity("fwj-job", "fwj-group")
                .build();
        // 定义触发器
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("fwj-trigger", "fwj-group")
                .startNow()
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever())
                .build();
        // 告诉调度器任务和使用的触发器
        scheduler.scheduleJob(job, trigger);
    }
}

public class QuartzUtil {
    private static final Logger logger = LoggerFactory.getLogger(QuartzUtil.class);

    public static List<JobEntity> getList(String jobGroup) throws SchedulerException {
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        Set<JobKey> jobKeys = scheduler.getJobKeys(GroupMatcher.jobGroupEquals(jobGroup));
        List<JobEntity> jobEntityList = new ArrayList<>();
        for (JobKey jobKey : jobKeys) {
            JobEntity entity = new JobEntity();
            entity.setJobName(jobKey.getName());
            entity.setJobGroup(jobKey.getGroup());
            entity.setClassName(scheduler.getJobDetail(jobKey).getJobClass().getName());
            TriggerKey triggerKey = TriggerKey.triggerKey(jobKey.getName(), jobGroup);
            entity.setCron(((CronTrigger)scheduler.getTrigger(triggerKey)).getCronExpression());
            jobEntityList.add(entity);
        }
        return jobEntityList;
    }

    /**
     * 添加任务
     * @param className 类路径
     * @param jobName 任务名称
     * @param jobGroup 组别
     * @param cronExpression cron表达式
     * @throws Exception
     */
    public static void addJob(String className, String jobName, String jobGroup, String cronExpression)
            throws Exception {
        JobDetail jobDetail = JobBuilder.newJob(getClass(className).getClass())
                .withIdentity(jobName, jobGroup).build();
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression)
                .withMisfireHandlingInstructionDoNothing();
        CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroup)
                .withSchedule(scheduleBuilder).build();
        try {
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
            scheduler.pauseJob(JobKey.jobKey(jobName, jobGroup));
            logger.info("创建定时任务{}成功", jobName);
        } catch (SchedulerException e) {
            logger.error("创建定时任务失败：" + e);
            throw new SchedulerException("创建定时任务失败");
        }
    }

    /**
     * 暂停任务
     * @param jobName 任务名
     * @param jobGroup 组别
     * @throws SchedulerException
     */
    public static void pauseJob(String jobName, String jobGroup) throws SchedulerException {
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        logger.info("停用任务{}", jobName);
        scheduler.pauseJob(JobKey.jobKey(jobName, jobGroup));
    }

    /**
     * 启用一个定时任务
     * @param jobName 任务名称
     * @param jobGroup 组别
     * @throws SchedulerException
     */
    public static void resumeJob(String jobName, String jobGroup) throws SchedulerException {
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        logger.info("启用任务{}", jobName);
        scheduler.resumeJob(JobKey.jobKey(jobName, jobGroup));
        if (!scheduler.isStarted()) {
            scheduler.start();
        }
    }

    /**
     * 删除定时任务
     * @param jobName 任务名称
     * @param jobGroup 组别
     * @throws SchedulerException
     */
    public static void deleteJob(String jobName, String jobGroup) throws SchedulerException {
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        logger.info("删除任务{}", jobName);
        scheduler.pauseTrigger(TriggerKey.triggerKey(jobName, jobGroup));
        scheduler.unscheduleJob(TriggerKey.triggerKey(jobName, jobGroup));
        scheduler.deleteJob(JobKey.jobKey(jobName, jobGroup));
    }

    public static void updateScheduler(String jobName, String jobGroup, String cronExpression) throws SchedulerException {
        try {
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
            TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
            CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder)
                    .startNow().build();
            scheduler.rescheduleJob(triggerKey, trigger);
            logger.info("更新定时任务{}成功", jobName);
        } catch (SchedulerException e) {
            logger.error("更新定时任务失败：" + e);
            throw new SchedulerException("更新定时任务失败");
        }
    }

    private static Job getClass(String className) throws ClassNotFoundException, IllegalAccessException, InstantiationException {
        Class<?> aClass = Class.forName(className);
        return (Job) aClass.newInstance();
    }
}

@RestController
@RequestMapping("/job")
public class SysJobController {

    @GetMapping("/add")
    public String addJob(@RequestParam("name") String jobName,
                         @RequestParam("class") String className,
                         @RequestParam("cron") String cron) {
        try {
            QuartzUtil.addJob("com.fang.quartzdemo.ram." + className, jobName,
                    "fwj-group", cron);
            return "success";
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "fail";
    }

    @GetMapping("/list")
    public List<JobEntity> getList(@RequestParam("group") String jobGroup) throws SchedulerException {
        return QuartzUtil.getList(jobGroup);
    }

    @GetMapping("/start")
    public String startJob(@RequestParam("name") String jobName, @RequestParam("group") String jobGroup) {
        try {
            QuartzUtil.resumeJob(jobName, jobGroup);
            return "success";
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return "fail";
    }

    @GetMapping("/stop")
    public String stopJob(@RequestParam("name") String jobName, @RequestParam("group") String jobGroup) {
        try {
            QuartzUtil.pauseJob(jobName, jobGroup);
            return "success";
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return "fail";
    }

    @GetMapping("/delete")
    public String deleteJob(@RequestParam("name") String jobName, @RequestParam("group") String jobGroup) {
        try {
            QuartzUtil.deleteJob(jobName, jobGroup);
            return "success";
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return "fail";
    }
}

@Component
public class InitStartScheduler implements CommandLineRunner {
    private static final Logger logger = LoggerFactory.getLogger(InitStartScheduler.class);
    @Override
    public void run(String... args) throws Exception {
        logger.info("启动调度器...");
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        scheduler.start();
    }
}