高并发之接口限流，springboot整合Resilience4j实现接口限流

添加依赖

<dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot2</artifactId><version>1.7.0</version>
</dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId>
</dependency>

这里有个坑，AOP依赖是必须的，因为Resilience4j 是依赖于 AOP 来拦截方法调用的。

application.properties

# 每秒允许的请求数（每个刷新周期内允许的请求数量）
resilience4j.ratelimiter.instances.myRateLimiter.limit-for-period=10
# 限流刷新周期，表示在多长时间内重置请求计数。
resilience4j.ratelimiter.instances.myRateLimiter.limit-refresh-period=1s
# 请求等待时间，超过该时间后请求会被拒绝
resilience4j.ratelimiter.instances.myRateLimiter.timeout-duration=1s

Controller

import com.example.testdemo.service.MyService;
import io.github.resilience4j.ratelimiter.annotation.RateLimiter;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequiredArgsConstructor
public class MyController {private final MyService myService;@GetMapping("/testRateLimiter")@RateLimiter(name = "myRateLimiter", fallbackMethod = "fallback")  // 限流public String testRateLimiter() {return myService.testRateLimiter();}// 限流降级方法public String fallback(Exception ex) {System.out.println("Rate limit exceeded! Please try again later.");return "Rate limit exceeded! Please try again later.";}}

Service

import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry;
import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;/*** @author user*/
@Service
public class MyService {public String testRateLimiter() {System.out.println("This is a rate-limited API!");return "This is a rate-limited API!";}}