• reactive 환경에서는 resilience4j만 사용할수 있다.

<aside> 📌 Resilience4J

</aside>

• java에서 circuit breaker를 지원하는 라이브러리다.
  • circuit breaker, Rate Limiter, Retry, Bulkhead, Time Limiter, Cache등의 기능을 제공한다.

<aside> 📌 Circuit breaker의 상태

</aside>

• Circuit breaker의 상태는 finite state machine으로 표현 가능하다.
  1. closed:
     • 정상적으로 요청을 받을 수 있는 상태
  2. open:
     • circuit breaker가ㅉ 작동하여, 목적지로 가는 트래픽, 요청을 막고 fallback반환
  3. half open:
     • 트래픽을 조금 흘려보고 open을 유지할지 closed로 변경할지 결정한다.

1. closed에서 open으로 변경

   • 호출하는 대상에 문제가 발생한 경우

2. open에서 half open으로 변경

   • 일정 시간이 지났을 경우
   • 강제로 상태를 변경할 경우

3. half open에서 open 혹은 closed로 변경

   • half open동안 실제 대상을 호출하여 문제가 없는지 검증한다.

<aside> 📌 Reactor의 transform 연산자

</aside>

• Circuit breaker 사용을 위해 Reactor의 transform 연산자를 알아야 한다.

public final <V> Mono<V> transform(
	Function<? super Mono<T>, ? extends Publisher<V>> transformer) {
		...
}

public final <V> Flux<V> transform(
	Function<? super Flux<T>, ? extends Publisher<V>> transformer) {
		...
}

• 원본 publisher를 인자로 전달 받고 변환된 publisher를 반환한다.
• 통째로 넘기기 때문에 다른 연산자보다 더 유연하게 데이터 스트림을 처리할 수 있다.
• Reactor transform 연산자 테스트
  • error를 반환하는 Flux를 무조건 1을 반환하는 Flux로 변환하여 반환

@Test
void reactorTransformWithError() {
		//given
		Flux<Integer> flux = Flux.error(new ArithmeticException());

		//when
		Function<Flux<Integer>, Flux<Integer>> transformer = (m) -> Flux.just(1);

		//then
		StepVerifier.create(flux.transform(transformer))
							.expectNext(1)
							.verifyComplete();
}