服务器之家：专注于VPS、云服务器配置技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|数据库技术|

服务器之家 - 数据库 - Redis - Redis+AOP+自定义注解实现限流

Redis+AOP+自定义注解实现限流

2022-10-25 16:04阿Q Redis

这篇文章主要为大家详细介绍了如何利用Redis+AOP+自定义注解实现个小功能：自定义拦截器限制访问次数，也就是限流，感兴趣的可以了解一下

Redis安装

一提到Redis，相信大家都不会感到陌生吧。今天就让我们在阿里云上安装一下Redis，为以后使用它做个准备。

下载

1，下载页面

2，下载

解压

tar -xzvf redis-5.0.7.tar.gz

准备编译

1, 请在操作前确认gcc是否已安装，gcc -v

如未安装，可以执行这个命令安装：yum install gcc

2，请在操作前确认tcl是否已安装如未安装，可以执行这个命令安装：yum install tcl

编译

?
1
2
[root@localhost source]# cd redis-5.0.7/
[root@localhost redis-5.0.7]# make MALLOC=libc

make 后加 MALLOC的参数的原因：

避免提示找不到 jemalloc/jemalloc.h

测试编译

?
1
[root@localhost redis-5.0.7]# make test

如果看到以下字样：表示无错误:\o/ All tests passed without errors!

安装

?
1
2
3
4
5
[root@localhost redis-5.0.7]# mkdir /usr/local/soft/redis5 可分步创建
[root@localhost redis-5.0.7]# cd /usr/local/soft/redis5/
[root@localhost redis5]# mkdir bin
[root@localhost redis5]# mkdir conf
[root@localhost redis5]# cd bin/

find / -name redis-cli 查找文件位置

?
1
2
3
4
[root@localhost bin]# cp /root/redis-5.0.7/src/redis-cli ./
[root@localhost bin]# cp /root/redis-5.0.7/src/redis-server ./
[root@localhost bin]# cd …/conf/
[root@localhost conf]# cp /root/redis-5.0.7/redis.conf ./

配置

?
1
[root@localhost conf]# vi redis.conf

设置以下两个地方:

?
1
2
3
4
# daemonize no
 daemonize yes
# maxmemory <bytes>
maxmemory 128MB

说明：分别是以daemon方式独立运行 / 内存的最大使用限制

运行

?
1
[root@localhost conf]# /usr/local/soft/redis5/bin/redis-server /usr/local/soft/redis5/conf/redis.conf

检查端口是否在使用中

?
1
2
[root@localhost conf]# netstat -anp | grep 6379
​​​​​​​tcp 0 0 127.0.0.1:6379 0.0.0.0:* LISTEN 16073/redis-server

查看redis的当前版本:

?
1
2
[root@localhost conf]# /usr/local/soft/redis5/bin/redis-server -v
​​​​​​​Redis server v=5.0.7 sha=00000000:0 malloc=libc bits=64 build=8e31d2ed9a4c9593

使redis可以用systemd方式启动和管理

1,编辑service文件

?
1
[root@localhost liuhongdi]# vim /lib/systemd/system/redis.service

2,service文件内容:

?
1
2
3
[Unit]Description=RedisAfter=network.target
[Service]Type=forkingPIDFile=/var/run/redis_6379.pidExecStart=/usr/local/soft/redis5/bin/redis-server /usr/local/soft/redis5/conf/redis.confExecReload=/bin/kill -s HUP $MAINPIDExecStop=/bin/kill -s QUIT $MAINPIDPrivateTmp=true
[Install]WantedBy=multi-user.target

3.重载系统服务

?
1
[root@localhost liuhongdi]# systemctl daemon-reload

4,用来管理redis

启动

systemctl start redis

查看状态

systemctl status redis

使开机启动

systemctl enable redis

查看本地centos的版本:

?
1
2
[root@localhost lib]# cat /etc/redhat-release
CentOS Linux release 8.1.1911 (Core)

客户端连接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启动之后测试是否可以连接命令

?
1
2
./redis-cli -h 127.0.0.1 -p 6379
127.0.0.1:6379> auth 123456//此处是你的密码

注意： 如果是阿里云的话一定要设置密码，否则很可能被矿机程序注入定时任务，用你的服务器挖矿，阿里云一直会有信息提示你。

Redis限流

服务器上的Redis已经安装完成了（安装步骤见上文），今天就让我们使用Redis来做个小功能：自定义拦截器限制访问次数，也就是限流。

首先我们要在项目中引入Redis

1、引入依赖

?
1
2
3
4
5
6
7
8
9
10
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
 
<!-- redis依赖commons-pool 这个依赖一定要添加 -->
<dependency>
  <groupId>org.apache.commons</groupId>
  <artifactId>commons-pool2</artifactId>
</dependency>

2、application.yml配置

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
server:
port: 8181
 
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

3、创建redisConfig，引入redisTemplate

