quartz定时器 Job的execute使用动态参数

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/wangh92/article/details/82381803
@GetMapping({"/addSearchIndexBySite"})
    public JsonResult addSearchIndexBySite(@RequestParam(required = false) String site) throws SchedulerException, ClassNotFoundException, IllegalAccessException, InstantiationException {
        JobDTO dto = new JobDTO();
        dto.setBeanName("tech.liveeasy.platform.kapok.elt.scheduler.UpdateSearchIndexJob");
        dto.setJobName("updateSearchIndexJob" + site);
        dto.setTriggerName("updateSearchIndexTrigger" + site);
        dto.setCronExpression("0 0 0 * * ? ");//每天0点

        JobDetail jobDetail = JobBuilder.newJob(UpdateSearchIndexJob.class)
                .withIdentity(dto.getJobName())
                .usingJobData("site", site)//在此处添加需要用的参数即可
                .build();
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(dto.getCronExpression());
        Trigger cronTrigger = newTrigger()
                .withIdentity(dto.getTriggerName())
                .startNow()
                .withSchedule(scheduleBuilder)
                .build();
        try {
            scheduler.scheduleJob(jobDetail, cronTrigger);
        } catch (ObjectAlreadyExistsException e) {
            String result = "Unable to store Job, because one already exists with this identification.";
            return new JsonResult(ResultCode.SYS_ERROR, "异常", result);
        }
        return new JsonResult(ResultCode.SUCCESS, "成功", dto);
    }
@Component
public class UpdateSearchIndexJob implements Job {

    @Override
    public void execute(JobExecutionContext context) {
        String site = null;
        try {//获取参数使用
            context.getMergedJobDataMap().getString("site");
        } catch (Exception e){
            site = null;
        }
 }
也可以这么用

trigger = trigger.getTriggerBuilder()
                .withIdentity(triggerKey)
                .usingJobData("site", jobDTO.getSite())
                .withSchedule(scheduleBuilder)
                .build();



site = context.getTrigger().getJobDataMap().getString("site");

猜你喜欢

转载自blog.csdn.net/wangh92/article/details/82381803