Spring Boot 4 Complete Guide · 课时

速率限制、重试与时间限制器

组合速率限制器、重试和超时机制,以调节负载并遏制级联故障。

第 3 / 4 课13 个步骤

速率限制、重试与时间限制器 是 CoddyKit 上的免费 Spring Boot 4 Complete Guide 课时。 这是第 3 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Spring Boot 4 Complete Guide 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Spring Boot 4 Complete Guide 课程共包含 4 节课。

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

Three Knobs for Shaping Load

Circuit breakers stop calling a dead dependency, but they are only one tool in the resilience toolbox. To shape inbound load and contain cascading failures you combine three more Resilience4j primitives:

  • RateLimiter — caps how many calls per time window are allowed to start. Excess callers wait or are rejected.
  • Retry — re-invokes a failed call a bounded number of times, ideally with backoff, to ride out transient errors.
  • TimeLimiter — caps how long a single call may run before it is cancelled, freeing the thread and bounding tail latency.

Used together they protect both you (don't overload your own service) and your downstream (don't hammer a struggling dependency).

Adding Resilience4j to Spring Boot 4

Spring Boot 4 integrates Resilience4j through the Spring Cloud Circuit Breaker / resilience4j-spring-boot3 starter, which exposes annotation-driven aspects for every primitive.

Add the starter and AOP support so the annotations are woven in:

  • resilience4j-spring-boot3 brings RateLimiter, Retry, TimeLimiter, CircuitBreaker, and Bulkhead aspects.
  • spring-boot-starter-aop is required — the annotations are implemented as AOP advice.
  • Metrics flow into Micrometer automatically when Actuator is present.
<dependencies>
  <dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-spring-boot3</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
  </dependency>
</dependencies>

RateLimiter: Capping Calls Per Window

A RateLimiter divides time into refresh periods. Each period grants a fixed number of permits. A caller that finds no permit available waits up to timeoutDuration; if still none, it fails fast with RequestNotPermitted.

Configure instances in application.yml under resilience4j.ratelimiter:

  • limitForPeriod — permits granted each refresh period.
  • limitRefreshPeriod — how often the permit count resets.
  • timeoutDuration — how long a caller blocks waiting for a permit before being rejected.
resilience4j:
  ratelimiter:
    instances:
      pricingApi:
        limitForPeriod: 50
        limitRefreshPeriod: 1s
        timeoutDuration: 200ms
        registerHealthIndicator: true

Applying @RateLimiter

Annotate the method that calls the protected resource. The name must match the YAML instance. When the limit is exceeded and no permit frees up within timeoutDuration, Resilience4j throws RequestNotPermitted — route it to a fallback so clients get a graceful 429 instead of a stack trace.

Key decision: a RateLimiter throttles your outbound calls. It does not slow down inbound HTTP traffic by itself — pair it with a fallback that signals back-pressure.

@Service
public class PricingClient {

    private final RestClient restClient;

    public PricingClient(RestClient restClient) {
        this.restClient = restClient;
    }

    @RateLimiter(name = "pricingApi", fallbackMethod = "throttled")
    public Quote fetchQuote(String symbol) {
        return restClient.get()
                .uri("/quotes/{symbol}", symbol)
                .retrieve()
                .body(Quote.class);
    }

    private Quote throttled(String symbol, RequestNotPermitted ex) {
        throw new ResponseStatusException(HttpStatus.TOO_MANY_REQUESTS,
                "Pricing rate limit exceeded, retry shortly");
    }
}

Retry: Riding Out Transient Failures

A Retry re-invokes a failed call up to maxAttempts times. It is only correct for transient faults — connection resets, 503s, brief timeouts — and only safe on idempotent operations. Retrying a non-idempotent POST can double-charge a customer.

Use exponential backoff to avoid synchronized retry storms, and be explicit about which exceptions retry vs. which abort immediately:

  • retryExceptions — only these trigger a retry.
  • ignoreExceptions — these abort instantly (e.g. 4xx client errors).
  • enableExponentialBackoff with a multiplier spreads attempts out.