?
1
2
3
4
5
6
7
8
9
10
11
12
13
@Configuration
public class RedisConfig {
   @Bean
   public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {
       RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
       redisTemplate.setKeySerializer(new StringRedisSerializer());
       redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
       redisTemplate.setHashKeySerializer(new StringRedisSerializer());
       redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
       redisTemplate.setConnectionFactory(redisConnectionFactory);
       return redisTemplate;
  }
}

自定义注解和拦截器

1、自定义注解

?
1
2
3
4
5
6
7
8
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Documented
public @interface AccessLimit {
   int seconds(); //秒数
   int maxCount(); //最大访问次数
   boolean needLogin()default true;//是否需要登录
}

2、创建拦截器

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
@Component
public class FangshuaInterceptor extends HandlerInterceptorAdapter {
 
   @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();
  }
}

3、将自定义拦截器加入到拦截器列表中

?
1
2
3
4
5
6
7
8
9
10
11
@Configuration
public class WebConfig extends WebMvcConfigurerAdapter {
 
   @Autowired
   private FangshuaInterceptor interceptor;
 
   @Override
   public void addInterceptors(InterceptorRegistry registry) {
       registry.addInterceptor(interceptor);
  }
}

最后做一下简单的测试

?
1
2
3
4
5
6
7
8
9
10
11
@RestController
@RequestMapping("test")
public class TestController {
 
   //每三十秒最多可以请求三次，不需要登录
   @AccessLimit(seconds=30, maxCount=3, needLogin=false)
   @PostMapping("/fangshua")
   public String fangshua(){
       return "成功";
  }
}

以上就是Redis+AOP+自定义注解实现限流的详细内容，更多关于Redis限流的资料请关注服务器之家其它相关文章！

原文链接：https://mp.weixin.qq.com/s/AiBv79sLh-H28T1BTOekKg

  • redis
  • 注解
  • AOP
  • 限流

    • 延伸 · 阅读

    精彩推荐
    • RedisRedis底层数据结构之dict、ziplist、quicklist详解

      Redis底层数据结构之dict、ziplist、quicklist详解

      本文给大家详细介绍了Redis的底层数据结构：dict、ziplist、quicklist的相关知识，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，...

      刘Java8532021-11-18
    • RedisRedis持久化深入详解

      Redis持久化深入详解

      这篇文章主要介绍了Redis持久化深入详解，讲解的还是比较详细的，有感兴趣的同学可以学习下...

      Tsing9032021-07-27
    • RedisWindows下搭建Redis集群的方法步骤

      Windows下搭建Redis集群的方法步骤

      本文主要介绍了Windows下搭建Redis集群的方法步骤，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...

      一菲聪天5852022-10-12
    • RedisRedis篇：事务和Lua 脚本的使用

      Redis篇：事务和Lua 脚本的使用

      现在多数秒杀，抽奖，抢红包等大并发高流量的功能一般都是基于 redis 实现，然而在选择 redis 的时候，我们也要了解 redis 如何保证服务正确运行的原理...

      潜行前行10152021-11-26
    • RedisRedis内部数据结构Dict的实现方法

      Redis内部数据结构Dict的实现方法

      这篇文章主要介绍了Redis内部数据结构Dict的实现方法,本篇文章所述的dict在Redis中最主要的作用就是用于维护Redis数据库中所有Key、value映射的数据结构，需...

      凤澜4922022-10-18
    • RedisRedis超详细讲解高可用主从复制基础与哨兵模式方案

      Redis超详细讲解高可用主从复制基础与哨兵模式方案

      Redis因为其高性能和易用性在我们后端的服务中发挥了巨大的作用，并且很多重要功能的实现都会依赖redis，本篇我们来了解Redis高可用主从复制与哨兵模式...

      静静子♡8292022-10-13
    • RedisRedis常用数据类型命令实例汇总

      Redis常用数据类型命令实例汇总

      这篇文章主要介绍了Redis常用数据类型命令实例汇总,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参...

      圣金巫灵9012020-12-28
    • RedisRedis Cluster集群动态扩容的实现

      Redis Cluster集群动态扩容的实现

      本文主要介绍了Redis Cluster集群动态扩容的实现，文中通过示例代码介绍的非常详细，需要的朋友们下面随着小编来一起学习学习吧...

      可均可可6192021-08-17
    最近更新
    编辑推荐
    阅读排行
    热门标签
    16384 　 批量提权 　 intset 　 节点迁移 　 事务机制 　 主从同步 　 十六进制 　 内部数据结构 　 Redis集群 　 Redis集群搭建 　 持久化方案 　 AOF 　 ziplist 　 限流器 　 内存型数据库 　 RDB 　 简介 　 自动取消 　 批量读写 　 密码认证 　 redis命令 　 未授权 　 访问漏洞 　 redislive 　 发布 　 集合类型 　 列表类型 　 快照模式 　 集群搭建 　 键 　
    © 2019-2022 服务器之家(www.tuohang.net) 版权所有关于我们联系我们版权申明网站地图