我有一份 Spring 批处理工作,可以通过其他URL来解决。我想确保只允许运行一个作业实例。如果另一个实例已经在运行,则不要启动另一个实例。即使参数不同。

我搜索后,没有发现任何开箱即用的解决方案。扩展SimpleJobLauncher的想法。检查作业的任何实例是否在运行。

最佳答案

您可以尝试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定义:
<job id="myJobConfig">
    <listeners>
        <listener ref="myListener"/>
    </listeners>
</job>

10-07 13:10