ItemWriteListener的onError方法中Repository无法保存数据求助

兄弟，我之前也碰到过一模一样的坑！咱们先理清楚问题根源，再一步步解决：

问题根源分析 #

Spring Batch的onWriteError和afterWrite处于完全不同的事务上下文里：

• afterWrite是在事务成功提交后执行的，这时候你的Repository操作在正常的事务里，自然能成功保存；
• 而onWriteError是在事务已经标记为回滚的状态下触发的，这时候你直接调用Repository的save，操作会被当前回滚事务“吞掉”——既不会抛异常，也不会真正写入数据库，因为整个事务最终会回滚。

靠谱的解决办法 #

1. 用独立事务执行失败数据的保存

这是最稳妥的方案：把失败数据的保存逻辑放到一个带有REQUIRES_NEW事务传播属性的方法里，强制开启新事务，脱离原Batch事务的回滚影响。

首先写一个专门处理错误数据的Service：

@Service
public class FailedItemService {
    private final TestRepository testRepository;

    // 构造注入，避免字段注入
    public FailedItemService(TestRepository testRepository) {
        this.testRepository = testRepository;
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void saveFailedItem(Object item) {
        testRepository.save(item);
    }
}

然后在你的Listener里注入这个Service，调用它的方法：

public class WriteListener implements ItemWriteListener {
    private final FailedItemService failedItemService;
    private final TestRepository testRepository;

    public WriteListener(FailedItemService failedItemService, TestRepository testRepository) {
        this.failedItemService = failedItemService;
        this.testRepository = testRepository;
    }

    public void beforeWrite(List items) {
        System.out.println("Going to write following items: "+ items.toString());
    }

    public void onWriteError(Exception exception, List items) {
        System.out.println("Error occurred when writing items!");
        // 用独立事务保存失败数据
        failedItemService.saveFailedItem(items.get(0));
    }

    public void afterWrite(List items) {
        testRepository.save(items.get(0)); // 正常工作
    }
}

2. 验证事务状态（辅助排查）

如果想确认是不是事务的问题，可以开启Spring事务的DEBUG日志，在application.yml或application.properties里加：

logging:
  level:
    org.springframework.transaction: DEBUG

运行后看日志，你会发现onWriteError执行时，当前事务已经处于ROLLBACK_ONLY状态，这时候普通的Repository操作都会被回滚。

3. 备选方案：手动刷新EntityManager（仅限JPA场景）

如果是用JPA Repository，也可以尝试在save后手动flush，但这个方案不如新开事务靠谱，因为还是可能受原事务影响：

public class WriteListener implements ItemWriteListener {
    @PersistenceContext
    private EntityManager entityManager;
    private final TestRepository testRepository;

    public WriteListener(TestRepository testRepository) {
        this.testRepository = testRepository;
    }

    public void onWriteError(Exception exception, List items) {
        System.out.println("Error occurred when writing items!");
        testRepository.save(items.get(0));
        // 手动刷入数据库
        entityManager.flush();
    }

    // 其他方法...
}

总结 #

最推荐第一种方案，用REQUIRES_NEW的独立事务来保存失败数据，既能保证数据不会被回滚，也符合Spring Batch处理错误数据的最佳实践——失败数据应该和正常数据的事务隔离开来。

内容的提问来源于stack exchange，提问作者prafful