基于redis实现的限流SpringBootStarter.zip

package com.ypp.ratelimit.starter.chain.impl; import cn.hutool.core.util.ObjectUtil; import com.ypp.ratelimit.starter.RateLimitProperties; import com.ypp.ratelimit.starter.blacklist.BlackListRecordHandler; import com.ypp.ratelimit.starter.chain.RateLimitHandlerChain; import com.ypp.ratelimit.starter.constant.LimitPrefixKey; import com.ypp.ratelimit.starter.limiter.BaseRateLimitProperties; import com.ypp.ratelimit.starter.limiter.counter.CounterRateLimitProperties; import com.ypp.ratelimit.starter.limiter.counter.CounterRateLimiter; import com.ypp.ratelimit.starter.limiter.slidingwindow.SlidingWindowRateLimitProperties; import com.ypp.ratelimit.starter.limiter.slidingwindow.SlidingWindowRateLimiter; import com.ypp.ratelimit.starter.limiter.tokenbucket.TokenBucketRateLimitProperties; import com.ypp.ratelimit.starter.limiter.tokenbucket.TokenBucketRateLimiter; import com.ypp.util.string.StringUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Scope; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; import java.util.ArrayList; import java.util.List; import java.util.concurrent.TimeUnit; /** * @author ypp * @date 2022-06-23 14:00 **/ @Slf4j @Component @Scope("prototype") public class DefaultRateLimitHandlerChain implements RateLimitHandlerChain, InitializingBean { private List<BaseRateLimitProperties> rateLimitPropertiesList; @Autowired private CounterRateLimiter counterRateLimiter; @Autowired private SlidingWindowRateLimiter slidingWindowRateLimiter; @Autowired private TokenBucketRateLimiter tokenBucketRateLimiter; @Autowired private RateLimitProperties rateLimitProperties; @Autowired private BlackListRecordHandler blackListRecordHandler; @Override public void afterPropertiesSet() throws Exception { rateLimitPropertiesList = new ArrayList<>(); } @Override public RateLimitHandlerChain add(BaseRateLimitProperties rateLimitProperties) { rateLimitPropertiesList.add(rateLimitProperties); return this; } @Override public RateLimitHandlerChain addAll(List<BaseRateLimitProperties> rateLimitPropertiesList) { this.rateLimitPropertiesList.addAll(rateLimitPropertiesList); return this; } @Override public boolean handle() { if (CollectionUtils.isEmpty(rateLimitPropertiesList)) { return true; } boolean acquire = false; for (BaseRateLimitProperties rateLimitProperties : rateLimitPropertiesList) { if (rateLimitProperties instanceof CounterRateLimitProperties) { acquire = handle((CounterRateLimitProperties) rateLimitProperties); } else if (rateLimitProperties instanceof SlidingWindowRateLimitProperties) { acquire = handle((SlidingWindowRateLimitProperties) rateLimitProperties); } else if (rateLimitProperties instanceof TokenBucketRateLimitProperties) { acquire = handle((TokenBucketRateLimitProperties) rateLimitProperties); } if (!acquire) { return false; } } return true; } private boolean handle(CounterRateLimitProperties counterRateLimitProperties) { boolean acquire = counterRateLimiter.tryAcquire(counterRateLimitProperties.getKey(), counterRateLimitProperties.getCount(), counterRateLimitProperties.getTime(), TimeUnit.valueOf(counterRateLimitProperties.getTimeUnit())); logLimit(acquire, counterRateLimitProperties.getPrefixKey(), counterRateLimitProperties.getKey()); return acquire; } private boolean handle(SlidingWindowRateLimitProperties slidingWindowRateLimitProperties) { boolean acquire = slidingWindowRateLimiter.tryAcquire(slidingWindowRateLimitProperties.getKey(), slidingWindowRateLimitProperties.getCount(), slidingWindowRateLimitProperties.getTime(), TimeUnit.valueOf(slidingWindowRateLimitProperties.getTimeUnit())); logLimit(acquire, slidingWindowRateLimitProperties.getPrefixKey(), slidingWindowRateLimitProperties.getKey()); return acquire; } private boolean handle(TokenBucketRateLimitProperties tokenBucketRateLimitProperties) { boolean acquire = tokenBucketRateLimiter.tryAcquire(tokenBucketRateLimitProperties.getKey(), tokenBucketRateLimitProperties.getRate(), tokenBucketRateLimitProperties.getCapacity()); logLimit(acquire, tokenBucketRateLimitProperties.getPrefixKey(), tokenBucketRateLimitProperties.getKey()); return acquire; } private void logLimit(boolean acquire, String prefixKey, String key) { if (!acquire) { if (ObjectUtil.equals(prefixKey, LimitPrefixKey.IP.getPrefixKey())) { log.debug("IP限流：{}", key); // IP限流 if (rateLimitProperties.getRecordIpLimit()) { blackListRecordHandler.record(LimitPrefixKey.IP, key.substring(0, key.indexOf(StringUtils.SPE2))); } } else if (ObjectUtil.equals(prefixKey, LimitPrefixKey.USER_ID.getPrefixKey())) { log.debug("用户限流：{}", key); // 用户限流 if (rateLimitProperties.getRecordUserIdLimit()) { blackListRecordHandler.record(LimitPrefixKey.USER_ID, key.substring(0, key.indexOf(StringUtils.SPE2))); } } else if (ObjectUtil.equals(prefixKey, LimitPrefixKey.TOTAL.getPrefixKey())) { log.debug("总限流：{}", key); } } } }