java - Spring批处理仅限制单个作业实例

Question

我有一个可以被 rest URL 踢掉的 spring batch 作业。我想确保只允许运行一个作业实例。如果另一个实例已经在运行，则不要启动另一个实例。即使参数不同。

我进行了搜索，但没有发现开箱即用的解决方案。考虑扩展 SimpleJobLauncher。检查作业的任何实例是否正在运行。

Answer 1

你可以试试 intercept the job execution , 实现 JobExecutionListener 接口(interface):

public class MyJobExecutionListener extends JobExecutionListener {

    //active JobExecution, used as a lock.
    private JobExecution _active;

    public void beforeJob(JobExecution jobExecution) {
        //create a lock
        synchronized(jobExecution) {
            if(_active!=null && _active.isRunning()) {
                jobExecution.stop();
            } else {
                _active=jobExecution;
            }
        }
    }

    public void afterJob(JobExecution jobExecution) {
          //release the lock
          synchronized(jobExecution) {
              if(jobExecution==_active) {
                _active=null; 
              }
          }
    }
}

然后，注入(inject)作业定义:

<job id="myJobConfig">
    <listeners>
        <listener ref="myListener"/>
    </listeners>
</job>