块中的Spring批处理异常

Question

步骤1：从数据库中加载10条记录。（Tasklet负责该工作）

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

据我所知，对于每一个记录

>

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

即使它不能回滚第7条记录的tx，它也不会处理第8、9、10条记录，作业也会停止。

注意：ItemProcessor实现正在调用使用@transactional(ReadOnly=False)注释标记为事务性的服务(@Service annotated)。

请提出解决方案。

下面的ItemProcessor代码

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批处理执行了writer，但在writer执行之后，我得到了下面的异常

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

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

如果您知道异常的根本原因，这可以通过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