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次后出现提示“没有可用资源”
至于如何使用到具体项目中,可以自行设计引入。
