Controlling Rollback

默认情况下，无论重试或跳过，从 ItemWriter 引发的任何异常都会导致由 Step 控制的交易回滚。如果按照前面所述配置跳过，则从 ItemReader 引发的异常不会导致回滚。然而，存在许多场景，在这种场景中，从 ItemWriter 引发的异常不应导致回滚，因为没有发生任何导致交易失效的操作。因此，您可以使用不应导致回滚的异常列表配置 Step。

Java

在 Java 中，您可以按如下方式控制回滚：

Java Configuration
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
	return new StepBuilder("step1", jobRepository)
				.<String, String>chunk(2, transactionManager)
				.reader(itemReader())
				.writer(itemWriter())
				.faultTolerant()
				.noRollback(ValidationException.class)
				.build();
}
XML

在 XML 中，您可以按如下方式控制回滚：

XML Configuration
<step id="step1">
   <tasklet>
      <chunk reader="itemReader" writer="itemWriter" commit-interval="2"/>
      <no-rollback-exception-classes>
         <include class="org.springframework.batch.item.validator.ValidationException"/>
      </no-rollback-exception-classes>
   </tasklet>
</step>

Transactional Readers

ItemReader 的基本契约是它仅进不退。该步骤缓冲了读取输入，因此在回滚的情况下，无需从读取器重新读取项目。然而，存在某些场景，在这种场景中，读取器是建立在交易资源之上，例如 JMS 队列。在此情况下，由于队列已绑定到已回滚的交易，因此从队列中提取的消息将被放回去。出于此原因，您可以配置该步骤以不缓冲项目。

Java

以下示例展示了如何在 Java 中创建一个不缓冲项目的读取器：

Java Configuration
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
	return new StepBuilder("step1", jobRepository)
				.<String, String>chunk(2, transactionManager)
				.reader(itemReader())
				.writer(itemWriter())
				.readerIsTransactionalQueue()
				.build();
}
XML

以下示例展示了如何在 XML 中创建一个不缓冲项目的读取器：

XML Configuration
<step id="step1">
    <tasklet>
        <chunk reader="itemReader" writer="itemWriter" commit-interval="2"
               is-reader-transactional-queue="true"/>
    </tasklet>
</step>