Redis中使用Lua脚本实现分布式计数器如何保证一致性?

老静大大_9411

老静大大_9411

2026-08-22

454人浏览

原创

“先查后incr”必出错,因其非原子操作:java中get、判断、incr三步存在竞态窗口,多请求可同时读旧值并写入,导致计数翻倍或漏限;而lua脚本将判断、计数、过期设置全置于redis单线程内执行,天然强一致。

redis中使用lua脚本实现分布式计数器如何保证一致性?

为什么“先查后 incr”一定会出错

因为这不是原子操作。常见写法是 Java 里先 stringRedisTemplate.opsForValue().get("counter"),再 if 判断,最后 incr("counter")。这三步之间有竞态窗口:多个请求可能同时读到旧值、同时判定未超限、同时写入,最终计数翻倍或漏限。

Redis 单命令(如 INCR)本身原子,但跨命令的逻辑判断不在 Redis 控制范围内。网络延迟、JVM 调度、本地计算时间都会放大这个窗口。

  • GET 和 INCR 是两次独立网络往返,中间可能插入任意其他客户端请求
  • MULTI/EXEC 不能解决「读-算-写」逻辑竞争,它只保证命令序列不被穿插,不保证条件分支不出错
  • 哪怕用 WATCH 做乐观锁,失败重试在高并发下开销大,且业务逻辑仍暴露在客户端

必须把全部逻辑塞进 Lua 脚本里

Lua 脚本在 Redis 单线程中一次性执行完毕,中间不会被任何其他命令打断。只要判断、计数、过期设置全在脚本内完成,就天然强一致。

典型固定窗口限流脚本结构:

local key = KEYS[1]
local window = tonumber(ARGV[1])  -- 窗口秒数,如 60
local max = tonumber(ARGV[2])     -- 最大请求数,如 100
<p>local current = redis.call('INCR', key)
if current == 1 then
redis.call('EXPIRE', key, window)
end
if current > max then
return 0
else
return 1
end</p>
  • INCR 自动初始化 key(不存在时从 0 开始),无需先 GET
  • EXPIRE 只在首次 INCR 时设置,避免重复覆盖过期时间
  • 返回值直接告诉调用方是否放行,Java 层不做任何判断

EVALSHA 与 SCRIPT LOAD 必须配对使用

生产环境绝不能每次都用 EVAL 发送完整脚本字符串。脚本太长会触发 ERR Error running script (call to f_): @user_script: N: user_script: too long 错误(Redis 默认限制 4KB)。

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

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

下载

正确做法是提前注册脚本,后续只传哈希值:

  • 首次调用前,必须执行 SCRIPT LOAD,例如:redis-cli --eval "script.lua" 1 counter 或代码中显式调用 redisTemplate.execute(RedisScript, ...) 触发预热
  • 之后统一用 EVALSHA,只传 40 字符 SHA1 值,大幅减少网络包体积和 Redis 解析开销
  • 若忘记 SCRIPT LOAD,EVALSHA 直接返回 NOSCRIPT 错误——这个错误极易被吞掉,导致限流完全失效

Redis Cluster 下多 key 的坑必须绕开

想用一个脚本同时操作多个计数器(比如按用户+接口双维度限流),在 Cluster 模式下会遇到 CROSSSLOT Keys in request don't hash to the same slot 报错。

这不是脚本问题,而是 Redis Cluster 架构硬约束:所有 KEYS 必须落在同一个 slot 才能被路由到同一节点执行。

  • 解决方案只有两个:要么改用单节点 Redis(适合中小规模);要么设计 key 名称让相关计数器强制落在同 slot,例如加固定前缀 {user:123}:api:/order,花括号内内容决定 slot 分配
  • 别试图在脚本里用 redis.call('GET', 'other:key') 跨 key 访问——Cluster 下照样报 CROSSSLOT
  • 如果真要跨 slot 计数,只能拆成多次 EVALSHA 调用,但此时「全局一致性」已无法保证,需接受最终一致性

真正难的不是写脚本,而是让整个链路没死角:脚本逻辑闭环、预热机制可靠、Cluster 分片可控、错误反馈可监控。少一个环节,一致性就塌一块。

相关文章

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

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

下载

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

相关专题

更多
什么是分布式
什么是分布式

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

2023.08.11

1953

5

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

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

2023.10.07

2794

5

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

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

2023.11.02

4309

19

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

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

2023.11.14

3795

11

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

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

2024.04.02

6892

6

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

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

2024.04.07

623

6

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

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

2024.04.07

736

6

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

6542

6

redis缓存一般存些什么数据
redis缓存一般存些什么数据

redis缓存中存储的数据类型包括:字符串、哈希、列表、集合、有序集合、位图、地理空间数据和hyperloglog。这些数据类型适用于存储各种数据,从简单信息到复杂对象和地理位置。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

1140

6

热门下载

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

精品课程

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

共0课时 | 0人学习

进程与SOCKET
进程与SOCKET

共6课时 | 0.5万人学习