SpringBoot3.4.3基于Resilience4j实现服务容错构建高可用系统

itbeien2025年3月3日大约 8 分钟

SpringBoot3.4.3基于Resilience4j实现服务容错构建高可用系统

本专栏前一篇文章SpringBoot3.4.3基于Openfeign实现声明式http接口调用。今天分享SpringBoot3.4.3基于Resilience4j实现服务容错功能，通过声明简单的注解即可处理SpringBoot3应用中服务延迟和容错问题。

完整代码在文章最后，如果觉得本篇文章对你有用，记得点赞、关注、收藏哦。你的支持是我持续更新的动力!

文章最后可以加入免费的Java&AI技术和支付系统沟通社群，一起探讨Java/你的产品如何与AI结合，请按照要求加入。在群中可以聊开发、系统设计、架构、行业趋势、AI等等话题

SpringBoot3专栏软件环境

JDK17.0.12
SpringBoot3.4.3
IDEA2024.3.4
resilience4j-spring-boot3 2.3.0

我们先看本篇文章对应的项目结构，请看下图

1 什么是Resilience4j

Resilience4j 是一个轻量级的容错库。它提供了一系列的容错机制，如熔断器、限流器、重试机制等，用于提高系统的可靠性和容错能力。以下是 Resilience4j 的一些主要特点和优势：

轻量级
Resilience4j 是一个轻量级的库，不需要额外的依赖，并且对应用程序的运行时性能影响非常小。
简单易用
Resilience4j 提供了简单易用的 API，使得开发者可以轻松地集成和使用容错机制。它支持函数式编程，使得代码更加简洁和可读。
高度可配置
Resilience4j 提供了高度可配置的选项，允许开发者根据具体需求调整容错策略。例如，可以配置熔断器的阈值、重试次数、超时时间等。
支持多种容错机制
Resilience4j 支持多种容错机制，包括熔断器、限流器、重试机制、隔离等。这些机制可以单独使用，也可以组合使用，以满足不同的容错需求。
健壮的容错策略
Resilience4j 提供了健壮的容错策略，如自动恢复、优雅降级等。这些策略可以帮助系统在出现故障时，仍然能够提供稳定的服务。
易于集成
Resilience4j 可以很容易地与 Spring Boot、Spring Cloud 等框架集成，使得开发者可以快速地实现容错功能。

Resilience4j 是一个功能强大、易于使用、高度可配置的容错库，可以帮助开发者构建更加健壮和可靠的系统。

2 项目搭建

今天一样会有两个项目，一个是客户端项目，另外一个为服务提供方。我们在客户端调用服务端接口时对Resilience4j组件进行应用，解决服务调用中的延迟和容错问题，提高系统的稳定性和可靠性

2.1 pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>cn.itbeien</groupId>
        <artifactId>springboot3-labs-master</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <artifactId>springboot-resilience4j</artifactId>
    <packaging>pom</packaging>
    <modules>
        <module>springboot-resilience4j-client</module>
        <module>springboot-resilience4j-server</module>
    </modules>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <resilience4j-spring-boot3.version>2.3.0</resilience4j-spring-boot3.version>
    </properties>


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>io.github.resilience4j</groupId>
            <artifactId>resilience4j-spring-boot3</artifactId>
            <version>${resilience4j-spring-boot3.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
    </dependencies>

</project>

2.2 配置信息

resilience4j.circuitbreaker.instances.myCircuitBreaker.slidingWindowSize=10
resilience4j.circuitbreaker.instances.myCircuitBreaker.minimumNumberOfCalls=5
resilience4j.circuitbreaker.instances.myCircuitBreaker.permittedNumberOfCallsInHalfOpenState=3
resilience4j.circuitbreaker.instances.myCircuitBreaker.waitDurationInOpenState=10s
resilience4j.circuitbreaker.instances.myCircuitBreaker.failureRateThreshold=50
resilience4j.circuitbreaker.instances.myCircuitBreaker.eventConsumerBufferSize=10
resilience4j.circuitbreaker.instances.myCircuitBreaker.recordExceptions[0]=java.lang.RuntimeException

2.3 客户端代码

客户端代码主要是对服务端功能调用，并在方法上添加熔断注解，当发生异常时调用指定回退方法

package cn.itbeien.resilience4j.client.controller;

import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.List;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Java/AI学习社群
 * Copyright© 2025 itbeien
 */
@RestController
@RequestMapping("/client")
@Slf4j
public class ClientController {
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/getData")
    @CircuitBreaker(name = "myCircuitBreaker", fallbackMethod = "fallback")
    public String getData(@RequestParam("id") Integer id) {
        // 记录日志，输出id
        log.info("[getData][准备调用 Resilience4j-server 获取客户端传递的({})详情]", id);
        // 使用RestTemplate发送HTTP GET请求，获取服务器返回的数据
        return restTemplate.getForEntity("http://127.0.0.1:9090/api/get?id=" + id, String.class).getBody();
    }

    @GetMapping("/getList")
    @CircuitBreaker(name = "myCircuitBreaker", fallbackMethod = "fallback")
    public String getList(@RequestParam("ids") List<Integer> ids) {
        // 记录日志，输出id
        log.info("[getList][准备调用 Resilience4j-server 获取客户端传递的({})详情]", ids);
        //使用RestTemplate发送HTTP GET请求，获取服务器返回的数据
        return restTemplate.getForEntity("http://127.0.0.1:9090/api/getlist?ids=" + ids, String.class).getBody();
    }

    public String fallback(Integer id, Throwable throwable) {
        // 记录日志，id和异常信息
        log.info("[fallback][id({}) exception({})]", id, throwable.getMessage());
        log.info("fallback mock server:{}",id);
        // 返回fallback mock server加上id的字符串
        return "fallback mock server:" + id;
    }
}