CircuitBreaker

一部のサービスが正常でない場合は、他の機能の代替を使用します->障害の回避

Resilience4j

使いやすい

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
        </dependency>

  private final CircuitBreakerFactory circuitBreakerFactory;
  
  ...
public UserDto getUserByUserId() {
  ...
  
// 주석
//  List<ResponseOrder> orderList = orderServiceClient.getOrders(userId); 

  CircuitBreaker circuitBreaker = circuitBreakerFactory.create("circuitbreaker");
  List<ResponseOrder> orderList = circuitBreaker.run(() -> orderServiceClient.getOrders(userId),
            throwable -> new ArrayList<>());

...
}

カスタム

package com.example.userservice.config;

import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig;
import io.github.resilience4j.timelimiter.TimeLimiterConfig;
import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JCircuitBreakerFactory;
import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JConfigBuilder;
import org.springframework.cloud.client.circuitbreaker.Customizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.time.Duration;

@Configuration
public class Resilience4jConfig {
  @Bean
  public Customizer<Resilience4JCircuitBreakerFactory> globalCustomConfiguration() {
    CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig.custom()
      .failureRateThreshold(4)
      .waitDurationInOpenState(Duration.ofMillis(1000))
      .slidingWindowType(CircuitBreakerConfig.SlidingWindowType.COUNT_BASED)
      .slidingWindowSize(2)
      .build();

    TimeLimiterConfig timeLimiterConfig = TimeLimiterConfig.custom()
      .timeoutDuration(Duration.ofSeconds(4))
      .build();

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