인프런 커뮤니티 질문&답변

딩코님! 강의 너무 잘 듣고 있습니다~! 강의를 따라가며 디비와 트랜잭션 그리고 락에 관해 심화 내용도 듣고 포폴도 하나하나 잘 채워가고 있습니다! 다름이 아니라 딩코님이 내주신 과제 중에 의문이 있어 질문을 드리게 되었습니다.

1. 현재 학습 진도

• 4주차 수강 후 락과 트랜잭션 최적화를 수행하고 있습니다.

   

• 현재 여러가지 작업(일기 작성, 포인트 적립, AI 댓글 작성 예약, 알림 이벤트 발생)에 대해 facade 계층을 만들어 중요한 작업(일기 작성, 포인트 적립)에 대해서는 트랜잭션을 묶어 우선적으로 처리되게 하고 AI 댓글은 TaskScheduler로 특정 시간 후에 비동기적으로 이루어지게 하며 알림은 spring event로 after commit 후 처리하려 합니다.

2. 어려움을 겪는 부분

• 현재 이벤트 발행 (트랜잭션 커밋 후 실행됨, after-commit)에 대해 의문이 있습니다.

현재 딩코님이 올려주신 코드에는

@Component
@RequiredArgsConstructor
@Slf4j
public class ImprovedEventJoinWithExternalApiUpdateFacade {
    private static final String TEST_PHONE_NUMBER = "01012341234";

    private final EventExternalUpdateService eventJoinService;
    private final ExternalEventApi externalEventApi;
    private final ApplicationEventPublisher eventPublisher;

    public void joinEvent(Long eventId, Long memberId) {
        // 1. 기존 서비스로 이벤트 참가 처리
        EventWithLockParticipant participant = eventJoinService.joinEventWithTransaction(eventId, memberId);

        // 2. 외부 API 호출
        ExternalEventResponse response = externalEventApi.registerParticipant(
                eventId, memberId, participant.getEvent().getName()
        );

        if (!response.isSuccess()) {
            throw new RuntimeException("외부 API 호출 실패: " + response.getErrorMessage());
        }

        // 3. 외부 API 응답으로 참가자 정보 업데이트
        eventJoinService.updateExternalId(participant, response.getExternalId());

        // 4. 이벤트 발행 (트랜잭션 커밋 후 실행됨)
        eventPublisher.publishEvent(new EventJoinCompletedEvent(
                eventId,
                participant.getEvent().getName(),
                TEST_PHONE_NUMBER
        ));
    }
}

이렇게 코드 내에 @Transactional이 걸려있지 않습니다. 그런데 이벤트 리스너에는

@Component
@RequiredArgsConstructor
@Slf4j
public class EventJoinEventListener {
    private final KakaoTalkMessageApi kakaoTalkMessageApi;

    @Async
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void handleEventJoinCompleted(EventJoinCompletedEvent event) {
        try {
            kakaoTalkMessageApi.sendEventJoinMessage(
                    event.getPhoneNumber(),
                    event.getEventName()
            );
        } catch (Exception e) {
            log.error("알림 발송 실패. eventId={}, eventName={}",
                    event.getEventId(),
                    event.getEventName(),
                    e);
        }
    }
} 

이렇게 transaction이 커밋된 후에 실행되도록 AFTER_COMMIT이 걸려있는데, 이렇게 되면 이벤트 리스너가 제대로 실행이 안되지 않나요? 제대로 이벤트 리스너가 실행이 되려면 joinEvent부터 @Transactional이 걸려있어야 하지 않나요?

3. 시도해보신 내용

따로 간단하게 코드를 작성하여 테스트해보았습니다.

@RequiredArgsConstructor
@Component
public class StudyFacade {

    private final StudyService studyService;
    private final ApplicationEventPublisher eventPublisher;

    // @Transactional : 주석 처리하면 밑에 eventEvent가 실행되지 않음
    public void execute() {
        studyService.saveStudy();
        eventPublisher.publishEvent("event published");
    }

    @Async
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void executeEvent(String event) {
        System.out.println("event = " + event);
    }
}

@RequiredArgsConstructor
@Service
public class StudyService {

    private final StudyRepository studyRepository;

    @Transactional
    public void saveStudy() {
        studyRepository.save(new Study("test"));
    }
}

 실제로 execute 메서드의 @Transactional을 주석처리하면 밑의 이벤트 리스너인 executeEvent가 실행이 되지 않더라구요.

이러면 ImprovedEventJoinWithExternalApiUpdateFacade의 joinEvent부터 트랜잭션을 걸어야 하니까 딩코님이 말씀하신 트랜잭션을 최대한 작게 나누는 트랜잭션 최적화가 어렵지 않나요?

항상 강의 잘 듣고 있습니다! 감사합니다!