位置: IT常识 - 正文

借助redis实现对IP限流(redis提供了对值进行运算的命令)

编辑:rootadmin
背景: 若依前后端分离项目(vue+springboot+springmvc+mybatis),redis。 需求: 借助redis实现对IP限流。 实现: 参考 https://blog.csdn.net/qq_33762302/article/details/116258617 代码如下: IP ... 背景:若依前后端分离项目(vue+springboot+springmvc+mybatis),redis。需求:借助redis实现对IP限流。实现:参考https://blog.csdn.net/qq_33762302/article/details/116258617代码如下:IPLimiter.java 定义注解类,将注解定义在需要分流IP的接口上 1 import java.lang.annotation.*; 2 3 @Target(ElementType.METHOD) 4 @Retention(RetentionPolicy.RUNTIME) 5 @Documented 6 public @interface IpLimiter { 7 /** 8 * 放行ip 9 */10 String[] ipAdress() default {""};11 /**12 * 单位时间限制通过请求数13 */14 long limit() default 10;15 /**16 * 单位时间,单位秒17 */18 long time() default 1;19 /**20 * 达到限流提示语21 */22 String message();23 24 /**25 * 是否锁住IP的同时锁住URI26 */27 boolean lockUri() default false;28 }

推荐整理分享借助redis实现对IP限流(redis提供了对值进行运算的命令),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:redis对外提供ip和端口,redis实现原理,使用redis可以做什么,用redis的好处,redis的使用案例,redis利用,redis提供了对值进行运算的命令,redis提供了对值进行运算的命令,内容如对您有帮助,希望把文章链接给更多的朋友!

借助redis实现对IP限流(redis提供了对值进行运算的命令)

IpLimterHandler.java 注解AOP处理。

