실습 환경

🔗 GitHub repository

✏️ Project Setting

• project - reactive
• dependencies
  • spring reacvice web
  • lombok
  • 아래는 기본적으로 설치된 reactor 로 구현된 코드를 테스트할 수 있는 라이브러리이다.

testImplementation 'io.projectreactor:reactor-test'

📍 실행 테스트

• 준비가 잘 됬는지 확인하기 위해서 간단한 텍스트를 콘솔에 출력하는 객체를 생성했다.
  • 아래코드에서 Mono 는 Publisher 를 의미한다.
    • just() 는 data 를 배포하는 메서드이다.
  • subscribe() 는 구독자를 의미하고,
    배포된 데이터를 받아드릴 수 있다.
• 아래 코드는 Mono 에서 subscribe() 를 호출하고 있기 때문에 publisher 가 구독을 한 것처럼 보일 수 있지만,
  이 메서드는 Mono 의 구독자를 호출하는 Methed 이기 때문에 사실상 구독자는 sebscribe() 의 인자라고 할 수 있다.

package com.reactive.reactive.reactorTest;

import reactor.core.publisher.Mono;

public class HelloReactor {
    public static void main(String[] args) {
        Mono.just("Hello Reactor")
                .subscribe(message -> System.out.println(message));
    }
}