openFeign Retry 처리하기

1. openFeign의 Retryer를 설정한다.

2. spring의 retry를 사용한다.

3. resilience4j의 retry를 사용한다.

• resilience4j-circuitbreaker: Circuit breaking

• resilience4j-ratelimiter: Rate limiting

• resilience4j-bulkhead: Bulkheading

• resilience4j-retry: Automatic retrying (sync and async)

• resilience4j-cache: Result caching

• resilience4j-timelimiter: Timeout handling

[Spring] OpenFeign에 Resilence4J 서킷 브레이커 적용하는 방법과 예시 및 주의사항

이번에는 Java 진영의 서킷브레이커 라이브러리인 Resilence4J를 OpenFeign에 적용하는 방법에 대해 알아보도록 하겠습니다. 아래의 내용은 공식 문서와 직접 구현 및 테스트한 부분을 바탕으로 작성되었습니다. 1. Resilence4J 라이브러리와 구성 요소 [ Resilience4J란? ] Resilience4J는 함수형 프로그래밍으로 설계된 경량(lightweight) 장애 허용(fault tolerance) 라이브러리로, 서킷브레이커 패턴을 위해 사용된다. 서킷 브레이커 패턴에 대해서는 앞선 포스팅을 참고하도록 하자. fault-tolerance란 하나 이상의 구성 요소에 문제가 생겨도 시스템이 중단없이 계속 작동할 수 있는 시스템을 의미한다. Resilience4J를 적용하면 외부 서비..

https://mangkyu.tistory.com/289

implementation 'org.springframework.cloud:spring-cloud-starter-circuitbreaker-resilience4j'

implementation("io.github.resilience4j:resilience4j-spring-boot3")

@Configuration
@RequiredArgsConstructor
public class Resilience4jConfig {
  private final RetryRegistry retryRegistry;

  @Bean
  public RetryConfig customRetryConfig() {
    Predicate<Throwable> retryOn500SeriesStatus = throwable ->
      throwable instanceof FeignException &&
        ((FeignException) throwable).status() / 100 == 5;

    return RetryConfig.custom()
      .maxAttempts(3)
      .waitDuration(Duration.ofSeconds(1))
      .retryOnException(retryOn500SeriesStatus) // 5xx 상태 코드에서만 재시도
      .build();
  }

  @Bean
  public Retry customRetry(RetryConfig customRetryConfig) {
    return Retry.of("customRetry", customRetryConfig);
  }
}

@Slf4j
@RequiredArgsConstructor
@Component
public class FeignErrorDecoder implements ErrorDecoder {
  private final ObjectMapper objectMapper;

  @Override
  public Exception decode(String methodKey, Response response) {
        String body = null;
        KftcBaseResponse kftcBaseResponse = null;
        try {
          body = Util.toString(response.body().asReader(StandardCharsets.UTF_8));
          log.info("feign decode response: {}", body);
          kftcBaseResponse = objectMapper.readValue(body, KftcBaseResponse.class);
        } catch (IOException e) {
          throw new ErrorException(ErrorStatus.KFTC_SERVER_EXCEPTION);
        }
        return new KftcErrorException(kftcBaseResponse);
      }
}

@Component
@FeignClient(
    name = "retry-test",
    url = "http://localhost:8080/",
    configuration = {DefaultFeignConfig.class})
public interface RetryTestClient {
  @Retry(name = "retryTest", fallbackMethod = "retryFallback")
  @GetMapping("test/retry")
  String exception();

  default String retryFallback(Exception e) {
    ObjectMapper om = new ObjectMapper();
    Map<String, String> fallbackResponse = new HashMap<>();
    fallbackResponse.put("rsp_code", "9999");
    fallbackResponse.put("rsp_message", "3회 재시도에도 응답이 없습니다.");
    try {
      return om.writeValueAsString(fallbackResponse);
    } catch (JsonProcessingException jsonEx) {
      return "{\"rsp_code\": \"9999\", \"rsp_message\": \"JSON 처리 오류\"}";
    }
  }
}

public class FeignClientDefaultFallback {
	private FeignClientDefaultFallback() {}
		public static String retryFallback(Exception e) {
			ObjectMapper om = new ObjectMapper();
			Map<String, String> fallbackResponse = new HashMap<>();
			fallbackResponse.put("rsp_code", "9999");
			fallbackResponse.put("rsp_message", "3회 재시도에도 응답이 없습니다.");
			try {
				return om.writeValueAsString(fallbackResponse);
			} catch (JsonProcessingException jsonEx) {
				return "{\"rsp_code\": \"9999\", \"rsp_message\": \"JSON 처리 오류\"}";
			}
	}
}

@FeignClient(
    name = "kftc-goods",
    url = "${kftc.api.url}",
    configuration = {DefaultFeignConfig.class, FeignRequestInterceptor.class})
@Retry(name = "customRetry", fallbackMethod = "retryFallback")
public interface GoodsClient {

@PostMapping(value = "/goods")
  String insertGoods(
      @RequestBody InsertGoodsRequest request, @RequestHeader(value = "requester") String header);

... 


default String retryFallback(Exception e) {
    return FeignClientDefaultFallback.retryFallback(e);
}