块中的春季批处理异常

Question

我有一个弹簧批处理作业，它有多个步骤。

步骤 1 ：从数据库加载 10 条记录。（任务包完成这项工作）

第 2 步：此处使用 ItemReader、ItemProcessor、ItemWriter 实现配置的面向块的处理，提交间隔 =1

现在据我了解，对于每条记录都会发生这种情况

开始事务 （ 读取 - 处理 - 写入 ） 提交 TX

1. 我的问题是假设它处理了六条记录，现在有了第七条记录，它在 ItemProcessor 实现中出现了异常，它尝试回滚但由于事务处于未知状态而无法回滚

2. 即使它无法回滚第 7 条记录的 tx，它也根本不处理第 8、9、10 条记录，并且作业已停止。

注意：ItemProcessor 实现正在调用使用@Transactional（readOnly=false） 注释标记为事务性的服务（@Service注释）。

请提出解决方案。

项目处理器代码如下

public Long process(LoanApplication loanApplication)throws Exception {
    Long createLoan = null;
    LoanStatus loanStatus = null;
    StaffUser user = staffUserService.getStaffUserByName(Constants.AUTO_USER);
    String notes = null;
    try{
        try{
            loanValidationService.validate(loanApplication);
            loanStatus=LoanStatus.U;
        }catch(LoanValidationException e){
            loanStatus=LoanStatus.UC;
            notes=e.getMessage();
        }
        dataLoadLoanManagementService.setText(notes);
        createLoan = dataLoadLoanManagementService.createLoan(loanApplication, user,loanStatus);
    }catch(Exception le){
        logger.error("Error creating the loan application ;  Parent Application Ref : " 
            + loanApplication
            + " with status as " +(loanStatus!=null ?loanStatus.getStatus():loanStatus)
            +"n"
            +" School Ref :"
            + loanApplication.getSchoolRef()
            +"n"
            +" Client Details :"
            +loanApplication.getClientDetails()
            + "Error Details: " + ExceptionUtils.getStackTrace(le));

    }   
    return createLoan;
}

---

即使配置了可跳过的异常类，这也不起作用。
为了解释更多，我在项目处理器中得到了持久性异常并捕获了它，因此 Spring 批处理执行编写器，但在编写器执行后，我得到以下异常

INFO  06-21 11:38:00 Commit failed while step execution data was already updated. Reverting to old version.  (TaskletStep.java:342) 
ERROR 06-21 11:38:00 Rolling back with transaction in unknown state  (TaskletStep.java:351) 
ERROR 06-21 11:38:00 Encountered an error executing the step  (AbstractStep.java:212)
org.springframework.transaction.TransactionSystemException: Could not commit JPA   transaction; nested exception is javax.persistence.RollbackException: Transaction marked as rollbackOnly

Answer 1

对于您的两个问题，跳过在修复阶段发生的异常将解决您的问题。

如果您知道异常的根本原因，则可以由skippable-exception-classes元素配置。例如，如果在处理器阶段出现除以零异常，并且确实想忽略它，则示例配置可能是：

<chunk reader="reader" processor="processor" writer="writer" 
commit-interval="1" >
<skippable-exception-classes>
<include class="java.lang.ArithmeticException" />
</skippable-exception-classes>
</chunk>

由于给定的异常类及其子类将被跳过，您甚至可以尝试java.lang.Exception

Answer 2

在 loanValidationService.validate 中检查事务传播选项

猜测从"事务标记为仅回滚"，"在步骤执行数据已更新时提交失败"

当前事务已

回滚，父事务应提交，但事务已结束。

如果 chunk 的交易在 LoanValidationService.validate 中相同

将传播选项更改为REQUIRES_NEW

以下文章可能有助于了解元数据的事务。http://blog.codecentric.de/en/2012/03/transactions-in-spring-batch-part-1-the-basics/

    class LoanValidationServiceImpl implements LoanValidationService {
        @Trasnactional(propagation=REQUIRES_NEW, rollbackFor=Exception.class)
        validate(LoanApplication loanApplication) {
             // business logic
        }
    }