[MSA] CircuitBreaker 개요 및 Resilence4J 를 활용한 실습

// Resilience4J 설정 클래스

@Configuration
public class Resilience4JConfig {

	@Bean
	public Customizer<Resilience4JCircuitBreakerFactory> globalCustomConfig() {
		CircuitBreakerConfig circuitBreakerConfig =
				CircuitBreakerConfig.custom()
									.ringBufferSizeInClosedState(5) // 닫힌 상태에서의 호출 수로, 써킷을 열어야 할지 결정할 때 사용
									.ringBufferSizeInHalfOpenState(1) // 열림 상태를 유지하는 시간(단위: 초), 해당 시간이후 반열림 상태로 변경
									.failureRateThreshold(50) // 실패한 호출에 대한 임계값(백분율), 이 값을 초과하면 써킷 오픈
									.waitDurationInOpenState(Duration.ofMillis(10000)) // 써킷 오픈 지속 시간
									.slidingWindowType(CircuitBreakerConfig.SlidingWindowType.COUNT_BASED) // 통계 집계 방식, 마지막 N번의 호출 결과를 집계, COUNT_BASED / TIME_BASED
									.build();

		TimeLimiterConfig timeLimiterConfig = TimeLimiterConfig.custom()
															   .timeoutDuration(Duration.ofSeconds(3)) // 타임 아웃 기간
															   .build();

		return factory -> factory.configureDefault(id -> new Resilience4JConfigBuilder(id)
				.timeLimiterConfig(timeLimiterConfig)
				.circuitBreakerConfig(circuitBreakerConfig)
				.build()
		);
	}
}

// 서비스
@Slf4j
@Service
@RequiredArgsConstructor
public class ProductDisplayService {

    private final ProductRemoteFeignService productRemoteFeignService;

    public String displayProducts() {
        Optional<String> products = productRemoteFeignService.products();
        if (!products.isPresent()) {
            log.error("product api result is empty!!");
            throw new RuntimeException("products is empty!");
        }

        return products.get();
    }
}

// product 외부 통신용 feign 정의 및 fallback factory 설정
@FeignClient(
        name = "product",
        url = "localhost:8066",
        fallbackFactory = ProductRemoteFallbackFactory.class)
public interface ProductRemoteFeignService {

    @GetMapping("/external-api/products")
    Optional<String> products();
}


@Slf4j
@Component
public class ProductRemoteFallbackFactory implements FallbackFactory<ProductRemoteFeignService> {
    @Override
    public ProductRemoteFeignService create(Throwable cause) {
        return new ProductRemoteFeignService() {

            @Override
            public Optional<String> products() {
                log.error("[ProductRemoteFallbackFactory] products API call error. " +
                        "cause = {}", cause);
                return Optional.empty();
            }
        };
    }
}

// product 마이크로서비스 외부 통신용 api

@RestController
@RequiredArgsConstructor
@RequestMapping(path = "/external-api")
public class ExternalProductController {

    @GetMapping("/products")
    public String products() {
        throw new RuntimeException("runtime exception!!!"); // 강제 exception 발생
//        return "products exist!";
    }
}