1 import com.missionex.common.annotation.IpLimiter; 2 import com.missionex.common.core.domain.AjaxResult; 3 import com.missionex.common.utils.DateUtils; 4 import com.missionex.common.utils.SecurityUtils; 5 import com.missionex.common.utils.http.IPAddressUtils; 6 import org.aspectj.lang.ProceedingJoinPoint; 7 import org.aspectj.lang.Signature; 8 import org.aspectj.lang.annotation.Around; 9 import org.aspectj.lang.annotation.Aspect; 10 import org.aspectj.lang.reflect.MethodSignature; 11 import org.slf4j.Logger; 12 import org.slf4j.LoggerFactory; 13 import org.springframework.beans.factory.annotation.Autowired; 14 import org.springframework.core.io.ClassPathResource; 15 import org.springframework.data.redis.core.StringRedisTemplate; 16 import org.springframework.data.redis.core.script.DefaultRedisScript; 17 import org.springframework.scripting.support.ResourceScriptSource; 18 import org.springframework.stereotype.Component; 19 import org.springframework.web.context.request.RequestContextHolder; 20 import org.springframework.web.context.request.ServletRequestAttributes; 21 22 import javax.annotation.PostConstruct; 23 import javax.servlet.http.HttpServletRequest; 24 import java.util.ArrayList; 25 import java.util.List; 26 27 @Aspect 28 @Component 29 public class IpLimterHandler { 30 31 private static final Logger LOGGER = LoggerFactory.getLogger("request-limit"); 32 33 @Autowired 34 StringRedisTemplate redisTemplate; 35 36 37 /** 38 * getRedisScript 读取脚本工具类 39 * 这里设置为Long,是因为ipLimiter.lua 脚本返回的是数字类型 40 */ 41 private DefaultRedisScript<Long> getRedisScript; 42 43 @PostConstruct 44 public void init() { 45 getRedisScript = new DefaultRedisScript<>(); 46 getRedisScript.setResultType(Long.class); 47 getRedisScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("ipLimiter.lua"))); 48 LOGGER.info("IpLimterHandler[分布式限流处理器]脚本加载完成"); 49 } 50 51 /** 52 * 这个切点可以不要,因为下面的本身就是个注解 53 */ 54 // @Pointcut("@annotation(com.jincou.iplimiter.annotation.IpLimiter)") 55 // public void rateLimiter() {} 56 57 /** 58 * 如果保留上面这个切点,那么这里可以写成 59 * @Around("rateLimiter()&&@annotation(ipLimiter)") 60 */ 61 @Around("@annotation(ipLimiter)") 62 public Object around(ProceedingJoinPoint proceedingJoinPoint, IpLimiter ipLimiter) throws Throwable { 63 if (LOGGER.isDebugEnabled()) { 64 LOGGER.debug("IpLimterHandler[分布式限流处理器]开始执行限流操作"); 65 } 66 String userIp = null; 67 String requestURI = null; 68 try { 69 // 获取请求信息 70 HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); 71 requestURI = request.getRequestURI(); 72 String requestMethod = request.getMethod(); 73 String remoteAddr = request.getRemoteAddr(); 74 // 获取请求用户IP 75 userIp = IPAddressUtils.getIpAdrress(request); 76 if (userIp == null) { 77 return AjaxResult.error("运行环境存在风险"); 78 } 79 } catch (Exception e) { 80 LOGGER.error("获取request出错=>" + e.getMessage()); 81 if (userIp == null) { 82 return AjaxResult.error("运行环境存在风险"); 83 } 84 } 85 Signature signature = proceedingJoinPoint.getSignature(); 86 if (!(signature instanceof MethodSignature)) { 87 throw new IllegalArgumentException("the Annotation @IpLimter must used on method!"); 88 } 89 /** 90 * 获取注解参数 91 */ 92 // 放行模块IP 93 String[] limitIp = ipLimiter.ipAdress(); 94 int len; 95 if (limitIp != null && (len = limitIp.length) != 0) { 96 for (int i = 0; i < len; i++) { 97 if (limitIp[i].equals(userIp)) { 98 return proceedingJoinPoint.proceed(); 99 }100 }101 }102 // 限流阈值103 long limitTimes = ipLimiter.limit();104 // 限流超时时间105 long expireTime = ipLimiter.time();106 boolean lockUri = ipLimiter.lockUri();107 if (LOGGER.isDebugEnabled()) {108 LOGGER.debug("IpLimterHandler[分布式限流处理器]参数值为-limitTimes={},limitTimeout={}", limitTimes, expireTime);109 }110 // 限流提示语111 String message = ipLimiter.message();112 /**113 * 执行Lua脚本114 */115 List<String> ipList = new ArrayList();116 // 设置key值为注解中的值117 if (lockUri) {118 ipList.add(userIp+requestURI);119 } else {120 ipList.add(userIp);121 }122 /**123 * 调用脚本并执行124 */125 try {126 Object x = redisTemplate.execute(getRedisScript, ipList, expireTime+"", limitTimes+"");127 Long result = (Long) x;128 if (result == 0) {129 Long userId = null;130 try {131 userId = SecurityUtils.getLoginUser().getAppUser().getId();132 } catch (Exception e) {133 134 }135 LOGGER.info("[分布式限流处理器]限流执行结果-ip={}-接口={}-用户ID={}-result={}-time={},已被限流", userIp,requestURI == null?"未知":requestURI136 ,userId==null?"用户未登录":userId,result, DateUtils.getTime());137 // 达到限流返回给前端信息138 return AjaxResult.error(message);139 }140 if (LOGGER.isDebugEnabled()) {141 LOGGER.debug("IpLimterHandler[分布式限流处理器]限流执行结果-result={},请求[正常]响应", result);142 }143 return proceedingJoinPoint.proceed();144 } catch (Exception e) {145 LOGGER.error("限流错误",e);146 return proceedingJoinPoint.proceed();147 }148 149 }150 }

ipLimiter.lua 脚本,放在resources文件夹中。

1 -获取KEY 2 local key1 = KEYS[1] 3 4 local val = redis.call('incr', key1) 5 local ttl = redis.call('ttl', key1) 6 7 --获取ARGV内的参数并打印 8 local expire = ARGV[1] 9 local times = ARGV[2]10 11 redis.log(redis.LOG_DEBUG,tostring(times))12 redis.log(redis.LOG_DEBUG,tostring(expire))13 14 redis.log(redis.LOG_NOTICE, "incr "..key1.." "..val);15 if val == 1 then16 redis.call('expire', key1, tonumber(expire))17 else18 if ttl == -1 then19 redis.call('expire', key1, tonumber(expire))20 end21 end22 23 if val > tonumber(times) then24 return 025 end26 return 1

