
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 Преглед Научете как да направите вашите микросървисни извиквания устойчиви, като използвате модела „Circuit Breaker“ с   и   — пълно демо, команди стъпка по стъпка, обяснения по класове, примерни изходи, сценарии от реалния живот и производствени съвети. Resilience4j Spring Boot Защо това е важно В разпределени системи, отказала низходяща услуга може да предизвика каскада и да доведе до цялостни прекъсвания на системата. Моделът  : „Circuit Breaker“ 
 
 
 
 
 Открива отказваща зависимост, Спира изпращането на заявки към нея (за да избегне изхабяване на ресурси), Връща елегантен резервен отговор, Периодично тества зависимостта и възстановява нормалната работа, когато тя е здрава. Това намалява времето на прекъсване, защитава пуловете от нишки, поддържа разумно потребителско изживяване и предотвратява „буря от повторни опити“. Резюме на демото (Какво имате) Демо с две услуги в Maven: 
 
 
 
  (порт  ) — прост REST доставчик, който умишлено отказва периодично. hello-service 8081 Крайна точка GET /api/hello
 
 
 
 
  (порт  ) — извиква hello-service, използвайки RestTemplate, и е защитена от   с резервен механизъм. client-service 8080 Resilience4j @CircuitBreaker Крайна точка GET /api/get-message
 Стартирайте и двете ( ) hello-service и client-service След това тествайте GET http://localhost:8080/api/get-message
 Диаграма на архитектурата Това е малък, фокусиран поток, подходящ за чертане на диаграма Файлове и код: Обяснение по класове hello-service HelloServiceApplication.java 
 
 
 
 Стандартен клас за стартиране  . @SpringBootApplication HelloController.java

@RestController
public class HelloController {

    private static int counter = 0;

    @GetMapping("/api/hello")
    public String sayHello() {
        counter++;
        // симулиране на периодичен отказ: отказ при всяко 3-то извикване
        if (counter % 3 == 0) {
            throw new RuntimeException("Simulated failure from Hello-Service!");
        }
        return "Hello from Hello-Service! (count=" + counter + ")";
    }
}
  Този контролер умишлено хвърля RuntimeException при периодични извиквания, за да симулира временни откази, които бихте видели в реални системи (отказ на база данни, лоши данни, времеви ограничения). Обяснение: client-service ClientServiceApplication.java 
 
 Стандартен основен клас на Spring Boot. Не е необходима специална конфигурация. AppConfig.java
@Configuration
public class AppConfig {
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
  Предоставя един единствен RestTemplate bean. Уверете се, че RestTemplate е Spring bean, така че AOP/resilience прокситата да работят правилно. Обяснение: HelloClientService.java
@Service
public class HelloClientService {

    private final RestTemplate restTemplate;

    @Value("${hello.service.url}")
    private String helloServiceUrl;

    public HelloClientService(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @CircuitBreaker(name = "helloService", fallbackMethod = "fallbackHello")
    public String getHelloMessage() {
        System.out.println("Calling hello service: " + helloServiceUrl);
        return restTemplate.getForObject(helloServiceUrl, String.class);
    }

    public String fallbackHello(Throwable t) {
        System.out.println("Fallback triggered: " + t);
        return "Hello Service is currently unavailable. Please try again later.";
    }
}
 Обяснение (ключови моменти) 
 
 
 
 
 
 @CircuitBreaker(name = "helloService", fallbackMethod = "fallbackHello") обвива извикването на getHelloMessage() в „circuit breaker“. Името се свързва с конфигурационни свойства. 
 
 
 
 fallbackHello(Throwable t) се извиква, когато извикването се провали според правилата на „breaker“-а. Резервният метод трябва:     o    Да е в същия клас

    o    Да има същия тип връщане

    o   Да приема оригиналните параметри на метода (тук няма) и финален параметър Throwable (или Exception/Throwable, съвместим с хвърлените изключения)
 
 
 Важно: Методът трябва да е public, а класът трябва да е Spring bean (@Service), за да може AOP, базиран на проксита, да работи. ClientController.java
@RestController
public class ClientController {

    private final HelloClientService helloClientService;

    public ClientController(HelloClientService helloClientService) {
        this.helloClientService = helloClientService;
    }

    @GetMapping("/api/get-message")
    public String getMessage() {
        return helloClientService.getHelloMessage();
    }
}
  Прост контролер, който препраща към  . Това гарантира, че извикването преминава през проксито, където е приложен „circuit breaker“-ът. Обяснение: HelloClientService Използвана конфигурация (client-service application.properties) Ключови настройки, използвани в демото server.port=8080
spring.application.name=client-service

hello.service.url=http://localhost:8081/api/hello

resilience4j.circuitbreaker.instances.helloService.registerHealthIndicator=true
resilience4j.circuitbreaker.instances.helloService.slidingWindowSize=5
resilience4j.circuitbreaker.instances.helloService.minimumNumberOfCalls=2
resilience4j.circuitbreaker.instances.helloService.failureRateThreshold=50
resilience4j.circuitbreaker.instances.helloService.waitDurationInOpenState=10s

logging.level.io.github.resilience4j.circuitbreaker=DEBUG
 Значение на важни свойства 
 
 
 
 
 
  брой извиквания, които „breaker“-ът наблюдава за процент на откази. slidingWindowSize:  минимален брой извиквания, преди да се оцени процентът на откази. minimumNumberOfCalls:  процент откази (напр. 50), за да се отвори „circuit“-ът. failureRateThreshold:  колко дълго „circuit“-ът остава отворен, преди да премине в полуотворено състояние. waitDurationInOpenState:  излага състоянието на „breaker“-а чрез actuator. registerHealthIndicator: Стартиране стъпка по стъпка и очаквани резултати Стартиране на услугите 
 
