Spring Boot Circuit Breaker, mikro hizmetler mimarisinde ardışık hataların önlenmesi için kullanılan bir hata toleransı mekanizmasıdır. Hataları algılayarak ve sağlıksız hizmetlere aşırı istekleri durdurarak uygulamaların hataları zarif bir şekilde yönetmesine yardımcı olur. Bu kılavuz, Spring Boot'ta Resilience4j kullanarak Circuit Breaker uygulamasını adım adım açıklamaktadır.
Bu bölümde Neden Circuit Breaker Kullanmalıyız? konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
Aşağıdakilere sahip olduğunuzdan emin olun:
Bu bölümde Adım 1: Bağımlılıkları Ekleyin konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
Maven:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId> </dependency>
Gradle:
implementation 'org.springframework.cloud:spring-cloud-starter-circuitbreaker-resilience4j'
application.yml dosyanızda Circuit Breaker ayarlarını tanımlayın.
resilience4j: circuitbreaker: instances: externalService: failure-rate-threshold: 50 slow-call-rate-threshold: 50 slow-call-duration-threshold: 2000ms permitted-number-of-calls-in-half-open-state: 3 sliding-window-size: 10 minimum-number-of-calls: 5 wait-duration-in-open-state: 5s
Uygulamayı başlatın:
./mvnw spring-boot:run
veya Gradle kullanarak:
gradle bootRun
Circuit Breaker’ı test etmek için:
curl -X GET http://localhost:8080/api/data
Artık Spring Boot Circuit Breaker için üretim odaklı bir Spring Boot temeliniz var. Sonraki adımda ayarları kendi domainine uyarlayıp test ve gözlemlenebilirlik katmanını ekleyerek gerçek trafik altında doğrulayın.
package com.example.circuitbreaker.service; import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; @Service public class ExternalService { private final RestTemplate restTemplate = new RestTemplate(); @CircuitBreaker(name = "externalService", fallbackMethod = "fallbackResponse") public String callExternalAPI() { return restTemplate.getForObject("http://unreliable-service/api/data", String.class); } public String fallbackResponse(Exception e) { return "Fallback response: Service is unavailable!"; } }
package com.example.circuitbreaker.service import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker import org.springframework.stereotype.Service import org.springframework.web.client.RestTemplate @Service class ExternalService { private val restTemplate = RestTemplate() @CircuitBreaker(name = "externalService", fallbackMethod = "fallbackResponse") fun callExternalAPI(): String { return restTemplate.getForObject("http://unreliable-service/api/data", String::class.java) ?: "" } fun fallbackResponse(e: Exception): String { return "Fallback response: Service is unavailable!" } }
package com.example.circuitbreaker.controller; import com.example.circuitbreaker.service.ExternalService; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/api") public class CircuitBreakerController { private final ExternalService externalService; public CircuitBreakerController(ExternalService externalService) { this.externalService = externalService; } @GetMapping("/data") public String fetchData() { return externalService.callExternalAPI(); } }
package com.example.circuitbreaker.controller import com.example.circuitbreaker.service.ExternalService import org.springframework.web.bind.annotation.GetMapping import org.springframework.web.bind.annotation.RequestMapping import org.springframework.web.bind.annotation.RestController @RestController @RequestMapping("/api") class CircuitBreakerController(private val externalService: ExternalService) { @GetMapping("/data") fun fetchData(): String { return externalService.callExternalAPI() } }
