Webflux, ReactiveTransactionManager 환경에서의 이벤트 발행

기존 AbstractPlatformTransactionManager에서의 이벤트 발행

AbstractPlatformTransactionManager를 사용하는 경우 commit을 수행하는 과정에서 TransactionSynchronizationUtils의 메서드를 활용하여 @TransactionalEventListener에게 이벤트를 전달합니다.

조금 더 구체적으로는 TransactionSynchronizationManager.getSynchronizations()을 통해 해당 트랜잭션에서 등록된 synchronizations을 조회하고 synchronization에 등록된 콜백을 실행하는 방법으로 이벤트를 전달합니다.

 

ReactiveTransactionManager에서의 이벤트 발행

하지만 Webflux에서 사용하는 ReactiveTransactionManager는 AbstractPlatformTransactionManager이 아닌 TransactionManager를 확장하고 있기에 기존의 방식으로 이벤트를 전달할 수 없습니다.

ReactiveTransactionManager에서의 이벤트 발행은 AbstractPlatformTransactionManager를 사용할 때와 비교하여 조금의 과정이 추가되지만 유사한 방식으로 진행할 수 있습니다.

1. 이벤트를 발행하기 전 org.springframework.transaction.reactive.TransactionSynchronizationManager.forCurrentTransaction을 통해 트랜잭션에서의 TransactionSynchronizationManager를 조회합니다.
2. 조회한 org.springframework.transaction.reactive.TransactionSynchronizationManager에  메서드 registerSynchronization를 통해TransactionSynchronization을 등록합니다.
   1. TransactionSynchronization에서 필요한 상황의 메서드를 오버라이드 합니다.
   2. 오버라이드한 메서드 내부에서 이벤트 퍼블리셔를 통해 이벤트를 발행합니다.

// afterCompletion 경우 예제
TransactionSynchronizationManager.forCurrentTransaction().map { manager ->
    manager.registerSynchronization(object : TransactionSynchronization {
        override fun afterCompletion(status: Int): Mono<Void> {
            applicationEventPublisher.publishEvent(event)
            log.info { "published event: $event" }
            return super.afterCompletion(status)
        }
    })

 

• 관련 이슈
  • https://github.com/spring-projects/spring-framework/issues/27515
  • https://github.com/spring-projects/spring-framework/issues/28343