0Pricing
Spring Boot 4 Microservices & REST APIs · 课时

使用 Resilience4j 实现熔断器

使用 Resilience4j 应用熔断器模式，防止微服务中的级联故障。

使用 Resilience4j 实现熔断器 是 CoddyKit 上的免费 Spring Boot 4 Microservices & REST APIs 课时。 这是第 1 节课，共 3 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Spring Boot 4 Microservices & REST APIs 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Spring Boot 4 Microservices & REST APIs 课程共包含 3 节课。

本课时的部分内容尚未翻译，以英文显示。

Building Resilient Microservices

Microservices are great, but they also bring new challenges. When one service fails, it shouldn't take down the whole system. This is where resilience comes in.

Building resilient systems means they can recover gracefully from failures and continue to function, even if in a degraded mode. It's crucial for maintaining service availability and user experience.

Avoiding Cascading Failures

Imagine a chain of services: Service A calls B, which calls C. If Service C becomes slow or unresponsive, Service B will wait, consuming resources. Then Service A will wait for B, and so on.

Eventually, all services in the chain might exhaust their resources (like threads or connections) and fail, leading to a complete system outage. This is a cascading failure, a common problem in distributed systems.

The Circuit Breaker Pattern

The circuit breaker pattern helps prevent cascading failures. It's like an electrical circuit breaker in your house: if there's an overload, it 'trips' and cuts off the power to prevent damage.

In software, a circuit breaker wraps a function call to a potentially failing service. If calls to that service repeatedly fail, the circuit breaker 'opens,' preventing further calls to the failing service and returning an error immediately.

Resilience4j: Our Tool

Resilience4j is a lightweight, easy-to-use fault-tolerance library for Java and Kotlin. It provides several patterns to make your applications more resilient, including:

  • Circuit Breaker: Prevents repeated calls to failing services.
  • Retry: Automatically retries failed operations.
  • Rate Limiter: Controls the rate of requests to a service.

In this lesson, we'll focus specifically on the Circuit Breaker pattern.

Setup: Adding Dependency

First, let's add the necessary dependency to our Spring Boot project. For Maven, you'd add this to your pom.xml:

<dependency>
<groupId>io.github.resilience4j</groupId>
<artifactId>resilience4j-spring-boot2</artifactId>
<version>2.2.0</version> <!-- Use latest stable -->
</dependency>

This dependency brings in the core Resilience4j modules and its Spring Boot integration for easy configuration.

Configuring Circuit Breaker

We can configure circuit breakers in our application.yml or application.properties. Here's a basic example for a service named 'myExternalService':

resilience4j.circuitbreaker:
instances:
myExternalService:
failureRateThreshold: 50
waitDurationInOpenState: 5s
slidingWindowType: COUNT_BASED
slidingWindowSize: 10

  • failureRateThreshold: If 50% of calls fail, the circuit opens.
  • waitDurationInOpenState: How long the circuit stays open (5 seconds).
  • slidingWindowType & slidingWindowSize: Metrics are collected over the last 10 calls.

Implementing Circuit Breaker

Now, let's protect a service call using the @CircuitBreaker annotation. This tells Spring to apply the configured circuit breaker named "myExternalService" to this method.

Try running this example. If callExternalService() throws an exception frequently (simulated here), the circuit will eventually open and reject calls immediately.

package com.coddykit.resilience;

import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Random;

@SpringBootApplication
@RestController
public class CircuitBreakerDemoApplication {

    private Random random = new Random();

    public static void main(String[] args) {
        SpringApplication.run(CircuitBreakerDemoApplication.class, args);
    }

    @GetMapping("/call-external")
    @CircuitBreaker(name = "myExternalService")
    public String callExternalService() {
        System.out.println("Attempting external service call...");
        if (random.nextBoolean()) { // Simulate 50% failure rate
            System.out.println("External service failed!");
            throw new RuntimeException("External Service Unavailable!");
        }
        System.out.println("External service call successful!");
        return "External Service Data";
    }
}

Circuit Breaker States

