스프링웹플럭스_5

1. Non-Blocking WebFlux 데이터 손실 이슈

 

응답에 따른 처리

 

2. 샘플코드

import java.util.concurrent.CompletableFuture;
import reactor.core.publisher.Mono;

public class JustTest {

    public static void main(String[] args) {
        //1번내용 ----------------
        String text = "abcd";
        Mono<String> mono = Mono.just(text);		
        mono.subscribe( str->{  //변수 text를 살펴보고, 그에대한 콜백행위는 아래의 출력
            System.out.println(str);
        });

        //2번내용 ----------------
        Mono<Object> function = Mono.create( sink->{  //마치 자바스크립트의 Promise 같은 느낌!
            //sink.error(new Exception("익셉션"));    -> 에러를 발생시킨다.
            sink.success("success");   //-> success값을 전달하여준다.
        });
        function.subscribe( arg->{  //위에서 전달한 success값
            System.out.println(arg);
        });
		
        //3번내용 ----------------		
        mono.doOnNext(str->{  //맨 처음 구독한 다음행위에 대한 지정
            System.out.println("next : "+str);
        }).subscribe();
		
		
        //4번내용 ----------------		        
        CompletableFuture<?> future = CompletableFuture.supplyAsync(()->{  
            System.out.println("run!");
            return "PARAM";
        });
        Mono<Object> mono2 = Mono.fromFuture(future); //비동기에 대한 구독!
        mono2.subscribe( (param)->{
            System.out.println("param : " + param);
        });
    }
}

 

Promise가 뭔가요?

“A promise is an object that may produce a single value some time in the future”

프로미스는 자바스크립트 비동기 처리에 사용되는 객체입니다. 여기서 자바스크립트의 비동기 처리란 ‘특정 코드의 실행이 완료될 때까지 기다리지 않고 다음 코드를 먼저 수행하는 자바스크립트의 특성’을 의미합니다. 비동기 처리에 대한 이해가 없으시다면 이전 글 ‘자바스크립트 비동기 처리와 콜백 함수’를 읽어보시길 추천드립니다 :)

 

2번을 통해서 subscribe 를 통해 에러에 대해서 로그 남긴두 처리가 안된 것 에 대해서 재시도나, 실패로그 기록 등 사후 처리를 진행 하면 될 것 같다.

 

Publisher 와 subscribe 에 대한 리마인드는 아래 게시글에서 확인

https://hanseungwan24.tistory.com/entry/%EC%8A%A4%ED%94%84%EB%A7%81%EC%9B%B9%ED%94%8C%EB%9F%AD%EC%8A%A41?category=788362

 

WebFlux 에러 처리에 대한 전략은 아래 블로그에 잘 나와 있어서 정리가 필요 할듯하다.

https://medium.com/@odysseymoon/spring-webflux%EC%97%90%EC%84%9C-error-%EC%B2%98%EB%A6%AC%EC%99%80-retry-%EC%A0%84%EB%9E%B5-a6bd2c024f6f

참고

https://lts0606.tistory.com/302

Spring Webflux 2 (웹플럭스 적용기, 기본 구조)

https://joshua1988.github.io/web-development/javascript/promise-for-beginners/

자바스크립트 Promise 쉽게 이해하기