1

我偶尔需要更新作业的触发器。我的触发器只触发一次，并且触发日期可能会有所不同。

所以我有一个 JobManager 来管理这种情况。这个想法是检查给定的 jobDetail 是否已经存在，然后删除它并创建一个新的，但我得到了奇怪的行为和这个异常。

所以我的控制器调用jobManager.createJob(interruttore, richiesta);它是：

public void createJob(Interruttore interruttore, Date richiesta) throws SchedulerException {

        JobDetail jobDetail = createJobDetail(interruttore);

        createOrUpdateScheduledJobs(interruttore, jobDetail, richiesta);
    }

这是 createJob

public JobDetail createJobDetail(Interruttore interruttore) throws SchedulerException {
        if (scheduler.getScheduler().checkExists(JobKey.jobKey("JobDetail" + interruttore.getNomeInterruttore()))) {
            logger.debug("jobDetail already present, delete it");scheduler.getScheduler().deleteJob(JobKey.jobKey("JobDetail" + interruttore.getNomeInterruttore()));
        } 
        logger.debug("Il jobDetail non esiste, lo creo");
        JobDetailFactoryBean jobDetailFactoryBean = new JobDetailFactoryBean();
        jobDetailFactoryBean.setJobClass(TimeoutJob.class);
        jobDetailFactoryBean.setName("JobDetail" + interruttore.getNomeInterruttore());
        jobDetailFactoryBean.setGroup("timeoutJobDetail");
        jobDetailFactoryBean.setDescription("Job for timeout");
        jobDetailFactoryBean.setDurability(true);

        Map<String, Integer> map = new HashMap<String, Integer>();
        map.put("idInterruttore", interruttore.getIdInterruttore());
        jobDetailFactoryBean.setJobDataAsMap(map);
        jobDetailFactoryBean.afterPropertiesSet();
        logger.debug("JobDetail is " + jobDetailFactoryBean.toString());

        return jobDetailFactoryBean.getObject();

    }

并且createOrUpdateScheduledJobs(interruttore, jobDetail, richiesta);是以下

public void createOrUpdateScheduledJobs(Interruttore interruttore, JobDetail jobDetail,
            Date richiesta) throws SchedulerException {


        // check if trigger exists
        boolean triggerExist = scheduler.getObject().checkExists(
                TriggerKey.triggerKey("myTrigger" + interruttore.getNomeInterruttore(), "timeoutTriggers"));
        logger.debug("Trigger exists? :" + triggerExist);

        if (triggerExist) { //replace trigger and reschedule job

            SimpleTrigger oldTrigger = (SimpleTrigger) scheduler.getScheduler().getTrigger(
                    TriggerKey.triggerKey("myTrigger" + interruttore.getNomeInterruttore(), "timeoutTriggers"));
            TriggerBuilder<SimpleTrigger> tb = oldTrigger.getTriggerBuilder();
            SimpleTrigger newTrigger = tb.startAt(richiesta).build();
            scheduler.getScheduler().rescheduleJob(((SimpleTrigger) oldTrigger).getKey(), newTrigger);
            logger.debug("new Trigger with firetime " + newTrigger.getNextFireTime());

        } else { // create a new one
            // creo il trigger e lo schedulo il job
            SimpleTriggerFactoryBean trigger = new SimpleTriggerFactoryBean();
            trigger.setName("myTrigger" + interruttore.getNomeInterruttore());
            trigger.setGroup("timeoutTriggers");
            trigger.setJobDetail(jobDetail.getObject());
            trigger.setStartTime(richiesta);
            trigger.setRepeatCount(0);
            trigger.afterPropertiesSet();
            try {
                scheduler.getScheduler().scheduleJob(jobDetail, trigger.getObject());
            } catch (SchedulerException e) {
                logger.error("Errore: ", e);
            }
            logger.debug("Trigger object is :" + trigger.getObject());
        }

    }

当我启动应用程序时，一切正常，然后我的控制器第二次调用该方法时出现异常

org.quartz.ObjectAlreadyExistsException: Unable to store Job : 'timeoutJobDetail.JobDetailZona -2A', because one already exists with this identification.

新建jobDetail的方法没有找到之前要删除的jobDetail实例，但是新建的时候发现确实存在...

4

1 回答 1

0

TriggerKey 和 JobKey 由 Name 和 Group 组成。

因此，您需要在 TriggerKey 和 JobKey 中指定与 SimpleTriggerFactoryBean 和 JobDetailFactoryBean 相同的 Group。

抱歉，我没有正确检查，但是当我更改 JobKey 和 TriggerKey 时。第二次在 createJobDetail 方法中调用 Scheduler.deleteJob() 方法。

于 2016-12-31T07:27:37.320 回答