目录
- 优化
- 思考
- 总结
说明:之前写过一篇使用Redis接口访问的博客,如下。最近有相关需求,把代码拿出来后,做了一些优化,挺有意思的,本文介绍在原基础上
使用Redis实现接口防抖
优化
总的来说,这次使用Redis实现接口防抖,增加了一个时间段参数,可以限制接口在某个时间段内,访问不能超过多少次。如下:
(自定义注解,打在接口上)
import Java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface LimitAccess {
String key();
int times();
int duration();
}
(切面,实现限制访问)
import com.hezy.annotation.LimitAccess;
import lombok.extern.log4j.Log4j2;
import org.ASPectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
@Component
@Aspect
@Log4j2
public class LimitAspect {
@Value("${access.enable:false}")
private boolean enable;
@Autowired
private RedisTemplate redisTemplate;
@Pointcut("@annotation(com.hezy.annotation.LimitAccess)")
public void pt(){};
@Around("pt()")
public Object aopAround(ProceedingJoinPoint pjp) throws Throwable {
// 设置一个开关,控制是否执行
if (!enable) {
return pjp.proceed();
}
// 获取切入点上面的自定义注解
Signature signature = pjp.getSignature();
MethodSignature methodSignature = (MethodSignature) signature;
// 获取方法上面的注解
LimitAccess limitAccess = methodSignature.getMethod().getAnnotation(LimitAccess.class);
// 获取注解上面的属性值
int limit = limitAccess.times();
String key = limitAccess.key();
int duration = limitAccess.duration();
// 递增键的值,如果键不存在则初始化为1
Long currentCount = redisTemplate.opsForValue().increment(key, 1);
// 如果键是新创建的,设置过期时间
if (currentCount != null && currentCount == 1) {
redisTemplate.expire(key, duration, TimeUnit.SECONDS);
}
// 检查是否超过限制
if (currentCount != null && currentCount > limit) {
log.info("访问过于频繁: " + pjp.toLongString());
throw new RuntimeException("访问过于频繁");
}
return pjp.proceed();
}
}
(使用,在对应的接口上,打上注解,填上数值,如下表示,1秒内不能访问超过3次)
@LimitAccess(key = "test", times = 3, duration = 1)
@GetMapping
public String test() {
return demoService.test();
}
另外,在代码中加了一个开关,可在配置文件中设置此配置,表示开启或者关闭,默认是关闭的
access:
enable: true
启动项目,测试一下
思考
以上代码,有两点需要思考:
注解能不能加在Service层的方法上,加了有没有用?另外加了会不会让声明式事务失效?
这个限制,没有到用户的维度,也就是说所有的用户,只要在一个时间段内访问超过次数就限制,这显然是不行的。有什么办法吗?
第一点,我测试过,注解可以加在Service层方法上,是可以的,不会让事务失效,如下:
@LimitAccess(key = "deleteUserById", times = 3, duration = 1)
@Transactional
@Override
public void deleteUserById(Integer id) {
// 删除用户
userMapper.deleteUserById(id);
int i = 1 / 0;
// 删除用户对应的角色
userMapper.deleteUserRoleMapper(id);
}
接口限制,事务,都生效了。
第二点,这确实是个问题,要做到针对用户层面的接口限制是必须的,不然有一个用户恶意刷新,其他用户都用不了了,这怎么可以。要解决这个问题,首先要拿到当前操作用的标识,用户名、用户ID,然后再存入key的时候,拼接上这个标识作为key。
String key = limitAccess.key() + 用户标识(用户名、用户id);
获取当前用户信息,参考下面这篇文章:
获取当前用户信息的几种方式
如果你不是自己从0开发项目,一般成熟的项目都会有获取当前操作用户信息的方式的。实在不行,你让前端把用户id作为参数传给你,你在切面里获取这个用户id都可以。
总结
本文是对之前用Redis接口访问的优化,以及对两个问题的考虑,希望能对大家有启发。
获取源码:https://github.com/HeZhongYing/limit_access_demo
到此这篇关于Redis接口访问优化的方法步骤的文章就介绍到这了,更多相关Redis接口访问优化内容请搜索编程客栈(www.lsjlt.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网(www.lsjlt.com)!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
软考中级精品资料免费领
- 历年真题答案解析
- 备考技巧名师总结
- 高频考点精准押题
- 资料下载
- 历年真题
193.9 KB下载数265
191.63 KB下载数245
143.91 KB下载数1148
183.71 KB下载数642
644.84 KB下载数2756
相关文章
发现更多好内容- 如何调用 Java 的 concat 方法?(java concat方法怎么调用)
- Java 中 System.in 的具体作用究竟是什么?(java中system.in的作用是什么)
- Java 中如何声明私有变量?(java私有变量如何声明)
- Java webservice 接口如何进行调用?(Java webservice接口如何调用)
- Java 下载文件的最佳实践究竟是什么?(java下载文件的最佳实践是什么)
- Java 如何实现拓扑图?详细步骤及代码示例(java如何实现拓扑图)
- Java 中如何设置 PrintWriter 的编码?(Java中printwriter设置编码的方法是什么)
- JavaWinForm 开发中常用的控件都有哪些呢?(javaWinForm开发中常用的控件有哪些)
- Java 中死循环问题该如何解决?(java死循环问题怎么解决)
- 如何进行 Java WebAPI 的版本控制?(Java WebAPI如何进行版本控制)