Quartz 两次触发同一个实例

Question

我们在 Java 类中使用 DisallowConcurrentExecutionAttribute 注释来防止多个实例的并发执行，但是，看起来 Quartz 已经同时触发了两次同一个实例。请解决此问题并向我们提供更多信息，如果是错误，请修复此问题。

@Override
@Transactional(propagation = Propagation.REQUIRED, readOnly = false)
public void execute(final JobExecutionContext jobExecutionContext) throws JobExecutionException {
    logger.log(Log.DEBUG, "++++ Quartz JOB BatchJobDetector started");
    try {
        this.setJobExecutionContext(jobExecutionContext);
        boolean triggerNextJob = true;
        while (triggerNextJob) {
            TriggeredBatchProcessDTO triggeredBatchProcessDTO = getNextJob(jobExecutionContext, 0);
            if (triggeredBatchProcessDTO != null) {

                triggerJobImmediatly(triggeredBatchProcessDTO.getId(), jobExecutionContext);
                triggeredBatchProcessDTO.setState(StatusType.RUNNING);  
                triggeredBatchProcessDTO.setProcessDtTm(triggeredBatchProcessDTO.getProcessDtTm());//CRGRO022
                updateTriggeredBatchProcessDTO(triggeredBatchProcessDTO);

            } else {
                triggerNextJob = false;
            }
        }
    } catch (final UnexpectedRuntimeException e) {
        logger.log(Log.ERROR, "Error during execution of TriggeredBatchProcessDetectorJob: " + e.getMessage(), e);
        throw e;
    } catch (final Throwable t) {
        throw new UnexpectedRuntimeException(CoreExceptionId.RUN_0001_UNEXPECTED_EXCEPTION,
            new Object[] { "TriggeredBatchProcessDetectorJob error" }, t);
    }
    logger.log(Log.DEBUG, "++++ Quartz JOB BatchDetector finished");
}

Answer 1

您需要通过属性正确设置石英以将其运行到集群模式，我不确定，但恕我直言，您还应该使用 @PersistJobDataAfterExecution 注释。我在使用集群石英时也没有任何问题 StatefulJob。您需要向我们展示您的配置 - here is sample - 并提供石英库版本