如何定义与用户删除同事务的Spring Bean持久化事件监听器？

方式一：使用Spring事务事件监听（推荐，无需额外配置） #

这种方式贴合Spring生态，天然支持Bean注入和事务一致性，步骤如下：

1. 编写Spring Bean监听器

@Component
public class AuditTrailListener {
    private static final Log log = LogFactory.getLog(AuditTrailListener.class);
    private final RelatedEntityRepository relatedEntityRepository;

    // 构造注入Spring Data仓库
    public AuditTrailListener(RelatedEntityRepository relatedEntityRepository) {
        this.relatedEntityRepository = relatedEntityRepository;
    }

    // 监听User实体的删除事件，绑定到当前事务提交前执行
    @TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
    public void handleUserDelete(EntityDeleteEvent event) {
        Object entity = event.getObject();
        if (entity instanceof User user) {
            log.info("[USER AUDIT] 处理用户删除后的关联表操作，用户ID: " + user.getId());
            
            // 执行关联表的更新/删除逻辑，比如清理用户关联数据
            relatedEntityRepository.deleteByUserId(user.getId());
            
            // 测试回滚：抛出运行时异常会触发整个事务回滚（包括用户删除）
            // throw new RuntimeException("测试事务回滚，用户删除操作将被撤销");
        }
    }
}

2. 确保删除方法处于事务中

Service层的用户删除方法需标记@Transactional，让Spring管理事务上下文：

@Service
public class UserService {
    private final UserRepository userRepository;

    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

    @Transactional
    public void deleteUser(Long userId) {
        userRepository.deleteById(userId);
        // 事件会自动触发，无需手动调用监听器
    }
}

核心特性说明

• 事务一致性：TransactionPhase.BEFORE_COMMIT确保监听器逻辑和用户删除操作同属一个事务，一旦监听器抛出运行时异常，整个事务会回滚，包括用户的删除操作。
• Bean注入：监听器通过@Component成为Spring Bean，可正常注入任何Spring管理的组件（如Spring Data仓库）。
• 事件过滤：通过instanceof User只处理User实体的删除事件，避免干扰其他实体操作。

方式二：改造原JPA监听器为Spring Bean（需AspectJ支持） #

如果想保留JPA的@PostRemove注解，可通过AspectJ织入实现Bean注入，但需要额外配置：

1. 改造监听器类

@Configurable(autowire = Autowire.BY_CONSTRUCTOR)
public class AuditTrailListener {
    private static final Log log = LogFactory.getLog(AuditTrailListener.class);
    private final RelatedEntityRepository relatedEntityRepository;

    public AuditTrailListener(RelatedEntityRepository relatedEntityRepository) {
        this.relatedEntityRepository = relatedEntityRepository;
    }

    @PostRemove
    public void afterDelete(User user) { // 需改为public，支持Spring代理
        log.info("[USER AUDIT] 用户删除完成，处理关联表操作，用户ID: " + user.getId());
        relatedEntityRepository.deleteByUserId(user.getId());
        
        // 抛出异常会触发事务回滚
        // throw new RuntimeException("测试回滚");
    }
}

2. 启用AspectJ织入

在Spring Boot启动类上添加@EnableLoadTimeWeaving注解，或在application.properties中添加：

spring.jpa.properties.hibernate.ejb.interceptor=org.springframework.orm.jpa.support.SpringBeanContainer
spring.aop.proxy-target-class=true

这种方式配置相对复杂，不如第一种方案简便，推荐优先使用Spring事务事件监听。

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