图解resilience4j容错机制在哪里

Resilience4j是一个轻量级、易于使用的容错库，其灵感来自Netflix Hystrix，但专为Java 8和函数式编程设计。轻量级，因为库只使用Vavr，它没有任何其他外部库依赖项。相比之下，Netflix Hystrix对Archaius有一个编译依赖关系，Archaius有更多的外部库依赖关系，如Guava和Apache Commons。

Resilience4j提供高阶函数（decorators）来增强任何功能接口、lambda表达式或方法引用，包括断路器、速率限制器、重试或舱壁。可以在任何函数接口、lambda表达式或方法引用上使用多个装饰器。优点是您可以选择所需的装饰器，而无需其他任何东西。

有了Resilience4j，你不必全力以赴，你可以选择你需要的。

https://resilience4j.readme.io/docs/getting-started

概览

本文将介绍resilience4j中的四种容错机制，不过鉴于容错机制原理的通用性，后文所介绍的这几种容错机制也可以脱离resilience4j而独立存在（你完全可以自己编码实现它们或者采用其他类似的第三方库，如Netflix Hystrix）。下面将会用图例来解释舱壁（Bulkhead）、断路器（CircuitBreaker）、限速器（RateLimiter）、重试（Retry）机制的概念和原理。

舱壁（Bulkhead）

Resilience4j提供了两种舱壁模式的实现，可用于限制并发执行的次数：

SemaphoreBulkhead（信号量舱壁，默认），基于Java并发库中的Semaphore实现。

FixedThreadPoolBulkhead（固定线程池舱壁），它使用一个有界队列和一个固定线程池。

SemaphoreBulkhead应该在各种线程和I / O模型上都能很好地工作。它基于信号量，与Hystrix不同，它不提供“影子”线程池选项。取决于客户端，以确保正确的线程池大小将与舱壁配置保持一致。

信号量舱壁（SemaphoreBulkhead）

img

👆原图地址：信号量舱壁（SemaphoreBulkhead）

如上图，当信号量存在剩余时进入系统的请求会直接获取信号量并开始业务处理。当信号量全被占用时，接下来的请求将会进入阻塞状态，SemaphoreBulkhead提供了一个阻塞计时器，如果阻塞状态的请求在阻塞计时内无法获取到信号量则系统会拒绝这些请求。若请求在阻塞计时内获取到了信号量，那将直接获取信号量并执行相应的业务处理。

固定线程池舱壁（FixedThreadPoolBulkhead）