产品中心
一提到Redis，相信大家都不会感到陌生吧。今天就让我们在阿里云上安装一下Redis，为以后使用它做个准备。
1，下载页面
2，下载
tar -xzvf redis-5.0.7.tar.gz
1, 请在操作前确认gcc是否已安装，gcc -v
如未安装，可以执行这个命令安装：yum install gcc
2，请在操作前确认tcl是否已安装如未安装，可以执行这个命令安装：yum install tcl
make 后加 MALLOC的参数的原因：
避免提示找不到 jemalloc/jemalloc.h
如果看到以下字样：表示无错误:\o/ All tests passed without errors!
find / -name redis-cli 查找文件位置
设置以下两个地方:
说明：分别是以daemon方式独立运行 / 内存的最大使用限制
1,编辑service文件
2,service文件内容:
3.重载系统服务
4,用来管理redis
启动
systemctl start redis
查看状态
systemctl status redis
使开机启动
systemctl enable redis
1、阿里云得设置redis.conf中的bind 后跟着的127.0.0.1修改为0.0.0.0，重启redis
2、开放端口：开放服务器的端口号，步骤如下：
打开实例列表，点击“ 更多”按钮，选择“ 网络和安全组 ”中的“安全组配置”，选择 “安全组列表”tab页面，点击 “配置规则”按钮，点击 “快速添加”按钮，勾选“Redis（6379）”，点击 “确定”之后就可以正常连接了。
3、给redis设置连接密码：
查找到# requirepass foobared 注释去掉并写入要设置的密码，例如：requirepass 123456
redis启动之后测试是否可以连接命令
注意： 如果是阿里云的话一定要设置密码，否则很可能被矿机程序注入定时任务，用你的服务器挖矿，阿里云一直会有信息提示你。
服务器上的Redis已经安装完成了（安装步骤见上文），今天就让我们使用Redis来做个小功能：自定义拦截器限制访问次数，也就是限流。
首先我们要在项目中引入Redis
<!– redis依赖commons-pool 这个依赖一定要添加 –>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
spring:
redis:
host: 127.0.0.1
port: 6379
timeout: 10s
lettuce:
pool:
# 连接池中的最小空闲连接 默认0
min-idle: 0
# 连接池中的最大空闲连接 默认8
max-idle: 8
# 连接池最大连接数 默认8 ，负数表示没有限制
max-active: 8
# 连接池最大阻塞等待时间（使用负值表示没有限制） 默认-1
max-wait: -1ms
#选择哪个库存储，默认是0
database: 0
password: 123456
@Autowired
private RedisTemplate redisTemplate;
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
//判断请求是否属于方法的请求
if(handler instanceof HandlerMethod){
HandlerMethod hm = (HandlerMethod) handler;
//获取方法中的注解,看是否有该注解
AccessLimit accessLimit = hm.getMethodAnnotation(AccessLimit.class);
if(accessLimit == null){
return true;
}
int seconds = accessLimit.seconds();
int maxCount = accessLimit.maxCount();
boolean login = accessLimit.needLogin();
String key = request.getRequestURI();
//如果需要登录
if(login){
//获取登录的session进行判断，此处只是例子，不写具体的业务
//…..
key+=””+”1″; //这里假设用户是1,项目中是动态获取的userId
}
//从redis中获取用户访问的次数
Integer count;
if(Objects.isNull(redisTemplate.opsForValue().get(key))){
count = 0;
}else{
count = (Integer) redisTemplate.opsForValue().get(key);
}
if(count == 0){
redisTemplate.opsForValue().set(key,1,seconds, TimeUnit.SECONDS);
}else if(count<maxCount){
//key的值加1
redisTemplate.opsForValue().increment(key);
}else{
//超出访问次数
Map<String,Object> errMap=new HashMap<>();
errMap.put(“code”,400);
errMap.put(“msg”,”请求超时，请稍后再试”);
render(response,errMap); //这里的CodeMsg是一个返回参数
return false;
}
}
return true;
}
private void render(HttpServletResponse response, Map<String,Object> errMap) throws Exception {
response.setContentType(“application/json;charset=UTF-8”);
OutputStream out = response.getOutputStream();
String str = JSON.toJSONString(errMap);
out.write(str.getBytes(“UTF-8”));
out.flush();
out.close();
}
}
@Autowired
private FangshuaInterceptor interceptor;
@Override
public void addInterceptors(InterceptorRegistry registry) {
registry.addInterceptor(interceptor);
}
}
最后做一下简单的测试
//每三十秒最多可以请求三次，不需要登录
@AccessLimit(seconds=30, maxCount=3, needLogin=false)
@PostMapping(“/fangshua”)
public String fangshua(){
return “成功”;
}
}
以上就是Redis+AOP+自定义注解实现限流的详细内容，更多关于Redis限流的资料请关注其它相关文章！
