下面是详细讲解：

Spring 项目实现限流方法示例

什么是限流

限流是指在一段时间内限制系统的访问量或并发量，从而保证系统的稳定性和安全性。

为什么要进行限流

在高并发的情况下，系统容易出现请求过多的情况，导致系统瘫痪。而进行限流可以避免这种情况的发生。另外，进行限流也可以防止恶意用户攻击。

限流的实现方式

在 Spring 项目中，可以使用 AOP 技术和注解来实现限流。

通过 AOP 技术实现限流

1. 首先，需要定义一个限流注解。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface RateLimiter {

    double count();

    long time();

}

count() 方法表示在 time() 时间内允许的请求次数。

1. 使用 AOP 技术，在 RateLimiterAspect 中实现限流逻辑。

@Aspect
@Component
public class RateLimiterAspect {

    private static final Map<String, RateLimiter> LIMITER_MAP = new ConcurrentHashMap<>();

    @Around("execution(* com.example.demo.controller.*.*(..)) && @annotation(rateLimiter)")
    public Object limit(ProceedingJoinPoint joinPoint, RateLimiter rateLimiter) throws Throwable {
        String key = String.format("%s_%d_%f", joinPoint.getSignature(), rateLimiter.time(), rateLimiter.count());
        if (!LIMITER_MAP.containsKey(key)) {
            synchronized (RateLimiterAspect.class) {
                if (!LIMITER_MAP.containsKey(key)) {
                    RateLimiter limiter = RateLimiter.create(rateLimiter.count(), rateLimiter.time(), TimeUnit.SECONDS);
                    LIMITER_MAP.put(key, limiter);
                }
            }
        }
        RateLimiter limiter = LIMITER_MAP.get(key);
        if (limiter.tryAcquire()) {
            return joinPoint.proceed();
        } else {
            throw new RuntimeException("too many requests");
        }
    }

}

以上代码中，我们使用了 Guava 的 RateLimiter 来实现限流。

通过注解实现限流

1. 定义一个限流注解。

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Limit {

    double count();

    long time();

}

count() 方法表示在 time() 时间内允许的请求次数。

1. 编写 LimitInterceptor 拦截器实现限流逻辑。

@Component
public class LimitInterceptor extends HandlerInterceptorAdapter {

    private static final Map<String, RateLimiter> LIMITER_MAP = new ConcurrentHashMap<>();

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        if (handler instanceof HandlerMethod) {
            HandlerMethod handlerMethod = (HandlerMethod) handler;
            Limit limit = handlerMethod.getMethodAnnotation(Limit.class);
            if (limit != null) {
                String key = String.format("%s_%d_%f", request.getRequestURI(),
                        limit.time(), limit.count());
                if (!LIMITER_MAP.containsKey(key)) {
                    synchronized (LimitInterceptor.class) {
                        if (!LIMITER_MAP.containsKey(key)) {
                            RateLimiter limiter = RateLimiter.create(limit.count(),
                                    limit.time(), TimeUnit.SECONDS);
                            LIMITER_MAP.put(key, limiter);
                        }
                    }
                }
                RateLimiter limiter = LIMITER_MAP.get(key);
                if (!limiter.tryAcquire()) {
                    throw new RuntimeException("too many requests");
                }
            }
        }
        return super.preHandle(request, response, handler);
    }

}

以上代码中，我们使用了 Guava 的 RateLimiter 来实现限流。

如何使用限流注解

在需要限流的地方，使用 @RateLimiter 或 @Limit 注解即可。

例如：

@RestController
public class DemoController {

    @GetMapping("/hello")
    @RateLimiter(count = 5, time = 60)
    public String hello() {
        return "hello";
    }

}

以上代码中，我们对 /hello 接口进行了限流，限制在 60 秒内最多只能请求 5 次。

另外，可以使用 @ControllerAdvice 和 @ExceptionHandler 注解来捕获限流异常，并进行处理以返回友好的提示信息。

以上就是 Spring 项目实现限流方法的示例说明。