如何在Spring Boot中实现Redis的分布式限流器_通过RateLimiter及Lua脚本

风萱酱_6318

风萱酱_6318

2026-06-26

527人浏览

原创

redis + lua 实现原子性限流更可靠,因单靠incr+expire存在崩溃导致key永久残留风险,而lua脚本在服务端原子执行,彻底规避竞态;必须将计数、过期设置、超限判断封装于同一脚本中。

如何在spring boot中实现redis的分布式限流器_通过ratelimiter及lua脚本

Redis + Lua 实现原子性限流为什么比单纯用 StringRedisTemplate 更可靠

因为单靠 INCR + EXPIRE 两步操作无法保证原子性:如果服务在 INCR 成功后、EXPIRE 前崩溃,key 就会永久存在;而 Lua 脚本在 Redis 服务端一次性执行,天然规避竞态。Spring Boot 中直接调用 redisTemplate.execute() 执行内联 Lua 或预加载脚本是最稳妥的方式。

常见错误现象:RateLimiter.tryAcquire() 在高并发下漏放行、限流阈值漂移、同一请求被重复计数。

  • 必须把“计数 + 过期设置 + 判断是否超限”全部写进一个 Lua 脚本里,不能拆成多次 Redis 命令
  • 脚本中用 redis.call('INCR', KEYS[1]) 而非 redis.call('GETSET', ...),避免覆盖旧值导致计数丢失
  • 首次调用时需用 redis.call('EXPIRE', KEYS[1], ARGV[2]) 设置过期,而不是 SETEX——后者在 key 已存在时不重设 TTL
  • 返回值建议统一为整数:0 表示拒绝,1 表示通过,-1 表示系统异常(如脚本执行报错)

如何封装一个线程安全、可复用的 RedisRateLimiter 类

别直接在 Controller 里硬写 Lua 调用逻辑。应该抽成一个 Bean,支持按 key(如用户 ID、接口路径)、permitsPerSecond、timeoutSeconds 动态限流。

关键点在于:Lua 脚本要预加载进 Redis,而不是每次拼字符串;RedisTemplate 的序列化器必须设为 StringRedisTemplate 或显式指定 StringRedisSerializer,否则 KEYS[1] 可能被序列化成乱码。

  • 使用 DefaultRedisScript<long></long> 加载脚本,设置 setScriptText(...) 或从 classpath 读取 rate_limit.lua
  • 执行时传入 Arrays.asList(key) 作为 keys,Arrays.asList(String.valueOf(permits), String.valueOf(windowSeconds)) 作为 args
  • 捕获 RedisSystemException 和 LuaScriptException,避免因 Redis 不可用导致整个接口失败
  • 不要在脚本里做复杂逻辑(比如拼接 key),key 应由 Java 层生成并传入,减少出错可能

tryAcquire 返回 false 却没触发限流日志?检查这几点

很多团队发现限流看似生效,但日志里看不到“被拒绝”的记录,其实是调用方没处理返回值,或拦截器吞掉了响应。

Redis Skill - 高性能缓存管理
Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis,支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

典型场景:Feign 调用下游接口前做限流,但 if (!limiter.tryAcquire(...)) { throw new RuntimeException("rejected"); } 没写,或者异常被全局 @ExceptionHandler 吞掉并返回了 200。

  • 确保限流判断后有明确分支:放行走业务逻辑,拒绝走 ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS).build() 或抛自定义异常
  • 如果用 Spring Cloud Gateway,别在 route filter 里手动调 Lua,优先用内置的 redis-rate-limiter 配置,它底层就是 Lua
  • 注意 Lua 脚本返回值类型:Spring 默认把 Long 当作布尔处理(0=false, 非0=true),但你实际需要的是数值对比,所以 execute 方法应声明返回 Long,而非 Boolean
  • 本地测试时禁用 Redis 密码或配置 spring.redis.password=,否则 RedisConnectionFailureException 会掩盖真实限流逻辑问题

为什么用 RateLimiter(Guava)+ Redis 同步状态是危险的组合

Guava 的 RateLimiter 是纯内存的,分布式环境下每个实例都有一份独立状态,根本起不到“分布式”限流作用。有人试图用 Redis 存储剩余 permits 并定时同步,这既增加延迟又引入一致性难题。

正确做法只有一种:所有限流决策必须由 Redis 单点完成。Guava 的 RateLimiter 只适合单机压测或降级兜底,绝不能作为主限流器。

  • 删掉所有类似 rateLimiter.tryAcquire() && updateRedisCount() 的代码——这是典型的伪分布式
  • 如果你需要平滑限流(比如令牌桶动态填充),Lua 脚本里必须自己实现时间戳差值计算,用 redis.call('TIME') 获取秒级时间,别依赖客户端时间
  • 注意 Redis 集群模式下,key 必须落在同一个 slot,所以 key 命名要带 {xxx} 前缀,例如 {user:123}:rate_limit

真正麻烦的不是写脚本,而是验证它在分片、故障转移、时钟偏移下的行为。上线前务必用 redis-cli --eval 手动跑几次 Lua,观察返回值和 TTL 变化。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

redis redis lua脚本

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

2025.08.06

2531

22

Java Spring Security 与认证授权
Java Spring Security 与认证授权

本专题系统讲解 Java Spring Security 框架在认证与授权中的应用,涵盖用户身份验证、权限控制、JWT与OAuth2实现、跨站请求伪造(CSRF)防护、会话管理与安全漏洞防范。通过实际项目案例,帮助学习者掌握如何 使用 Spring Security 实现高安全性认证与授权机制,提升 Web 应用的安全性与用户数据保护。

2026.01.26

457

25

什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2013

5

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.07

3054

5

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.02

4489

19

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.14

4015

11

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.02

7412

6

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

643

6

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

756

6

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习