스프링 인 액션 : 스프링 5.2.x : 스프링 5의 강력한 기능과 생산성을 활용한 웹 애플리케이션 개발

4개의 인터페이스

• Publisher(발행자)

  @FunctionalInterface
  public static interface Publisher<T> {
  	/*
  	 * Subscriber(구독자)가 Publisher(발행자)를 구독 신청할 수 있는 메서드.
  	 */
    public void subscribe(Subscriber<? super T> subscriber);
  }
  

• Subscriber(구독자)

  • Subscriber가 구독 신청되면 Publisher로부터 이벤트를 수신할 수 있다. 이 이벤트는 Subscriber 인터페이스의 메서드를 통해 전송된다.

  public static interface Subscriber<T> {
  	/*
  	 * Subscriber가 수신하는 첫번째 이벤트. 
     * Publisher가 onSubscribe()를 호출할 때 이 메서드의 인자로 Subscription전달
     * Subscriber는 Subscription 객체를 통해서 구독을 관리한다.
  	 * Subscription.request(Long)로 데이터 요청. 
  	 */
    public void onSubscribe(Subscription subscription);
    public void onNext(T item);
    public void onError(Throwable throwable);
    public void onComplete();
  }
  

• Subscription(구독정보)

  • Subscriber는 request()를 호출하여 데이터를 요청하거나, cancle()로 구독을 취소한다.
  • 백 프레셔: Subscriber가 처리할 수 있는 것보다 더 많은 데이터를 Publisher가 전송하는 것을 막아준다.

  public static interface Subscription {
  	/*
     * 데이터를 요청 
  	 * @param n 받고자 하는 데이터의 항목 수(백 프레셔)
  	 */
    public void request(long n);
  	/* 구독 취소 */
    public void cancel();
  }
  

• Processor(프로세서)

  • Subscriber 인터페이스와 Publisher 인터페이스를 결합한 것

  public static interface Processor<T,R> extends Subscriber<T>, Publisher<R> {
  }
  

• Subscriber.onError(Throwable), Subscription.cancel() 등.. 생략함.

Mono / Flux

• 리액터의 핵심 타입(파이프라인).
• 리액티브 스트림의 Publisher 인터페이스를 구현한 것임.

Mono

• 하나의 데이터 항목만 갖는 데이터셋에 최적화된 리액티브 타입.

Flux