Resilience4j 从入门到放弃

2023-10-24 09:59
文章标签 入门 放弃 resilience4j

本文主要是介绍Resilience4j 从入门到放弃，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Resilience4j

  • 简介
  • 1.基本用法
    • 1.1熔断器
      • 1.1.1 首先看一个正常的断路器：
      • 1.1.2 一个异常的断路器：
      • 1.1.3 断路器重置
    • 1.2 RateLimiter 限流
    • 1.3 请求重试
  • 2. Resilience4j 结合微服务
    • 2.1 Retry 请求重试
    • 2.2 CircuitBreaker 断路器
    • 2.3 RateLimiter 限流

简介

Resilience4j 是 Spring Cloud Greenwich 版推荐的容错解决方案，相比 Hystrix ，Resilience4j 专为 Java8 以及函数编程而设计。在 Resilience4j 中你用什么可直接添加什么以来就行。
Resilience4j 主要有以下功能：

  1. CircuitBreaker(熔断器)
  2. RateLimiter(限流)
  3. Retry(请求重试)
  4. 限时
  5. 缓存
  6. 信号量的隔离

1.基本用法

首先搭建一个测试环境。新建maven子模，导入pom

        <dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency>

1.1熔断器

添加断路器依赖：

        <dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-circuitbreaker</artifactId><version>0.13.2</version></dependency>

