@PrePersist中注册的领域事件未触发的问题求助

核心问题原因 #

Spring Data 通过AbstractAggregateRoot实现的领域事件机制，是在调用save/delete方法时，从你传入的实体实例中提取事件并发布。但 JPA 的@PrePersist/@PreRemove生命周期回调，是在 EntityManager 托管的实例上触发的——这个实例和你传入仓库方法的实例可能不是同一个（比如传入游离态实例时，JPA 会重新加载或生成托管实例）。事件被注册到了托管实例，但 Spring Data 去原始传入的实例中读取事件，自然拿不到，导致事件无法发布。

解决方案 #

方案1：直接在实体创建/业务方法中注册事件 #

放弃 JPA 生命周期回调，把事件注册逻辑放在实体的构造函数、工厂方法或业务方法中，确保事件被注册到 Spring Data 要处理的实例上：

class ExampleEntity(id: Int, name: String) : AbstractAggregateRoot<ExampleEntity>() {
    // 构造时注册创建事件
    init {
        registerEvent(ExampleCreated(this))
        logger.info("Adding created event for $this")
    }

    // 硬删除场景：在业务方法中注册删除事件
    fun prepareForDelete() {
        registerEvent(ExampleDeleted(this))
        logger.info("Adding deleted event for $this")
    }
}

服务层调用示例：

fun createExample(id: Int, name: String): ExampleEntity {
    val entityToSave = ExampleEntity(id, name)
    logger.info("saving entity $entityToSave")
    return repository.saveAndFlush(entityToSave)
}

fun deleteExample(entity: ExampleEntity) {
    entity.prepareForDelete()
    repository.delete(entity)
}

这种方式完全贴合 Spring Data 领域事件的设计逻辑，是最可靠的方案。

方案2：绕过AbstractAggregateRoot，直接发布事件 #

如果必须依赖 JPA 生命周期回调，可以在回调中直接使用 Spring 的ApplicationEventPublisher发布事件，不依赖AbstractAggregateRoot的事件收集机制：

需要先让实体能获取到ApplicationEventPublisher，可以通过@Configurable结合 Spring 组件扫描实现：

@Entity
@Configurable(dependencyCheck = true)
class ExampleEntity(id: Int, name: String) {
    @Autowired
    private lateinit var eventPublisher: ApplicationEventPublisher

    @PrePersist
    fun addCreatedEvent() {
        logger.info("Adding created event for $this")
        eventPublisher.publishEvent(ExampleCreated(this))
    }
}

注意：这种方式需要开启 Spring 的@EnableSpringConfigured配置，会增加实体与 Spring 容器的耦合度，非必要不推荐。

补充说明 #

对于@PreRemove的失效场景，本质和@PrePersist一致：JPA 在删除游离态实例时，会先从数据库加载托管实例并触发@PreRemove，事件被注册到托管实例，但 Spring Data 从你传入的游离态实例中读取事件，导致发布失败。用上述两种方案同样可以解决。

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