A circuit breaker operates in three main states:

  • CLOSED: Normal operation. Calls go through. If failures exceed a threshold, it transitions to OPEN.
  • OPEN: Calls are immediately rejected with an error. After a waitDurationInOpenState, it transitions to HALF_OPEN.
  • HALF_OPEN: A limited number of test calls are allowed through. If these succeed, it transitions back to CLOSED. If they fail, it returns to OPEN.

This cycle prevents overwhelming a struggling service while allowing it to recover.

Graceful Fallbacks

When a circuit breaker is OPEN, or if a call fails for other reasons, we don't want to just return a generic error. We can provide a fallback method to return a default response or perform alternative logic.

Resilience4j's @CircuitBreaker annotation allows you to specify a fallback method that will be called if the primary method fails or the circuit is open. This ensures a more graceful degradation of service.

Circuit Breaker with Fallback

Let's enhance our previous example with a fallback method. When the circuit is open or callExternalService() fails, fallbackMethod() will be executed instead.

Run this and try to trigger the circuit breaker. Notice how the fallback message is returned when the external service fails or the circuit is open, providing a better user experience.

package com.coddykit.resilience;

import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Random;

@SpringBootApplication
@RestController
public class CircuitBreakerWithFallbackApplication {

    private Random random = new Random();

    public static void main(String[] args) {
        SpringApplication.run(CircuitBreakerWithFallbackApplication.class, args);
    }

    @GetMapping("/call-external-with-fallback")
    @CircuitBreaker(name = "myExternalService", fallbackMethod = "fallbackMethod")
    public String callExternalService() {
        System.out.println("Attempting external service call...");
        if (random.nextBoolean()) { // Simulate 50% failure rate
            System.out.println("External service failed!");
            throw new RuntimeException("External Service Unavailable!");
        }
        System.out.println("External service call successful!");
        return "External Service Data";
    }

    // The fallback method must have the same return type and can accept a Throwable parameter
    public String fallbackMethod(Throwable t) {
        System.out.println("Fallback method called: " + t.getMessage());
        return "Fallback: Default Data (Service Currently Unavailable)";
    }
}

Circuit Breaker Check

Consider a circuit breaker configured with failureRateThreshold: 70 and slidingWindowSize: 10. If 8 out of the last 10 consecutive calls fail while the circuit is CLOSED, what is the most likely immediate next state of the circuit breaker?

Recap: Circuit Breakers

We've learned how circuit breakers, especially with Resilience4j, are vital for building resilient microservices. They prevent cascading failures by stopping repeated calls to failing services.

Key takeaways:

  • Circuit breakers protect services from overload and unresponsiveness.
  • They operate in CLOSED, OPEN, and HALF_OPEN states.
  • Fallbacks provide graceful degradation when a service is unavailable.

Next, we'll explore other resilience patterns like implementing fallbacks and timeouts more deeply.

常见问题解答

「使用 Resilience4j 实现熔断器」课时是免费的吗？

是的 — 「使用 Resilience4j 实现熔断器」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Spring Boot 4 Microservices & REST APIs 课程的其余内容，请升级到 CoddyKit PRO。 Spring Boot 4 Microservices & REST APIs 课程共包含 3 节课。

「使用 Resilience4j 实现熔断器」这节课中我会学到什么？

使用 Resilience4j 应用熔断器模式，防止微服务中的级联故障。 你通过在浏览器中直接运行的动手代码来练习 Spring Boot 4 Microservices & REST APIs，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Spring Boot 4 Microservices & REST APIs 需要有经验吗？

无需任何先前经验。CoddyKit 上的 Spring Boot 4 Microservices & REST APIs 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。 这是第 1 节课，共 3 节。

「使用 Resilience4j 实现熔断器」课时需要多长时间？

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。

我能在这节 Spring Boot 4 Microservices & REST APIs 课中编写并运行代码吗？

能。每节 Spring Boot 4 Microservices & REST APIs 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

  1. 使用 Resilience4j 实现熔断器
  2. 实现故障回退与超时
  3. 使用 Zipkin 进行分布式追踪
← 返回 Spring Boot 4 Microservices & REST APIs