如何在JPA事务回滚时执行代码？（基于EclipseLink）

针对你遇到的事务回滚时需要同步恢复文件重命名的问题，以下是几种可行的实现方式：

1. 使用EclipseLink原生TransactionListener（推荐） #

EclipseLink提供了TransactionListener接口，能直接绑定到当前事务，无需全局匹配，是最精准的方案。你可以从EntityManager获取对应的UnitOfWork（EclipseLink的事务核心对象），然后注册自定义监听器：

// 获取当前事务对应的UnitOfWork
UnitOfWork uow = ((JpaEntityManager) entityManager.getDelegate()).getUnitOfWork();

// 注册事务监听器
uow.registerTransactionListener(new TransactionListener() {
    @Override
    public void afterRollback(TransactionEvent event) {
        // 回滚触发时执行文件恢复逻辑
        try {
            // 将重命名后的文件恢复原名称，根据实际路径调整
            Files.move(Paths.get(newFileName), Paths.get(oldFileName), StandardCopyOption.REPLACE_EXISTING);
        } catch (IOException e) {
            // 记录恢复失败的错误日志
            logger.error("文件恢复失败", e);
        }
    }

    // 其他回调方法（beforeCommit、afterCommit、beforeRollback）可按需实现或留空
    @Override public void beforeCommit(TransactionEvent event) {}
    @Override public void afterCommit(TransactionEvent event) {}
    @Override public void beforeRollback(TransactionEvent event) {}
});

这个监听器的回调会严格绑定到当前UnitOfWork对应的事务，不会出现跨事务匹配的问题，逻辑清晰且无需额外全局状态管理。

2. 结合事务状态检测的try-finally方案 #

如果担心回滚在调用栈上层触发，可以在事务入口方法中通过try-finally结合事务状态判断来覆盖所有回滚场景：

如果你的项目使用Spring框架，可借助TransactionSynchronizationManager检测事务状态：

@Transactional
public void processFileRename(String oldFileName, String newFileName) {
    boolean committed = false;
    try {
        // 1. 执行文件重命名
        Files.move(Paths.get(oldFileName), Paths.get(newFileName));
        // 2. 调用DAO更新数据库
        fileRepository.updateFileName(oldFileName, newFileName);
        committed = true;
    } finally {
        // 检查事务是否存在且处于回滚状态
        if (!committed && TransactionSynchronizationManager.isActualTransactionActive()) {
            if (TransactionSynchronizationManager.getCurrentTransactionStatus().isRollbackOnly()) {
                // 执行文件恢复
                try {
                    Files.move(Paths.get(newFileName), Paths.get(oldFileName), StandardCopyOption.REPLACE_EXISTING);
                } catch (IOException e) {
                    logger.error("回滚时文件恢复失败", e);
                }
            }
        }
    }
}

若未使用Spring，可直接通过EntityManager判断事务状态：

public void processFileRename(String oldFileName, String newFileName) {
    EntityTransaction tx = entityManager.getTransaction();
    boolean committed = false;
    try {
        tx.begin();
        Files.move(Paths.get(oldFileName), Paths.get(newFileName));
        fileDao.updateFileName(oldFileName, newFileName);
        tx.commit();
        committed = true;
    } catch (Exception e) {
        if (tx.isActive()) {
            tx.rollback();
        }
        throw e;
    } finally {
        if (!committed) {
            // 尝试恢复文件
            try {
                Files.move(Paths.get(newFileName), Paths.get(oldFileName), StandardCopyOption.REPLACE_EXISTING);
            } catch (IOException ioEx) {
                logger.error("文件恢复失败", ioEx);
            }
        }
    }
}

这种方式能覆盖回滚在当前方法或上层触发的场景，适合需要兼容不同事务触发层级的情况。

3. SessionEventListener的事务匹配方案（备选） #

如果一定要使用SessionEventListener，可以通过ThreadLocal存储当前事务的UnitOfWork，在监听器中对比匹配：

// 用ThreadLocal存储当前事务的UnitOfWork，避免线程污染
private static final ThreadLocal<UnitOfWork> currentTransactionUow = new ThreadLocal<>();

// 事务开始时存储UnitOfWork
UnitOfWork uow = ((JpaEntityManager) entityManager.getDelegate()).getUnitOfWork();
currentTransactionUow.set(uow);

// 注册SessionEventListener
Session session = uow.getSession();
session.getEventManager().addListener(new SessionEventListener() {
    @Override
    public void postRollbackTransaction(SessionEvent event) {
        UnitOfWork eventUow = event.getUnitOfWork();
        // 匹配当前线程的事务UnitOfWork
        if (eventUow.equals(currentTransactionUow.get())) {
            try {
                Files.move(Paths.get(newFileName), Paths.get(oldFileName), StandardCopyOption.REPLACE_EXISTING);
            } catch (IOException e) {
                logger.error("文件恢复失败", e);
            }
            currentTransactionUow.remove(); // 清理ThreadLocal，防止内存泄漏
        }
    }
});

注意必须在事务结束后清理ThreadLocal，避免内存泄漏，这种方案适合纯EclipseLink无框架的场景。

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