职教集团网站建设,网站开发前端就业前景,佛山网站建设兼职,丽江市住房建设局网站令牌桶算法属于流量控制算法#xff0c;在一定时间内保证一个键#xff08;key#xff09;的访问量不超过某个阈值。这里的关键是设置一个令牌桶#xff0c;在某个时间段内生成一定数量的令牌#xff0c;然后每次访问时从桶中获取令牌#xff0c;如果桶中没有令牌#x…令牌桶算法属于流量控制算法在一定时间内保证一个键key的访问量不超过某个阈值。这里的关键是设置一个令牌桶在某个时间段内生成一定数量的令牌然后每次访问时从桶中获取令牌如果桶中没有令牌就拒绝访问。 参考网上一个博主写的https://blog.csdn.net/xdx_dili/article/details/133683315 注意我这边只是学习实践加上修改对应的代码记录下而已
第一步记得要下载redis并配置好
第二步创建springboot项目并引入maven配置好配置文件 注意我这边使用的springboot版本是2.6.x因为2.7开始博主的部分代码不可用了
dependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-aop/artifactId/dependencydependencygroupIdcom.google.guava/groupIdartifactIdguava/artifactIdversion21.0/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactId/dependencydependencygroupIdorg.apache.commons/groupIdartifactIdcommons-lang3/artifactId/dependencydependencygroupIdcom.alibaba/groupIdartifactIdfastjson/artifactIdversion1.2.78/version/dependency
/dependencies#application.properties
#redis
spring.redis.host127.0.0.1
spring.redis.port6379server.port8081第三步代码部分
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;import java.io.Serializable;/*** RedisTemplate调用实例*/
Configuration
public class RedisLimiterHelper {//spring会帮助我们注入LettuceConnectionFactoryBeanpublic RedisTemplateString, Serializable limitRedisTemplate(LettuceConnectionFactory redisConnectionFactory) {RedisTemplateString, Serializable template new RedisTemplate();template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer());template.setConnectionFactory(redisConnectionFactory);return template;}
}/*** 限流类型枚举类*/
public enum LimitType {/*** 自定义key*/CUSTOMER,/*** 请求者IP*/IP;
}import java.lang.annotation.*;/*** 自定义限流注解*/
//Target({ElementType.METHOD, ElementType.TYPE}) 表示这个注解可以应用到方法和类上。
//ElementType.METHOD 表示这个注解可以应用到方法上即可以在方法上添加这个注解。
//ElementType.TYPE 表示这个注解可以应用到类上即可以在类上添加这个注解。
//Retention(RetentionPolicy.RUNTIME) 表示这个注解的元数据信息metadata在运行时可用。
//Inherited 表示这个注解可以被继承。
//Documented 表示这个注解的文档信息documentation会被自动生成
Target({ElementType.METHOD, ElementType.TYPE})
Retention(RetentionPolicy.RUNTIME)
Inherited
Documented
public interface RedisLimit {/*** 名字*/String name() default ;/*** key*/String key() default ;/*** Key的前缀*/String prefix() default ;/*** 给定的时间范围 单位(秒)*/int period();/*** 一定时间内最多访问次数*/int count();/*** 限流的类型(用户自定义key 或者 请求ip)*/LimitType limitType() default LimitType.CUSTOMER;}import org.apache.commons.lang3.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.data.redis.core.script.RedisScript;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;import javax.servlet.http.HttpServletRequest;
import java.io.Serializable;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.List;/*** 限流切面实现*/
Aspect
Configuration
public class LimitInterceptor {private static final Logger logger LoggerFactory.getLogger(LimitInterceptor.class);private static final String UNKNOWN unknown;private final RedisTemplateString, Serializable limitRedisTemplate;Autowiredpublic LimitInterceptor(RedisTemplateString, Serializable limitRedisTemplate) {this.limitRedisTemplate limitRedisTemplate;}//切面使用了该RedisLimit注解时触发Around(execution(public * *(..)) annotation(com.zhangximing.redis_springboot.annotate.RedisLimit))public Object interceptor(ProceedingJoinPoint pjp) {MethodSignature signature (MethodSignature) pjp.getSignature();Method method signature.getMethod();RedisLimit limitAnnotation method.getAnnotation(RedisLimit.class);LimitType limitType limitAnnotation.limitType();String key;int limitPeriod limitAnnotation.period();int limitCount limitAnnotation.count();/*** 根据限流类型获取不同的key ,如果不传我们会以方法名作为key*/switch (limitType) {case IP:key getIpAddress();break;case CUSTOMER:key limitAnnotation.key();break;default:key StringUtils.upperCase(method.getName());}ListString keys Arrays.asList(StringUtils.join(limitAnnotation.prefix(), key));try {//lua脚本String luaScript buildLuaScript();//获取已调用数量RedisScriptLong redisScript new DefaultRedisScript(luaScript, Long.class);Long count limitRedisTemplate.execute(redisScript, keys, limitCount, limitPeriod);//判断是否已超过限制if (count ! null count limitCount) {return pjp.proceed();} else {throw new RuntimeException(服务忙请稍后再试);}} catch (Throwable e) {if (e instanceof RuntimeException) {
// throw new RuntimeException(e.getLocalizedMessage());return e.getLocalizedMessage();}
// throw new RuntimeException(server exception);return 服务异常;}}//编写 redis Lua 限流脚本public String buildLuaScript() {StringBuilder lua new StringBuilder();lua.append(local c);//KEYS[1]表示keylua.append(\nc redis.call(get,KEYS[1]));// 调用不超过最大值则直接返回 ARGV[1]表示第一个参数lua.append(\nif c and tonumber(c) tonumber(ARGV[1]) then);lua.append(\nreturn c;);lua.append(\nend);// 执行计算器自加lua.append(\nc redis.call(incr,KEYS[1]));lua.append(\nif tonumber(c) 1 then);// 从第一次调用开始限流设置对应键值的过期lua.append(\nredis.call(expire,KEYS[1],ARGV[2]));lua.append(\nend);lua.append(\nreturn c;);return lua.toString();}//获取id地址public String getIpAddress() {HttpServletRequest request ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();String ip request.getHeader(x-forwarded-for);if (ip null || ip.length() 0 || UNKNOWN.equalsIgnoreCase(ip)) {ip request.getHeader(Proxy-Client-IP);}if (ip null || ip.length() 0 || UNKNOWN.equalsIgnoreCase(ip)) {ip request.getHeader(WL-Proxy-Client-IP);}if (ip null || ip.length() 0 || UNKNOWN.equalsIgnoreCase(ip)) {ip request.getRemoteAddr();}return ip;}
}import com.zhangximing.redis_springboot.annotate.LimitType;
import com.zhangximing.redis_springboot.annotate.RedisLimit;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.atomic.AtomicInteger;/*** Author: zhangximing* Email: 530659058qq.com* Date: 2023/12/20 10:59* Description: 限流测试类 参考 https://blog.csdn.net/xdx_dili/article/details/133683315*/
RestController
RequestMapping(/limit)
public class LimitController {private static final AtomicInteger ATOMIC_INTEGER_1 new AtomicInteger();//十秒同一IP限制访问5次RedisLimit(period 10, count 5, name 测试接口, limitType LimitType.IP)RequestMapping(/test)public String testLimit(){return SUCCESSATOMIC_INTEGER_1.incrementAndGet();}}效果展示
