@TransactionalEventListener 不起作用，因为 @EventListener 对于相同上下文就像魅力一样工作

我正在从事 Spring Boot 应用程序的事件驱动设计。

该代码由以下文件组成：

1. Spring boot：ApplicationEvent 文件，即 MyBusinessEvent.{java

   @Data
   @AllArgsConstructor
   public class MyBusinessEvent {
   
      private String data;
   
   }
   

2. 事件发布者文件：MyBusinessService.java

   @Slf4j
   @Service
   public class MyBusinessService {
   
       private final ApplicationEventPublisher applicationEventPublisher;
   
       @Autowired
       public MyBusinessService(
               ApplicationEventPublisher applicationEventPublisher) {
   
           this.applicationEventPublisher = applicationEventPublisher;
       }
   
       @Override
       public void save() {
           String data = "Testing event data";
           MyBusinessEvent event = new MyBusinessEvent(data);
           applicationEventPublisher.publishEvent(event);
       }
   }
   

3. 事件监听器：MyBusinessEventListener.java

   @Slf4j
   @Component
   public class MyBusinessEventListener {
   
       @EventListener
       public void handleEvent(MyBusinessEvent myBusinessEvent) {
           log.info("[MyBusinessEventListener] New event received with following data: {}", myBusinessEvent);
       }
   }
   

重点是侦听器文件何时包含@EventListener然后应用程序按预期工作，但是当我这样做时@TransactionEventListener。例如：

4. 事务事件监听器：MyBusinessEventListener.java

   @Slf4j
   @Component
   public class MyBusinessEventListener {
   
       @TransactionalEventListener
       public void handleEvent(MyBusinessEvent myBusinessEvent) {
           log.info("[MyBusinessEventListener] New event received with following data: {}", myBusinessEvent);
       }
   }
   

with @TransactionalEventListener，根本不起作用。

应用程序没有遇到任何异常（甚至在运行时也没有），但没有按预期进行日志记录。

是否缺少任何配置？

Add @Transactional注释到MyBusinessService.save应该解决这个问题。

根据java文档，@TransactionalEventListener工作范围内@Transactional边界。

这是文档所说的，

If the event is not published within the boundaries of a managed transaction, the
 * event is discarded unless the {@link #fallbackExecution} flag is explicitly set.

如果您不想在事务边界中使用服务方法，请使用@TransactionalEventListener(fallbackExecution = true)

编辑： 对于上述问题，存在三种可能的解决方案。

i. Mark class as @Transactional被视为交易性的

@Transactional
@Service
public class MyBusinessService {

    private final ApplicationEventPublisher applicationEventPublisher;

    @Autowired
    public MyBusinessService(
            ApplicationEventPublisher applicationEventPublisher) {

        this.applicationEventPublisher = applicationEventPublisher;
    }

    @Override
    public void save() {
        String data = "Testing event data";
        MyBusinessEvent event = new MyBusinessEvent(data);
        applicationEventPublisher.publishEvent(event);
    }
 }

二.具体服务方式为@Transactional

@Override
@Transactional
public void save() {
    String data = "Testing event data";
    MyBusinessEvent event = new MyBusinessEvent(data);
    applicationEventPublisher.publishEvent(event);
}

三.如果您不想在事务边界中使用服务方法，请使用

@Slf4j
@Component
public class MyBusinessEventListener {

    @TransactionalEventListener(fallbackExecution = true)
    public void handleEvent(MyBusinessEvent myBusinessEvent) {
        log.info("[MyBusinessEventListener] New event received with following data: {}", myBusinessEvent);
    }
}