[실습] 게시글 작성 로직 수정하기

JSCODE 박재성

2026. 03. 18.

✅ 게시글 작성 로직 수정하기

✅ 코드 수정하기

board-service에서 코드 수정하기

1. DTO 수정하기
dto/CreateBoardRequestDto

public class CreateBoardRequestDto {
  private String title;

  private String content;

  private Long userId;

  public String getTitle() {
    return title;
  }

  public String getContent() {
    return content;
  }

  public Long getUserId() {
    return userId;
  }
}

 

2. Controller 수정하기
controller/BoardController

@RestController
@RequestMapping("/api/boards")
public class BoardController {
	...
	
	@PostMapping
  public ResponseEntity<Void> create(
      @RequestBody CreateBoardRequestDto createBoardRequestDto,
      @RequestHeader("X-User-Id") Long userId
  ) {
    boardService.create(createBoardRequestDto, userId);
    return ResponseEntity.noContent().build();
  } 
}

 

3. Service 수정하기
service/BoardService

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

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

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

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

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

    // '게시글 작성 완료' 이벤트 발행
    BoardCreatedEvent boardCreatedEvent
        = new BoardCreatedEvent(userId);
    this.kafkaTemplate.send("board.created", toJsonString(boardCreatedEvent));

  } catch (Exception e) {
    if (isBoardCreated) {
      // 게시글 작성 보상 트랜잭션 => 게시글 삭제
      this.boardRepository.deleteById(savedBoardId);
      System.out.println("[보상 트랜잭션] 게시글 삭제");
    }
    if (isPointDeducted) {
      // 포인트 차감 보상 트랜잭션 => 포인트 적립
      pointClient.addPoints(userId, 100);
      System.out.println("[보상 트랜잭션] 포인트 적립");
    }

    // 실패 응답으로 처리하기 위해 예외 던지기
    throw e;
  }
}

 

4. 서버 다시 실행시키기