Springboo中事务事件监听类的使用

1. TransactionalEventListener注解介绍

• @TransactionalEventListener 注解：常用于标记一个事件监听方法，当指定的事务阶段完成时，会触发该事件。它是 @EventListener 的扩展，专门用于处理事务相关的事件。

• phase 属性：用于指定事务事件监听的阶段。常见的选项包括：

  • TransactionPhase.BEFORE_COMMIT：事务提交之前触发。
  • TransactionPhase.AFTER_COMMIT：事务成功提交之后触发。
  • TransactionPhase.AFTER_ROLLBACK：事务回滚之后触发。
  • TransactionPhase.AFTER_COMPLETION：事务完成（无论是提交还是回滚）之后触发。

• 必须在带有@Transactional注解的方法中发布事件才能触发@TransactionalEventListener。如果事件发布方法没有事务，则事务事件监听器不会被触发。

• @TransactionalEventListener自身不需要@Transactional，但需要事件发布的上下文有事务管理。

2. 监听类

@GetterpublicclassCommitEventextendsApplicationEvent{privateStringeventValue;privateObjectpayload;publicCommitEvent(Objectsource,StringeventValue,Objectpayload){super(source);this.eventValue=eventValue;this.payload=payload;}}

3. 添加事务

@RestController@Slf4jpublicclassDemoController{@AutowiredprivateDemoServicedemoService;@GetMapping("/update")publicResponseEntity<String>update(Peoplepeople){demoService.updateFtp(people);returnResponseEntity.ok("success");}}@ServicepublicclassDemoService{@AutowiredprivateApplicationEventPublisherapplicationEventPublisher;@AutowiredprivatePeopleMapperpeopleMapper;@TransactionalpublicvoidupdateFtp(Peoplepeople){// 1. 执行用户更新逻辑（更新到数据库）peopleMapper.update(people);// 2. 发布用户更新事件（此时事务尚未提交）applicationEventPublisher.publishEvent(this,"test01","test");}}

4. 事务事件监听类

@Slf4j@ComponentpublicclassDemoListener{@Async@TransactionalEventListener(condition="#commitEvent.eventValue == 'test01'",phase=TransactionPhase.AFTER_COMMIT)publicvoidafterDataBaseCommit(CommitEventcommitEvent){log.info("afterDataBaseCommit : commitEvent = {} ",commitEvent);}}