春季批次：单个工作实例侦听器

Question

我想确保仅允许一个工作实例运行。如果另一个实例已经运行，请停止它。 因此，我实施了一个听众，该听众检查以下操作的数量：（如果是正确的停止工作，我不是SUR）

public class SingleJobInstanceListener implements JobExecutionListener {

    @Override
    public void beforeJob(JobExecution jobExecution) {
        final String jobName = jobExecution.getJobInstance().getJobName();
        LOGGER.info("Listener to check one {} job instance is running", jobName);
        if (Constants.JOB_NAME.equals(jobName)) {
            final Set<JobExecution> executionSet = jobExplorer.findRunningJobExecutions(jobName);
            if (executionSet.size() > 1) {
                for (JobExecution execution : executionSet) {
                        execution.stop();
                        LOGGER.info("{} job instance {} is stopped", jobName, execution.getJobInstance().getInstanceId());
                }
            }
        }
    }
    
}

运行工作：

 @Scheduled(cron = "0/10 * * * * *")
 public void runSpringBatchJob() {
     LOGGER.info("Job was started");
     final JobExecution streamExecution = jobLauncher.run(job, newExecution());
     LOGGER.info("Exit data job with status: {}", streamExecution.getStatus());
     LOGGER.info("Exit data job ID: {}", streamExecution.getJobId());
     LOGGER.info("-----------------------------------------------------");
}

日志：

SpringBatchJobLauncher       : Job was started
SingleJobInstanceListener    : Listener to check one testJob job instance is running
SingleJobInstanceListener    : testJob job instance 178 is stopped
SingleJobInstanceListener    : testJob job instance 160 is stopped
SingleJobInstanceListener    : testJob job instance 154 is stopped
StreamWriter                 : Writing data: [......]
SpringBatchJobLauncher       : Exit data job with status: COMPLETED
SpringBatchJobLauncher       : Exit data job ID: 178
SpringBatchJobLauncher       : -----------------------------------------------------
SpringBatchJobLauncher       : Job was started
SingleJobInstanceListener    : Listener to check one testJob job instance is running
SingleJobInstanceListener    : testJob job instance 160 is stopped
SingleJobInstanceListener    : testJob job instance 179 is stopped
SingleJobInstanceListener    : testJob job instance 154 is stopped
StreamWriter                 : Writing data: [......]
SpringBatchJobLauncher       : Exit data job with status: COMPLETED
SpringBatchJobLauncher       : Exit data job ID: 179

我的问题是什么是使工作的原因实例3次（因为每次作业正在运行它的本身3次），如果停止作业178，为什么它再次运行退出数据作业ID：178

Answer 1

鉴于您正确地定义了一个集中的交易库存储库，并正确设计具有独特的识别作业参数的工作实例，因此您要实现的功能已经由Spring Batch提供。

使用此侦听器方法，您正在运行额外的作业执行，并检查当前是否有另一个工作。借助Spring Batch的内置功能，第二个作业执行甚至还没有开始，该作业启动器将阻止在启动时（这种失败快速的方法更有效）。

像您似乎拥有的本地计划的作业一样，一个很好的识别作业参数可能是运行时间戳。例如，您将每10分钟就有一个工作实例。现在，如果另一种计划的方法试图运行相同的作业实例，则与第一个方法同时说9:10 ，春季批次将阻止其中一个人运行，这要归功于集中的交易工作存储库方法。

这也可以在聚类的环境中起作用，在该环境中，您的应用程序的另一个实例（在JVM级别）试图与第一个应用程序同时运行9:10 的相同作业实例。春季批次还将防止同一实例的重复作业执行。但是，在不保证时钟同步的分布式环境中，单个时间戳参数不足以识别工作实例，您需要将另一个歧视器添加到设置的识别作业参数中，以便在集群中唯一地识别工作实例等级。