最近在開發(fā)項(xiàng)目的時(shí)候，需要用到限流的功能，搜索資料發(fā)現(xiàn)，最近resilience4j這個(gè)框架還是挺火的，使用了一下還是挺簡單實(shí)用的。這篇博客主要是SpringBoot簡單整合resilience4j框架實(shí)現(xiàn)接口限流功能。

Resilience4j是一個(gè)用于增強(qiáng)容錯(cuò)能力的Java庫，旨在幫助開發(fā)人員構(gòu)建可靠的分布式系統(tǒng)。它基于斷路器模式和其他容錯(cuò)模式，提供了一組輕量級(jí)的、可組合的容錯(cuò)模塊，如斷路器、限流器、重試等。其原理如下：

• 斷路器模式：Resilience4j主要基于斷路器模式，當(dāng)被保護(hù)的服務(wù)或資源發(fā)生故障或長時(shí)間不可用時(shí)，斷路器會(huì)打開，從而避免對(duì)該服務(wù)的連續(xù)請(qǐng)求，減輕了服務(wù)的負(fù)載，快速失敗，同時(shí)能夠提供降級(jí)或備用方案。
• 限流器模式：Resilience4j提供了限流器模式來控制請(qǐng)求的流量。限流器可以被配置為每秒鐘、每分鐘或每小時(shí)允許的最大請(qǐng)求數(shù)。當(dāng)請(qǐng)求數(shù)超出限制時(shí)，可以選擇拒絕請(qǐng)求、返回錯(cuò)誤信息或放入隊(duì)列等處理方式。
• 重試機(jī)制：Resilience4j提供了靈活的重試機(jī)制，可以在服務(wù)調(diào)用失敗時(shí)自動(dòng)重試，減少因臨時(shí)故障造成的服務(wù)不可用時(shí)間?？梢耘渲弥卦嚨拇螖?shù)、重試的間隔等參數(shù)，還可以根據(jù)不同的異常類型進(jìn)行針對(duì)性的重試。
• 異步支持：Resilience4j支持異步操作，可以在異步任務(wù)中使用各種容錯(cuò)模塊。可以使用CompletableFuture、RxJava或Java 8的CompletionStage進(jìn)行異步編程。
• 配置靈活：Resilience4j提供了靈活的配置選項(xiàng)，可以根據(jù)具體的需求對(duì)每個(gè)容錯(cuò)模塊進(jìn)行個(gè)性化配置?？梢酝ㄟ^代碼或者配置文件進(jìn)行配置，也可以使用注解來標(biāo)記需要增加容錯(cuò)功能的方法。

總之，Resilience4j利用斷路器模式、限流器模式、重試機(jī)制等容錯(cuò)模式，結(jié)合靈活的配置選項(xiàng)和異步支持，幫助開發(fā)人員構(gòu)建可靠、彈性的分布式系統(tǒng)。

這里Resilience4j只簡單實(shí)現(xiàn)接口限流功能。

版本說明

• SpringBoot 2.5.15版本
• JDK8

代碼開發(fā)整合

引入Jar

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

  <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-aop</artifactId>
  </dependency>

引入Jar包特別要注意版本，我的SpringBoot版本是2.5.15，所以我的resilience4j使用的是spring-boot2版本，且resilience4j-spring-boot2必須不能高于1.7.1，不然不兼容。

第二還要注意引入spring-boot-starter-aop，不然resilience4j不能起作用，畢竟它是通過AOP來實(shí)現(xiàn)功能的。

application配置

resilience4j: # resilience4j的配置開始，用于增加服務(wù)彈性的庫
  ratelimiter: #限流機(jī)制的配置，用于防止過多的請(qǐng)求涌入系統(tǒng)
    instances:
      ratelimitApi: # 第一個(gè)限流策略實(shí)例的名稱
        limit-for-period: 5 # 在一個(gè)特定的時(shí)間周期內(nèi)，允許的最大請(qǐng)求數(shù)量為5
        limit-refresh-period: 1s # 時(shí)間周期長度為1s，即每秒會(huì)重置請(qǐng)求計(jì)數(shù)
        timeout-duration: 100ms # 當(dāng)請(qǐng)求超過限制時(shí)，客戶端應(yīng)立即收到超時(shí)的響應(yīng)，而不等待處理

控制器實(shí)現(xiàn)

@RestController
@Slf4j
public class Resilience4jController {

    @GetMapping("ratelimit")
    @RateLimiter(name="ratelimitApi",fallbackMethod = "fallback")
    public ResponseEntity<String> ratelimitApi(){
        log.info("request ratelimitApi");
        return new ResponseEntity<>("success",HttpStatus.OK);
    }

    public ResponseEntity fallback(Throwable e){
        log.error("fallback exception , {}",e.getMessage());
        return new ResponseEntity<>("您請(qǐng)求過于頻繁，稍后再試",HttpStatus.OK);
    }
}

ratelimitApi是在application.yml中配置的名稱，從這里也可以知道，不同的接口可以使用不同的限流策略，fallbackMethod是指當(dāng)出現(xiàn)異常的時(shí)候調(diào)用的方法，即為降級(jí)服務(wù)方法。

多線程測(cè)試

import org.springframework.web.client.RestTemplate;

public class ThreadTest {
    public static void main(String[] args) {
        for(int i=0;i<5;i++){
            new Thread(()->{
                System.out.println(new RestTemplate().getForObject("http://localhost:8080/ratelimit",String.class));
            }).start();
        }
    }
}

限流設(shè)定是每秒只能處理5個(gè)請(qǐng)求，所以我這邊用5個(gè)線程的時(shí)候，都是正常的

success
success
success
success
success

之后我調(diào)整為6個(gè)線程

success
success
success
success
success
您請(qǐng)求過于頻繁，稍后再試

最后一個(gè)線程無法正常請(qǐng)求，實(shí)現(xiàn)效果。

Resilience4j還有其他強(qiáng)大的功能，等我慢慢研究一下。

到此這篇關(guān)于SpringBoot整合resilience4j實(shí)現(xiàn)接口限流的文章就介紹到這了,更多相關(guān)SpringBoot resilience4j接口限流內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論