import com.google.common.util.concurrent.RateLimiter;

@Service
public class MyService {

    private final RateLimiter rateLimiter = RateLimiter.create(10.0); // 每秒允許10個請求

    public void doSomething() {
        if (rateLimiter.tryAcquire()) {
            // 執(zhí)行業(yè)務(wù)邏輯
        } else {
            // 請求被拒絕，可以返回錯誤信息或進行其他處理
        }
    }
}

// 自定義限流注解
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface RateLimit {
    double permitsPerSecond() default 1.0; // 每秒允許通過的請求數(shù)
}

// 使用AspectJ實現(xiàn)切面
@Aspect
@Component
public class RateLimitAspect {

    @Autowired
    private Map<String, RateLimiter> rateLimiterMap; // 假設(shè)這里有一個RateLimiter的Map，用于存儲不同接口的RateLimiter

    @Around("@annotation(rateLimit)")
    public Object around(ProceedingJoinPoint joinPoint, RateLimit rateLimit) throws Throwable {
        String key = joinPoint.getSignature().toShortString(); // 根據(jù)方法簽名生成key
        RateLimiter rateLimiter = rateLimiterMap.getOrDefault(key, RateLimiter.create(rateLimit.permitsPerSecond()));
        if (rateLimiter.tryAcquire()) {
            return joinPoint.proceed(); // 執(zhí)行原方法
        } else {
            // 請求被拒絕，可以拋出異?；蚍祷劐e誤信息
            throw new RuntimeException("Too many requests, please try again later.");
        }
    }
}

import com.alibaba.csp.sentinel.annotation.SentinelResource;

@Service
public class MyService {

    @SentinelResource(value = "doSomething", blockHandler = "blockHandler")
    public void doSomething() {
        // 執(zhí)行業(yè)務(wù)邏輯
    }

    public void blockHandler(BlockException ex) {
        // 處理被限流的請求
    }
}