java 一个注解实现限流

news2024/12/25 13:01:12

在Java中，可以使用自定义注解来实现限流功能。

```java
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface RateLimit {
int value() default 1;
}
```

上面的代码定义了一个名为`RateLimit`的注解，通过给方法添加这个注解，可以限制方法的访问频率。

然后，创建一个切面类来拦截被`RateLimit`注解标注的方法：

```java
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;

@Aspect
public class RateLimitAspect {

private ConcurrentHashMap<String, Integer> counterMap = new ConcurrentHashMap<>();

@Around("@annotation(rateLimitAnnotation)")
public Object rateLimit(ProceedingJoinPoint joinPoint, RateLimit rateLimitAnnotation) throws Throwable {
String methodName = joinPoint.getSignature().getName();

// 检查方法名对应的计数器是否存在
counterMap.putIfAbsent(methodName, 0);

int counter = counterMap.get(methodName);
int limit = rateLimitAnnotation.value();

if (counter >= limit) {
throw new RuntimeException("Rate limit exceeded");
}

// 执行目标方法
Object result = joinPoint.proceed();

// 计数器加1
counterMap.put(methodName, counter + 1);

return result;
}
}
```

`RateLimitAspect`类是一个切面类，通过`@Around`注解实现对被`RateLimit`注解标注的方法的拦截。

最后，使用这个注解和切面示例：

```java
public class Main {
@RateLimit(5) // 每秒限制调用次数为5次
public void doSomething() {
System.out.println("Doing something...");
}

public static void main(String[] args) {
// 创建切面
RateLimitAspect aspect = new RateLimitAspect();

// 创建代理对象
Main mainObj = (Main) aspect.aspectOf(Main.class);

// 调用被限流的方法
for (int i = 0; i < 10; i++) {
try {
mainObj.doSomething();
} catch (RuntimeException e) {
System.out.println("Rate limit exceeded");
}

// 每次调用后暂停一秒钟
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
```