spring webflux error 처리

spring webflux error 처리

Mono / Flux

• .doOnError() : 예외가 발생했을 경우 특정 행위를 실행 시킬대 사용
• .onErrorReturn () : 예외가 발생 했을때 특정 값을 리턴 함
• .onErrorResume() : 예외가 발생 했을때 오류에 따라 대체를 선택하는 기능을 사용함. 오류가 발생하면 반환된 대체 게시자를 구독 하여 사용
• .onErrorContinue() : 예외가 발생 했을대 멈추지 않고 해당 영역만 skip 하고 동작함.

@Slf4j
public class WebFluxError {

    @Test
    public void onErrorResume() {
        Flux.range(0, 5)
                .map(integer -> {
                    if (integer == 3) {
                        throw new RuntimeException("숫자  = " + 3);
                    }

                    return integer;
                })
                .onErrorResume(throwable -> {
                    log.error("flux error = {}", throwable.getMessage());
                    return Flux.range(6,10);
                })
                .log()
                .subscribe()
        ;

    }
}