Spring Boot 优雅实现降级功能:Hystrix 与 Resilience4j 的实践

简介: 【6月更文挑战第19天】在分布式系统中,服务降级是一种重要的容错机制。当某个服务不可用或响应慢时,降级机制可以保证系统的整体稳定性。本文将详细介绍如何在 Spring Boot 中使用 Hystrix 和 Resilience4j 实现降级功能。

在分布式系统中,服务降级是一种重要的容错机制。当某个服务不可用或响应慢时,降级机制可以保证系统的整体稳定性。本文将详细介绍如何在 Spring Boot 中使用 Hystrix 和 Resilience4j 实现降级功能。

什么是服务降级?

服务降级是在某个服务出现故障或响应慢时,提供备选方案(如返回默认值或缓存数据),以保证系统的整体可用性。降级机制可以防止单个服务的故障扩散到整个系统,从而提升系统的稳定性和容错能力。

Hystrix 与 Resilience4j

  • Hystrix:由 Netflix 开发的一个开源库,用于处理分布式系统的延迟和容错问题。尽管功能强大,但 Hystrix 已经停止维护。
  • Resilience4j:一个轻量级的、功能强大的容错库,用于处理分布式系统中的各种故障。它是 Hystrix 的替代品,具有更好的性能和更丰富的功能。

使用 Hystrix 实现降级

1. 引入依赖

pom.xml 文件中添加 Hystrix 依赖:

xml复制代码

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    <version>2.2.6.RELEASE</version>
</dependency>

2. 启用 Hystrix

在 Spring Boot 应用的主类上添加 @EnableHystrix 注解:

java复制代码

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;

@SpringBootApplication
@EnableCircuitBreaker
public class HystrixExampleApplication {
    public static void main(String[] args) {
        SpringApplication.run(HystrixExampleApplication.class, args);
    }
}

3. 实现服务调用和降级方法

创建一个服务类,模拟远程调用并实现降级方法:

java复制代码

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class MyService {

    private final RestTemplate restTemplate;

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

    @HystrixCommand(fallbackMethod = "fallback")
    public String callExternalService() {
        // 模拟远程服务调用
        return restTemplate.getForObject("http://external-service/api/resource", String.class);
    }

    public String fallback(Throwable t) {
        // 降级处理逻辑
        return "Fallback response: Service is currently unavailable.";
    }
}

4. 配置 RestTemplate

在你的配置类中配置 RestTemplate

java复制代码

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class AppConfig {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

5. 创建控制器

创建一个控制器,调用服务并返回结果:

java复制代码

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    private final MyService myService;

    public MyController(MyService myService) {
        this.myService = myService;
    }

    @GetMapping("/call")
    public String call() {
        return myService.callExternalService();
    }
}

使用 Resilience4j 实现降级

1. 引入依赖

pom.xml 文件中添加 Resilience4j 相关的依赖:

xml复制代码

<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-spring-boot2</artifactId>
    <version>1.7.1</version>
</dependency>
<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-circuitbreaker</artifactId>
    <version>1.7.1</version>
</dependency>

2. 配置 Resilience4j

application.yml 中配置 Resilience4j 的熔断器和降级策略:

yaml复制代码

resilience4j:
  circuitbreaker:
    configs:
      default:
        registerHealthIndicator: true
        ringBufferSizeInClosedState: 5
        ringBufferSizeInHalfOpenState: 2
        waitDurationInOpenState: 10000
        # failureRateThreshold: 50
        # minimumNumberOfCalls: 5
        # slidingWindowSize: 10
    instances:
      myService:
        baseConfig: default
        failureRateThreshold: 50
        waitDurationInOpenState: 10000
        ringBufferSizeInClosedState: 5
        ringBufferSizeInHalfOpenState: 2

3. 实现服务调用和降级方法

创建一个服务类,模拟远程调用并实现降级方法:

java复制代码