1.1.1 首先看一个正常的断路器：

    @Testpublic void test1() {//获取一个CircuitBreakerRegistry实例，可以调用ofDefaults获取一个CircuitBreakerRegistry实例，也可以自定义属性。CircuitBreakerRegistry registry = CircuitBreakerRegistry.ofDefaults();CircuitBreakerConfig config = CircuitBreakerConfig.custom()//故障率阈值百分比(百分之50)，超过这个阈值，断路器就会打开.failureRateThreshold(50)//断路器保持打开的时间，在到达设置的时间之后，断路器会进入到 half open 状态.waitDurationInOpenState(Duration.ofMillis(1000))//当断路器处于half open 状态时，环形缓冲区的大小.ringBufferSizeInHalfOpenState(2).ringBufferSizeInClosedState(2).build();CircuitBreakerRegistry r1 = CircuitBreakerRegistry.of(config);CircuitBreaker cb1 = r1.circuitBreaker("javaboy");//创建断路器CircuitBreaker cb2 = r1.circuitBreaker("javaboy2", config);CheckedFunction0<String> supplier = CircuitBreaker.decorateCheckedSupplier(cb1, () -> "hello resilience4j");Try<String> result = Try.of(supplier).map(v -> v + " hello world");System.out.println(result.isSuccess());System.out.println(result.get());}

在这里插入图片描述

1.1.2 一个异常的断路器：

public void test2() {CircuitBreakerConfig config = CircuitBreakerConfig.custom()//故障率阈值百分比，超过这个阈值，断路器就会打开.failureRateThreshold(50)//断路器保持打开的时间，在到达设置的时间之后，断路器会进入到 half open 状态.waitDurationInOpenState(Duration.ofMillis(1000))//当断路器处于half open 状态时，环形缓冲区的大小.ringBufferSizeInClosedState(2).build();CircuitBreakerRegistry r1 = CircuitBreakerRegistry.of(config);CircuitBreaker cb1 = r1.circuitBreaker("javaboy");System.out.println(cb1.getState());//获取断路器的一个状态cb1.onError(0, new RuntimeException());System.out.println(cb1.getState());//获取断路器的一个状态cb1.onError(0, new RuntimeException());System.out.println(cb1.getState());//获取断路器的一个状态

在这里插入图片描述
把这段代码添加到上面代码的后面，重新测试。

...   
CheckedFunction0<String> supplier = CircuitBreaker.decorateCheckedSupplier(cb1, () -> "hello resilience4j");Try<String> result = Try.of(supplier).map(v -> v + " hello world");System.out.println("result.isSuccess()="+result.isSuccess());System.out.println("result.get()="+result.get());}

如下(由于断路器已经打开了，就无法执行下面的代码了)：
在这里插入图片描述

注意：由于 ringBufferSizeInClosedState 的值为2，表示当有两条数据时才会去统计故障率，所以，下面的手动故障测试，至少调用两次 onError，断路器才会打开。

1.1.3 断路器重置

circuitBreaker.reset();

1.2 RateLimiter 限流

RateLimiter 本身和前面的断路器差不多。

 /*** 限流 和断路器类似*/@Testpublic void test3(){RateLimiterConfig build = RateLimiterConfig.custom()// 阈值刷新的时间 1 秒.limitRefreshPeriod(Duration.ofMillis(1000))// 限制频次.limitForPeriod(2)// 限流之后的冷却时间 1秒.timeoutDuration(Duration.ofMillis(1000)).build();RateLimiter limiter = RateLimiter.of("learning", build);CheckedRunnable runnable = RateLimiter.decorateCheckedRunnable(limiter, () -> {System.out.println(new Date());});// 执行4次Try.run(runnable).andThenTry(runnable).andThenTry(runnable).andThenTry(runnable).onFailure(t -> System.out.println(t.getMessage()));}

在这里插入图片描述

1.3 请求重试

先引入依赖：

      <dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-retry</artifactId><version>0.13.2</version></dependency>

    /*** 请求重试*/@Testpublic void test4(){RetryConfig config = RetryConfig.custom()// 重试次数 【小于等于下面的count次数就抛出异常】.maxAttempts(4)// 重试间隔.waitDuration(Duration.ofMillis(500))// 重试异常.retryExceptions(RuntimeException.class).build();Retry retry = Retry.of("leaning1", config);Retry.decorateRunnable(retry, new Runnable() {int count = 0;// 重试功能开启后 执行run方法 若抛出异常 会自动触发重试功能@Overridepublic void run() {if (count++ < 4){System.out.println(count);throw new RuntimeException();}}}).run();}

在这里插入图片描述

2. Resilience4j 结合微服务

Retry、CircuitBreaker、RateLimiter

2.1 Retry 请求重试

首先新建一个Spring boot 项目，创建时，添加如下依赖：
在这里插入图片描述
创建成功后再添加 Resilience4j 的依赖如下：

        <dependency<!--resilience4j-spring-boot2中包含了resilience4j 的所有功能，但是没有配置的功能无法使用，需要将之从依赖中剔除掉  --><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot2</artifactId><version>1.2.0</version><exclusions><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-circuitbreaker</artifactId></exclusion><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-ratelimiter</artifactId></exclusion><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-bulkhead</artifactId></exclusion><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-timelimiter</artifactId></exclusion></exclusions></dependency>

resilience4j-spring-boot2中包含了resilience4j 的所有功能，但是没有配置的功能无法使用，需要将之从依赖中剔除掉。
配置yml文件：

resilience4j:retry:retry-aspect-order: 399 # 表示Retry优先级(级别高于比如ratelimiter bulkhead timelimiter) 值越小 优先级 越高backends:retryA: # 设置组名maxRetryAttempts: 5 # 对比之前的案例 重试的次数waitDuration: 500 # 重试等待 500毫秒exponentialBackoffMultiplier: 1.1 # 间隔乘数(场景: 正好每次间隔为1的时候卡顿 它就有用了 间隔就变了 例如 1 1.1 1.21....)retryExceptions:- java.lang.RuntimeException
spring:application:name: resilience4j
server:port: 5000
eureka:client:service-url:defaultZone: http://localhost:1111/eureka

最后创建RestTemplate和HelloService:

@SpringBootApplication
public class Resilience4j2Application {public static void main(String[] args) {SpringApplication.run(Resilience4j2Application.class, args);}@BeanRestTemplate restTemplate(){return new RestTemplate();}
}@Service
@Retry(name = "retryA")//表示要使用的重试策略
public class HelloService {@AutowiredRestTemplate restTemplate;public String hello(){return restTemplate.getForObject("http://127.0.0.1:1113/hello", String.class);}
}@RestController
public class HelloController {@AutowiredHelloService helloService;@GetMapping("/hello")public String hello(){return helloService.hello();}
}

浏览器访问: http:/127.0.0.1:5000/hello ，观看 provider 控制台，发现错误打印了5次，与yml中的配置一致。

2.2 CircuitBreaker 断路器

首先去除掉circuitbreaker 的依赖。然后在yml 文件中配置：

<dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot2</artifactId><version>1.2.0</version><exclusions><!-- 没有配置的 先排除 不然会报错 -->
<!--                <exclusion>-->
<!--                    <groupId>io.github.resilience4j</groupId>-->
<!--                    <artifactId>resilience4j-circuitbreaker</artifactId>-->
<!--                </exclusion>--><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-ratelimiter</artifactId></exclusion><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-bulkhead</artifactId></exclusion><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-timelimiter</artifactId></exclusion></exclusions></dependency>
resilience4j:retry:retry-aspect-order: 399 # 表示Retry优先级(级别高于比如ratelimiter bulkhead timelimiter) 值越小 优先级 越高backends:retryA: # 设置组名maxRetryAttempts: 5 # 对比之前的案例 重试的次数waitDuration: 500 # 重试等待 500毫秒exponentialBackoffMultiplier: 1.1 # 间隔乘数(场景: 正好每次间隔为1的时候卡顿 它就有用了 间隔就变了 例如 1 1.1 1.21....)retryExceptions:- java.lang.RuntimeExceptioncircuitbreaker: # 和之前的maven类似instances:cba:ringBufferSizeInHalfOpenState: 3ringBufferSizeInClosedState:  5waitInterval: 5000recordExceptions:- org.springframework.web.client.HttpServerErrorExceptioncircuit-breaker-aspect-order: 398 # 表示 circuitbreaker 优先级，比上面的399小 (先执行当前断路器)
spring:application:name: resilience4j
server:port: 5000
eureka:client:service-url:defaultZone: http://localhost:1111/eureka

配置完成后，用 @CircuitBreaker 注解标记相关方法：

@Service
//@Retry(name = "retryA")//【Retry】表示要使用的重试策略
@CircuitBreaker(name = "cba" , fallbackMethod = "error")
public class HelloService {@AutowiredRestTemplate restTemplate;public String hello(){return restTemplate.getForObject("http://127.0.0.1:1113/hello", String.class);}// 服务降级方法中 不加参数Throwable 会报错提示缺少Throwable 要添加异常参数public String error(Throwable throwable){return "error";}
}

@CircuitBreaker 注解中的 name 属性用来指定 circuitbreaker 配置 ， fallbackMethod 属性用来指定服务降级的方法，需要注意的是，服务降级方法中，要添加异常参数 (Throwable)。

2.3 RateLimiter 限流

RateLimiter 作为限流工具，主要在服务端使用，用来保护服务端的接口。
首先在 provider 中添加RateLimiter 依赖：

      <dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot2</artifactId><version>1.2.0</version><exclusions><!--  没有配置的 先排除 不然会报错 --><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-circuitbreaker</artifactId></exclusion><!--ratelimiter依赖移除-->
<!--                <exclusion>-->
<!--                    <groupId>io.github.resilience4j</groupId>-->
<!--                    <artifactId>resilience4j-ratelimiter</artifactId>-->
<!--                </exclusion>--><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-bulkhead</artifactId></exclusion><exclusion><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-timelimiter</artifactId></exclusion></exclusions></dependency>

接下来，在 provider 的 application.properties 配置文件中去配置 RateLimiter：

# 这里配置每一秒处理一个请求，多个请求就排队
resilience4j.ratelimiter.limiters.rlA.limit-for-period=1
resilience4j.ratelimiter.limiters.rlA.limit-refresh-period=1s
resilience4j.ratelimiter.limiters.rlA.timeout-duration=1s

配置 provider 的 Controller 层

@RestController
public class HelloController {@Value("${server.port}")Integer port;@GetMapping("/hello")@RateLimiter(name = "rltA") //通过@RateLimiter注解标记该接口限流public String hello(){System.out.println(new Date());return "hello provider：" + port;}
}

接着在 resilience4j2 客户端模拟多个请求，启动 eureka、provider 、resilience4j 服务，访问 http://127.0.0.1:5000/hello1 查看限流效果。如下：


@RestController
public class HelloController {@AutowiredHelloService helloService;@GetMapping("/hello")public String hello(){return helloService.hello();}
}@Servic
@CircuitBreaker(name = "cba" , fallbackMethod = "error")
public class HelloService {@AutowiredRestTemplate restTemplate;// 限流配置 【模拟多次请求】public String hello(){for (int i = 0; i < 5; i++) {restTemplate.getForObject("http://127.0.0.1:1113/hello", String.class);}return "success ratA";}
}

每秒处理一个请求。
在这里插入图片描述

这篇关于Resilience4j 从入门到放弃的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/274375。

相关文章

Spring WebClient从入门到精通

Spring WebClient从入门到精通

《SpringWebClient从入门到精通》本文详解SpringWebClient非阻塞响应式特性及优势,涵盖核心API、实战应用与性能优化,对比RestTemplate,为微服务通信提供高效解决... 目录一、WebClient 概述1.1 为什么选择 WebClient？1.2 WebClient 与
阅读更多...
Spring Boot 与微服务入门实战详细总结

Spring Boot 与微服务入门实战详细总结

《SpringBoot与微服务入门实战详细总结》本文讲解SpringBoot框架的核心特性如快速构建、自动配置、零XML与微服务架构的定义、演进及优缺点,涵盖开发环境准备和HelloWorld实战... 目录一、Spring Boot 核心概述二、微服务架构详解1. 微服务的定义与演进2. 微服务的优缺点三
阅读更多...
从入门到精通详解LangChain加载HTML内容的全攻略

从入门到精通详解LangChain加载HTML内容的全攻略

《从入门到精通详解LangChain加载HTML内容的全攻略》这篇文章主要为大家详细介绍了如何用LangChain优雅地处理HTML内容,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录引言：当大语言模型遇见html一、HTML加载器为什么需要专门的HTML加载器核心加载器对比表二
阅读更多...
从入门到进阶讲解Python自动化Playwright实战指南

从入门到进阶讲解Python自动化Playwright实战指南

《从入门到进阶讲解Python自动化Playwright实战指南》Playwright是针对Python语言的纯自动化工具,它可以通过单个API自动执行Chromium,Firefox和WebKit... 目录Playwright 简介核心优势安装步骤观点与案例结合Playwright 核心功能从零开始学习
阅读更多...
从入门到精通MySQL联合查询

从入门到精通MySQL联合查询

《从入门到精通MySQL联合查询》：本文主要介绍从入门到精通MySQL联合查询,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下... 目录摘要1. 多表联合查询时mysql内部原理2. 内连接3. 外连接4. 自连接5. 子查询6. 合并查询7. 插入查询结果摘要前面我们学习了数据库设计时要满
阅读更多...
从入门到精通C++11 ＜chrono＞ 库特性

从入门到精通C++11 ＜chrono＞ 库特性

《从入门到精通C++11＜chrono＞库特性》chrono库是C++11中一个非常强大和实用的库,它为时间处理提供了丰富的功能和类型安全的接口,通过本文的介绍,我们了解了chrono库的基本概念... 目录一、引言1.1 为什么需要<chrono>库1.2<chrono>库的基本概念二、时间段（Durat
阅读更多...
解析C++11 static_assert及与Boost库的关联从入门到精通

解析C++11 static_assert及与Boost库的关联从入门到精通

《解析C++11static_assert及与Boost库的关联从入门到精通》static_assert是C++中强大的编译时验证工具,它能够在编译阶段拦截不符合预期的类型或值,增强代码的健壮性,通... 目录一、背景知识：传统断言方法的局限性1.1 assert宏1.2 #error指令1.3 第三方解决
阅读更多...
从入门到精通MySQL 数据库索引(实战案例)

从入门到精通MySQL 数据库索引(实战案例)

《从入门到精通MySQL数据库索引(实战案例)》索引是数据库的目录,提升查询速度,主要类型包括BTree、Hash、全文、空间索引,需根据场景选择,建议用于高频查询、关联字段、排序等,避免重复率高或... 目录一、索引是什么？能干嘛？核心作用：二、索引的 4 种主要类型（附通俗例子）1. BTree 索引（
阅读更多...
Redis 配置文件使用建议redis.conf 从入门到实战

Redis 配置文件使用建议redis.conf 从入门到实战

《Redis配置文件使用建议redis.conf从入门到实战》Redis配置方式包括配置文件、命令行参数、运行时CONFIG命令,支持动态修改参数及持久化,常用项涉及端口、绑定、内存策略等,版本8... 目录一、Redis.conf 是什么？二、命令行方式传参（适用于测试）三、运行时动态修改配置（不重启服务
阅读更多...
MySQL DQL从入门到精通

MySQL DQL从入门到精通

《MySQLDQL从入门到精通》通过DQL,我们可以从数据库中检索出所需的数据,进行各种复杂的数据分析和处理,本文将深入探讨MySQLDQL的各个方面,帮助你全面掌握这一重要技能,感兴趣的朋友跟随小... 目录一、DQL 基础：SELECT 语句入门二、数据过滤：WHERE 子句的使用三、结果排序：ORDE
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2