springboot限流实现的方式有哪些

在Spring Boot中，可以使用以下几种方式来实现限流：

1. 基于注解的限流：可以使用自定义的注解，在接口方法上添加注解来限制访问频率。通过在方法上添加注解，可以设置允许的最大访问次数、时间窗口等参数。 示例代码：

@RateLimit(max = 100, duration = 60)
@GetMapping("/api/someEndpoint")
public String someEndpoint() {
    // 方法逻辑
}

2. 基于拦截器的限流：可以创建一个拦截器，在拦截器中对接口进行限流控制。拦截器可以在请求进入控制器之前或之后执行相应的逻辑。 示例代码：

@Component
public class RateLimitInterceptor implements HandlerInterceptor {

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 判断访问次数是否超过限制
        if (isRateLimited(request)) {
            response.setStatus(HttpStatus.TOO_MANY_REQUESTS.value());
            response.getWriter().write("Rate limit exceeded");
            return false;
        }
        return true;
    }

    private boolean isRateLimited(HttpServletRequest request) {
        // 判断访问次数是否超过限制的逻辑
    }
}

在Spring Boot中注册拦截器：

@Configuration
public class WebConfig implements WebMvcConfigurer {

    @Autowired
    private RateLimitInterceptor rateLimitInterceptor;

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(rateLimitInterceptor);
    }
}

3. 基于缓存的限流：可以使用缓存来记录每个接口的访问次数和时间。在每次请求到达时，检查缓存中的计数器，如果超过了限制，则拒绝请求。 示例代码：

@Component
public class RateLimitService {

    private final Cache<String, AtomicInteger> cache;

    public RateLimitService() {
        cache = CacheBuilder.newBuilder()
                .maximumSize(100)
                .expireAfterWrite(1, TimeUnit.MINUTES)
                .build();
    }

    public boolean isRateLimited(String key, int max, long duration) {
        AtomicInteger counter = cache.get(key, () -> new AtomicInteger(0));
        int count = counter.incrementAndGet();
        if (count > max) {
            return true;
        }
        return false;
    }
}

在控制器中使用RateLimitService限流：

@RestController
public class SomeController {

    @Autowired
    private RateLimitService rateLimitService;

    @GetMapping("/api/someEndpoint")
    public String someEndpoint(HttpServletRequest request) {
        String key = request.getRemoteAddr();
        if (rateLimitService.isRateLimited(key, 100, 60)) {
            return "Rate limit exceeded";
        }
        // 方法逻辑
    }
}

这些是Spring Boot中实现限流的几种方式，你可以根据具体需求选择适合的方式来实现限流功能。