import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class MyService {

    private final RestTemplate restTemplate;

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

    @CircuitBreaker(name = "myService", fallbackMethod = "fallback")
    public String callExternalService() {
        // 模拟远程服务调用
        return restTemplate.getForObject("http://external-service/api/resource", String.class);
    }

    public String fallback(Throwable t) {
        // 降级处理逻辑
        return "Fallback response: Service is currently unavailable.";
    }
}

4. 配置 RestTemplate

在你的配置类中配置 RestTemplate

java复制代码

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class AppConfig {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

5. 创建控制器

创建一个控制器,调用服务并返回结果:

java复制代码

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    private final MyService myService;

    public MyController(MyService myService) {
        this.myService = myService;
    }

    @GetMapping("/call")
    public String call() {
        return myService.callExternalService();
    }
}

测试

启动 Spring Boot 应用并访问 /call 端点。如果模拟的外部服务不可用,你将看到降级方法返回的响应。

总结

通过本文,我们展示了如何使用 Hystrix 和 Resilience4j 在 Spring Boot 中实现服务降级功能。尽管 Hystrix 功能强大,但由于其已停止维护,Resilience4j 成为更推荐的选择。Resilience4j 提供了丰富的功能,可以帮助构建健壮的分布式系统。

希望本文对你理解和实现服务降级有所帮助。Happy Coding!

相关文章
|
1天前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
Spring Cloud Alibaba 发布了 Scheduling 任务调度模块 [#3732]提供了一套开源、轻量级、高可用的定时任务解决方案,帮助您快速开发微服务体系下的分布式定时任务。
|
11天前
|
JavaScript Java 测试技术
基于SpringBoot+Vue+uniapp的多功能智能手机阅读APP的详细设计和实现(源码+lw+部署文档+讲解等)
基于SpringBoot+Vue+uniapp的多功能智能手机阅读APP的详细设计和实现(源码+lw+部署文档+讲解等)
|
14天前
|
JavaScript Java 测试技术
基于springboot+vue.js+uniapp的多功能智能手机阅读APP附带文章源码部署视频讲解等
基于springboot+vue.js+uniapp的多功能智能手机阅读APP附带文章源码部署视频讲解等
17 1
|
21天前
|
监控 Java 开发者
Spring Cloud中的服务熔断与降级
Spring Cloud中的服务熔断与降级
|
21天前
|
开发框架 Java 开发者
Spring框架的最新功能与应用案例解析
Spring框架的最新功能与应用案例解析
|
1天前
|
Java Spring
Spring框架使用了哪些技术来实现其核心功能
Spring框架使用了哪些技术来实现其核心功能?
|
1天前
|
SQL Java 索引
Hystrix的降级触发条件有哪些
Hystrix的降级触发条件有哪些
|
18天前
|
Java 微服务 Spring
微服务04---服务远程调用,根据订单id查询订单功能,根据id查询订单的同时,把订单所属的用户信息一起返回,Spring提供了一个工具RestTemplate,Bean写在对象前面,以后可以在任何地
微服务04---服务远程调用,根据订单id查询订单功能,根据id查询订单的同时,把订单所属的用户信息一起返回,Spring提供了一个工具RestTemplate,Bean写在对象前面,以后可以在任何地
|
18天前
|
存储 Java
软件开发常用之SpringBoot文件上传接口编写(中),一本书,代码大全(里面有很多代码重构的方法),屎山代码的原因是不断追加逻辑,在错误代码上堆积新的功能,在写完逻辑之后去思考一下,逻辑合理不
软件开发常用之SpringBoot文件上传接口编写(中),一本书,代码大全(里面有很多代码重构的方法),屎山代码的原因是不断追加逻辑,在错误代码上堆积新的功能,在写完逻辑之后去思考一下,逻辑合理不
|
18天前
|
Java 文件存储
软件开发常用之SpringBoot文件上传和下载功能(上){fileName},利用hutool提供的依赖,拿到当前目录的路径,System.getProperty从变量获取路径 ,不存在就用mkdi
软件开发常用之SpringBoot文件上传和下载功能(上){fileName},利用hutool提供的依赖,拿到当前目录的路径,System.getProperty从变量获取路径 ,不存在就用mkdi