SpringBoot+Resilience4j实现接口限流的示例代码

<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-spring-boot2</artifactId>
    <version>1.7.1</version> <!-- 请根据需要选择合适的版本 -->
</dependency>

resilience4j:
  rate-limiter:
    instances:
      myRateLimiter:
        limitForPeriod: 10       # 每 1 秒允许的请求数
        limitForBurst: 5         # 突发请求允许的最大数量
        limitRefreshPeriod: 1s    # 限制刷新周期

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("/limited")
    public String limitedEndpoint() {
        return myService.limitedMethod();
    }
}

import io.github.resilience4j.ratelimiter.RequestNotPermitted;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;

@ControllerAdvice
public class GlobalExceptionHandler {

    @ExceptionHandler(RequestNotPermitted.class)
    public ResponseEntity<String> handleRequestNotPermitted(RequestNotPermitted ex) {
        return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS)
                             .body("Request limit exceeded, please try again later.");
    }
}