resilience4j:
  retry:
    instances:
      pricingApi:
        maxAttempts: 3
        waitDuration: 200ms
        enableExponentialBackoff: true
        exponentialBackoffMultiplier: 2
        retryExceptions:
          - java.io.IOException
          - org.springframework.web.client.HttpServerErrorException
        ignoreExceptions:
          - org.springframework.web.client.HttpClientErrorException

Exponential Backoff with Jitter, Conceptually

Exponential backoff multiplies the wait after each attempt: 200ms, 400ms, 800ms... But if thousands of clients fail at the same instant, they all back off in lock-step and re-converge — a retry storm. Adding jitter (randomized wait) de-synchronizes them.

This standalone program models the wait schedule so you can see the spread of backoff-with-jitter delays an online judge can run with no framework:

import java.util.concurrent.ThreadLocalRandom;

public class BackoffDemo {
    static long backoffWithJitter(int attempt, long baseMillis, double multiplier) {
        double exp = baseMillis * Math.pow(multiplier, attempt - 1);
        long jitter = ThreadLocalRandom.current().nextLong((long) (exp / 2) + 1);
        return (long) (exp / 2) + jitter; // half fixed, half random
    }

    public static void main(String[] args) {
        for (int attempt = 1; attempt <= 4; attempt++) {
            long wait = backoffWithJitter(attempt, 200, 2.0);
            System.out.println("Attempt " + attempt + " -> wait ~" + wait + "ms");
        }
    }
}

Applying @Retry

Stack @Retry on the same method. Order matters when annotations combine: Resilience4j applies aspects in the order Retry → CircuitBreaker → RateLimiter → TimeLimiter → Bulkhead (outermost to innermost), so a retry wraps the rate-limited call and each attempt re-acquires a permit.

The fallback receives the final exception after all attempts are exhausted:

@Service
public class PricingClient {

    @Retry(name = "pricingApi")
    @RateLimiter(name = "pricingApi", fallbackMethod = "throttled")
    public Quote fetchQuote(String symbol) {
        return restClient.get()
                .uri("/quotes/{symbol}", symbol)
                .retrieve()
                .body(Quote.class);
    }

    private Quote throttled(String symbol, Throwable ex) {
        // Returns a last-known-good or default after retries + limit exhausted
        return Quote.unavailable(symbol);
    }
}

TimeLimiter: Bounding Tail Latency

A TimeLimiter caps how long a single asynchronous call may run. It only works with futures — the method must return CompletableFuture (or another supported async type) so Resilience4j can cancel it when the deadline passes.

This is the antidote to slow dependencies: a retry handles failures, but a call that simply hangs for 30 seconds will exhaust your thread pool. The TimeLimiter converts a hang into a fast TimeoutException.

  • timeoutDuration — the per-call deadline.
  • cancelRunningFuture — interrupt the running task on timeout to free its thread.
resilience4j:
  timelimiter:
    instances:
      pricingApi:
        timeoutDuration: 2s
        cancelRunningFuture: true

Applying @TimeLimiter on an Async Method

@TimeLimiter requires the method to return a CompletableFuture. Without an async return type the aspect silently does nothing. Combine it with a CircuitBreaker so repeated timeouts eventually open the breaker and stop wasting effort.

Note the fallback also returns a CompletableFuture — its signature must match the protected method's return type:

@Service
public class PricingClient {

    @TimeLimiter(name = "pricingApi")
    @CircuitBreaker(name = "pricingApi", fallbackMethod = "timedOut")
    public CompletableFuture<Quote> fetchQuoteAsync(String symbol) {
        return CompletableFuture.supplyAsync(() ->
                restClient.get()
                        .uri("/quotes/{symbol}", symbol)
                        .retrieve()
                        .body(Quote.class));
    }

