SpringBoot整合resilience4j实现接口限流

 <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>

resilience4j: # resilience4j的配置开始，用于增加服务弹性的库
  ratelimiter: #限流机制的配置，用于防止过多的请求涌入系统
    instances:
      ratelimitApi: # 第一个限流策略实例的名称
        limit-for-period: 5 # 在一个特定的时间周期内，允许的最大请求数量为5
        limit-refresh-period: 1s # 时间周期长度为1s，即每秒会重置请求计数
        timeout-duration: 100ms # 当请求超过限制时，客户端应立即收到超时的响应，而不等待处理

@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<>("您请求过于频繁，稍后再试",HttpStatus.OK);
    }
}

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();
        }
    }
}