알림 발행 실패 시 전체 트랜잭션 롤백 트러블 슈팅 - KimGyuBek/Threadly GitHub Wiki

@Service
@RequiredArgsConstructor
public class PostLikeCommandService implements LikePostUseCase {

  private final NotificationService notificationService; // 동기 처리
  private final CreatePostLikePort createPostLikePort;

  @Transactional
  @Override
  public LikePostApiResponse likePost(LikePostCommand command) {
    // 1. 비즈니스 로직 (좋아요 저장)
    PostLike newLike = post.like(command.getUserId());
    createPostLikePort.createPostLike(newLike);  // 성공

    // 2. 알림 발행 (동기) - Kafka 예외 발생 지점
    try {
      notificationService.publish(createNotificationCommand());
    } catch (KafkaException e) {
      log.error("Kafka 발행 실패: {}", e.getMessage());
      throw e; // 예외 재발생 → 전체 롤백!
    }

    return new LikePostApiResponse(post.getPostId(), getLikeCount(command));
  }
}

@Service
@RequiredArgsConstructor
public class PostLikeCommandService implements LikePostUseCase {

  private final ApplicationEventPublisher eventPublisher; // 비동기 처리
  private final CreatePostLikePort createPostLikePort;

  @Transactional
  @Override
  public LikePostApiResponse likePost(LikePostCommand command) {
    // 1. 비즈니스 로직 (좋아요 저장)
    PostLike newLike = post.like(command.getUserId());
    createPostLikePort.createPostLike(newLike);  // 성공

    // 2. 이벤트 발행 (메모리상 저장) - 예외 없음
    eventPublisher.publishEvent(PostLikedEvent.create(
        post.getPostId(), command.getUserId(), post.getUserId()
    ));

    return new LikePostApiResponse(post.getPostId(), getLikeCount(command));
    // 트랜잭션 커밋 완료 → 좋아요 저장 성공!
  }
}

// 비동기 이벤트 핸들러
@Component
@RequiredArgsConstructor
public class PostLikeEventHandler {

  private final NotificationService notificationService;

  @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
  @Async("eventExecutor")
  public void handlePostLikedEvent(PostLikedEvent event) {
    try {
      // 트랜잭션 커밋 후 별도 스레드에서 처리
      NotificationPublishCommand command = new NotificationPublishCommand(
          event.getPostAuthorId(),
          event.getUserId(),
          NotificationType.POST_LIKE,
          new PostLikeMeta(event.getPostId())
      );

      notificationService.publish(command);

    } catch (Exception e) {
      // 알림 실패해도 좋아요 기능에는 영향 없음
      log.error("알림 발행 실패 (좋아요는 정상 저장됨): postId={}, error={}",
          event.getPostId(), e.getMessage());
    }
  }
}