    private CompletableFuture<Quote> timedOut(String symbol, Throwable ex) {
        return CompletableFuture.completedFuture(Quote.unavailable(symbol));
    }
}

Ordering the Three Together Correctly

When you stack all three, the aspect order determines behavior. Resilience4j's documented default decoration order, from outer to inner, is:

Retry( CircuitBreaker( RateLimiter( TimeLimiter( Bulkhead( call ) ) ) ) )

  • Retry outermost so a retry re-runs the whole protected chain, re-checking the circuit breaker and re-acquiring a rate-limit permit each attempt.
  • TimeLimiter inner so each individual attempt has its own deadline — a retry of a timed-out call gets a fresh clock.
  • Putting Retry inside the RateLimiter would let one logical call consume several permits per attempt — usually wrong, and it can starve other callers.

With annotations you don't manually order them; Resilience4j enforces this order via aspect precedence.

Observing and Tuning via Actuator

You cannot tune what you cannot see. With Actuator on the classpath, every instance publishes Micrometer metrics and health indicators. Expose them and watch the key signals:

  • resilience4j_ratelimiter_available_permissions — if this sits at zero, you are throttling real traffic; raise the limit or scale out.
  • resilience4j_retry_calls tagged kind=successful_with_retry vs failed_with_retry — high failed-with-retry means retries aren't helping; the fault isn't transient.
  • resilience4j_timelimiter_calls tagged kind=timeout — rising timeouts signal a degrading dependency before the breaker even opens.
management:
  endpoints:
    web:
      exposure:
        include: health, metrics, ratelimiters, retries
  metrics:
    tags:
      application: tracing-service
  health:
    ratelimiters:
      enabled: true

Quick Check: Choosing the Right Primitive

A downstream pricing API occasionally hangs for 30+ seconds instead of returning an error, and these hangs are exhausting your service's request threads. Which Resilience4j primitive most directly addresses this specific failure mode?

Recap: Shaping Load and Containing Failure

You combined three complementary primitives to shape load and contain cascading failures:

  • RateLimiter caps calls per window, rejecting excess with RequestNotPermitted so you never overload yourself or a downstream.
  • Retry rides out transient faults on idempotent calls, using exponential backoff plus jitter to avoid retry storms.
  • TimeLimiter bounds tail latency on async (CompletableFuture) calls, turning hangs into fast timeouts that free threads.

Stack them via annotations; Resilience4j enforces the order Retry → CircuitBreaker → RateLimiter → TimeLimiter → Bulkhead so a retry re-runs the whole protected chain while each attempt keeps its own deadline. Always wire fallbacks for graceful degradation and watch Actuator/Micrometer metrics to tune the limits against real traffic.

免费开始

用 AI 导师学习 Java — 免费

在浏览器中编写并运行真实代码,获得全天候 AI 导师的即时帮助,并在网页或应用中继续学习。

课程
21
课程
84

常见问题解答

「速率限制、重试与时间限制器」课时是免费的吗?

是的 — 「速率限制、重试与时间限制器」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Spring Boot 4 Complete Guide 课程的其余内容,请升级到 CoddyKit PRO。 Spring Boot 4 Complete Guide 课程共包含 4 节课。

「速率限制、重试与时间限制器」这节课中我会学到什么?

组合速率限制器、重试和超时机制,以调节负载并遏制级联故障。 你通过在浏览器中直接运行的动手代码来练习 Spring Boot 4 Complete Guide,全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Spring Boot 4 Complete Guide 需要有经验吗?

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

「速率限制、重试与时间限制器」课时需要多长时间?

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

我能在这节 Spring Boot 4 Complete Guide 课中编写并运行代码吗?

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

此课程中的所有课时

  1. 上下文传播与跨度插桩
  2. 断路器与舱壁隔离
  3. 速率限制、重试与时间限制器
  4. 关联日志、指标与跟踪
← 返回 Spring Boot 4 Complete Guide