如何从应用程序的多个实例同时运行相同的spring批处理作业

Question

我创建了一个Spring批处理作业，它在定义的时间使用调度器执行。我们有同一个应用程序的多个实例，因此相同的作业从多个实例中同时执行。所有应用程序使用相同的数据库。由于那我得到下面的错误

堆栈跟踪：org。springframework。交易TransactionSystemException:无法提交JDBC事务；嵌套的异常是org。postgresql。util。PSQLException:错误：由于事务之间的读/写依赖关系，无法序列化访问详细信息：原因代码：在提交尝试期间，在标识为枢轴时取消。提示：如果重试，事务可能会成功。在org。springframework。jdbc。数据源。数据源事务管理器。doCommit（DataSourceTransactionManager.java:335）位于org。springframework。交易支持AbstractPlatformTransactionManager。processCommit（AbstractPlatformTransactionManager.java:743）位于org。springframework。交易支持AbstractPlatformTransactionManager。在org提交（AbstractPlatformTransactionManager.java:711）。springframework。交易拦截器。TransactionSpect支持。commitTransactionAfterReturning（TransactionSpectSupport.java:631）位于org。springframework。交易拦截器。TransactionSpect支持。在org上调用Withintransaction（TransactionSpectSupport.java:385）。springframework。交易拦截器。交易接收器。在org调用（TransactionInterceptor.java:118）。springframework。aop。框架ReflectiveMethodInvocation。在org上继续（ReflectiveMethodInvocation.java:186）。springframework。一批果心存储库。支持AbstractJobRepositoryFactoryBean$1。在org调用（AbstractJobRepositoryFactoryBean.java:181）。springframework。aop。框架ReflectiveMethodInvocation。在org上继续（ReflectiveMethodInvocation.java:186）。springframework。aop。框架JdkDynamicAopProxy。在com上调用（JdkDynamicAopProxy.java:212）。太阳代理$Proxy209。组织上的createJobExecution（未知源）。springframework。一批果心发射支持simplejoblancher。运行（simplejoblancher.java:137）

我用下面的代码说明了我的工作-

JobParameters params = new JobParametersBuilder()
            .addString("JobID", UUID.randomUUID().toString(), true)
            .toJobParameters();
jobLauncher.run(job, params);

并在yaml文件中执行以下配置

batch:
job:
  enabled: false
initialize-schema: always
repository:
  isolationlevelforcreate: ISOLATION_READ_COMMITTED

我添加了监听器来检查任何正在运行的作业是否处于启动状态，如果找到任何正在运行的作业，则当前作业将停止

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) {

}

}

但我仍然得到上述错误。如果只有一个应用程序实例，那么作业运行正常。有没有办法同时从多个应用程序实例运行相同的作业，或者只允许从任何一个应用程序运行一个作业。

Answer 1

隔离级别没有像您期望的那样考虑到该属性。要自定义隔离级别，需要通过BatchConfigurer提供JobRepository。下面是一个简单的例子：

@Configuration
@EnableBatchProcessing
public class MyJobConfig extends BasicBatchConfigurer {

    @Override
    protected JobRepository createJobRepository() throws Exception {
        JobRepositoryFactoryBean repositoryFactoryBean = new JobRepositoryFactoryBean();
        repositoryFactoryBean.setIsolationLevelForCreate("ISOLATION_READ_COMMITTED");
        // set other properties on the factory bean
        repositoryFactoryBean.afterPropertiesSet();
        return repositoryFactoryBean.getObject();
    }
}

在这里的留档中解释了这一点：JobRepository的事务配置。

注意：BasicBatchConfigurer来自Spring Boot。如果在没有Spring Boot的情况下使用Spring批处理，则可以扩展DefaultBatchConfigurer。