 Стартирайте  hello-service Посетете: http://localhost:8081/api/hello
  → „Hello from Hello-Service!“ (или хвърля симулиран отказ) Връща 
 
 Стартирайте  client-service Посетете: http://localhost:8080/api/get-message
 Сценарии за тестване и резултати Сценарий А — Hello-Service е здрав Направете заявка GET http://localhost:8080/api/get-message
 Клиентски логове Calling hello service: http://localhost:8081/api/hello
2025-11-13T11:58:23.366+05:30 DEBUG 32692 --- [client-service] [nio-8080-exec-8] i.g.r.c.i.CircuitBreakerStateMachine : CircuitBreaker 'helloService' succeeded:
2025-11-13T11:58:23.366+05:30 DEBUG 32692 --- [client-service] [nio-8080-exec-8] i.g.r.c.i.CircuitBreakerStateMachine : Event SUCCESS published: 2025-11-13T11:58:23.366634+05:30[Asia/Calcutta]: CircuitBreaker 'helloService' recorded a successful call. Elapsed time: 15 ms
 Отговор Hello from Hello-Service! (count=4)
 Сценарий Б — Периодични откази на Hello-Service Ако извиквате многократно и hello-service хвърля   при някои заявки: RuntimeException ● Успешни извиквания: клиентът връща съобщението „hello“.
●  Когато извикване към низходяща услуга върне HTTP 500/изключение:             o    Resilience4j записва отказа.

            o    Ако процентът на откази надвиши прага (напр. 50% за времевия прозорец), „Circuit“-ът става **ОТВОРЕН**.

            o    Докато е ОТВОРЕН, извикванията се заобикалят; **fallbackHello**() се изпълнява незабавно — без мрежово извикване. \n                       **Клиентски отговор, докато резервният механизъм е активен**
 Клиентски отговор, докато е активен Отговор Hello Service is currently unavailable. Please try again later.
 Примерна последователност на клиентския лог Calling hello service: http://localhost:8081/api/hello
2025-11-13T12:00:55.842+05:30 DEBUG 32692 --- [client-service] [nio-8080-exec-1] i.g.r.c.i.CircuitBreakerStateMachine : CircuitBreaker 'helloService' recorded an exception as failure:
 Сценарий В — Възстановяване След    waitDurationInOpenState (10s): 
 
 
 
 „Circuit“-ът преминава в състояние  : позволяват се няколко тестови извиквания. HALF_OPEN Ако тестовите извиквания са успешни, „breaker“-ът се   и нормалният трафик се възобновява. ЗАТВАРЯ Ако тестовете се провалят, „breaker“-ът се връща в състояние  . OPEN Сценарии от реалния живот 
 
 
 
 
 Услуга за плащане, която извиква външна банкова API: ако API-то на банката стане бавно/откаже, „circuit breaker“-ът връща разбираемо съобщение за потребителя и предотвратява „буря от повторни опити“. Интеграция на плащания —  API-та с ограничение на броя заявки в секунда — когато лимитите са достигнати, „circuit“-ът се отваря, за да се избегне достигането на квотите; резервният механизъм връща кеширани данни. API на трети страни с ограничени заявки —  Услуга А извиква Б, която извиква В. Ако В е нестабилна, отворените „circuit“-и защитават Б и А, предотвратявайки забавяне в цялата система. Вериги от микросървиси в предприятие —  Когато услуга за некритична функция откаже, върнете по-опростен резултат, за да поддържате основната функционалност налична (напр. върнете списък с продукти без препоръки). Превключватели на функции и елегантно деградиране —  Предимства и бизнес стойност 
 
 
 
 
 
 
  — предотвратява каскадирането на една лоша зависимост. Изолиране на откази  — отказва бързо, вместо да чака времеви ограничения. Бърз отговор при отказ  — предлага резервни отговори вместо пълни прекъсвания. Елегантно деградиране  — избягва изхабяването на процесорно време, нишки и мрежа. Защита на ресурсите  — автоматично се връща към нормална работа, когато зависимостта е здрава. Автоматично възстановяване  — състоянията и метриките на „breaker“-а могат да бъдат изведени чрез Actuator и наблюдавани. Наблюдаемост Примерни логове, които ще видите (реалистични) Calling hello service: http://localhost:8081/api/hello
2025-11-13T12:00:55.842+05:30 DEBUG 32692 --- [client-service] [nio-8080-exec-1] i.g.r.c.i.CircuitBreakerStateMachine : CircuitBreaker 'helloService' recorded an exception as failure
2025-11-13T12:00:55.847+05:30 DEBUG 32692 --- [client-service] [nio-8080-exec-1] i.g.r.c.i.CircuitBreakerStateMachine : Event ERROR published: 2025-11-13T12:00:55.847908200+05:30[Asia/Calcutta]: CircuitBreaker 'helloService' recorded an error: 'org.springframework.web.client.HttpServerErrorException$InternalServerError: 500 : "{"timestamp":"2025-11-13T06:30:55.842+00:00","status":500,"error":"Internal Server Error","path":"/api/hello"}"'. Elapsed time: 8 ms
Fallback triggered: org.springframework.web.client.HttpServerErrorException$InternalServerError: 500 : "{"timestamp":"2025-11-13T06:30:55.842+00:00","status":500,"error":"Internal Server Error","path":"/api/hello"}"


Read My Stories

Това аудио е създадено на оригиналния език на историята!

Как да изградим устойчиви API с Resilience4j Circuit Breaker в Spring Boot

About Author

КОМЕНТАРИ

ЗАКАЧВАЙТЕ ЕТИКЕТИ

ТАЗИ СТАТИЯ Е ПРЕДСТАВЕНА В

Related Stories

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps