Spring批处理：在容错步骤中调整事务属性

Question

在Spring批处理作业中，我有一个非常基本的步骤（使用Java配置）：

@Bean
public Step step1() {
    return stepBuilders.get("stepName")
        .<Object1, Void>chunk(50)
        .reader(reader(inputResource(null))
        .processor(processor())
        .listener(stepLogger())
        .transactionAttribute(transactionTimeoutAttribute(null))
        .build();
}

   .......

@Bean
@StepScope
public StepExecutionListener stepLogger() {
    return new StepLogger();
}

@Bean
@StepScope
public TransactionAttribute transactionTimeoutAttribute(
        @Value("#{jobParameters[transactionTimeout]}") Integer timeout) {
    timeout = timeout != null ? timeout : DEFAULT_TRANSACTION_TIMEOUT;
    RuleBasedTransactionAttribute transactionAttribute = new RuleBasedTransactionAttribute();
    transactionAttribute.setTimeout(timeout);
    return transactionTimeout;
}

正如您所看到的，需要将事务超时作为作业参数给定。这样做是完美无缺的，如果我将transactionTimeout作业参数设置得太低，那么由于事务在块完成之前超时，作业执行将失败。

@Bean
public Step step1() {
    return stepBuilders.get("stepName")
        .<Object1, Void>chunk(50)
        .reader(reader(inputResource(null))
        .processor(processor())
        .faultTolerant()
        .listener(stepLogger())
        .transactionAttribute(transactionTimeoutAttribute(null))
        .build();
}

BeanCreationException: Error creating bean with name 'scopedTarget.transactionTimeoutAttribute': Scope 'step' is not active for the current thread; consider defining a scoped proxy for this bean if you intend to refer to it from a singleton; nested exception is java.lang.IllegalStateException: No context holder available for step scope

使用Java配置在Spring批处理中指定事务属性和步骤的跳过策略的正确方法是什么？

编辑：只是为了让这个问题更容易理解，我的要求是做一个容错步骤，事务超时可以配置为作业参数。对于非容错step，这不是问题，只需创建一个step范围的TransactionAttribute bean，其中连接了作业参数。但是FaultRolantStepBuilder对事务属性的处理方式不同（它基本上将给定的事务属性与其内部属性合并），因此step范围不可用。如何使用作业参数配置容错步骤的事务属性（Java配置）？

Answer 1

如果您使用的是Spring Batch3或更新版本，那么可以将transaction属性和步骤标记为@jobscope。这将防止容错步骤过早访问事务属性。