1. Spring Cloud Stream를 사용하는 이유

<aside> 1️⃣ Spring Cloud Stream을 왜 사용할까?

</aside>

• Spring Cloud Stream과 같은 메시지 브로커를 사용하는 이유 중 하나는 서비스의 비동기화를 통해 부하를 분산하는 것이다.
  • 만약 사용자가 상세보기를 요청하면, 그 요청을 처리하는 것과 논문 조회수를 증가시키는 것이 서로 독립적으로 처리되게 된다.
    1. 사용자가 상세보기를 요청하면, 상세보기를 처리하는 로직은 논문의 내용을 반환하고 종료한다.
    2. 동시에, 메시지 브로커로 조회수 증가 이벤트가 전달된다.
    3. 메시지 브로커는 이 이벤트를 순차적으로 처리하며, DB에 조회수를 증가시키는 쿼리를 실행한다.
• 이렇게 하면 상세보기 요청에 따른 부하가 DB에 즉시 반영되지 않고, 메시지 브로커를 통해 비동기적으로 처리되므로 DB의 부하를 분산시킬 수 있다.
• 다만, 메시지 브로커도 결국 DB에 쓰기 작업을 수행하므로, 결국 DB에 데이터를 쓰는 횟수가 증가하게 된다. 그래서 메시지 브로커를 사용하는 것이 DB 부하를 완전히 제거하는 것은 아니다. DB의 부하를 줄이려면 캐싱, DB 파티셔닝, 샤딩 등의 방법을 고려해 볼 수 있다.

2. 코드 작성

<aside> 1️⃣ gradle에 의존성 추가

</aside>

// spring cloud stream
implementation 'org.springframework.cloud:spring-cloud-starter-stream-rabbit'
implementation 'org.springframework.boot:spring-boot-starter-amqp'

<aside> 2️⃣ application.yml에 속성 추가

</aside>

spring:
 cloud:
    stream:
      bindings:
        paperViewOutput:
          destination: paperViewCountTopic
        paperDownloadOutput:
          destination: paperDownloadCountTopic
        itemViewOutput:
          destination: itemViewCountTopic

<aside> 3️⃣ 이벤트 생성 (지금은 DB insert용)

</aside>

@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@ToString
public class PaperViewEvent {
    private Integer paperSn;
    private String ipAddress;
    private Paper paper;
}

<aside> 4️⃣ EventSource 생성

</aside>

public interface PaperEventSource {

    String PAPER_VIEW_OUTPUT = "paperViewOutput";
    String PAPER_DOWNLOAD_OUTPUT = "paperDownloadOutput";
    String ITEM_VIEW_OUTPUT = "itemViewOutput";

    @Output(PAPER_VIEW_OUTPUT)
    MessageChannel paperViewOutput();

    @Output(PAPER_DOWNLOAD_OUTPUT)
    MessageChannel paperDownloadOutput();

    @Output(ITEM_VIEW_OUTPUT)
    MessageChannel itemViewOutput();
}