[실습] 게시글 작성 API에 Saga 패턴 적용시키기 - 2

JSCODE 박재성

2025-12-06

✅ 게시글 작성 API의 Saga 패턴이 잘 작동하는 지 테스트해보기

1. 어떤 식으로 작동했는 지 추적하기 좋게 코드 추가하기
service/BoardService

public void create(CreateBoardRequestDto createBoardRequestDto) {
  // 게시글 저장을 성공했는 지 판단하는 플래그
  boolean isBoardCreated = false;
  Long savedBoardId = null;

  // 포인트 차감을 성공했는 지 판단하는 플래그
  boolean isPointDeducted = false;

  try {
    // 게시글 작성 전 100 포인트 차감
    pointClient.deductPoints(createBoardRequestDto.getUserId(), 100);
    isPointDeducted = true; // 포인트 차감 성공 플래그
    System.out.println("포인트 차감 성공");

    // 게시글 작성
    Board board = new Board(
        createBoardRequestDto.getTitle(),
        createBoardRequestDto.getContent(),
        createBoardRequestDto.getUserId()
    );

    Board savedBoard = this.boardRepository.save(board);
    savedBoardId = savedBoard.getBoardId();
    isBoardCreated = true; // 게시글 저장 성공 플래그
    System.out.println("게시글 저장 성공");

    // 게시글 작성 시 작성자에게 활동 점수 10점 부여
    userClient.addActivityScore(createBoardRequestDto.getUserId(), 10);
    System.out.println("포인트 적립 성공");
    
  } catch (Exception e) {
    if (isBoardCreated) {
      // 게시글 작성 보상 트랜잭션 => 게시글 삭제
      this.boardRepository.deleteById(savedBoardId);
      System.out.println("[보상 트랜잭션] 게시글 삭제");
    }
    if (isPointDeducted) {
      // 포인트 차감 보상 트랜잭션 => 포인트 적립
      pointClient.addPoints(createBoardRequestDto.getUserId(), 100);
      System.out.println("[보상 트랜잭션] 포인트 적립");
    }
    
    // 실패 응답으로 처리하기 위해 예외 던지기
    throw e;
  }
}

 

2. board-service 서버 다시 실행시키기
 

3. DB 데이터 정리하기
체크하기 쉽게 포인트는 1000포인트로 맞춰놓기



 

4. 활동 점수 적립 API에 예외 코드 잘 있는 지 확인
이전에 트랜잭션을 테스트하기 위해, ‘포인트 적립 → 게시글 작성 → 활동 점수 적립’의 작업 중에 ‘활동 점수 적립’에서 예외가 발생하도록 만들었었다.
service/UserService

@Service
public class UserService {
	...
	
	@Transactional
  public void addActivityScore(
      AddActivityScoreRequestDto addActivityScoreRequestDto
  ) {
    User user = userRepository.findById(addActivityScoreRequestDto.getUserId())
        .orElseThrow(() -> new IllegalArgumentException("사용자를 찾을 수 없습니다."));

    user.addActivityScore(addActivityScoreRequestDto.getScore());

    userRepository.save(user);
    throw new RuntimeException("에러 발생");
  }
}

 

5. 게시글 작성 API 테스트해보기



 

7. board-service의 로그 확인하기



로그만 봤을 때는 정상적으로 모든 작업이 잘 취소된 것처럼 보인다. DB도 확인해보자.
 

8. DB 확인하기







중간에 에러가 발생했을 때 일부 작업만 취소되지 않고, ‘포인트 차감, 게시글 작성, 활동 점수 적립’의 모든 작업이 취소됐다는 걸 알 수 있다.
 

8. 에러 발생하는 코드 주석 처리하기
그럼 이번에는 에러 코드를 주석 처리하고, 정상적으로 ‘게시글 작성 API’가 잘 처리되는 지도 확인해보자.
service/UserService

@Service
public class UserService {
	...
	
	@Transactional
  public void addActivityScore(
      AddActivityScoreRequestDto addActivityScoreRequestDto
  ) {
    User user = userRepository.findById(addActivityScoreRequestDto.getUserId())
        .orElseThrow(() -> new IllegalArgumentException("사용자를 찾을 수 없습니다."));

    user.addActivityScore(addActivityScoreRequestDto.getScore());

    userRepository.save(user);
    // throw new RuntimeException("에러 발생");
  }
}

 

9. user-service 서버 다시 실행시키기
 

5. 게시글 작성 API 테스트해보기



 

12. DB 확인하기







‘포인트 차감, 게시글 작성, 활동 점수 증가’의 작업이 전부 정상적으로 작동했다는 걸 알 수 있다.

✅ 정리