Redisson是一个在Redis的基础上实现的Java驻内存数据网格(In-Memory Data Grid)。它不仅提供了一系列的分布式的Java常用对象,还提供了许多分布式服务。
Redisson的宗旨是促进使用者对Redis的关注分离(Separation of Concern),从而让使用者能够将精力更集中地放在处理业务逻辑上。
如果是Spring工程中使用Redison,那直接引用Redisson即可,相关使用也可以参考之前文章
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.16.8</version> </dependency>
由于我们是SpringBoot集成,我引用starter
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.17.0</version> </dependency>
这不是最高版本,请不要使用最高版本,因为具体使用的Redisson版本,要和你的SpringBoot版本对应。
在resources文件夹新建配置文件redisson.yml
# 单节点配置 singleServerConfig: # 连接空闲超时,单位:毫秒 idleConnectionTimeout: 10000 # 连接超时,单位:毫秒 connectTimeout: 10000 # 命令等待超时,单位:毫秒 timeout: 3000 # 命令失败重试次数,如果尝试达到 retryAttempts(命令失败重试次数) 仍然不能将命令发送至某个指定的节点时,将抛出错误。 # 如果尝试在此限制之内发送成功,则开始启用 timeout(命令等待超时) 计时。 retryAttempts: 3 # 命令重试发送时间间隔,单位:毫秒 retryInterval: 1500 # 单个连接最大订阅数量 subscriptionsPerConnection: 5 # 客户端名称 clientName: SpringBootTest # # 节点地址 address: redis://127.0.0.1:6379 # 密码 password: # 发布和订阅连接的最小空闲连接数 subscriptionConnectionMinimumIdleSize: 1 # 发布和订阅连接池大小 subscriptionConnectionPoolSize: 50 # 最小空闲连接数 connectionMinimumIdleSize: 8 # 连接池大小 connectionPoolSize: 16 # 数据库编号 database: 6 # DNS监测时间间隔,单位:毫秒 dnsMonitoringInterval: 5000 # 线程池数量,默认值: 当前处理核数量 * 2 threads: 8 # Netty线程池数量,默认值: 当前处理核数量 * 2 nettyThreads: 16 # 编码 codec: !<org.redisson.codec.JsonJacksonCodec> {} # 传输模式 transportMode : "NIO"
然后在application.yml中配置Redis的地方引用该配置文件,或者你可以把内容直接放在配置Redis的地方
spring: redis: host: 127.0.0.1 port: 6379 password: database: 6 connect-timeout: 30ms lettuce: pool: max-idle: 20 max-active: 50 min-idle: 10 max-wait: 5000ms redisson: file: classpath:redisson.yml
然后我们编写一个Controller接口,用户测试限流是否生效
/** * 测试限流 */ @GetMapping("/testRateLimiter") public String testRateLimiter(){ String key = "sendEvent"; // 标记 int time = 5; // 5 秒内 int count = 3; // 限制 3个 RateType rateType = RateType.OVERALL; // 全局,集群时也可以指定单节点 RRateLimiter rateLimiter = client.getRateLimiter(key); // 在多长时间窗口内(rateInterval+IntervalUnit),许可总量不超过多少(rate) rateLimiter.trySetRate(rateType, count, time, RateIntervalUnit.SECONDS); if (rateLimiter.tryAcquire()) { Long availablePermits = rateLimiter.availablePermits(); return StrUtil.format("剩余可用资源:{}", availablePermits); } else { return "没有可用资源"; } }
启动工程后,连续请求该接口,请求3次后出现提示“没有可用资源”
至于如何使用到具体项目中,可以自行设计引入。