Java小强个人技术博客站点    手机版
当前位置: 首页 >> 开源 >> SpringBoot集成Redisson实现接口限流

SpringBoot集成Redisson实现接口限流

3100 开源 | 2024-2-23

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次后出现提示“没有可用资源”

至于如何使用到具体项目中,可以自行设计引入。


推荐您阅读更多有关于“ 分布式 springboot Redisson 限流 ”的文章

下一篇:Lock4J分布式锁

猜你喜欢

发表评论: