控制回滚

默认情况下，无论是否配置了重试或跳过，从 ItemWriter 抛出的任何异常都会导致 Step 控制的事务回滚。如果按照前面描述的方式配置了跳过，则从 ItemReader 抛出的异常不会导致回滚。然而，在许多场景中，从 ItemWriter 抛出的异常不应导致回滚，因为没有发生任何操作来使事务无效。因此，您可以为 Step 配置一个不应导致回滚的异常列表。

  • Java

  • XML

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

Java 配置
@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 配置
<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>

事务性 ItemReader

ItemReader 的基本约定是它只能向前读取。step 会缓冲 reader 的输入，以便在发生回滚时，无需从 reader 重新读取项目。然而，在某些场景中，reader 是构建在事务性资源之上的，例如 JMS 队列。在这种情况下，由于队列与回滚的事务绑定在一起，从队列中拉取的消息会被放回队列。因此，您可以配置 step 不缓冲这些项目。

  • Java

  • XML

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

Java 配置
@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 中创建一个不缓冲项目的 ItemReader

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