RedisConfig.java redis配置(该配置继承了CachingConfigurerSupport)中对写入redis的数据的序列化。

如果使用IP锁的时候,错误出现在了AOP中的使用脚本写入redis的时候(像什么Long无法转String的错误),基本是这边序列化没配好。

1    @Bean 2 @SuppressWarnings(value = { "unchecked", "rawtypes" }) 3 public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) 4 { 5 RedisTemplate<Object, Object> template = new RedisTemplate<>(); 6 template.setConnectionFactory(connectionFactory); 7 FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class); 8 // 使用StringRedisSerializer来序列化和反序列化redis的key值 9 template.setKeySerializer(new StringRedisSerializer());10 template.setValueSerializer(serializer);11 // Hash的key也采用StringRedisSerializer的序列化方式12 template.setHashKeySerializer(new StringRedisSerializer());13 template.setHashValueSerializer(serializer);14 template.afterPropertiesSet();15 return template;16 }

使用示范。

1 @PostMapping("/test")2 @IpLimiter(limit = 2, time = 5, message = "您访问过于频繁,请稍候访问",lockUri = true)3 public AjaxResult test(@RequestBody Map map){4 //代码......5 }
本文链接地址:https://www.jiuchutong.com/zhishi/304639.html 转载请保留说明!

上一篇:电脑学习网首发极简的4K迷你MPlayer的视频播放器支持win7/win10/win11/64位(网上学电脑的软件)

下一篇:python字符的获取方式(python获取字符串中汉字的个数)

  • 苹果恢复出厂设置还能找回照片吗(苹果恢复出厂设置)(苹果恢复出厂设置能清干净吗)

    苹果恢复出厂设置还能找回照片吗(苹果恢复出厂设置)(苹果恢复出厂设置能清干净吗)

  • 哔哩哔哩账号是uid吗(哔哩哔哩账号是用户名吗)

    哔哩哔哩账号是uid吗(哔哩哔哩账号是用户名吗)

  • 爱奇艺怎样关闭自动续费(爱奇艺怎样关闭弹幕)

    爱奇艺怎样关闭自动续费(爱奇艺怎样关闭弹幕)

  • 荣耀30s支持多少倍变焦呢(荣耀30s参数)

    荣耀30s支持多少倍变焦呢(荣耀30s参数)

  • 三星a70s怎么截屏(三星a7手机截图怎么截)

    三星a70s怎么截屏(三星a7手机截图怎么截)

  • 公众号能看到谁关注吗(公众号能看到谁转发了吗)

    公众号能看到谁关注吗(公众号能看到谁转发了吗)

  • 机械硬盘不定时掉盘(机械硬盘不定时发出哒哒声)

    机械硬盘不定时掉盘(机械硬盘不定时发出哒哒声)

  • ipad充一夜可以吗(ipad充了一夜没事吧)

    ipad充一夜可以吗(ipad充了一夜没事吧)

  • 淘宝发票怎么下载打印(淘宝发票怎么下载不了)

    淘宝发票怎么下载打印(淘宝发票怎么下载不了)

  • ar vr mr分别代表什么(ar.vr.mr是什么意思)

    ar vr mr分别代表什么(ar.vr.mr是什么意思)

  • oppoa8怎么关机(oppoa8怎么关机重启)

    oppoa8怎么关机(oppoa8怎么关机重启)

  • 手机怎么读取移动硬盘(手机怎么读取移动硬盘数据)

    手机怎么读取移动硬盘(手机怎么读取移动硬盘数据)

  • 苹果8pgsm和global的区别

    苹果8pgsm和global的区别

  • 苹果11通话有杂音是怎么回事(苹果11通话有杂音)

    苹果11通话有杂音是怎么回事(苹果11通话有杂音)

  • vivo蓝牙设置在哪里(vivo手机蓝牙在哪里设置)

    vivo蓝牙设置在哪里(vivo手机蓝牙在哪里设置)

  • iphonex是2k屏幕么(苹果x是2k分辨率吗)

    iphonex是2k屏幕么(苹果x是2k分辨率吗)

  • 接听电话黑屏怎么设置(接听电话黑屏怎么设置vivo)

    接听电话黑屏怎么设置(接听电话黑屏怎么设置vivo)

  • 放键盘的抽屉叫啥(键盘抽屉怎么固定)

    放键盘的抽屉叫啥(键盘抽屉怎么固定)

  • 手机里koeve是什么(手机kol是什么意思)

    手机里koeve是什么(手机kol是什么意思)

  • 百度贴吧怎么私信(百度贴吧怎么私聊别人)

    百度贴吧怎么私信(百度贴吧怎么私聊别人)

  • 打印机安装好了无法打印(打印机安装好了扫描仪需要安装吗)

    打印机安装好了无法打印(打印机安装好了扫描仪需要安装吗)

  • 二类卡能绑微信吗(微信身份证证件在哪里)

    二类卡能绑微信吗(微信身份证证件在哪里)

  • qq号手机号码换了上不去了怎么办(qq号手机号码换了怎么改)

    qq号手机号码换了上不去了怎么办(qq号手机号码换了怎么改)

  • 手机3gb和4gb有什么区别(4g手机和3g手机的区别在哪)

    手机3gb和4gb有什么区别(4g手机和3g手机的区别在哪)

  • XMAPP在php中搭建环境(使用xampp建立www服务)

    XMAPP在php中搭建环境(使用xampp建立www服务)

  • 应纳税所得额是利润总额吗
  • 注册资本认缴到哪里
  • 三方合同怎么盖章
  • 跨年度冲红的账务处理
  • 个人所得税怎么算公式是什么
  • 红字发票可以开部分金额吗
  • 小规模应交的增值税
  • 欠员工薪酬如何赔偿
  • 非居民企业所得税核定利润率
  • 代扣代缴个人所得税手续费是否缴纳增值税
  • 土地流转承包费拖欠
  • 税控盘抵税账务处理
  • 没有核定税种怎么报税
  • 金税三期有什么功能
  • 一般纳税人的主表
  • 双薪如何扣税
  • 加速折旧税收优惠
  • 高新技术企业软著数量
  • 怎么区分进和近
  • 库存商品怎么结转损益
  • 代征税款手续费规定
  • 总资产净利率计算
  • 待处理财产损益科目编码
  • 审计费可以抵扣进项吗
  • 木制手链品种
  • 购置土地税款怎么入账?
  • 收到投资的会计科目
  • 关于工程施工的文章
  • 合同付款会计分录
  • 电脑删文件需要授权
  • win7为什么现在不能用了
  • 冲销应收账款怎么记账
  • 其它权益工具投资处置时其他综合收益转那
  • 事业单位收到租金收入
  • 原材料盘亏计入
  • win11预览版更新界面
  • 电脑找不到ie浏览器
  • 在php中,字符串有哪些表示形式
  • 购买股票会计处理流程
  • 应纳税所得额的意思
  • 今天是520该说什么
  • php 时间
  • get请求与post
  • vue中的组件
  • 其他综合收益转入盈余公积和未分配利润
  • 在税务局怎么查补缴的社保
  • 固定资产折旧如何进行会计处理
  • 非货币性资产交换准则
  • 运输费用会计
  • 一般纳税人接受捐赠的固定资产,捐赠方提供了有关凭证
  • 在建工程如何转固
  • 个人劳务报酬的个税
  • 收到政府补贴如何入账
  • 商业汇票的会计核算
  • 企业取得生产或制造某项财产物资时
  • 股权过户费用
  • 转账支票的密码需要填写吗
  • 实务操作中如何快速记忆
  • 明细分类账如何填写
  • mysql查询语句大全讲解
  • MySQL 5.6 中 TIMESTAMP有那些变化
  • windows10访问xp
  • linux www服务器配置
  • 运行ghost
  • win8.1如何更改开始菜单
  • mini programes
  • onekey.exe是什么
  • 新版电脑装win7
  • Node.js中的什么模块是用于处理文件和目录的
  • android 生成图片
  • 你知道python不
  • list嵌套list采用什么结构
  • javascript教学视频
  • javascript设置字体
  • 北京社保退保手续办理
  • 江苏宿迁个体户那个园区好
  • 外贸公司如何开发客户
  • 税务社保费是什么意思
  • 火车报销凭证丢了还能退款吗
  • 美国企业所得税税率2022
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设