들어가며

스프링에서 @Transactional은 우리가 생각하는 것보다 더 많은 걸 책임지고 있습니다.
특히 DB 트랜잭션과 관련된 모든 작업을 하나의 단위로 묶어 성공하면 커밋, 실패하면 롤백을 보장하죠.

그런데 Redis 같은 외부 저장소를 다룰 때는 이야기가 조금 달라집니다.
왜냐하면 Redis는 RDBMS가 아니기 때문에 스프링의 트랜잭션 관리 범위에 포함되지 않기 때문입니다.

최근 프로젝트에서 바로 이 부분 때문에 데이터 유실 문제가 발생했고, 이를 해결하기 위해 TransactionSynchronization의 afterCommit을 활용했습니다.
이 글에서는 그 과정을 정리해보겠습니다.

문제 상황

프로젝트에서는 DB(MySQL)과 Redis를 함께 사용하고 있었습니다.

• DB → 메인 데이터 저장

• Redis → sorted set을 활용한 임시 큐(대기열) 데이터 관리

문제가 된 부분은 Redis에서 데이터를 pop하는 시점이었습니다.

@Transactional
public void processTicket() {
    // DB 저장
    ticketRepository.save(ticket);
    
    // Redis에서 pop
    Ticket ticket = redisQueue.pop();

    // ...중간 생략
    // 예외 발생 시 롤백
}

의도한 흐름

1. 신청 데이터를 DB에 저장한다.

2. Redis(대기열)에서 데이터를 pop(삭제)한다.

3. 문제가 있으면 트랜잭션을 롤백한다.

실제 동작

• Redis에서 데이터를 pop → Redis에는 더 이상 해당 데이터가 없음 ❌

• DB 저장 중 예외 발생 → DB 트랜잭션 롤백

• Redis는 롤백되지 않음 → 결국 데이터 유실 발생 ⚠️

즉, RDBMS인 MySQL은 @Transactional로 관리가 되지만 Redis는 관리되지 않기 때문에 불일치 문제가 발생했습니다.

해결 : TransactionSynchronization란?

여기서 등장하는 것이 바로 TransactionSynchronization입니다.

스프링에서는 트랜잭션의 생명주기(lifecycle)에 맞춰 특정 동작을 콜백(callback) 형태로 등록할 수 있습니다.
이를 제공하는 인터페이스가 TransactionSynchronization입니다.

대표적인 메서드는 다음과 같습니다:

beforeCommit() : 실제 커밋 직전에 실행

afterCommit() : 트랜잭션이 성공적으로 커밋된 후 실행

afterCompletion(int status) : 트랜잭션이 끝난 후(성공/실패 포함) 실행

즉, DB 트랜잭션이 끝난 시점에 맞춰 외부 리소스 작업을 안전하게 실행할 수 있는 방법을 제공하는 것이죠.

afterCommit vs afterCompletion

afterCommit

DB 트랜잭션이 커밋에 성공했을 때만 실행됩니다.

실패(rollback) 시에는 호출되지 않습니다.

afterCompletion

트랜잭션이 끝나면 무조건 실행됩니다.

성공/실패 여부를 파라미터(STATUS_COMMITTED, STATUS_ROLLED_BACK)로 확인할 수 있습니다.

👉 Redis에서 pop 작업은 afterCommit에 넣어야 데이터 유실을 막을 수 있습니다.

실제 코드 적용

import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;

@Transactional
public void processTicket() {
    Ticket ticket = redisQueue.peek(); // 일단 peek으로 확인만
    
    ticketRepository.save(ticket);

    // 트랜잭션이 커밋된 이후에 pop 실행
    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
        @Override
        public void afterCommit() {
            redisQueue.pop(ticket.getId());
        }
    });
}

변경된 흐름

1. Redis에서는 데이터를 peek만 하고 → 아직 안전하게 보관

2. DB 저장 시도

3. DB 트랜잭션 커밋 성공 시 → afterCommit() 호출 → Redis에서 최종 pop

4. DB 트랜잭션 실패 시 → afterCommit() 실행되지 않음 → Redis 데이터 그대로 유지

   • 참고로 Quartz를 이용한 스케줄러로 일정한 시간마다 1~4번까지 계속 진행됨으로 Redis에 데이터가 그대로 유지되면 데이터 유실이 없음

✅ 이 방식으로 데이터 유실 문제를 해결할 수 있었습니다.

참고

💡 Redis에서도 @Transactional처럼 동작하게 만드는 옵션(setEnableTransactionSupport)이 존재합니다.
이 옵션을 적용하면 @Transactional 안에서 redis도 롤백이 되어 이 옵션을 사용하는 것이 부가작업 없어 간편합니다. (필자도 TransactionSynchronization에서 이 옵션으로 리팩토링 하였습니다)