Spring批处理限制多个服务器上作业的单个实例

Question

我有一个Spring批处理作业，它可能在多个服务器上运行。我有一个监听器,可以防止作业的多个实例在一台服务器上同时运行。但是，我要确保该作业不能同时在多台服务器上运行。

我已经找遍了，但没有找到解决这个问题的办法

Answer 1

我实现了一个侦听器，它检查spring批处理控制表中与某个名称匹配的正在运行的作业执行数。如果执行的大小超过1，则当前作业的jobExecution失败。代码如下：

@Component
public class SingleInstanceListener implements JobExecutionListener {
    @Autowired
    private JobExplorer explorer;

    @Override
    public void beforeJob(JobExecution jobExecution) {
        String jobName = jobExecution.getJobInstance().getJobName();
        Set<JobExecution> executions = explorer.findRunningJobExecutions(jobName);
        if(executions.size() > 1) {
            jobExecution.stop();
        }
    }

    @Override
    public void afterJob(JobExecution jobExecution) {

    }

}