java - 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

您需要通过属性正确设置 quartz 才能将其运行到集群模式，我不确定，但恕我直言，您还应该使用 @PersistJobDataAfterExecution 注释。我使用的是集群 quartz ，没有任何问题，也没有任何问题，也有贬低的工作实现 StatefulJob .您需要向我们展示您的配置 - here is sample - 并提供 quartz 库版本