kafka

spring kafka를 사용할 때의 트랜잭션 처리

일반적인 서비스 로직을 작성할 때 메소드 내에서 복잡한 서비스 로직을 수행하고 이벤트(kafka)를 발행하는 경우가 많다. 이런 경우 트랜잭션이 성공적으로 완료된 이후에 이벤트가 발행되기를 기대하지만 로직 내의 실행 순서에 따라 의도하지 않게 이벤트가 발행이 되는 경우도 있다. 그래서 스프링에서는 트랜잭션을 종료하고 이벤트를 발행하는 방법으로 @TransactionalEventListener를 사용을 한다. @TransactionalEventListener를 사용하게 되면 트랜잭션이 종료된 이후에 이벤트를 발행하는 것이기 때문에 이벤트 발행시점을 트랜잭션 이후로 미룰 수 있는 장점이 있다. 하지만, 여기서는 @TransactionalEventListener를 사용하지 않고 kafka 트랜잭션과 DB 트랜..

2023. 10. 10. 07:20

spring

JPA에서 @Modifying의 clearAutomatically가 왜 필요한가?

일반적으로 복잡한 로직을 작성할 때 @Transactional 안에서 여러 개의 로직을 구현하는 경우가 많이 있다. Spring Data Jpa를 사용하여 해당 메소드 내에서 find, modify를 사용하는 경우 기본적으로 영속성 컨텍스트에서 관리를 해주는데 JPQL로 작성된 SQL이 있는 경우 쿼리 결과가 영속성 컨텍스트에 갱신되지 않아서 실제 DB와 메모리 상의 값이 다른 경우가 있다. 이런 케이스에 대해 예제를 만들어보고 어떻게 처리할 수 있는지 알아보자. 시나리오 사용자 등록 특정 서비스 메소드를 작성하고 사용자의 이름을 변경 해당 서비스 메소드 내에서 사용자 이름을 조회해보자. JpaRepository의 save 이용시 소스 코드 @Transactional public void modify(U..

2023. 9. 5. 15:13

spring

Spring에서 트랜잭션 사용

Spring boot에서 어노테이션으로 트랜잭션을 구성하는 방법을 알아보고 여러가지 트랜잭션 전파 옵션(propagation)에 따른 실행결과가 어떻게 달라지는지 확인해보자. @Transactional 어노테이션 트랜잭션을 구성할 때 빈 클래스 혹은 메소드 레벨에서 @Transactional을 적용할 수 있다. @Service @Transactional public class UserService { // ... } Transaction과 프록시 고수준에서, 스프링은 @Transactional 어노테이션이 있는 모든 클래스 혹은 메소드 레벨에 대해 프록시를 만든다. 프록시는 실행 메소드 전과 후에 트랜잭션 시작과 커밋하는 트랜잭션 로직을 주입한다. @Transactional 사용하는 방법을 알아보자. @..

2023. 1. 8. 20:52

spring

스프링 트랜잭션 로그 찍기

spring 개발 시 트랜잭션 로그를 볼 필요가 있다. application.yml에 아래 로그를 추가하면 트랜잭션 로그를 확인할 수 있다. [application.yml] logging.level.org.springframework.transaction.interceptor: trace 로그 내용 07:56:27.031 TRACE [,] [040-exec-6] o.s.t.i.TransactionInterceptor :623 TransactionInfo Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById] 07:56:27.032 TRACE [,] [040-exec-6] o.s..

2023. 1. 6. 07:58