Spring Modulith事件：非事务发布者无法触发监听器且事件不持久化求助

核心问题分析 #

• @TransactionalEventListener默认仅在存在活跃事务时触发，无事务场景下会直接忽略事件。
• 普通@EventListener能监听非事务事件，但无法触发Spring Modulith的事件持久化机制。
• 要实现「无论发布者是否在事务中，事件都能被监听执行+持久化」，需要同时解决监听器触发逻辑和事件持久化绑定两个问题。

具体实现步骤 #

1. 标记事件为Spring Modulith领域事件 #

给ProductEvent添加@DomainEvent注解，让Spring Modulith自动将事件纳入持久化管理，无论发布时是否有事务。

import org.springframework.context.ApplicationEvent;
import org.springframework.modulith.events.DomainEvent;

@DomainEvent
public class ProductEvent extends ApplicationEvent {
    private String name;
    private String description;
    private int id;

    public ProductEvent(Object source, String name, String description, int id) {
        super(source);
        this.name = name;
        this.description = description;
        this.id = id;
    }

    // Getter方法
    public String getName() { return name; }
    public String getDescription() { return description; }
    public int getId() { return id; }
}

2. 调整监听器的触发规则 #

修改@TransactionalEventListener的fallbackExecution属性为true，让监听器在无事务场景下也能触发。如果需要异步处理，可添加@Async注解（需提前在配置类上开启@EnableAsync）。

import org.springframework.scheduling.annotation.Async;
import org.springframework.transaction.event.TransactionalEventListener;

// 可选：添加@Async实现异步处理，需配合@EnableAsync使用
@Async
@TransactionalEventListener(fallbackExecution = true)
public void handleProductEvent(ProductEvent event) {
    System.out.println("Listener 1 Start");
    System.out.println("Processing event: " + event.getName());
    System.out.println("Listener 1 End");
}

3. 确认Spring Modulith事件配置 #

确保项目已正确启用Spring Modulith事件机制：

• 在配置类上添加@EnableModulith或@EnableModulithEvents注解。
• PostgreSQL数据源配置正常，Spring Modulith会自动创建event_publications表用于事件存储。

4. 发布事件逻辑保持不变 #

无论发布者方法是否标注@Transactional，直接使用ApplicationEventPublisher发布事件即可：

// 可自由选择是否添加@Transactional
// @Transactional
public void publishEvent() {
    System.out.println("Publisher Start");
    ProductEvent productEvent = new ProductEvent(this, "Product A", "THIS IS PRODUCT", 777);
    applicationEventPublisher.publishEvent(productEvent);
    System.out.println("Publisher End");
}

原理说明 #

• @DomainEvent：标记事件为领域事件，Spring Modulith会自动将事件持久化到数据库的event_publications表，保证事件不丢失，无论发布时是否有事务。
• fallbackExecution = true：打破@TransactionalEventListener的事务绑定限制，无事务场景下也会触发监听器执行。
• 事务场景下：事件会在事务提交后触发监听器（默认afterCommit阶段），保证数据一致性；非事务场景下：监听器立即执行，事件同时被持久化。

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